ja7ad / amqp Goto Github PK
View Code? Open in Web Editor NEWWrapped amqp091-go with specific stable/safe regarding connection (Production Ready)
License: MIT License
Wrapped amqp091-go with specific stable/safe regarding connection (Production Ready)
License: MIT License
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.
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.
rabbitmq-plugins enable rabbitmq_delayed_message_exchange
We want support auto encoder and decoder json
, gob
and protobuf
.
for example: https://github.com/nats-io/nats.go/tree/main/encoders/builtin
when create New()
we register default encoder for auto encode and decode then base options we can customize to another encoder type.
types.Delivery
we have a unmarshaler interface to decode message body on specific value with any type.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.
A declarative, efficient, and flexible JavaScript library for building user interfaces.
๐ Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
An Open Source Machine Learning Framework for Everyone
The Web framework for perfectionists with deadlines.
A PHP framework for web artisans
Bring data to life with SVG, Canvas and HTML. ๐๐๐
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
Some thing interesting about web. New door for the world.
A server is a program made to process requests and deliver data to clients.
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
Some thing interesting about visualization, use data art
Some thing interesting about game, make everyone happy.
We are working to build community through open source technology. NB: members must have two-factor auth.
Open source projects and samples from Microsoft.
Google โค๏ธ Open Source for everyone.
Alibaba Open Source for everyone
Data-Driven Documents codes.
China tencent open source team.