All Questions
23 questions
1
vote
1
answer
1k
views
Batch fetching from JMS queue
I need to implement the following workflow:
Every N milliseconds fetch all available messages from JMS queue, but not more than K items
Do some processing
Acknowledge all of them once processing is ...
- 6,519
0
votes
1
answer
188
views
How to stop one micro service from consuming the message from Message queue-RabbitMQ
Please help me in this scenario
Suppose there are multiple micro service consuming the messages from rabbitmq
But I want to stop for sometime one microservice to consume the message.
1.How will I ...
- 11
1
vote
1
answer
131
views
Have a Queue subscribed to multiple Queues, programmaticaly
I have two Virtual Topics: T1, T2. I have a consumer named FOO.
session.createTopic("VirtualTopic.T1");
session.createTopic("VirtualTopic.T2");
With this I can get messages for every one of the ...
- 10.6k
2
votes
1
answer
1k
views
ZeroMQ brokerless network with queues (Java)
Is it possible to implement a brokerless network with queues using ZeroMQ (with JeroMQ Java porting)?
In my network all peers are both publishers and receivers (SUB/PUB pattern), so that when a peer ...
- 2,805
0
votes
1
answer
2k
views
Apache Camel not sending reply for incoming message
I have Camel route which listens for incoming JMS messages. For some reason, the route doesn't send response to the JMS replyTo address. In the following example, the program hangs waiting for the ...
- 23.6k
0
votes
1
answer
2k
views
Verify if all the messages sent in a queue are being consumed by the application
I am using JMS(Fiorano provider) as a synchronization between the two applications.
App-A will publish a message on the Topic of there is any data changes to App-B so that the App-B can update its ...
- 5,768
0
votes
1
answer
196
views
Pentaho JMS consumer - multiple producer to a single consumer
I have 2 JMS queues where my application can publish the message to any one of the queue based on the node to which the request is being received. Pentaho should actively look to both the queues and ...
- 11.4k
1
vote
3
answers
2k
views
How do I get multiple clients to listen to the same consumer?
For instance, Producer A delivers a message on a queue/channel to Consumer A. Let's say it's a sports score.
How can I get multiple clients (desktops, mobile devices, etc) to listen in or connect to ...
- 161
0
votes
0
answers
182
views
Real-time messaging between PHP backend and JAVA frontend
My company has a desktop application which is made in JAVA and is communicating with PHP backend. Now, we have many clients, who are all given with a desktop app, and for each client there are many ...
- 153
1
vote
1
answer
2k
views
Concurrent message consumption in ActiveMQ
I use a ActiveMQServer as a broker.
Server.java
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import org.apache.activemq.api.core.TransportConfiguration;
import org....
- 9,002
1
vote
1
answer
6k
views
JMSException: Queue does not exist
I am new in JMS and want to create a basic MessageProducer who sends a message and MessageConsumer who receives the message asynchronously. When I run this code I get error message :
MessageProducer....
- 9,002
1
vote
2
answers
2k
views
is there a java pattern for a process to constantly run to poll or listen for messages off a queue and process them?
planning on moving a lot of our single threaded synchronous processing batch jobs to a more distributed architecture with workers. the thought is having a master process read records off the database, ...
- 686
2
votes
3
answers
2k
views
How often should I instantiate a JMS topic connection and session
I am just starting to gain knowledge and use JMS(activemq). The pseudo code looks like below
// 1. TopicConnectionFactory tcf = (TopicConnectionFactory) ctx.lookup("XXConnFactory");
// 2. ...
- 2,245
0
votes
0
answers
199
views
JMS queue with persistence enabled - performance bottlenecks
This question is to try and understand performance bottlenecks, if any, that would exist in listening to a message from a queue in which messages are persisted where the JMS provider resides vs ...
- 7,438
37
votes
5
answers
26k
views
How does JMS Receive work internally?
I've been researching various communication technologies/architectures/patterns/implementations (read: buzzwords) including Web Services (WCF, Axis2), ESBs, SOA, and wanted to know more about JMS with ...
- 2,664