Sorry, There is no need to put a infinite loop here. The onMessage() it self
listens to the queue 24/7.
Sorry for confusion.
Mparida wrote:
>
> Hi,
>
> I want to configure a 24 hrs listener which shall listen to a queue
> through out the day and listen if there are a ny messages in queue or n
I just do like this:
[code]package com.mindtree.ch07;
import javax.jms.ExceptionListener;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueReceiver;
import javax.jm
Hi,
I'm using ActiveMQ5.2.0/5.3.0 and we have our custom code embedded into
ActiveMQ. Recently, we have updated our code to use Spring 3.0.0 binaries
and it seems this is not all OK with the ActiveMQ and it is not starting up.
the problems I observed are:
1). XBean configuration is not support
Dear all,
I'm also wondering if it is normal than, if someone sends one message to the
network of brokers, all Active Mq embedded in my clients will receive 2
messages, but only one is read by my client. I guess this is the
normal behavior, as my embedded broker has open a duplex connection with th
Hello All,
I am trying to deploy the war into tomcat, and have it directly connect to
the broker I am already running on my machine is this possible?
I seem to be having troubles, I have followed the directions from here:
http://activemq.apache.org/web-console.html#WebConsole-StartingtheWebCons
(Background on my setup)
I am trying to evaluate ActiveMQ's reliabilities for our messaging need. So
in my three node cluster setup. I have two producers published a random
number of messages between 0 and 2000 to node 1 and 2 in the cluster every
30 seconds. And I have two consumers remove messag
Just a quick followup, I looked into org.apache.activemq.broker.region.Queue
to see where the supposedly deleted messages were coming from and they're
being picked up from the "pagedInPendingDispatch" list during doBrowse(...):
// Messages that are paged in but have not yet been targeted at a
I have a test case in ActiveMQ 5.3 that is failing and would like to know if
this is expected behaviour or a bug.
Here's the test:
1) Create 100 test messages in a queue
2) Use jconsole and verify that the queue size is 100
3) Use jconsole and browseAsTable() to view the messages
4) Use jconsole
I'm seeing the exact behaviour described below with ActiveMQ 5.3.
Using the JMX MBean, I purge a queue that contains 100 persistent messages.
The statistics are updated to indicate the 100 dequeue and resulting 0 queue
size. However, browseAsTable[] still shows all 100 messages.
There was no f
Dejan Bosanac writes:
> Hi,
>
> it's not a but. With client ack, the ack you send will acknowledge all
> message up to the one you're sending ack for. So if you send acks
> out of order, you'll get "unexpected ack" message.
Interesting, I presume this is ActiveMQ's own interpretation of a
STOMP
Hi,
in 5.3 we changed how localhost is treated. Take a look at comments in
this issue http://issues.apache.org/activemq/browse/AMQ-2094. Do you
by any change resolve bigip to localhost in your dns (/etc/hosts or
something)?
Cheers
--
Dejan Bosanac - http://twitter.com/dejanb
Open Source Integrat
Post the code you used please
On 17 Dec 2009, at 15:12, Mparida wrote:
Hi,
I want to configure a 24 hrs listener which shall listen to a queue
through
out the day and listen if there are a ny messages in queue or not.
I tried it through an infinite loop but as you know it creates high
CP
Hi,
what particular issue are you experiencing. Some code and log would
help diagnose the problem.
Cheers
--
Dejan Bosanac - http://twitter.com/dejanb
Open Source Integration - http://fusesource.com/
ActiveMQ in Action - http://www.manning.com/snyder/
Blog - http://www.nighttale.net
On Wed, D
Hi,
I want to configure a 24 hrs listener which shall listen to a queue through
out the day and listen if there are a ny messages in queue or not.
I tried it through an infinite loop but as you know it creates high CPU.
I do not want to use schedulers for this.
If any one has done similar kin
Hi,
it's not a but. With client ack, the ack you send will acknowledge all
message up to the one you're sending ack for. So if you send acks out
of order, you'll get "unexpected ack" message.
You can use client-individual ack to achieve your desired
functionality (http://issues.apache.org/activem
Hi,
I have a consumer with prefetch>1 and client ack. If I send the acks
out of order (not in the order the messages are received), I get an
exception:
org.apache.activemq.transport.stomp.ProtocolException: Unexpected ACK received
for message-id
is this in JMS specification that acks need to b
16 matches
Mail list logo
