thank you tabish!
You've mentioned the key point.
For some reason I have to set the prefetch size=0 in my connection
string(jms.prefetchPolicy.queuePrefetch=0).
That's no wonder why I always receive null message while I call
receveNoWait().
I will call receive(timeout) instead. thanks again!
The contract of the receiveNoWait method is such that it never guarantees
that it will return a message. In your case its most likely that the
Message that's pending in the Queue has not reached the client's prefetch
buffer. Your code should take into account the fact that the receiveNoWait
metho
thank you prabugp.
These are my codes listed below,
myQueue = session.createQueue(queueName);
myCons = session.createConsumer(myQueue);
inMsg = myCons.receiveNoWait();
so sure that I've listened to the right queue and no message selectors as
well.
When the program runs into myCons.receiveNoWait(
I'm seeing this situation happen more often in my servers and seems pretty
random, some servers do connect and some don't.
Am I missing some parameter in the networkConnector bridge configuration?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/FailOver-transport-not-rec
I restarted my stand alone persistent broker using KahaDB and I found this
error message bellow in the log, no more messages are being consumed or
forwarded. Advice? This is very high priority for me and quick help would be
really appreciated.
INFO | jvm 1| 2012/09/18 23:13:50 | ERROR | Pro
If I understand how this works, there isn't a way to have a JMS producer send
messages in a load balanced way directly to multiple brokers (random,
round-robin, algorithm based upon feedback from brokers, etc) unless I want
to make my own thread pool that opens connections to a URI list, correct?
receiveNoWait() should retrieve the message, if there is one available in the
queue to be picked up. I'd check the configuration of the consumer to see if
it's listening on the Queue of interest and also that there are no message
selectors involved that could make the consumer not pick the msg. Thi
Is there some other program that manages the destinations that are in
ActiveMQ? Because, I find it almost impossible to create a queue without a
name from the Admin console or edit it afterwards. (If you managed to do it,
do let me know. I'm a new user myself).
Otherwise, I'd check other places wh
Hello,
I'm trying to delete a persistent message from a large queue with
removeMatchingMessages. The code works well until the memory that is used to
browse the queue hits the systemUsage.memoryUsage.limit.
I've changed the LargeQueueSparseDelete test case to reproduce this problem
(see below).
Excellent information. Thank you Gary!
-Original Message-
From: Gary Tully [mailto:gary.tu...@gmail.com]
Sent: Tuesday, September 18, 2012 3:02 AM
To: users@activemq.apache.org
Subject: Re: Intermittent delayed delivery
redelivery takes place on the consumer (client side only), so from
there are two options.
disable conduitSubscriptions so that there is a one to one mapping
between consumers on the standalone brokers and forwarding consumers
on the embedded brokers.
this will cause the embedded broker to drain faster and should move
the bottle neck to the network connector singl
I would expect some sort of truncation on the body of a large message
for the UI. So show only a few 100 bytes. sort of thing.
Like we do when we log a message.
If you use jconsole, do you see the full 20MB?
To implement browsing limited to headers, that would require some code
changes to suppor
redelivery takes place on the consumer (client side only), so from the
broker perspective the messages is seen as inflight to a consumer.
Redelivery respects order, so a message pending redelivery with a
delay will pause delivery of later messages to that consumer.
Check in jconsole (jmx stats) t
13 matches
Mail list logo
