All Questions
38 questions
-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
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
1
answer
158
views
MessageDispatchingException: Dispatcher has no subscribers bad message cause = null
I'm implementing an MQ producer which will send messages via an OUT Queue. I have the channel, bridge, outbound bean, and the JMS outbound-channel-adapter setup. When I run my test case by sending the ...
0
votes
1
answer
1k
views
Getting original message from Camel route after splitting
I have a camel route which reads in messages in batches from a queue, processes the message and proceeds to send them one by one to an api and awaits the api response.
I am having issue with ...
- 45
2
votes
1
answer
2k
views
How can I use @RabbitListener in multiple classes?
I have a Spring application using RabbitMQ (spring-boot-starter-amqp).
I wanted to know if it's possible to use the @RabbitListener annotation across different classes.
I currently have two classes:...
- 2,806
-1
votes
1
answer
475
views
Two way RMI with Spring backed by a message queue
The system consists of 1 or more clients and a single server. Each client is added manually and provided with an identifier (client.id). Each client can send messages to the server. The server can ...
- 129
1
vote
1
answer
1k
views
Camel creating too many tcp connections (over 15000) in TIME_WAIT status to connect ActiveMQ
I am using Apache Camel(with Spring) and ActiveMQ in project. Here are the settings related to JMS/ActiveMQ:
Camel version: activemq-camel-5.15.3.jar (all ActiveMQ related jars)
ActiveMQ version : 5....
0
votes
1
answer
59
views
Return a job to the queue silently
I have a RabbitMQ with a job queue defined, and I'm consuming it with the Java through Spring Framework. I know that, if I throw an exception somewhere in the code while processing the job which I ...
- 1,435
0
votes
1
answer
652
views
RabbitMQ Listen messages from queue from multiple servers
We are listening rabbimq messages from a clustered environment where we have multiple nodes. We want to make one node as a primary node that always listens to messages and by any chance, if that node ...
0
votes
1
answer
287
views
Shutting down producers/consumers in spring-integration with poison pill
How would one utilize poison pill to stop message handlers (and message suppliers) with spring-integration?
I have a setup of N producers (subclassed Supplier) and M consumers (subclasses ...
- 5,709
4
votes
1
answer
2k
views
Using Kafka in a resquest/response scenario inside a REST web service
I am currently building a REST web service that needs to communicate with Kafka in a request/response pattern. (I know that Kafka is not really designed for that).
Client calls the REST web service.
...
- 91
0
votes
1
answer
83
views
How to notify JMS listener for 'no objects' message
I need to sync some 'car' repositories (managed by different slave-servers) to one repository (managed by one master-server).
For that matter I'm using ActiveMQ.
I've defined a queue (master.car....
- 3,155
5
votes
3
answers
9k
views
Read without removing message from JMS queue
How to read a message from WebSphere MQ without deleting the original message from queue?
I have spring application which reads the message from the WebSphere MQ.
After reading, I have a process ...
- 361
1
vote
1
answer
127
views
rabbitmq setting requeue in spring xd
1) spring-xd rabbitmq 'requeue=false' option not working.
below both setting result is same.
i was set 'requeue' option to 'false' but rabbitmq always attempt requeue(=retry).
Are there any ...
- 87