All Questions
15 questions
0
votes
1
answer
757
views
Rabbit listener method is not getting invoked with the incoming message
I have a method to consume messages in similar line as shown below:
@RabbitListener(queues = "${com.rabbimq.myQueue}")
public void receive(String msg, Channel channel, @Header(AmqpHeaders....
- 105
0
votes
1
answer
527
views
How to halt consuming messages in an AMQP for a certain period of time (where time is not fixed)?
I am trying to achieve the following scenario in my application:
When my application is up, the message from the incoming exchange should be consumed by the incoming queue.
If any exception/error ...
- 105
0
votes
1
answer
183
views
Queue Server that allows global consume rate for all workers
I have many tasks that my servers need to handle. these tasks must be handled at a specific given rate due to API call rate limit that the workers need to meet.
In order to guarantee that these tasks ...
- 21
0
votes
0
answers
438
views
rabbitmq unacked messages after channel is dead
We have implemented RMQ in our application and it handles around 7 million messages a day. We have set TTL for every queue and also on message level. one queue may have one or multiple consumers.
Now ...
- 744
0
votes
1
answer
726
views
QPID Proton-J deprecates Messenger - but what to use instead?
I'm using Apache QPID with Java an as AMQP implementation and I've just got proton-j upgraded to version 0.16 (automatically, even though Maven web site still lists 0.15 as the latest version - weird) ...
- 32.5k
0
votes
1
answer
2k
views
RabbitMQ delete queue can not release connection
on my java program, some kind of messages are being sent over RabbitMQ queues as below :
if(!con.isConnected()){
log.error("Not connected !!!");
return false;
}
con.getChannel()....
- 426
2
votes
3
answers
2k
views
Java Message Queue Abstraction
I'm fairly new to Java and am currently writing a web application using a number of Dropwizard based micro services and Java8 SE. I now want to integrate a Message Queue for Async communication ...
- 219
0
votes
1
answer
2k
views
Rabbitmq: Modify message body before consuming
I'm new in RabbitMQ and I want to modify a message before consuming it by a queue. I have an exchange which should stay untouchable. The client receives messages with a specific routing key. But there ...
1
vote
0
answers
281
views
Embedded Java Amqp broker with Federation capabilities
I want to have micro services that communicate with amqp messages. I want to have a local queue that, when a connection is established to the RabbitMQ-server, sends/federates all the messages from the ...
- 811
157
votes
8
answers
69k
views
JMS and AMQP - RabbitMQ
I am trying to understand what JMS and how it is connected to AMQP terminology.
I know JMS is an API and AMQP is a protocol.
Here are my assumptions (and questions as well)
RabbitMQ uses AMQP ...
- 14.5k
26
votes
2
answers
17k
views
Are there any MQ servers that can run embedded in a Java process?
I'm researching queuing solutions for one of my team's apps. Ideally we would like something that can be configured both as a lightweight, in-process broker (for low-throughput messaging between ...
- 2,584
0
votes
1
answer
480
views
AMQP (Qpid) one to many queue
I have one producer, one queue and N consumers. Producer creates 'jobs' to be performed by consumers. I'd like to use pull model, in which consumer pulls job from queue, when it finishes the previous ...
- 2,014
30
votes
2
answers
71k
views
RabbitMQ: messages remain "Unacknowledged"
My Java application sends messages to RabbitMQ exchange, then exchange redirects messages to binded queue.
I use Springframework AMQP java plugin with RabbitMQ.
The problem: message comes to queue, ...
- 1,945
9
votes
2
answers
8k
views
when does an AMQP/RabbitMQ channel with no connections die?
I have a simple RabbitMQ test program randomly enqueuing messages, and another reading them, all using Spring-AMQP. If the consumer dies (for example killing a process without having a chance to close ...
- 7,547
5
votes
1
answer
4k
views
Apache qpid queue url
I'm trying to learn more information on how apache Qpid works and I do so by following examples from official svn :
http://svn.apache.org/repos/asf
I was looking at :
http://svn.apache.org/repos/...
- 15.3k