So far I have tried to put a wait(2000) in the preProcessDispatch:
@Override
public void preProcessDispatch(MessageDispatch messageDispatch) {
String contentStr = new
String(messageDispatch.getMessage().getContent().getData());
if (pauseThisMsg(conte
I would like to jump into this thread and ask a related question.
I would like to pause message from being consumed selectively, meaning that
I would like to pause message #2 and #4. But all messages to be consumed.
And then let message #2 and #4 to be consumed later.
I think this would create
What version (apollo and/or windows) are you using?
I just tried on WinXP and it works fine with Apollo v1.4
-
http://www.christianposta.com/blog
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Apollo-as-Windows-Service-tp4655390p4655403.html
Sent from the ActiveMQ -
My thoughts on this :
1.) For the test harness activeMQ brokers, install an Interceptor based on
BrokerFilter.
http://activemq.apache.org/interceptors.html
Install my interceptor into the broker.
On inspection of the accessible methods on BrokerFilter, I am not sure which
methods would allow my
I am having issues adding the websocket transport to an embedded broker. The
standalone works fine. I keep getting ws protocol not recognized error. Is
the websocket support only for the standalone broker? I am using:
Mark
--
View this message in context:
http://activemq.2283324.n4.nabbl
So, instead of having N brokers (1 per consumer), why not have N
destinations (1 per consumer)? If possible, further simplify it to less
than N destinations if you can shard/group your messages (don't know your
domain) and just use message properties and selectors to filter them at the
time of retr
Have a look at the following, this method is in the javax.jms.Session class.
public TopicSubscriber createDurableSubscriber(Topic topic,
String name)
throws JMSException
-Original Message-
From: joesa
Can you show me some pointers on how to use a durable consumer?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-Master-Slave-Message-Integrity-tp4655369p4655391.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
On Tue, 2012-08-21 at 08:22 -0700, joesan wrote:
> I just performed the following test on my Master / Slave:
>
> Started AMQ1 and AMQ2 - Both runs on the same host but with a different port
>
> Started my Consumer and Producer - Both have the fail-over protocol to
> connect to the AMQ
>
> I sen
I just performed the following test on my Master / Slave:
Started AMQ1 and AMQ2 - Both runs on the same host but with a different port
Started my Consumer and Producer - Both have the fail-over protocol to
connect to the AMQ
I send messages using my producer in a loop... where with every 10 seco
Thanks for the info. So all I have to do is just to durable subscribe my
Producer. On the Consumer side, I do not have to specify durable
subscription?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-Master-Slave-Message-Integrity-tp4655369p4655381.html
Sent from
5.4.2 is really old now. A huge number of bugs have been fixed since. I would
highly encourage you to upgrade to the latest version in the mid term time
frame.
Torsten
On Aug 21, 2012, at 3:36 PM, Tlholoe, Peter wrote:
> Hi Torsten,
> We are using ActiveMQ 5.4.2
> Thank you for your help, I
Hi Torsten,
We are using ActiveMQ 5.4.2
Thank you for your help, I will try that and advise of the results.
-Original Message-
From: Torsten Mielke [mailto:tors...@fusesource.com]
Sent: 21 August 2012 03:25 PM
To: users@activemq.apache.org
Subject: Re: ActiveMQ hangs
What version of Act
Answers in-line.
On Aug 21, 2012, at 2:48 PM, joesan wrote:
> I have a Master / Slave setup of two ActiveMQ Brokers on the same host and
> has a shared network drive for persistence. According to the ActiveMQ
> documentation, when the Master goes down the slave picks up and the clients
> can stil
What version of ActiveMQ are you using?
Even with producer flow control disabled, the broker will still suspend
producers when it reaches any of the configured systemUsage limits. If you
don't specify any systemUsage in your brokers configuration, a default and hard
coded systemUsage applies. S
There isn't a timeout for JMSXGroupID as far as I can tell.
I wonder if you could listen to advisories for a particular destination and
log last-seen group ids? and then send the -1 group sequence after your
desired timeout?
-
http://www.christianposta.com/blog
--
View this message in conte
Hi,
I am currently monitoring all the queues/ topics at the moment. In the interim
I did disable producer-flow-control, and increasing the memoryLimit=1024Mb, but
I didn't activate systemUsage, and I read that the memory limit configuration
is dependent on the systemUsage configuration.
My idea
any chance you took a heap dump?
-
http://www.christianposta.com/blog
--
View this message in context:
http://activemq.2283324.n4.nabble.com/java-lang-OutOfMemoryError-Java-heap-space-tp4655291p4655364.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Hi everybody.
In order to mitigate the number of threads created by ActiveMQ, I'm trying to
migrate from the "old" tcp and ssl to the new nio and nio+ssl protocols.
I'm having an issue with the secure version of nio: in my authentication plugin
I cannot get the certificate associated with the ss
Hello,
In your Camel route you seem to route message from various destinations on the
broker to other destinations on the same broker.
Is it possible that the destinations you route message to are getting filled up
(not all, but some of them).
If that happens, producer flow control might kick i
We currently have a problem in our production environment. We have one general
purpose topic where all messages are published to, and A Camel subscribed to
that general purpose topic, apply rules to route the messages to different
topics. That consumer constantly has higher MessageCountAwaiting
21 matches
Mail list logo
