Workaround for messages stuck in a queue

Hi, It appears we may be getting by this https://issues.apache.org/activemq/browse/AMQ-2009 or some variant of it i.e. messages are getting stuck in a queue. We are busy looking at our config and gradually making changes to try and resolve it but we can't replicate in dev so it's slow going. We're

Re: Duplicate messages with a Durable Subscriber with networked brokers

UPDATE is activeMQ 5.3 install rsmith198 wrote: > > Duplicate messages with a Durable Subscriber in networked brokers I have a > network of three brokers wsmithe6400 who has two bridges one to DrWho > the other to FUJI I; I have a Durable Subscriber set up on wsmithe6400 to > receive messages

Re: 5.4 Snapshot: java.lang.NoClassDefFoundError: org/fusesource/commons/management/ManagementStrategy

Hi Ben, thank you for your help! For now I removed the jetty entry in the activemq.xml as a q&d solution :) Regards, Michael Benjamin Keil-2 wrote: > > Hi Michael, > > What's needed in this case is the commons-management-1.0.jar. > > You can get it here: > http://repo.fusesource.com/maven2/

Re: 5.4 Snapshot: java.lang.NoClassDefFoundError: org/fusesource/commons/management/ManagementStrategy

Hi Michael, What's needed in this case is the commons-management-1.0.jar. You can get it here: http://repo.fusesource.com/maven2/org/fusesource/commonman/commons-management/1.0/ Place it into the ${ACTIVEMQ_HOME}/lib directory, and you should be golden. Hope that works for you, Ben. mjustin wr

Re: Consumers are being duplicated

You're the first response that I've had cheers stelios wrote: > > I have a similar issue, where the consumers seem to duplicate after a > couple of days. Although it's not always the case. Did you find any more > information on this? > > thanks > stelios > > Tim Sparg wrote: >> >> Hi all, >

Delay messages with Stomp: connection reset

Hello, following http://activemq.apache.org/delay-and-schedule-message-delivery.html I tried to delay a message using a AMQ_SCHEDULED_DELAY header property. The Stom frames look like this: send: CONNECT received: CONNECTED session:ID:mj-PC-49610-1268150511998-3:10 send: SUBSCRIBE destinati

5.4 Snapshot: java.lang.NoClassDefFoundError: org/fusesource/commons/management/ManagementStrategy

Hello, the current snapshot and some of the olders fail to start the admin console. The log says: 2010-03-09 16:56:49,784 | INFO | ActiveMQ Console at http://0.0.0.0:8161/admin | org.eclipse.jetty.util.log | main 2010-03-09 16:56:49,945 | INFO | Initializing Spring root WebApplicationContext |

Re: MessageConsumer stops receiving messages

Thanks. I figured out the problem had nothing to do with ACTIVEMQ. The onMessage method was calling a DB function which was blocking. T Márcio Geovani Jasinski wrote: > > Hi Tom, > > This is pretty strange behavior - looks like your consumer is not running > after a while. > I think you

Re: ActiveMQ doesn't close connections

Hi Dejan, Dejan Bosanac wrote: > > it seems like you're closing all that is there to close, but maybe missing > to close it in some situations. There isn't much we can do, until we have > a > reproducible "test case", so if you can just strip down your app only on > messaging related part and t

AMQ-2379: query statistics with Stomp

Hello, following the description on https://issues.apache.org/activemq/browse/AMQ-2379 I tried to retrieve the broker statistics for a Queue. The Stomp frames are: send: CONNECT received: CONNECTED session:ID:mj-PC-49441-1268147472223-4:0 send: SUBSCRIBE destination:/queue/Habari ack:auto i

Re: Client side SSL with specified Key and Truststores

Hi, We have traced the problem down to the failover transport. If the "failover" transport is removed from the configuration I showed above, then the Trust and KeyManagers are overridden as expected and the certificates are validated against our own keystore. As soon as failover is added back

AverageEnqueueTime (milliSeconds) ?

Hi, Is this value expressed in milliseconds (AverageEnqueueTime) ? Kind regards, Charles - Charles Moulliard SOA Architect My Blog : http://cmoulliard.blogspot.com/ http://cmoulliard.blogspot.com/ -- View this message in context: http://old.nabble.com/AverageEnqueueTime-%28milliSecon

Re: Consumers are being duplicated

I have a similar issue, where the consumers seem to duplicate after a couple of days. Although it's not always the case. Did you find any more information on this? thanks stelios Tim Sparg wrote: > > Hi all, > > We are using ActiveMQ 5.2.0 over the WAN. We have a remote application > that has

Message production / consumption process explained

Hi, I try to figure out How ActiveMQ works since the creation of a message till its consumption by a client. Is there a sequence diagram or something similar showing what ActiveMq do to store the message in the queue, update or create index, keep cursor information, keep info in storage for persi

Re: MessageConsumer stops receiving messages

Hi Tom, This is pretty strange behavior - looks like your consumer is not running after a while. I think you should separate the code (pub/sub) and then start a second consumer when first is no longer taking messages from the queue. In case second consumer stops after another 5 messages - you know

Re: Issue in example with failover

Hi Frank, this is the issue we had before (and apparently it reoccurred). The problem is that example application you're running doesn't have any non-deamon threads and as transport is disconnected, the application shuts down before it can reconnect. This is usually not the case in "real" applicat

Re: Issue in example with failover

If I use the following url -Durl='failover://(tcp://broker1:61616,tcp://broker2:61616)' I got the following output: r...@broker1:/opt/apache-activemq-5.3.0/example # ant topic-listener -Durl='failover://(tcp://ppst-broker1:61616,tcp://broker2:61616)' Buildfile: build.xml init: compile: topic-l

Re: Issue in example with failover

Hi Dejan, thanks for your reply. In fact, your example works ... unfortunately just until one server fails :-( If I stop the server the example is connected to, I got the following output: r...@broker1:/opt/apache-activemq-5.3.0/example # ant topic-listener -Durl='failover://(tcp://broker1:6282

Re: activemq-broker.xml file and plugins !!!!

Sorry for my mistake. That was before systemUsage ;-) Dejan Bosanac wrote: > > Hi Charles, > > try putting it before > > Cheers > -- > Dejan Bosanac - http://twitter.com/dejanb > > Open Source Integration - http://fusesource.com/ > ActiveMQ in Action - http://www.manning.com/snyder/ > Blog

Re: activemq-broker.xml file and plugins !!!!

Hi Charles, try putting it before 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 Tue, Mar 9, 2010 at 9:43 AM, cmoulliard wrote: > > Hi Dejan, > > I us

Re: activemq-broker.xml file and plugins !!!!

Hi Dejan, I use Spring 2.5.6 and activemq-broker.xml is deployed in Fuse SMX 4.2. I have placed plugins after the SystemUsage and before transportConnectors and it works now . Kind regards, Charles Dejan Bosanac wrote: > > Hi Charles, > > if you run with Spring 3.x then you need to keep yo

Re: activemq-broker.xml file and plugins !!!!

Hi Charles, if you run with Spring 3.x then you need to keep your tags in alphabetical order. You probably have something in front of tag that messes things up. Cheers -- Dejan Bosanac - http://twitter.com/dejanb Open Source Integration - http://fusesource.com/ ActiveMQ in Action - http://www.m

activemq-broker.xml file and plugins !!!!

Hi, I try to configure the plugins in the activemq-broker.xml file but I get an error. dleXmlApplicationContext(bundle=activemq-broker.xml, config=osgibundle:/META-INF/spring/*.xml)) org.springframework.beans.factory.xml.XmlBeanDefinitionStoreException: Line 113 in XML document from URL [bundle

Clarification requested for slow - consumers - matched messages

Hi, Im' sorry but I don't understand what is the purpose of the matched (???) and discarded messages and How we can avoid slow customers by using such a strategy (http://activemq.apache.org/slow-consumer-handling.html) ? "Currently we have a strategy that lets you configure the maximum number o