All Questions
Tagged with message-queue java
505 questions
0
votes
0
answers
60
views
How to define RabbitMQ queue using spring-cloud-streams without a listener
I need to set the exchange and queue for RabbitMQ in my Spring Boot application, the thing is, The application only acts as a producer, but I need to define de queue as well in the service.
steps that ...
- 306
-1
votes
1
answer
67
views
Sping Kafka @KafkaHandler ignores message
I am developing a project with Spring Boot + Kafka. I'm having hard times with understanding why my @KafkaHandler not catching the event I'm sedning through windows commandline. To send message I'm ...
- 355
0
votes
0
answers
52
views
Issue with Dynamically Configuring Streams in RabbitMQ with STOMP and WebSocket
I hope you are all well. I would like to share a problem I am facing in my messaging architecture.
Architecture:
Web clients: Connect to RabbitMQ using the STOMP protocol.
Exchange: Clients subscribe ...
-1
votes
1
answer
66
views
How to send a message to a flow in spring integration?
Suppose the following flow:
public IntegrationFlow sendFlow() {
return IntegrationFlow.from(inputChannel())
.handle("something","someMethod")
...
- 93
0
votes
1
answer
295
views
Can't start Listener Java Application using ActiveMQ in IntelliJ
I have a Java MQ Listener Application that listens a Queue. When I use it locally, I use ActiveMQ to send messages, my issue is:
I am having a problem when trying to run this Listener Application in ...
- 13
0
votes
0
answers
247
views
How to configure Wildfly poolsize and MDB's maxSession while keeping it scalable at runtime?
Let's assume I have a Wildfly pool, my-pool, configured in the Wildfly standalone:
<strict-max-pool name="my-pool" max-pool-size="1" instance-acquisition-timeout="5" ...
- 45
3
votes
1
answer
710
views
What protocols do message queues use to communicate with clients?
I have worked with message queues but never wondered, what protocol do they use to communicate? Basicly all of them support blocking methods e.g
// sleeps the thread until any message is available
...
- 1,316
0
votes
0
answers
2k
views
Kafka: org.apache.kafka.common.errors.DisconnectException: null & Node -1 disconnected
I used Kafka 2.5.1 before and the program ran well. Rencently, the version of Kafka has been changed to 3.4.0, and the Kafka server online is 2.8.1. Then, when I start the program, some exception info ...
- 1
0
votes
1
answer
328
views
Could not get connection while getPartitionedTopicMetadata - Connection handshake failed
I have setup apache pulsar by following this tutorial: https://pulsar.apache.org/docs/3.0.x/deploy-aws/ but I use aws ansible dynamic inventory rather than terraform inventory in a tutorial. The ...
- 1
0
votes
1
answer
456
views
IBM MQ, Send message to first queue and wait for an answer at a confirmation queue
In my setup we want to place an "Order" at order_queue and wait at the same thread until the backends sends a reply at the shipment_queue. The code is in Java.
private Shipment placeOrder(...
- 19
0
votes
0
answers
130
views
Java and WebSphere MQ server integration
I am using IBM Websphere MQ of v7.5.0.6 which is installed on Linux 3.10.0-1160.90.1.0.1.el7.x86_64. I have created the required queue manager and channel.
I need to send a message to a queue hosted ...
-2
votes
1
answer
2k
views
ActiveMQ Artemis + Spring Boot 3 + Apache Camel - RouteBuilder is not working
I created a very simple Spring Boot 3.0 project with Apache Camel and ActiveMQ Artemis since ActiveMQ "Classic" support has been discontinued in Spring Boot 3. My MQ routes are not working. ...
- 35
1
vote
0
answers
2k
views
why rabbitmq message consumption is so slow
Currently I am making logic to consume Message using Rabbitmq. However, contrary to expectations, it takes too long to consume the message.
If you look at the Queued messages graph in the picture ...
- 21
1
vote
1
answer
976
views
Unauthorized access to the RabbitMQ API
I am trying to accomplish each time when I start my app, to get from the RabbitMQ API, all the queues and exchanges that exist. But unfortunately I get the following error:
org.springframework.web....
user20598130
-1
votes
1
answer
686
views
Is there a Solace Direct Queue?
In the Solace Java API, I can create a persistent messaging queue using
MessagingService.createPersistentMessageReceiverBuilder()
The above takes a Queue.durableNonExclusiveQueue() or Queue....
- 1,189