658 questions
146
votes
4
answers
87k
views
What's the purpose of Kafka's key/value pair-based messaging?
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:
producer....
- 29.8k
49
votes
5
answers
32k
views
Does Spring @SubscribeMapping really subscribe the client to some topic?
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 the ...
- 1,634
33
votes
3
answers
40k
views
Which option is more suitable for microservice? GRPC or Message Brokers like RabbitMQ [closed]
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
...
16
votes
2
answers
3k
views
Synch and Asynchronous interface of MqttClient object are not working
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("...
- 1,086
14
votes
5
answers
20k
views
When to use Java and Message Broker?
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 used ...
- 9,296
12
votes
3
answers
31k
views
Publish/Subscribe samples with RabbitMQ in .NET [closed]
I've built this sample: Getting Started With RabbitMQ in .net, but made 2 programs:
one-publisher
one-subscriber
I'm using BasicPublish to publish and BasicAck to listen as in example. If I run one ...
- 8,724
12
votes
1
answer
7k
views
Difference between ApacheActiveMQ and ApacheActiveMQApollo
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 ...
- 6,958
10
votes
1
answer
63k
views
How to configure embedded ActiveMQ Broker URL with Spring Boot
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 structured ...
- 535
9
votes
1
answer
2k
views
How do I make my ActiveMQ broker drop offline durable subscribers
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) ...
- 225k
8
votes
0
answers
362
views
How Do You Configure The Spring Websocket STOMP Server Name?
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 extends ...
- 81
7
votes
2
answers
4k
views
Inbox pattern and outbox pattern
I don't see the difference between the Inbox pattern and the Outbox pattern.
the Inbox pattern saves messages in a database. The Outbox pattern too, so what is the difference?
6
votes
1
answer
2k
views
How to organize queues in Masstransit/RabbitMQ?
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) ...
- 1,034
6
votes
2
answers
4k
views
Using ActiveMQ and RabbitMQ simultaneously
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 want ...
user4944451
5
votes
4
answers
9k
views
How to reset a rabbitmq node to get rid of an enabled feature flag
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 ...
- 197
5
votes
1
answer
7k
views
is redis pub/sub realistic in php?
I'd like to use redis pub/sub in PHP, but I'm afraid PHP can't be the only tool: a subscriber need to be always callable, since php isn't built for running as a daemon, I can't trust it to reliably be ...
- 1,138
5
votes
3
answers
5k
views
Is it possible to use RabbitMQ and gRPC to queue messages with .NET?
Like the title says.
Is there a way to use gRPC in combination with some kind of message broker/ Queue with .NET?
It does not have to be RabbitMQ. I am open to use alternatives.
\
I want to send ...
- 351
4
votes
2
answers
21k
views
Unable to connect to queue manager in WebSphere MQ 7.1
I've installed WebSphere MQ 7.1 on Linux platform, after which I installed WebSphere Message Broker 8.0.0.1. Now when I try to create an execution group, I get an exception: Reason code 2035. This ...
- 379
4
votes
1
answer
4k
views
Will rabbitmq server recover messages for queue marked as durable, when rabbitmq-server gets crashed?
I am going through the documentation of AMQP given by Rabbitmq official site.
It says that
Queue Durability Durable queues are persisted to disk and thus survive
broker restarts. Queues that are ...
- 11.5k
4
votes
1
answer
3k
views
Subscribing to an Azure Event Grid topic directly from an Angular client
I'm working on an application that needs to respond to events from a third-party WebHook. I chose Azure Event Grid as my chosen event broker, Angular for the frontend and Asp.Net Core for the backend.
...
4
votes
1
answer
2k
views
java.lang.OutOfMemoryError: GC overhead limit exceeded on WSO2 MB
I've been recently working on with the WSO2 Message Broker (Ver : 3.1.0 ) in order to publish and consume messages using JMeter as the jms client. So I've got my publisher Java program where I'm ...
- 9,532
4
votes
2
answers
6k
views
Is it possible to wait until celery group done?
I am trying to do group tasks and wait until all the group subtasks finished then run the last task. But when I call task it calls group and last tasks but the last task finished before group finish. ...
- 605
4
votes
1
answer
4k
views
IBM Cast Iron and ESB
I'm trying to define the integration architecture roadmap for my company and I'm looking for some guidance on my approach.
Most (90-95%) of our applications are based on .NET with Microsoft SQL ...
- 449
4
votes
1
answer
3k
views
Log4jNode in Message flow in Websphere Message Broker is throwing error
I am developing a simple message flow which uses Log4j to log the status at various stages. But when I am trying to run this flow I am getting the following error. I have use Log4jNode in the message ...
user1882601
4
votes
1
answer
2k
views
Kafka Consumer path must not end with / character
I am using Apache Kafka 0.8.2.1 to stream web events to other datasources. The Kafka Producer I wrote is working great and I'm able to see the data getting streaming through my topic when I run kafka-...
- 41
4
votes
0
answers
986
views
Which is the best configuration for a Kafka consumer to increase throughput
I have a bunch of services that are integrated via Apache Kafka, and each of the services has their consumers and producers, but im facing slowing consuming rate like there's something slowing the ...
- 491