rabbitmq

How to add plugin to RabbitMQ docker image?

by

FROM rabbitmq:3.7-management RUN apt-get update && \ apt-get install -y curl unzip RUN curl https://dl.bintray.com/rabbitmq/community-plugins/3.7.x/rabbitmq_delayed_message_exchange/rabbitmq_delayed_message_exchange-20171201-3.7.x.zip > rabbitmq_delayed_message_exchange-20171201-3.7.x.zip && \ unzip rabbitmq_delayed_message_exchange-20171201-3.7.x.zip && \ rm -f rabbitmq_delayed_message_exchange-20171201-3.7.x.zip && \ mv rabbitmq_delayed_message_exchange-20171201-3.7.x.ez plugins/ RUN rabbitmq-plugins enable rabbitmq_delayed_message_exchange

How does RabbitMQ compare to Mule

by

Mule is an ESB (Enterprise Service Bus). RabbitMQ is a message broker. An ESB provides added layers atop of a message broker such as routing, transformations and business process management. It is a mediator between applications, integrating Web Services, REST endpoints, database connections, email and ftp servers – you name it. It is a high-level … Read more

Delayed message in RabbitMQ

by

There are two approaches you can try: Old Approach: Set the TTL(time to live) header in each message/queue(policy) and then introduce a DLQ to handle it. once the ttl expired your messages will move from DLQ to main queue so that your listener can process it. Latest Approach: Recently RabbitMQ came up with RabbitMQ Delayed … Read more

Messaging Confusion: Pub/Sub vs Multicast vs Fan Out

by

I’m confused by your choice of three terms to compare. Within RabbitMQ, Fanout and Direct are exchange types. Pub-Sub is a generic messaging pattern but not an exchange type. And you didn’t even mention the 3rd and most important Exchange type, namely Topic. In fact, you can implement Fanout behavior on a Topic exchange just … Read more

When to use RabbitMQ shovels and when Federation plugin?

by

Shovels and queue provide different means to be forward messages from one RabbitMQ node to another. Federated Exchange With a federated exchange, queues can be connected to the queue on the upstream(source) node. In addition, an exchange on the downstream(destination) node will receive a copy of messages that are published to the upstream node. Federated … Read more

Unmarshaling Into an Interface{} and Then Performing Type Assertion

by

The default types that the json package Unmarshals into are shown in the Unmarshal function documentation bool, for JSON booleans float64, for JSON numbers string, for JSON strings []interface{}, for JSON arrays map[string]interface{}, for JSON objects nil for JSON null Since you’re unmarshaling into an interface{}, the returned types will only be from that set. … Read more

RabbitMQ/AMQP – Best Practice Queue/Topic Design in a MicroService Architecture [closed]

by

I generally find it is best to have exchanges grouped by object type / exchange type combinations. in you example of user events, you could do a number of different things depending on what your system needs. in one scenario, it might make sense to have an exchange per event as you’ve listed. you could … Read more