You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by YoungSoul <yo...@inbox.com> on 2007/01/17 16:32:08 UTC
Is anyone else seeing messages stuck on a queue?
I see this frequently - and I just can't believe that others are not either.
So either, amq is fine and my usage of it is incorrect somehow or there is
something fundementally wrong with it.
There does not seem to be a pattern for when a message is stuck. My simple,
simple app posts messages very infrequently. 1 every few seconds. Most of
the time the messages get through, sometimes one gets stuck. I have a
single client pulling the message off. I can see the message in the queue
browser but it wont come off the queue.
thanks
--
View this message in context: http://www.nabble.com/Is-anyone-else-seeing-messages-stuck-on-a-queue--tf3027911.html#a8412294
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Is anyone else seeing messages stuck on a queue?
Posted by rajdavies <ra...@gmail.com>.
Has anyone who is experiencing this problem also see in it in the 4.1.0
snapshot ?
http://people.apache.org/repo/m2-snapshot-repository/org/apache/activemq/apache-activemq/4.1-incubator-SNAPSHOT/
YoungSoul wrote:
>
>
> I see this frequently - and I just can't believe that others are not
> either.
>
> So either, amq is fine and my usage of it is incorrect somehow or there is
> something fundementally wrong with it.
>
> There does not seem to be a pattern for when a message is stuck. My
> simple, simple app posts messages very infrequently. 1 every few seconds.
> Most of the time the messages get through, sometimes one gets stuck. I
> have a single client pulling the message off. I can see the message in
> the queue browser but it wont come off the queue.
>
> thanks
>
--
View this message in context: http://www.nabble.com/Is-anyone-else-seeing-messages-stuck-on-a-queue--tf3027911.html#a8762238
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Is anyone else seeing messages stuck on a queue?
Posted by YoungSoul <yo...@inbox.com>.
This is related to the following post:
http://www.nabble.com/Messages-%27stuck%27-on-queue%2C-until-client-restart-tf3017349.html#a8379662
For the version, I went to the following page:
http://www.activemq.org/site/activemq-410-release.html
and pulled: apache-activemq-4.1.0-incubator.zip or
apache-activemq-4.1.0-incubator.tar.gz depending upon my test environment.
Below is my method for creating the consumer - at the moment no producers
are created, i.e. this consumer does not push the message to another queue.
public void afterPropertiesSet() throws Exception {
Assert.hasText(name, "You must set the name property in the spring
config file");
Assert.hasText(id, "You must set the consumer ID property in the spring
config file");
Assert.notNull(messageListener, "You must set the
MessageConsumerListener property in the spring config file");
Assert.notNull(connectionFactory, "You must set the
connectionFactory in the spring config file");
log.info("Attempting to obtain a transacted session from JMS
ConntectionFactory in class: " + this.getClass().getName());
Connection conn = connectionFactory.createConnection();
if( conn != null ) {
session = conn.createSession(true, Session.SESSION_TRANSACTED);
Queue readQueue = session.createQueue(readQueueName);
messageConsumer = session.createConsumer(readQueue);
if( writeQueueNames != null ) {
for (Iterator iter = writeQueueNames.iterator();
iter.hasNext();) {
String writeQueueName = (String) iter.next();
Queue writeQueue = session.createQueue(writeQueueName);
MessageProducer mp = session.createProducer(writeQueue);
mp.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
messageProducers.add(mp);
queue2MessageProducerMap.put(writeQueueName,mp);
}
}
if( deadQueueName != null ) {
Queue deadLetter = session.createQueue(deadQueueName);
deadMessageQueue = session.createProducer(deadLetter);
deadMessageQueue.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
}
initialized = true;
}
}
to read a message I ultimately perform the following:
message = messageConsumer.receive(5000);
Thanks for any help.
Pat
James.Strachan wrote:
>
> Which version are you using? Also what kind of consumer is it
> (transactional / sync/async etc)
>
> On 1/17/07, YoungSoul <yo...@inbox.com> wrote:
>>
>>
>> I see this frequently - and I just can't believe that others are not
>> either.
>>
>> So either, amq is fine and my usage of it is incorrect somehow or there
>> is
>> something fundementally wrong with it.
>>
>> There does not seem to be a pattern for when a message is stuck. My
>> simple,
>> simple app posts messages very infrequently. 1 every few seconds. Most
>> of
>> the time the messages get through, sometimes one gets stuck. I have a
>> single client pulling the message off. I can see the message in the
>> queue
>> browser but it wont come off the queue.
>>
>> thanks
>> --
>> View this message in context:
>> http://www.nabble.com/Is-anyone-else-seeing-messages-stuck-on-a-queue--tf3027911.html#a8412294
>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>
>>
>
>
> --
>
> James
> -------
> http://radio.weblogs.com/0112098/
>
>
--
View this message in context: http://www.nabble.com/Is-anyone-else-seeing-messages-stuck-on-a-queue--tf3027911.html#a8413018
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Is anyone else seeing messages stuck on a queue?
Posted by YoungSoul <yo...@inbox.com>.
>From my perspective, 3.2.2 was solid. I never really had any issues with
it.
Here is the stack trace from the starting of activemq. Hope it helps.
[root@mdl1 bin]# ./activemq
ACTIVEMQ_HOME: /usr/local/activemq-4.2
ACTIVEMQ_BASE: /usr/local/activemq-4.2
Loading message broker from: xbean:activemq.xml
INFO BrokerService - Using Persistence Adapter:
JournalPersistenceAdapator(JDBCPersistenceAdaptor(org.apache.derby.jdbc.EmbeddedDataSource@9b42e6))
INFO BrokerService - ActiveMQ null JMS Message Broker
(localhost) is starting
INFO BrokerService - For help or more information please
see: http://incubator.apache.org/activemq/
INFO ManagementContext - JMX consoles can connect to
service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
INFO JDBCPersistenceAdapter - Database driver recognized:
[apache_derby_embedded_jdbc_driver]
INFO DefaultDatabaseLocker - Attempting to acquire the exclusive
lock to become the Master broker
INFO DefaultDatabaseLocker - Becoming the master on dataSource:
org.apache.derby.jdbc.EmbeddedDataSource@9b42e6
INFO JournalPersistenceAdapter - Journal Recovery Started from: Active
Journal: using 5 x 20.0 Megs at:
/usr/local/activemq-4.2.0-snapshot/apache-activemq-4.2-incubator-SNAPSHOT/activemq-data/journal
INFO JournalPersistenceAdapter - Journal Recovered: 1 message(s) in
transactions recovered.
INFO TransportServerThreadSupport - Listening for connections at:
tcp://mdl1.myco.com:61616
INFO TransportConnector - Connector openwire Started
INFO TransportServerThreadSupport - Listening for connections at:
ssl://mdl1.myco.com:61617
INFO TransportConnector - Connector ssl Started
INFO TransportServerThreadSupport - Listening for connections at:
stomp://mdl1.myco.com:61613
INFO TransportConnector - Connector stomp Started
INFO NetworkConnector - Network Connector default-nc Started
INFO BrokerService - ActiveMQ JMS Message Broker
(localhost, ID:mdl1.myco.com-56746-1169487078117-1:0) started
INFO TransportConnector - Connector vm://localhost Started
INFO KahaStore - Kaha Store successfully deleted data
directory activemq-data/localhost/tmp_storage
ERROR Service - Async error occurred:
java.util.ConcurrentModificationException
java.util.ConcurrentModificationException
at
java.util.LinkedList$ListItr.checkForComodification(LinkedList.java:761)
at java.util.LinkedList$ListItr.next(LinkedList.java:696)
at
org.apache.activemq.broker.region.cursors.VMPendingMessageCursor.next(VMPendingMessageCursor.java:71)
at
org.apache.activemq.broker.region.PrefetchSubscription.dispatchMatched(PrefetchSubscription.java:380)
at
org.apache.activemq.broker.region.PrefetchSubscription.pullTimeout(PrefetchSubscription.java:111)
at
org.apache.activemq.broker.region.PrefetchSubscription.access$000(PrefetchSubscription.java:49)
at
org.apache.activemq.broker.region.PrefetchSubscription$1.run(PrefetchSubscription.java:94)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
at
java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:98)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:207)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:885)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:907)
at java.lang.Thread.run(Thread.java:619)
ERROR Service - Async error occurred:
java.util.ConcurrentModificationException
java.util.ConcurrentModificationException
at
java.util.LinkedList$ListItr.checkForComodification(LinkedList.java:761)
at java.util.LinkedList$ListItr.next(LinkedList.java:696)
at
org.apache.activemq.broker.region.cursors.VMPendingMessageCursor.next(VMPendingMessageCursor.java:71)
at
org.apache.activemq.broker.region.PrefetchSubscription.dispatchMatched(PrefetchSubscription.java:380)
at
org.apache.activemq.broker.region.PrefetchSubscription.pullTimeout(PrefetchSubscription.java:111)
at
org.apache.activemq.broker.region.PrefetchSubscription.access$000(PrefetchSubscription.java:49)
at
org.apache.activemq.broker.region.PrefetchSubscription$1.run(PrefetchSubscription.java:94)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
at
java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:98)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:207)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:885)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:907)
at java.lang.Thread.run(Thread.java:619)
ERROR Service - Async error occurred:
java.util.ConcurrentModificationException
<This then repeats another 1/2 dozen times or so >
Thanks
rajdavies wrote:
>
> wow! 3.2.2 was solid! Could you post the stack trace with the
> concurrent modification exceptions please ?
>
> cheers,
>
> Rob
>
> On 23 Jan 2007, at 19:10, YoungSoul wrote:
>
>>
>>
>> I tried the 4.2 snapshot, and while I did not get any stuck
>> messages, I did
>> a number of concurrent modification exceptions. Interestingly with
>> the
>> number of clients I was running I did seem to get through all of the
>> messages.
>>
>> Also - 4.2 did not seem to balance the requests very well at all
>> between
>> clients. I created 2 separate clients on two different machines, both
>> multi-threaded. It seems like the first client to start was the
>> one that
>> received nearly all of the messages.
>>
>>
>> I dont ever remember having these problems with 3.x - so for fun? I
>> rolled
>> back to 3.2.2 and I ran my test app a number of times a. I never
>> received a
>> stuck message, nor the concurrent exception and the balancing
>> looked very
>> even.
>>
>>
>>
>>
>> James.Strachan wrote:
>>>
>>>
>>> James.Strachan wrote:
>>>>
>>>> I wonder if either of you could try out trunk to see if the
>>>> problem is
>>>> still there? There's been a number of patches in the acknowledgement
>>>> code of late. (Unfortunatley the nightly snapshots haven't been
>>>> working for a little while but we'll hopefully get them working
>>>> again
>>>> ASAP).
>>>>
>>>
>>> Incidentally the nightly backups are back now if you wanna try a
>>> binary
>>> download of 4.2-snapshot (pick one near the bottom thats dated
>>> January :)
>>>
>>> http://people.apache.org/repo/m2-snapshot-repository/org/apache/
>>> activemq/apache-activemq/4.2-incubator-SNAPSHOT/
>>>
>>> --
>>>
>>> James
>>> -------
>>> http://radio.weblogs.com/0112098/
>>>
>>>
>>>
>>
>> --
>> View this message in context: http://www.nabble.com/Is-anyone-else-
>> seeing-messages-stuck-on-a-queue--tf3027911.html#a8528222
>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>
>
>
>
--
View this message in context: http://www.nabble.com/Is-anyone-else-seeing-messages-stuck-on-a-queue--tf3027911.html#a8550623
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Is anyone else seeing messages stuck on a queue?
Posted by Rob Davies <ra...@gmail.com>.
wow! 3.2.2 was solid! Could you post the stack trace with the
concurrent modification exceptions please ?
cheers,
Rob
On 23 Jan 2007, at 19:10, YoungSoul wrote:
>
>
> I tried the 4.2 snapshot, and while I did not get any stuck
> messages, I did
> a number of concurrent modification exceptions. Interestingly with
> the
> number of clients I was running I did seem to get through all of the
> messages.
>
> Also - 4.2 did not seem to balance the requests very well at all
> between
> clients. I created 2 separate clients on two different machines, both
> multi-threaded. It seems like the first client to start was the
> one that
> received nearly all of the messages.
>
>
> I dont ever remember having these problems with 3.x - so for fun? I
> rolled
> back to 3.2.2 and I ran my test app a number of times a. I never
> received a
> stuck message, nor the concurrent exception and the balancing
> looked very
> even.
>
>
>
>
> James.Strachan wrote:
>>
>>
>> James.Strachan wrote:
>>>
>>> I wonder if either of you could try out trunk to see if the
>>> problem is
>>> still there? There's been a number of patches in the acknowledgement
>>> code of late. (Unfortunatley the nightly snapshots haven't been
>>> working for a little while but we'll hopefully get them working
>>> again
>>> ASAP).
>>>
>>
>> Incidentally the nightly backups are back now if you wanna try a
>> binary
>> download of 4.2-snapshot (pick one near the bottom thats dated
>> January :)
>>
>> http://people.apache.org/repo/m2-snapshot-repository/org/apache/
>> activemq/apache-activemq/4.2-incubator-SNAPSHOT/
>>
>> --
>>
>> James
>> -------
>> http://radio.weblogs.com/0112098/
>>
>>
>>
>
> --
> View this message in context: http://www.nabble.com/Is-anyone-else-
> seeing-messages-stuck-on-a-queue--tf3027911.html#a8528222
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
Re: Is anyone else seeing messages stuck on a queue?
Posted by YoungSoul <yo...@inbox.com>.
I tried the 4.2 snapshot, and while I did not get any stuck messages, I did
a number of concurrent modification exceptions. Interestingly with the
number of clients I was running I did seem to get through all of the
messages.
Also - 4.2 did not seem to balance the requests very well at all between
clients. I created 2 separate clients on two different machines, both
multi-threaded. It seems like the first client to start was the one that
received nearly all of the messages.
I dont ever remember having these problems with 3.x - so for fun? I rolled
back to 3.2.2 and I ran my test app a number of times a. I never received a
stuck message, nor the concurrent exception and the balancing looked very
even.
James.Strachan wrote:
>
>
> James.Strachan wrote:
>>
>> I wonder if either of you could try out trunk to see if the problem is
>> still there? There's been a number of patches in the acknowledgement
>> code of late. (Unfortunatley the nightly snapshots haven't been
>> working for a little while but we'll hopefully get them working again
>> ASAP).
>>
>
> Incidentally the nightly backups are back now if you wanna try a binary
> download of 4.2-snapshot (pick one near the bottom thats dated January :)
>
> http://people.apache.org/repo/m2-snapshot-repository/org/apache/activemq/apache-activemq/4.2-incubator-SNAPSHOT/
>
> --
>
> James
> -------
> http://radio.weblogs.com/0112098/
>
>
>
--
View this message in context: http://www.nabble.com/Is-anyone-else-seeing-messages-stuck-on-a-queue--tf3027911.html#a8528222
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Is anyone else seeing messages stuck on a queue?
Posted by Simon Wistow <si...@thegestalt.org>.
On Sat, Jan 20, 2007 at 02:34:58AM +0800, Adrian Co said:
> How did you run it? i.e. parameters you used?
>
> Could you run it via ./activemq xbean:activemq.xml?
Running ./activemq start xbean:activemq.xml
with the svn bin/activemq and tailing /target/activemq.xml seems to now
start although it doesn't seem to start any services. I'll fiddle around
with the config and rerun our unit tests and see if the snapshot fixes
our (suspected) ACKing problems.
Thanks,
Simon
Re: Is anyone else seeing messages stuck on a queue?
Posted by Adrian Co <ac...@exist.com>.
Simon Wistow wrote:
> On Thu, Jan 18, 2007 at 09:50:46AM -0800, James.Strachan said:
>
>> Incidentally the nightly backups are back now if you wanna try a binary
>> download of 4.2-snapshot (pick one near the bottom thats dated January :)
>>
>
> The Snapshots don't seem to have *nix shell scripts in the bin/
> directory.
>
> Using an old copy fo the activemq script gets to the point of
>
> Loading message broker from: xbean:activemq.xml
>
> and then just hangs. strace doesn't reveal anything.
>
I think this could be a logging issue, id check the log4j.properties
file that its writing to console.
> (This is after creating a writeable /target/test.log by hand)
>
>
> Downloading
>
> https://svn.apache.org/repos/asf/incubator/activemq/trunk/assembly/src/release/bin/activemq
>
> gets an error message
>
> ERROR: java.lang.RuntimeException: Failed to execute start task. Reason:
> java.lang.IllegalArgumentException: Invalid broker URI, no scheme
> specified:
>
How did you run it? i.e. parameters you used?
Could you run it via ./activemq xbean:activemq.xml?
> Any ideas?
>
> Simon
>
>
>
Re: Is anyone else seeing messages stuck on a queue?
Posted by Simon Wistow <si...@thegestalt.org>.
On Tue, Jan 23, 2007 at 08:20:27AM +0000, James Strachan said:
> The .zip file currently only has the .bat files. The tar.gz has the
> shell scripts. I've just patched the code so that the next nightly
> snapshot of the zip will have the unix scripts too (I often use zips
> on OS X for example :)
Doh, yeah - realised there was a .tar.gz yesterday - we had a script
that was downloading zip files automatically for Windows and I was just
being blind.
> I tried the tar.gz distro and it worked perfectly for me on OS X.
> Maybe try try tar.gz too or today's snapshot to see if it works for
> you now?
I'd got the zip file from the 15th working by running
bin/activemq start xbean:file:conf/activemq.xml
however our unit tests still failed - we're still trying to make a
concise test case but, essentially, using Net::Stomp under Perl we had
been seeing some messages coming through twice, even after an ACK, or
the broker wedging.
With the snapshot from the 15th we found that if there were multiplke
consumers then our problems seem to go away (with either multiple
producers or a single producer). However if there was only a single
consumer it sat indefinitely waiting a message (again, multiple or a
single producer). Very odd. We're doing traces and trying to work out
what's going on.
With the latest .tar.gz snapshot (from the 17th?) I had to use different
command line arguments
bin/activemq start
immediately fails with an invalid broker uri exception.
bin/activemq xbean:activemq.xml
bin/activemq xbean:file:conf/activemq.xml
both work (you probably know this buit incase anybody else is
wondering). However we still see the same problems.
I can send you our test scripts if it'll help.
Simon
Re: Is anyone else seeing messages stuck on a queue?
Posted by James Strachan <ja...@gmail.com>.
On 1/19/07, Simon Wistow <si...@thegestalt.org> wrote:
> On Thu, Jan 18, 2007 at 09:50:46AM -0800, James.Strachan said:
> > Incidentally the nightly backups are back now if you wanna try a binary
> > download of 4.2-snapshot (pick one near the bottom thats dated January :)
>
> The Snapshots don't seem to have *nix shell scripts in the bin/
> directory.
The .zip file currently only has the .bat files. The tar.gz has the
shell scripts. I've just patched the code so that the next nightly
snapshot of the zip will have the unix scripts too (I often use zips
on OS X for example :)
> Using an old copy fo the activemq script gets to the point of
>
> Loading message broker from: xbean:activemq.xml
>
> and then just hangs. strace doesn't reveal anything.
I tried the tar.gz distro and it worked perfectly for me on OS X.
Maybe try try tar.gz too or today's snapshot to see if it works for
you now?
--
James
-------
http://radio.weblogs.com/0112098/
Re: Is anyone else seeing messages stuck on a queue?
Posted by Simon Wistow <si...@thegestalt.org>.
On Thu, Jan 18, 2007 at 09:50:46AM -0800, James.Strachan said:
> Incidentally the nightly backups are back now if you wanna try a binary
> download of 4.2-snapshot (pick one near the bottom thats dated January :)
The Snapshots don't seem to have *nix shell scripts in the bin/
directory.
Using an old copy fo the activemq script gets to the point of
Loading message broker from: xbean:activemq.xml
and then just hangs. strace doesn't reveal anything.
(This is after creating a writeable /target/test.log by hand)
Downloading
https://svn.apache.org/repos/asf/incubator/activemq/trunk/assembly/src/release/bin/activemq
gets an error message
ERROR: java.lang.RuntimeException: Failed to execute start task. Reason:
java.lang.IllegalArgumentException: Invalid broker URI, no scheme
specified:
Any ideas?
Simon
Re: Is anyone else seeing messages stuck on a queue?
Posted by "James.Strachan" <ja...@gmail.com>.
James.Strachan wrote:
>
> I wonder if either of you could try out trunk to see if the problem is
> still there? There's been a number of patches in the acknowledgement
> code of late. (Unfortunatley the nightly snapshots haven't been
> working for a little while but we'll hopefully get them working again
> ASAP).
>
Incidentally the nightly backups are back now if you wanna try a binary
download of 4.2-snapshot (pick one near the bottom thats dated January :)
http://people.apache.org/repo/m2-snapshot-repository/org/apache/activemq/apache-activemq/4.2-incubator-SNAPSHOT/
--
James
-------
http://radio.weblogs.com/0112098/
--
View this message in context: http://www.nabble.com/Is-anyone-else-seeing-messages-stuck-on-a-queue--tf3027911.html#a8435668
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Is anyone else seeing messages stuck on a queue?
Posted by James Strachan <ja...@gmail.com>.
I wonder if either of you could try out trunk to see if the problem is
still there? There's been a number of patches in the acknowledgement
code of late. (Unfortunatley the nightly snapshots haven't been
working for a little while but we'll hopefully get them working again
ASAP).
A tutorial on how to build from the source code is here...
http://incubator.apache.org/activemq/building.html
On 1/17/07, tony.x.rippy@jpmchase.com <to...@jpmchase.com> wrote:
> Hi,
>
> I've noticed the same behavior. Every now and then a message will be
> visible through the JMX interface but not accessible to consumers. I'm
> using ActiveMQ 4.1.0 for both the broker and clients. We have a single
> producer and about 1000 consumers. The consumers use queuePrefetch=1 and
> AUTO_ACKNOWLEDGE sessions.
>
> Hope this helps,
>
> - Tony
>
>
>
>
> "James Strachan" <ja...@gmail.com>
> 01/17/2007 10:46 AM
> Please respond to
> activemq-users@geronimo.apache.org
>
>
> To
> activemq-users@geronimo.apache.org
> cc
>
> Subject
> Re: Is anyone else seeing messages stuck on a queue?
>
>
>
>
>
>
> Which version are you using? Also what kind of consumer is it
> (transactional / sync/async etc)
>
> On 1/17/07, YoungSoul <yo...@inbox.com> wrote:
> >
> >
> > I see this frequently - and I just can't believe that others are not
> either.
> >
> > So either, amq is fine and my usage of it is incorrect somehow or there
> is
> > something fundementally wrong with it.
> >
> > There does not seem to be a pattern for when a message is stuck. My
> simple,
> > simple app posts messages very infrequently. 1 every few seconds. Most
> of
> > the time the messages get through, sometimes one gets stuck. I have a
> > single client pulling the message off. I can see the message in the
> queue
> > browser but it wont come off the queue.
> >
> > thanks
> > --
> > View this message in context:
> http://www.nabble.com/Is-anyone-else-seeing-messages-stuck-on-a-queue--tf3027911.html#a8412294
>
> > Sent from the ActiveMQ - User mailing list archive at Nabble.com.
> >
> >
>
>
> --
>
> James
> -------
> http://radio.weblogs.com/0112098/
>
>
>
>
> -----------------------------------------
> This transmission may contain information that is privileged,
> confidential, legally privileged, and/or exempt from disclosure
> under applicable law. If you are not the intended recipient, you
> are hereby notified that any disclosure, copying, distribution, or
> use of the information contained herein (including any reliance
> thereon) is STRICTLY PROHIBITED. Although this transmission and
> any attachments are believed to be free of any virus or other
> defect that might affect any computer system into which it is
> received and opened, it is the responsibility of the recipient to
> ensure that it is virus free and no responsibility is accepted by
> JPMorgan Chase & Co., its subsidiaries and affiliates, as
> applicable, for any loss or damage arising in any way from its use.
> If you received this transmission in error, please immediately
> contact the sender and destroy the material in its entirety,
> whether in electronic or hard copy format. Thank you.
>
>
--
James
-------
http://radio.weblogs.com/0112098/
Re: Is anyone else seeing messages stuck on a queue?
Posted by to...@jpmchase.com.
Hi,
I've noticed the same behavior. Every now and then a message will be
visible through the JMX interface but not accessible to consumers. I'm
using ActiveMQ 4.1.0 for both the broker and clients. We have a single
producer and about 1000 consumers. The consumers use queuePrefetch=1 and
AUTO_ACKNOWLEDGE sessions.
Hope this helps,
- Tony
"James Strachan" <ja...@gmail.com>
01/17/2007 10:46 AM
Please respond to
activemq-users@geronimo.apache.org
To
activemq-users@geronimo.apache.org
cc
Subject
Re: Is anyone else seeing messages stuck on a queue?
Which version are you using? Also what kind of consumer is it
(transactional / sync/async etc)
On 1/17/07, YoungSoul <yo...@inbox.com> wrote:
>
>
> I see this frequently - and I just can't believe that others are not
either.
>
> So either, amq is fine and my usage of it is incorrect somehow or there
is
> something fundementally wrong with it.
>
> There does not seem to be a pattern for when a message is stuck. My
simple,
> simple app posts messages very infrequently. 1 every few seconds. Most
of
> the time the messages get through, sometimes one gets stuck. I have a
> single client pulling the message off. I can see the message in the
queue
> browser but it wont come off the queue.
>
> thanks
> --
> View this message in context:
http://www.nabble.com/Is-anyone-else-seeing-messages-stuck-on-a-queue--tf3027911.html#a8412294
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>
--
James
-------
http://radio.weblogs.com/0112098/
-----------------------------------------
This transmission may contain information that is privileged,
confidential, legally privileged, and/or exempt from disclosure
under applicable law. If you are not the intended recipient, you
are hereby notified that any disclosure, copying, distribution, or
use of the information contained herein (including any reliance
thereon) is STRICTLY PROHIBITED. Although this transmission and
any attachments are believed to be free of any virus or other
defect that might affect any computer system into which it is
received and opened, it is the responsibility of the recipient to
ensure that it is virus free and no responsibility is accepted by
JPMorgan Chase & Co., its subsidiaries and affiliates, as
applicable, for any loss or damage arising in any way from its use.
If you received this transmission in error, please immediately
contact the sender and destroy the material in its entirety,
whether in electronic or hard copy format. Thank you.
Re: Is anyone else seeing messages stuck on a queue?
Posted by James Strachan <ja...@gmail.com>.
Which version are you using? Also what kind of consumer is it
(transactional / sync/async etc)
On 1/17/07, YoungSoul <yo...@inbox.com> wrote:
>
>
> I see this frequently - and I just can't believe that others are not either.
>
> So either, amq is fine and my usage of it is incorrect somehow or there is
> something fundementally wrong with it.
>
> There does not seem to be a pattern for when a message is stuck. My simple,
> simple app posts messages very infrequently. 1 every few seconds. Most of
> the time the messages get through, sometimes one gets stuck. I have a
> single client pulling the message off. I can see the message in the queue
> browser but it wont come off the queue.
>
> thanks
> --
> View this message in context: http://www.nabble.com/Is-anyone-else-seeing-messages-stuck-on-a-queue--tf3027911.html#a8412294
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>
--
James
-------
http://radio.weblogs.com/0112098/
Re: Is anyone else seeing messages stuck on a queue?
Posted by "Dan.Connelly" <Da...@state.vt.us>.
I should have mentioned that my 2 brokers have different vm transport URIs.
I should have mentioned, also, the two brokers have different journaledJDBC
dataDirectories. I assume, therefore, that they have different Derby
databases URIs, but I am not absolutely sure on that point.
--
View this message in context: http://www.nabble.com/Is-anyone-else-seeing-messages-stuck-on-a-queue--tf3027911.html#a8525663
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Is anyone else seeing messages stuck on a queue?
Posted by "Dan.Connelly" <Da...@state.vt.us>.
I am seeing stuck message using AMQ 4.1 with JBoss embedded brokers, SLSB
producers, MDB consumers, vm transport and derby persistence. (Also with
an external JMS consumer.) I have 2 embedded brokers and 3 queues (1+2) so
far.
This seems to be a start-up issues. If I re-start JBoss, the queue(s) gets
unstuck and seem to run fine after that. (But I have not tested with a
heavy load.)
When I shutdown JBoss from the JMX Console I (always) get the following
error, which may or may not be related. Perhaps my EJBs need to be
clossing JMS connections?? Perhaps ActiveMQ is neglecting to close
them????
[ActiveMQManagedConnection] Error occured during close of a JMS connection.
javax.jms.JMSException: Peer (vm://localhost#35) disposed.
at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:58)
at
org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1153)
at
org.apache.activemq.ActiveMQConnection.close(ActiveMQConnection.java:578)
at
org.apache.activemq.ra.ActiveMQManagedConnection.destroy(ActiveMQManagedConnection.java:225)
--
View this message in context: http://www.nabble.com/Is-anyone-else-seeing-messages-stuck-on-a-queue--tf3027911.html#a8524461
Sent from the ActiveMQ - User mailing list archive at Nabble.com.