Virtuesoft.Framework.Queue.Extensions
消息队列扩展 services.AddQueueService<RabbitQueueService>(new RabbitQueuOptions() { Host = Configuration["rabbit.queque.host"], Port = int.Parse(Configuration["rabbit.queque.port"]), User = Configuration["rabbit.queque.user"], Password = Configuration["rabbit.queque.user.password"], VirtualHost = "/" }); 发送消息 await Context.SendQueueMessageAsync("rabbit.queque.name", message); 接收消息 var queque = Context.RequestServices.GetService(typeof(IQueueService)) as TRabbitQueueService; await queque.ConnectionAsync("rabbit.queque.name", (sender, message) => { var msg = Encoding.UTF8.GetString(message as byte[]); });
Activity
- Latest release
- 5y ago
- Total releases
- 6
- Cadence
- ~daily
- Last 12 months
- 0
Details
- First release
- Jan 05, 2021
| Version | Released | |
|---|---|---|
1.0.6
patch
|
1.0.6
patch
Dependencies (3)
|
|
1.0.5
patch
|
1.0.5
patch
Dependencies (3)
|
|
1.0.4
patch
|
1.0.4
patch
Dependencies (3)
|
|
1.0.3
patch
|
1.0.3
patch
Dependencies (3)
|
|
1.0.2
patch
|
1.0.2
patch
Dependencies (3)
|
|
1.0.0
initial
|
1.0.0
initial
Dependencies (3)
|