olivertappin / scoop Goto Github PK
View Code? Open in Web Editor NEWMove a specified number of messages from one queue to another over the Advanced Message Queuing Protocol (AMQP).
License: MIT License
Move a specified number of messages from one queue to another over the Advanced Message Queuing Protocol (AMQP).
License: MIT License
Line 178 in 57f1807
https://godoc.org/github.com/streadway/amqp#Channel.Publish it states;
Since publishings are asynchronous, any undeliverable message will get returned by the server. Add a listener with Channel.NotifyReturn to handle any undeliverable message when calling publish with either the mandatory or immediate parameters as true.
and...
This can return an error when the channel, connection or socket is closed. The error or lack of an error does not indicate whether the server has received this publishing.
This leads to the potential for dropped messages.
Hello,
There's been an issue in using scoop that has seemingly created an issue in queues that are using messages with content types other than text/plain
looking at the code, the content type is always fixed to text/plain meaning if used on a queue where messages are different to this, it can cause issues on the consuming application.
https://github.com/olivertappin/scoop/blob/master/scoop/scoop.go#L184
I would suggest we need to accept content_type as a parameter, rather than only being hardcoded, this gives the option to choose the content_type at point of use.
I can try open a PR, if this is ok?
Line 178 in 57f1807
In https://godoc.org/github.com/streadway/amqp#Channel.Consume it states;
It's advisable to use separate connections for Channel.Publish and Channel.Consume so not to have TCP pushback on publishing affect the ability to consume messages, so this parameter is here mostly for completeness.
It might be advisable to separate the channels for greater robustness.
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.