Nope, its not 200. Number of messages sent by JMS to consumer varies as per
the size of message. IF all messages are of same size, then number is very
consistent.
Problem is JMS waits for acknowledgment before sending further batch of
messages. If consumer acknowledges after receiving small set o
Yes, I am calling commit on the session but only after receiving say X number
of messages. Consumer will accumulate X number of messages before processing
and acknowledging them.
This X is configurable number. We tried with 500 and consumer was receiving
only around 350 messages. Messages which ar
Use the following URL option to avoid hanging on startup when using the
failover transport.
activemq:failover:tcp://activemqhost:61616*
?transport.StartupMaxReconnectAttempts=3*
Set the startup max reconnect attempts to whatever number you want. It
will eventually stop trying at start up. Once
On 07/30/2013 11:59 PM, yq8925 wrote:
In NMS.ActiveMQ1.5.6 and 1.6.0, if target JMS server URL is invalid or no
responsible, the client program will be hung at code "ISession session =
connection.CreateSession(AcknowledgementMode.AutoAcknowledge)".
The "connection.RequestTimeout" does not work h
Swapnil wrote
> Active MQ stops sending further messages to sole consumer after certain
> number of messages.
Is this "certain number of messages" equal to persistent adapter's
MAX_PAGE_SIZE (200)?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-stops-sending-me
Is the consume sending ack's back? Are you calling commit on your session?
Might help to post your code
On Wed, Jul 31, 2013 at 6:49 AM, Swapnil
wrote:
> Hello,
>
> We have a use case wherein we create just one consumer to process messages
> in the Queue. Message processor accumulates certain n
Hello,
We have a use case wherein we create just one consumer to process messages
in the Queue. Message processor accumulates certain number of messages
before acknowledging. Receiving messages in Asynchronous way and using
Transacted session. Size of message is very small.
Active MQ stops sendin
So keep in mind that nak_limit on the broker side is the number of poison
pills the broker will accept before moving a message to dlq.
I'm guessing in your ActiveQM 5.x client, you are expecting your redelivery
policy to send back an nack for each rollback? ...but it doesn't. It sends
a nack (pois
I use OpenWire protocol on the client side, where connection is created by
ActiveMQConnectionFactory
On Wed, Jul 31, 2013 at 9:43 PM, Christian Posta
wrote:
> What protocol are you using on the client side?
>
>
> On Wed, Jul 31, 2013 at 6:31 AM, Yong Ouyang
> wrote:
>
> > Hello,
> >
> > I am pl
What protocol are you using on the client side?
On Wed, Jul 31, 2013 at 6:31 AM, Yong Ouyang wrote:
> Hello,
>
> I am playing with Apollo 1.6 recently. Given the below config, I am
> expecting a dead message (being rolled back 3 times, for example) of queue
> "app1.queue1" will be forwarded to
Hello,
I am playing with Apollo 1.6 recently. Given the below config, I am
expecting a dead message (being rolled back 3 times, for example) of queue
"app1.queue1" will be forwarded to the dead letter queue "dlq.app1.queue1".
But this doesn't actually happen at all. Did anyone encounter the same
b
JMSTimestamp is understood by the spec to be set by the client. The broker
would override this.
JMSTimestamp is what the broker uses for TTL expiration.
On Wed, Jul 31, 2013 at 12:11 AM, Marco.Crivellaro wrote:
> Thanks.
> What would be the difference in setting JMSTimestamp using the timestamp
Yes, session#createProducer gives the impl for MessageProducer interface.
You should use the method I mentioned earlier in the thread to set the TTL.
On Wed, Jul 31, 2013 at 3:58 AM, ssahu wrote:
> When i do session.createProducer(..) ,will it automatically create the
> implementation for Me
Could it be that jconsole wasn't refreshing as often as you had expected?
ie, if you manually refresh, does it show the updated values? The memory
counters should not have a lag as they are updated as messages are coming
in and going out in real time.
On Wed, Jul 31, 2013 at 5:06 AM, Liviu I. wr
Take a look at the patch for https://issues.apache.org/jira/browse/AMQ-3215.
Either you can upgrade to 5.8.0 or see if you can apply the fix from the
JIRA.
Might be best to upgrade if you can.
On Wed, Jul 31, 2013 at 1:27 AM, Prashant wrote:
> We are using version 5.4.3(apache-activemq-5.4.3)
>
Hi Dejan,
The solution you are proposing is very elegant, however I don't think we can
make it work in our situation.
In our current setup the monitoring/alert software polls an HTTP REST
endpoint on the application, which in turn executes some internal checks and
returns health status informatio
I have tested this scenario again and I have noticed something strange.
Every time I run an integration test I check the queue with jconsole. Among
the attributes of the queue that I am able to see in jconsole are four that
caught my attention: CursorMemoryUsage, CursorPercentUsage,
MemoryPercentU
In NMS.ActiveMQ1.5.6 and 1.6.0, if target JMS server URL is invalid or no
responsible, the client program will be hung at code "ISession session =
connection.CreateSession(AcknowledgementMode.AutoAcknowledge)".
The "connection.RequestTimeout" does not work here...
Anyone could help on it?
--
V
When i do session.createProducer(..) ,will it automatically create the
implementation for MessageProducer ??
Then will i be able to call messageProducer.setTimeTOLive(2000); ???
How can i be able to call messageProducer.setTimeTOLive(2000); as it is
giving compilation error on this line???
I im
We are using version 5.4.3(apache-activemq-5.4.3)
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Help-for-small-customization-tp4668853p4669906.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Thank you for the quick answer.
We are using ActiveMQ 5.8.0. Our application uses Spring(3.1.0) and Camel
(2.10.3).
I will look into this test and see if I can reproduce what I am seeing. I
believe that this is more like an integration problem, how our application
and Camel work with AMQ or how t
Thanks.
What would be the difference in setting JMSTimestamp using the timestamp
plugin and using JMSActiveMQBrokerInTime?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/how-is-JMSTimestamp-set-tp4669820p4669904.html
Sent from the ActiveMQ - User mailing list archive at
22 matches
Mail list logo
