Skip to content

Releases: berkaroad/RabbitMQTopic

v1.2.6

09 Jul 16:16
Compare
Choose a tag to compare

1)Producer增加RegisterTopic重载方法,允许指定消费组列表,并在配置autoConfig时,自动创建消费组相关的Exchange、Queue,未指定消费组列表时,消费组列表为默认消费组。

v1.2

22 Apr 15:13
Compare
Choose a tag to compare

1)TopicMessage更名为Message,取消属性QueueCount,更名DelayedMillisecond为DelayedMilliseconds;
2)Producer启动前,需先注册Topic,仅注册过Topic的才可以发送消息;
3)优化Producer配置Topic的逻辑,由原先伴随SendMessage,改为Start的时候;
4)Producer发送消息时,增加返回类型SendResult;
5)ProducerSettings,增加配置SendMsgTimeout,用于发送确认超时设置,默认3秒;
6)增加Producer和Consumer是否运行的逻辑验证;
7)路由Hash算法,改为Crc16算法;
8)IMessageTransportationContext 属性ExchangeName改为Topic,属性QueueName改为QueueIndex;
9)增加Pull模式。

v1.1.3

14 Apr 13:31
Compare
Choose a tag to compare

1)支持延迟消息,需启用插件 rabbitmq_delayed_message_exchange;
2)Producer、Consumer初始化时,增加autoConfig参数,仅为true时才会配置Exchange、Queue和Bind。

v1.0.1

11 Apr 11:55
Compare
Choose a tag to compare

1)支持集群消费:相同消费组,不同消费者之间实现负载均衡,一个队列有且仅有一个消费者;
2)支持广播消费:不同消费组,可以消费同一个消息。