You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by ChicagoBob123 <bo...@bobfx.com> on 2010/08/31 19:30:02 UTC
Newbie question about many consumers and many producers
Newbie question about many consumers and many producers.
I have searched and read through some of the archives but have not been able
to find an answer to this question.
I am working on an application that will have several different producers.
They supply messages to
a common queue. The messages contain ID's for consumers of the messages to
know to it is their message/task. But when ever I acknowledge I have
received a message all the messages from
the queue are removed and now consumers that may have been off line can no
longer get their message.
Am I missing something basic here.
I tried to browse the queue and that will not remove any messages.
I tried to only acknowledge messages via the Client Acknowledge. As soon as
I acknowledge all the messages are removed. ???
--
View this message in context: http://activemq.2283324.n4.nabble.com/Newbie-question-about-many-consumers-and-many-producers-tp2402003p2402003.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Newbie question about many consumers and many producers
Posted by ChicagoBob123 <bo...@bobfx.com>.
We are trying to work with another organization and their spec.
I suggested the multiple queue idea to my boss today but have not heard back
as he is out of town.
So the answer is I just don't know if this is a hard core requirement yet.
Is it ok to have 40 or 50 queues?
Bob
--
View this message in context: http://activemq.2283324.n4.nabble.com/Newbie-question-about-many-consumers-and-many-producers-tp2402003p2402090.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Newbie question about many consumers and many producers
Posted by Michael Justin <mi...@gmx.net>.
Am 31.08.2010 19:30, ChicagoBob123 wrote:
> The messages contain ID's for consumers of the messages to
> know to it is their message/task.
If the IDs are set as message properties, the client can filter their
own messages by using a selector on the messageconsumer.
> I tried to only acknowledge messages via the Client Acknowledge. As soon as
> I acknowledge all the messages are removed. ???
Acknowledging a message also acks all preview messages iirc.
Hope this helps,
--
Michael Justin
SCJP, SCJA
betasoft - Software for Delphi™ and for the Java™ platform
http://www.mikejustin.com - http://www.betabeans.de
Re: Jboss 5.1 and ActiveMQ 5.3.2: Endpoint did not release properly: null
Posted by Benoit Xhenseval <be...@yahoo.com>.
Hi
Same issue happens with ActiveMQ 5.4.0 and JBoss 5.1; Spring 2.5.5
This is a major hurdle for us; we can debug/try to find the issue with some
guidance...
A full ra.xml example (article/blog) with JBoss 5.1 would be very useful. I
note that the ActiveMQ website only mentions that it was tested with JBoss
4.x... is this a known issue?
I enclose our ra.xml and broker config.
The application-ra.jar is then packaged up in an EAR file. It all worked fine
with JBoss 4.0.5.
First message is processed ok, second message, the thread says this:
2010-09-01 10:19:25,076 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1]
(org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor#7cb73752-1)
Work accepted:
javax.resource.spi.work.WorkEvent[source=org.springframework.jca.work.SimpleTaskWorkManager$DelegatingWorkAdapter@7d5103e7]
2010-09-01 10:19:25,076 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1]
(org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor#7cb73752-1)
Work started:
javax.resource.spi.work.WorkEvent[source=org.springframework.jca.work.SimpleTaskWorkManager$DelegatingWorkAdapter@7d5103e7]
2010-09-01 10:19:25,076 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1]
(org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor#7cb73752-1)
Running
2010-09-01 10:19:25,076 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1]
(org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor#7cb73752-1)
run loop start
2010-09-01 10:19:25,091 INFO [org.apache.activemq.ra.ServerSessionImpl:1]
(org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor#7cb73752-1)
Endpoint failed to process message. Reason: Endpoint before delivery
notification failure
2010-09-01 10:19:25,091 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1]
(org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor#7cb73752-1)
run loop end
2010-09-01 10:19:25,093 DEBUG [org.apache.activemq.ra.ServerSessionImpl:1]
(org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor#7cb73752-1)
Endpoint did not release properly: null
org.apache.activemq.ra.InvalidMessageEndpointException
at
org.apache.activemq.ra.MessageEndpointProxy$MessageEndpointDead.release(MessageEndpointProxy.java:159)
at
org.apache.activemq.ra.MessageEndpointProxy.release(MessageEndpointProxy.java:74)
at org.apache.activemq.ra.ServerSessionImpl.close(ServerSessionImpl.java:263)
at
org.apache.activemq.ra.ServerSessionPoolImpl.removeFromPool(ServerSessionPoolImpl.java:230)
at org.apache.activemq.ra.ServerSessionImpl.run(ServerSessionImpl.java:188)
at
org.springframework.jca.work.SimpleTaskWorkManager$DelegatingWorkAdapter.run(SimpleTaskWorkManager.java:232)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:637)
Any help / guidance would be very welcome
Thanks
Benoit
------------------------IMPORTANT NOTICE This communication contains information
that is considered confidential and may also be privileged . It is for the
exclusive use of the intended recipient(s). If you are not the intended
recipient(s) please note that any form of distribution, copying or use of this
communication or the information in it is strictly prohibited and may be
unlawful. If you have received this communication in error please return it to
the sender and delete the original.
________________________________
From: Benoit Xhenseval <be...@yahoo.com>
To: users@activemq.apache.org
Sent: Tue, August 31, 2010 9:51:43 PM
Subject: Jboss 5.1 and ActiveMQ 5.3.2: Endpoint did not release properly: null
Hi *,
We're in the process of upgrading from JBoss 4.0.5.GA to 5.1.0.GA.
Changes were minimal BUT we're facing an issue with ActiveMQ deployed as an
embedded broker via RA.
The enclosed settings work fine with Jboss 4.0.5.
The first message is received correctly but after that we seem to be unable to
process any further message.
I am aware of https://issues.apache.org/activemq/browse/AMQ-2670 but this does
not seem to apply in our case as we used this ra.xml:
<outbound-resourceadapter>
<connection-definition>
<!-- JMS 1.1 -->
<managedconnectionfactory-class>org.apache.activemq.ra.ActiveMQManagedConnectionFactory</managedconnectionfactory-class>
<connectionfactory-interface>javax.jms.ConnectionFactory</connectionfactory-interface>
<connectionfactory-impl-class>org.apache.activemq.ra.ActiveMQConnectionFactory</connectionfactory-impl-class>
<connection-interface>javax.jms.Connection</connection-interface>
<connection-impl-class>org.apache.activemq.ra.ManagedConnectionProxy</connection-impl-class>
</connection-definition>
<connection-definition>
<!-- JMS 1.0/1.1 -->
<managedconnectionfactory-class>org.apache.activemq.ra.ActiveMQManagedConnectionFactory</managedconnectionfactory-class>
<connectionfactory-interface>javax.jms.QueueConnectionFactory</connectionfactory-interface>
<connectionfactory-impl-class>org.apache.activemq.ra.ActiveMQConnectionFactory</connectionfactory-impl-class>
<connection-interface>javax.jms.QueueConnection</connection-interface>
<connection-impl-class>org.apache.activemq.ra.ManagedConnectionProxy</connection-impl-class>
</connection-definition>
<connection-definition>
<!-- JMS 1.0/1.1 -->
<managedconnectionfactory-class>org.apache.activemq.ra.ActiveMQManagedConnectionFactory</managedconnectionfactory-class>
<connectionfactory-interface>javax.jms.TopicConnectionFactory</connectionfactory-interface>
<connectionfactory-impl-class>org.apache.activemq.ra.ActiveMQConnectionFactory</connectionfactory-impl-class>
<connection-interface>javax.jms.TopicConnection</connection-interface>
<connection-impl-class>org.apache.activemq.ra.ManagedConnectionProxy</connection-impl-class>
</connection-definition>
<!-- XA support! Critical -->
<transaction-support>XATransaction</transaction-support>
<!-- but not used @ the moment -->
<authentication-mechanism>
<authentication-mechanism-type>BasicPassword</authentication-mechanism-type>
<credential-interface>javax.resource.spi.security.PasswordCredential</credential-interface>
</authentication-mechanism>
<reauthentication-support>false</reauthentication-support>
</outbound-resourceadapter>
The log file shows something along the line of "Endpoint did not release
properly: null"
What could cause this?
Is there an example somewhere with JBoss 5.1 and ActiveMQ 5.3.2?
Thanks, all examples I have seen seem to be old.
See:
------
19:01:06,590 DEBUG [AMQMessageStore] Doing batch update... adding: 1 removing: 0
19:01:06,590 DEBUG [Queue] queue.stage_trade_data toPageIn: 1, Inflight: 0,
pagedInMessages.size 0, enqueueSize: 1
19:01:06,590 DEBUG [KahaReferenceStore] queue.stage_trade_data add:
ID:WLDNTECC018024L-4159-1283275933801-4:0:1:2:1
19:01:06,590 DEBUG [AMQMessageStore] adding message
ref:ID:WLDNTECC018024L-4159-1283275933801-4:0:1:2:1
19:01:06,590 DEBUG [AMQMessageStore] Batch update done.
19:01:06,590 DEBUG [AMQMessageStore] flush starting ...
19:01:06,590 DEBUG [AMQMessageStore] flush starting ...
19:01:06,590 DEBUG [ServerSessionPoolImpl] ServerSession requested.
19:01:06,590 DEBUG [ServerSessionPoolImpl] Using idle session:
ServerSessionImpl:0
19:01:06,590 DEBUG [ServerSessionImpl:0] Starting run.
19:01:06,590 DEBUG [ServerSessionImpl:0] Work accepted:
javax.resource.spi.work.WorkEvent[source=org.springframework.jca.work.SimpleTaskWorkManager$DelegatingWorkAda
pter@d7759]
19:01:06,590 DEBUG [ServerSessionImpl:0] Work started:
javax.resource.spi.work.WorkEvent[source=org.springframework.jca.work.SimpleTaskWorkManager$DelegatingWorkAdap
ter@d7759]
19:01:06,590 DEBUG [ServerSessionImpl:0] Running
19:01:06,590 DEBUG [ServerSessionImpl:0] run loop start
19:01:06,590 INFO [ServerSessionImpl:0] Endpoint failed to process message.
Reason: Endpoint before delivery notification failure
19:01:06,590 DEBUG [ServerSessionImpl:0] run loop end
19:01:06,590 DEBUG [ServerSessionImpl:0] Endpoint did not release properly: null
org.apache.activemq.ra.InvalidMessageEndpointException
at
org.apache.activemq.ra.MessageEndpointProxy$MessageEndpointDead.release(MessageEndpointProxy.java:159)
at
org.apache.activemq.ra.MessageEndpointProxy.release(MessageEndpointProxy.java:74)
at
org.apache.activemq.ra.ServerSessionImpl.close(ServerSessionImpl.java:263)
at
org.apache.activemq.ra.ServerSessionPoolImpl.removeFromPool(ServerSessionPoolImpl.java:230)
at
org.apache.activemq.ra.ServerSessionImpl.run(ServerSessionImpl.java:188)
at
org.springframework.jca.work.SimpleTaskWorkManager$DelegatingWorkAdapter.run(SimpleTaskWorkManager.java:232)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:619)
19:01:06,590 DEBUG [ServerSessionImpl:0] Run finished
19:01:06,590 DEBUG [ServerSessionImpl:0] Work completed:
javax.resource.spi.work.WorkEvent[source=org.springframework.jca.work.SimpleTaskWorkManager$DelegatingWorkAd
apter@d7759]
19:01:08,027 DEBUG [InactivityMonitor] 10000 ms elapsed since last write check.
19:01:08,027 DEBUG [InactivityMonitor] 30000 ms elapsed since last read check.
19:01:08,496 DEBUG [InactivityMonitor] 10000 ms elapsed since last write check.
19:01:17,559 DEBUG [AMQPersistenceAdapter] Checkpoint started.
19:01:17,559 DEBUG [AMQPersistenceAdapter] Marking journal at: offset = 47128,
file = 1, size = 24148, type = 1
19:01:17,559 DEBUG [AMQPersistenceAdapter] Checkpoint done.
19:01:18,027 DEBUG [InactivityMonitor] 10000 ms elapsed since last write check.
19:01:18,496 DEBUG [InactivityMonitor] 10000 ms elapsed since last write check.
Thanks a lot
Benoit
Jboss 5.1 and ActiveMQ 5.3.2: Endpoint did not release properly: null
Posted by Benoit Xhenseval <be...@yahoo.com>.
Hi *,
We're in the process of upgrading from JBoss 4.0.5.GA to 5.1.0.GA.
Changes were minimal BUT we're facing an issue with ActiveMQ deployed as an
embedded broker via RA.
The enclosed settings work fine with Jboss 4.0.5.
The first message is received correctly but after that we seem to be unable to
process any further message.
I am aware of https://issues.apache.org/activemq/browse/AMQ-2670 but this does
not seem to apply in our case as we used this ra.xml:
<outbound-resourceadapter>
<connection-definition>
<!-- JMS 1.1 -->
<managedconnectionfactory-class>org.apache.activemq.ra.ActiveMQManagedConnectionFactory</managedconnectionfactory-class>
<connectionfactory-interface>javax.jms.ConnectionFactory</connectionfactory-interface>
<connectionfactory-impl-class>org.apache.activemq.ra.ActiveMQConnectionFactory</connectionfactory-impl-class>
<connection-interface>javax.jms.Connection</connection-interface>
<connection-impl-class>org.apache.activemq.ra.ManagedConnectionProxy</connection-impl-class>
</connection-definition>
<connection-definition>
<!-- JMS 1.0/1.1 -->
<managedconnectionfactory-class>org.apache.activemq.ra.ActiveMQManagedConnectionFactory</managedconnectionfactory-class>
<connectionfactory-interface>javax.jms.QueueConnectionFactory</connectionfactory-interface>
<connectionfactory-impl-class>org.apache.activemq.ra.ActiveMQConnectionFactory</connectionfactory-impl-class>
<connection-interface>javax.jms.QueueConnection</connection-interface>
<connection-impl-class>org.apache.activemq.ra.ManagedConnectionProxy</connection-impl-class>
</connection-definition>
<connection-definition>
<!-- JMS 1.0/1.1 -->
<managedconnectionfactory-class>org.apache.activemq.ra.ActiveMQManagedConnectionFactory</managedconnectionfactory-class>
<connectionfactory-interface>javax.jms.TopicConnectionFactory</connectionfactory-interface>
<connectionfactory-impl-class>org.apache.activemq.ra.ActiveMQConnectionFactory</connectionfactory-impl-class>
<connection-interface>javax.jms.TopicConnection</connection-interface>
<connection-impl-class>org.apache.activemq.ra.ManagedConnectionProxy</connection-impl-class>
</connection-definition>
<!-- XA support! Critical -->
<transaction-support>XATransaction</transaction-support>
<!-- but not used @ the moment -->
<authentication-mechanism>
<authentication-mechanism-type>BasicPassword</authentication-mechanism-type>
<credential-interface>javax.resource.spi.security.PasswordCredential</credential-interface>
</authentication-mechanism>
<reauthentication-support>false</reauthentication-support>
</outbound-resourceadapter>
The log file shows something along the line of "Endpoint did not release
properly: null"
What could cause this?
Is there an example somewhere with JBoss 5.1 and ActiveMQ 5.3.2?
Thanks, all examples I have seen seem to be old.
See:
------
19:01:06,590 DEBUG [AMQMessageStore] Doing batch update... adding: 1 removing: 0
19:01:06,590 DEBUG [Queue] queue.stage_trade_data toPageIn: 1, Inflight: 0,
pagedInMessages.size 0, enqueueSize: 1
19:01:06,590 DEBUG [KahaReferenceStore] queue.stage_trade_data add:
ID:WLDNTECC018024L-4159-1283275933801-4:0:1:2:1
19:01:06,590 DEBUG [AMQMessageStore] adding message
ref:ID:WLDNTECC018024L-4159-1283275933801-4:0:1:2:1
19:01:06,590 DEBUG [AMQMessageStore] Batch update done.
19:01:06,590 DEBUG [AMQMessageStore] flush starting ...
19:01:06,590 DEBUG [AMQMessageStore] flush starting ...
19:01:06,590 DEBUG [ServerSessionPoolImpl] ServerSession requested.
19:01:06,590 DEBUG [ServerSessionPoolImpl] Using idle session:
ServerSessionImpl:0
19:01:06,590 DEBUG [ServerSessionImpl:0] Starting run.
19:01:06,590 DEBUG [ServerSessionImpl:0] Work accepted:
javax.resource.spi.work.WorkEvent[source=org.springframework.jca.work.SimpleTaskWorkManager$DelegatingWorkAda
pter@d7759]
19:01:06,590 DEBUG [ServerSessionImpl:0] Work started:
javax.resource.spi.work.WorkEvent[source=org.springframework.jca.work.SimpleTaskWorkManager$DelegatingWorkAdap
ter@d7759]
19:01:06,590 DEBUG [ServerSessionImpl:0] Running
19:01:06,590 DEBUG [ServerSessionImpl:0] run loop start
19:01:06,590 INFO [ServerSessionImpl:0] Endpoint failed to process message.
Reason: Endpoint before delivery notification failure
19:01:06,590 DEBUG [ServerSessionImpl:0] run loop end
19:01:06,590 DEBUG [ServerSessionImpl:0] Endpoint did not release properly: null
org.apache.activemq.ra.InvalidMessageEndpointException
at
org.apache.activemq.ra.MessageEndpointProxy$MessageEndpointDead.release(MessageEndpointProxy.java:159)
at
org.apache.activemq.ra.MessageEndpointProxy.release(MessageEndpointProxy.java:74)
at
org.apache.activemq.ra.ServerSessionImpl.close(ServerSessionImpl.java:263)
at
org.apache.activemq.ra.ServerSessionPoolImpl.removeFromPool(ServerSessionPoolImpl.java:230)
at
org.apache.activemq.ra.ServerSessionImpl.run(ServerSessionImpl.java:188)
at
org.springframework.jca.work.SimpleTaskWorkManager$DelegatingWorkAdapter.run(SimpleTaskWorkManager.java:232)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:619)
19:01:06,590 DEBUG [ServerSessionImpl:0] Run finished
19:01:06,590 DEBUG [ServerSessionImpl:0] Work completed:
javax.resource.spi.work.WorkEvent[source=org.springframework.jca.work.SimpleTaskWorkManager$DelegatingWorkAd
apter@d7759]
19:01:08,027 DEBUG [InactivityMonitor] 10000 ms elapsed since last write check.
19:01:08,027 DEBUG [InactivityMonitor] 30000 ms elapsed since last read check.
19:01:08,496 DEBUG [InactivityMonitor] 10000 ms elapsed since last write check.
19:01:17,559 DEBUG [AMQPersistenceAdapter] Checkpoint started.
19:01:17,559 DEBUG [AMQPersistenceAdapter] Marking journal at: offset = 47128,
file = 1, size = 24148, type = 1
19:01:17,559 DEBUG [AMQPersistenceAdapter] Checkpoint done.
19:01:18,027 DEBUG [InactivityMonitor] 10000 ms elapsed since last write check.
19:01:18,496 DEBUG [InactivityMonitor] 10000 ms elapsed since last write check.
Thanks a lot
Benoit
Re: Newbie question about many consumers and many producers
Posted by ChicagoBob123 <bo...@bobfx.com>.
Hi,
I appreciate your reply but I don't know what this means. >>> Acknowledging
a message also acks all preview messages iir >>>
>>>If the IDs are set as message properties, the client can filter their
>>> own messages by using a selector on the messageconsumer.
This I can investigate. I know you can produce a message with a property but
I did not see anything on filter yet.
Does this mean that when I have exhausted the queue that only the filtered
messages are removed?
I might be able to stuff that into the spec.
Thanks,
--
View this message in context: http://activemq.2283324.n4.nabble.com/Newbie-question-about-many-consumers-and-many-producers-tp2402003p2402091.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Newbie question about many consumers and many producers
Posted by ChicagoBob123 <bo...@bobfx.com>.
We are trying to work with another organization and this is their spec.
I suggested this to my boss today but have not heard back as he is
out of town.
So the answer is I just don't know if this is a hard core requirement yet.
Bob
At 12:43 PM 8/31/2010, you wrote:
>Is there a reason you would not consider using separate queues for
>each of the different consumers? Seems that it may simplify your solution.
>
>Matt Pavlovich
>
>On Aug 31, 2010, at 12:30 PM, ChicagoBob123 <[hidden email]> wrote:
>
> >
> > Newbie question about many consumers and many producers.
> > I have searched and read through some of the archives but have
> not been able
> > to find an answer to this question.
> > I am working on an application that will have several different producers.
> > They supply messages to
> > a common queue. The messages contain ID's for consumers of the messages to
> > know to it is their message/task. But when ever I acknowledge I have
> > received a message all the messages from
> > the queue are removed and now consumers that may have been off line can no
> > longer get their message.
> >
> > Am I missing something basic here.
> >
> > I tried to browse the queue and that will not remove any messages.
> > I tried to only acknowledge messages via the Client Acknowledge.
> As soon as
> > I acknowledge all the messages are removed. ???
> >
> > --
> > View this message in context:
> <http://activemq.2283324.n4.nabble.com/Newbie-question-about-many-consumers-and-many-producers-tp2402003p2402003.html?by-user=t>http://activemq.2283324.n4.nabble.com/Newbie-question-about-many-consumers-and-many-producers-tp2402003p2402003.html
> > Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>View message @
><http://activemq.2283324.n4.nabble.com/Newbie-question-about-many-consumers-and-many-producers-tp2402003p2402022.html>http://activemq.2283324.n4.nabble.com/Newbie-question-about-many-consumers-and-many-producers-tp2402003p2402022.html
>
>To unsubscribe from Newbie question about many consumers and many
>producers,
><http://activemq.2283324.n4.nabble.com/template/TplServlet.jtp?tpl=unsubscribe_by_code&node=2402003&code=Ym9idEBib2JmeC5jb218MjQwMjAwM3wtMTM2MjgyMzM4OQ==>click
>here.
--
View this message in context: http://activemq.2283324.n4.nabble.com/Newbie-question-about-many-consumers-and-many-producers-tp2402003p2402046.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Newbie question about many consumers and many producers
Posted by Matt Pavlovich <ma...@gmail.com>.
Is there a reason you would not consider using separate queues for each of the different consumers? Seems that it may simplify your solution.
Matt Pavlovich
On Aug 31, 2010, at 12:30 PM, ChicagoBob123 <bo...@bobfx.com> wrote:
>
> Newbie question about many consumers and many producers.
> I have searched and read through some of the archives but have not been able
> to find an answer to this question.
> I am working on an application that will have several different producers.
> They supply messages to
> a common queue. The messages contain ID's for consumers of the messages to
> know to it is their message/task. But when ever I acknowledge I have
> received a message all the messages from
> the queue are removed and now consumers that may have been off line can no
> longer get their message.
>
> Am I missing something basic here.
>
> I tried to browse the queue and that will not remove any messages.
> I tried to only acknowledge messages via the Client Acknowledge. As soon as
> I acknowledge all the messages are removed. ???
>
> --
> View this message in context: http://activemq.2283324.n4.nabble.com/Newbie-question-about-many-consumers-and-many-producers-tp2402003p2402003.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.