sorry to hear that. I need this feature very much. is it possible to
"extend" activemq to achive this? is it difficult to modify the
dispatch logic of activemq?
On Mon, Mar 3, 2014 at 1:56 PM, artnaseef wrote:
> JMS does not provide such a method. You could use one queue per consumer and
> have
Thank you artnaseef, but I have tested a scenario like that;
I sent 1.000.000 object messages to the queue, and my kahadb's db.data file
became 480 mb. Then my consumer started to get messages. After a while
consuming finished and all messages in the queue reached to the target. But
when I checked
It is working as-designed.
Sent from my iPhone
> On Mar 2, 2014, at 11:14 PM, "jasonyangshadow [via ActiveMQ]"
> wrote:
>
> for example:
> i have a queue named:Queues.Test
> and i can add two listeners:
> one is : Queues.Test
> the other is : Queues.>
> the second one is wildcards type o
for example:
i have a queue named:Queues.Test
and i can add two listeners:
one is : Queues.Test
the other is : Queues.>
the second one is wildcards type of amq
so when there is a message coming to the Queues.Test
which listener is called?
i have tested the situation, and found that it called the
JMS does not provide such a method. You could use one queue per consumer and
have a consumer send the message back to an input queueon failure, but it would
get complex since a way of knowing which consumers rejected the message would
need to be tracked with the message, as well as knowing all t
Deletion is handled automatically. Each datafile remains until all of the
messages it contains are no longer needed.
Sent from my iPhone
> On Mar 2, 2014, at 1:50 PM, "turkuaz07 [via ActiveMQ]"
> wrote:
>
> I am using ActiveMQ in my app. My question is how to delete messages that ı
> consum
I have tested it with auto_acknowledge mode. it will be redediveryed
to the same consumer again and again before be moved to dead letter
queue.
what I want is, this message be sent to other consumers
On Mon, Mar 3, 2014 at 1:13 PM, Noel OConnor wrote:
> If the mdb is in a transaction you could tr
If the mdb is in a transaction you could try rolling it back. If not (I
think) the message should be redelivered if you throw a runtime exception
from within the MDB.
On Mon, Mar 3, 2014 at 3:35 PM, Li Li wrote:
> hi all,
> can a queue message consumer "refuse" a message after receive a
> m
hi all,
can a queue message consumer "refuse" a message after receive a message?
because a client don't know the message in advance.
onMessage(Message msg){
if(CannotProcess(msg)){
//refuse this message
}
}
what I need is: if the message can't be
We are using activeMQ 5.7 release and use static network of brokers. Every
now and then( 12 hrs or so) we get
javax.jms.InvalidClientIDException: Broker: broker-1 - Client:
network-broker-1_broker-3_outbound already connected from
tcp://:
at
org.apache.activemq.broker.region.RegionBroker.a
I am using ActiveMQ in my app. My question is how to delete messages that ı
consumed successfully from kahadb. Because if it is not deleted, my db.data
file is growing up constantly.
I just wanna delete messages from db.data file after consumer got the
message, but how ?
Here is my consumer;
11 matches
Mail list logo
