- Support
TLS
logic - Support
Authentication
logic - Support
Proxy
logic - Support
Hostname verification
logic
Producer​
- Add
Send()
method in Producer
interface - Add
SendAsync()
method in Producer
interface - Add
LastSequenceID()
method in Producer
interface - Add
Flush()
method in Producer
interface - Add
Close()
method in Producer
interface - Add
Topic()
method in Producer
interface - Add
Name()
method in Producer
interface - Support
MessageRouter
logic - Support
batch
logic - Support
compression message
logic - Support
HashingScheme
logic - Support
User defined properties producer
logic
Consumer​
- Add
Subscription()
method in Consumer
interface - Add
Unsubscribe()
method in Consumer
interface - Add
Receive()
method in Consumer
interface - Add
Ack()
method in Consumer
interface - Add
AckID()
method in Consumer
interface - Add
Nack()
method in Consumer
interface - Add
NackID()
method in Consumer
interface - Add
Seek()
method in Consumer
interface - Add
SeekByTime()
method in Consumer
interface - Add
Close()
method in Consumer
interface - Support
Dead Letter Queue
consumer policy - Support
Topics Pattern
and Topics
logic - Support
topic consumer regx
logic - Support
multi topics consumer
logic - Support
Exclusive
, Failover
, Shared
and KeyShared
subscribe type logic - Support
Latest
and Earliest
logic - Support
ReadCompacted
logic - Support
ReplicateSubscriptionState
logic - Support
User defined properties consumer
logic - Support
Delayed Delivery Messages
logic
- Add
Topic()
method in Reader
interface - Add
Next()
method in Reader
interface - Add
HasNext()
method in Reader
interface - Add
Close()
method in Reader
interface - Support
read compacted
logic - Support
start messageID
logic - Support
User defined properties reader
logic