It happened after restart of a node in cluster. It complains about incompatible_feature_flags and stops. The doc says that once a feature flag enabled it is impossible to disable. The only other ru...

From what I understand, a message queue helps with inter-process communication, but it is limited to basically allow communication between only 2 applications? I'm asking this because for example M...

I want develop a project in microservice structure. I have to use php/laravel and nodejs/nestjs What is the best connection method between my microservices. I read about RabbitMQ and NATS messaging...

I have created a client of type MqttClient and as shown below in the code, I create a client and se its Asynchronous callback. The problem is, 1-when I run the programm, the System.out.println("C...

All of the examples of Kafka | producers show the ProducerRecord's key/value pair as not only being the same type (all examples show <String,String>), but the same value. For example: produc...

I am using Spring Websocket with STOMP, Simple Message Broker. In my @Controller I use method-level @SubscribeMapping, which should subscribe the client to a topic so that the client would receive ...

I have a mqtt beoker which i am trying to connect and subscribe in python. code client = mqtt.Client("P1",clean_session=True) #create new instance client.on_connect = on_connect client.on_message...

We have the first version of an application based on a microservice architecture. We used REST for external and internal communication. Now we want to switch to AP from CP (CAP theorem)* and use a...

I have implemented this ZMQ Client-Server architecture with the order to one message from Sender client, this message arrives at other clients Receiver 1, Receiver 2 and Receiver 3. This means th...

I have a system that exposes a REST API with a rich set of CRUD endpoints to manage different resources. The REST API is used also by a front-end application that executes calls by using Ajax. I ...

I'd like to know best practices for consuming messages. I've read MassTransit docs and I've searching about this but I don't get to come to any conclusion. I have one api (hosting a bus instance) ...

I have a task to implement a message broker at choice in a distributed system. Is Firebase Cloud Messaging considered one?

We have an ActiveMQ broker that's connected to from very different clients using JMS, AMQP, and MQTT. For some reason we haven't figured out yet a specific set of MQTT clients often (not always) su...

I am trying to start the ActiveMQ 5.11 and I see a WARNING as below: WARN | Transport Connection to: tcp://127.0.0.1:40890 failed: java.io.EOFException My activemq.xml is as below: <transportCo...

I followed a simple example of setting up and running embedded ActiveMQ with Spring Boot (version 1.4.X). Here's link to the example https://spring.io/guides/gs/messaging-jms/ My class is structu...

I'm a little confused as to what the difference is between a message broker e.g. RabbitMQ and Message-orientated Middleware. I can't find much info apart from what's on Wikipedia. When searching MO...

I am a bit tired of seeing 'connected to server undefined' in the Chrome dev console. How do I give my server a name? @Configuration @EnableWebSocketMessageBroker public class WebsocketConfig exte...

While trying to get a deep understanding of the Kafka distribution model, one sentence here from StackOverflow got me buzzing, and I can't get a confirmation nor deny. So, the more subscriber g...

According to my experience in working with message brokers, RabbitMq has a better performance under heavy loads. However, for the sake of simplicity, it is better to use AtiveMQ in the browser. I w...

What is the difference between a Websphere Message Broker and a Queue Manager. I guess the queue manager puts messages in the queue, takes messages out of the queue, moves messages to backout queue...

I am a developer at my office where SOA development is at its peaks. We use IBM MQ, IBM Message Broker and Java/J2EE Technologies. I have been currently put into project where Message Broker is u...

I have created a cluster consists of three RabbitMQ nodes using join_cluster command. i.e. rabbitmqctl –n rabbit2@MYPC1 join_cluster rabbit2@MYPC1 (currently the cluster runs on a single computer...

I am begining to implement an ActiveMQ based messaging service to send worker tasks to various servers, however I am noticing that in the default mode, if no one is "listening" to a producer's topi...

What's the difference between Apache ActiveMQ and Apache ActiveMQ Apollo? Apollo documents says:"ActiveMQ Apollo is a faster, more reliable, easier to maintain messaging broker built from the foun...

I have WebSphere MQ and WebSphere Message Broker installed on Linux and when I execute mqsicreateexecutiongroup I get an error saying: BIP1046E: Unable to connect with the queue manager (Could ...