ja7ad / amqp Goto Github PK

Describe the problem you'd like to have solved

Your consumer can not handle the received message and you need to reject it. If you reject the message with requeue being true, it will be instantly redelivered to your consumer, resulting in very high workload, as your consumer will reject that message.

Describe the ideal solution

The RabbitMQ Delay Message Plugin adds a new exchange type to RabbitMQ that allows messages routed through that exchange to be delayed if the user so desires. Let us see how the deployment and scheduling go with these 2 methods.

• Using TTL and DLX to Delay Message Delivery
• RabbitMQ Delayed Message Plugin

rabbitmq-plugins enable rabbitmq_delayed_message_exchange

Describe the problem you'd like to have solved

We want support auto encoder and decoder json, gob and protobuf.

for example: https://github.com/nats-io/nats.go/tree/main/encoders/builtin

Describe the ideal solution

when create New() we register default encoder for auto encode and decode then base options we can customize to another encoder type.

• for consumer on types.Delivery we have a unmarshaler interface to decode message body on specific value with any type.
• for publisher get data with any type from body then encode auto base on registered encoder, encode body and publish message.

I am experiencing an unknown issue with the close channel during the reconnection of the publisher.

message 0 publised
message 1 publised
message 2 publised
message 3 publised
[2023/11/28 09:51:14] WARN attempting to reconnect to amqp server after close with error: Exception (501) Reason: "read tcp 192.168.0.10:54974->65.109.234.125:5672: i/o timeout" {"source":{"file":"/home/javad/Projects/go/personal/amqp/channel.go","function":"github.com/Ja7ad/amqp.(*channel).startNotifyCancelOrClosed","line":63}}
[2023/11/28 09:51:14] ERROR attempting to reconnect to amqp server after connection close with error: Exception (501) Reason: "read tcp 192.168.0.10:54974->65.109.234.125:5672: i/o timeout" {"source":{"file":"/home/javad/Projects/go/personal/amqp/connection.go","function":"github.com/Ja7ad/amqp.(*connection).startNotifyClose","line":51}}
[2023/11/28 09:51:15] WARN waiting 5s seconds to attempt to reconnect to amqp server {"source":{"file":"/home/javad/Projects/go/personal/amqp/channel.go","function":"github.com/Ja7ad/amqp.(*channel).reconnectLoop","line":93}}
2023/11/28 09:51:24 Exception (504) Reason: "channel/connection is not open"

The reconnection channel manager does not have issues with the consumer and continues to run in the background to return to a normal state, but it encounters issues with the publisher during the close on reconnection.