CAP

Features:

• Optimize snowflake algorithm. (#1065) Thanks @Allen-dududu
• Add authorization policy option feature to CAP dashboard. (#1113) Thanks @albertopm19
• Added support of ScheduledEnqueueTimeUtc for AzureServiceBus transport. (#1137) Thanks @webinex
• Add option to configure failed messages expiration term. (#1142) Thanks @dima-zhemkov

Bug Fixed:

• Fixed sequence validation error when both enable Challenge and Auth of dashboard authentication. (#1097)
• Used concurrentdictionary since PublishedMessages and ReceivedMessages are public and accessed from various places. (#1104) Thanks @wakiter
• Fixed the health check could not get the status correctly when RabbitMQ lost connection and quickly recovered. (#1140)
• Fixed date file format bug when retrying query from database. (#1143)
• Change reading/creating streams and consumer groups to handle non idempotent operations. (#1150) Thanks @MahmoudSamir101

Bug Fixed:

• Fixed kafka consume excepiton for GroupLoadInProress errcode (#1085)
• Fixed deserialization exception when message body is empty byte array. (#1087)
• Fixed dashboard authentication challenge bug. (#1077)

Features:

• Fully support .NET 6.
• Add support for OpenTelemetry. (#885)
• Improve support for NATS JetStream wildcard topic. (#1047)
• Add support customer header for Azure Service Bus. (#1063) Thanks @Mateus Viegas

Features:

• Add support for NATS JetStream. (#983)
• Add support for Apache Pulsar. (#610)
• Add possibility to process messages for each consumer group indepedently. (#1027)

Bug Fixed:

• Fixed message content of bigint type cannot be displayed correctly in dashboard. (#1028)
• Fixed unobserved tasks of async method calls in Amazon SQS. (#1033)
• Fixed RabbitMQ federation plugin message header object values cause exceptions. (#1036)

Features:

• Add support scanning subscribers from the assembly. (#993)
• Allows the overriding of the Kafka ProviderBuilder and ConsumerBuilder. (#978)

Bug Fixed:

• Fixed inmemory storage IndexOutOfRangeException. (#977)

Features:

• Upgrade NATS client to support message headers. (#960)
• Added ability to create topic if it is not found in the topics cache for AWS transport. (#962)
• Add support to customize the interval of cleaning messages for collector. (#973)

Bug Fixed:

• Fixed rabbitmq consumer reconnection warnings bug. (#966)

Bug Fixed:

• Fixed consumer register cancellation token source null referencee bug. (#952)
• Fixed redis streams transport cluster keys cross-hashslot bug. (#944)

Features:

• Improve flow control for message cache of in memory. (#935)
• Add cancellation token support to subscribers. (#912)
• Add pathbase options for dashbaord. (#901)
• Add custom authorization scheme support for dashbaord. (#906)

Bug Fixed:

• Fixed mysql connect timeout expired bug. (#931)
• Fixed consul health check path invalid bug. (#921)
• Fixed mongo dashbaord query bug. (#909)

Features:

• Add Redis Streams transport support. (#817)
• Add configure options for json serialization. (#879)
• New dashboard build with vue. (#880)
• Add subscribe filter support. (#894)

Bug Fixed:

• Fixed use CapEFDbTransaction to get dbtransaction extension method bug. (#868)
• Fixed pending message has not been deleted from buffer list in SQL Server. (#889)
• Fixed dispatcher processing when storage message exception bug. (#900)

Bug Fixed:

• Fix the bug of getting db transaction through the IDbContextTransaction for SQLServer. (#867)
• Fix RabbitMQ Connection close forced. (#861)

Features:

• Add support for Azure Service Bus sessions. (#829)
• Add custom message headers support for RabbitMQ consumer. (#818)

Bug Fixed:

• Downgrading Microsoft.Data.SqlClient to 2.0.1. (#839)
• DiagnosticObserver does not use null connection. (#845)
• Fix null reference in AmazonSQSTransport. (#846)

Features:

• Add KafkaOptions.MainConfig to AutoCreateTopic. (#810)
• Add support rewriting the default configuration of Kafka consumer. (#822)
• Add DefaultChallengeScheme dashboard options to specify dashboard auth challenge scheme. (#815)

Bug Fixed:

• Fixed topic selector in IConsumerServiceSelector. (#806)
• Update AWS topic subscription and SQS access policy generation. (#808)
• Fixed memory leak when using transction to publish message. (#816)
• Fixed SQL content filter on IMonitoringApi.PostgreSql.cs. (#814)
• Fixed the expiration time display problem in the dashboard due to time zone issues (#820)
• Fixed the creation timing of Kafka automatically creating Topic. (#823)
• Fixed Dashboard metric not update. (#819)

Features:

• Upgrade to .NET Standard 2.1 and support .NET 5. (#727)
• Replace Newtonsoft.Json to System.Text.Json. (#740)
• Support NATS Transport. (#595,#743)
• Enabling publiser confirms for RabbitMQ. (#730)
• Support query subscription from DI implementation factory. (#756)
• Add options to create lazy queue for RabbitMQ. (#772)
• Support to add custom tags for Consul. (#786)
• Support custom group and topic prefiex. (#780)
• Renemae DefaultGroup option to DefaultGroupName.
• Add auto create topic at startup for Kafka. (#795,#744)

Bug Fixed:

• Fixed retrying process earlier than consumer registration to DI. (#760)
• Fixed Amazon SQS missing pagination topics. (#765)
• Fixed RabbitMQ MessageTTL option to int type. (#787)
• Fixed Dashboard auth. (#793)
• Fixed ClientProvidedName could not be renamed for RabbitMQ. (#791)
• Fixed EntityFramework transaction will not rollback when exception occurred. (#798)

Features:

• Support record the exception message in the headers. (#679)
• Support consul service check for https. (#722)
• Support custom producer threads count options for sending. (#731)
• Upgrade dependent nuget packages to latest.

Bug Fixed:

• Fixed InmemoryQueue expired messages are not removed bug. (#691)
• Fixed Executor key change lead to possible null reference exception. (#698)
• Fixed Postgresql delete expires data logic error. (#714)

Features:

• Add consumer parameter with interface suppport. (#669)
• Add custom correlation id and message id support. (#668)
• Enhanced custom serialization support. (#641)

Bug Fixed:

• Solve the issue of being duplicated executors from different assemblies. (#666)
• Added comparer to remove duplicate ConsumerExecutors. (#653)
• Add re-enable the auto create topics configuration item for Kafka, it's false by default. now is true. (#635)
• Fixed postgresql transaction rollback invoke bug. (#640)
• Fixed SQLServer table name customize bug. (#632)

Features:

• Add Amazon SQS support. (#597)
• Remove Dapper and replace with ADO.NET in storage project. (#583)
• Add debug symbols package to nuget.
• Upgrade dependent nuget package version to latest.
• English docs grammar correction. Thanks @mzorec

Bug Fixed:

• Fix mysql transaction rollback bug. (#598)
• Fix dashboard query bug. (#600)
• Fix mongo db query bug. (#611)
• Fix dashboard browser language detection bug. (#631)

Bug Fixed:

• Fix kafka consumer group does not works bug. (#541)
• Fix cast object to primitive types failed bug. (#547)
• Fix subscriber primitive types convert exception. (#568)
• Add conosole app sample.
• Upgrade Confluent.Kafka to 1.4.3

Bug Fixed :

• Change ISubscribeInvoker interface access modifier to public. (#537)
• Fix rabbitmq connection may be reused when close forced. (#533)
• Fix dahsboard message reexecute button throws exception bug. (#525)

Bug Fixed:

• Fixed diagnostics event data object error. (#504 )
• Fixed RabbitMQ transport check not working. (#503 )
• Fixed Azure Service Bus subscriber error. (#502 )

Bug Fixed:

• Fixed Dashboard requeue and reconsume failed bug. (#482 )
• Fixed Azure service bus null reference exception. (#483 )
• Fixed type cast exception from storage. (#473 )
• Fixed SqlServer connection undisponse bug. (#477 )