Re: timeout is not being used ?

I saw some warning when start the web application, not sure what it means: 2010-05-20 08:53:45.750:WARN::Skipping PostConstruct annotation on org.apache.activemq.broker.BrokerService.start: throws checked exceptions 2010-05-20 08:53:45.750:WARN::Skipping PreDestroy annotation on org.apache.activ

timeout is not being used ?

Hi, I have a very basic configuration and did a quick test. I am using Spring 3.0, ActiveMQ 5.4, Jetty 7.0.2. web.xml == SpringAMQ org.springframework.web.servlet.DispatcherServlet contextConfigLocation /WEB-INF/spring/app-config.xml 1 SpringAMQ /app/* org.apache.activemq.b

Negative pending queue counts

We are occasionally getting negative pending queue counts using ActiveMQ v5.1. We're using jms.useAsyncSend=true, jms.prefetchPolicy.queuePrefetch=0, and we're running tens of thousands to hundreds of thousands of messages through an hour at top capacity. Ended up running across this ticket https:

Re: activemq network of brokers

Hi All, I have 2 brokers running in two diffrent network with firewall in between. I have static ip address specified to connect to each other. If I add another broker to this cluster then I need to add this new ip address to this cluser of network configuration. To avoid this I am thinking if

Hopefully easy question: NoLocal doesn't appear to be working

Hi All, Rather new to the JMS as a whole. I am using the ActiveMQ-CPP (3.1.2) client to connect to the ActiveMQ server (5.3.2). I am receiving my own messages, and would like to stop! I am using code extended from one of the examples (http://activemq.apache.org/cms/example.html). I am using top

Fully programmatic authorization map

I'd like to implement an authorization plugin that would allow me to implement a fully automatic authorization policy. Here's an outline of what I want: We have a broker that is a hub in a hub & spoke topology network of brokers. A connections to this hub broker are via SSL and the hub broker requ

Re: Duplicate messages with a Durable Subscriber with networked brokers

Hi I am not using a master slave configuration it a peer-peer Thanks -- View this message in context: http://old.nabble.com/Duplicate-messages-with-a-Durable-Subscriber-with-networked-brokers-tp27827251p28609396.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ freeze

We are not aware of any consumers having trouble. No exception or similar. We use one connection and several consumers on the queues. But we have enabled the master/slave only a short while before these problems came up. Before this configuration, we had zero problems at all (only with KahaDB but

Re: ActiveMQ freeze

The master is blocked on a write, is some consumer having trouble? Would be interested to know the state of the process on the other end of that connection. That pending write is blocking the next message dispatch on that connection. "ActiveMQ Connection Dispatcher: /127.0.0.1:59497" daemon prio=

Re: ActiveMQ freeze

I am a collegue of Andreas. It happened again on tuesday but again we don't know the reasons. Attached are two thread dumps. I cannot see anything in it, but maybe you are seeing more. http://old.nabble.com/file/p28607920/dumps.zip dumps.zip We had also problems with KahaDB before which forced

About statistics and statisticsBrokerPlugin

Hi all, some time ago I needed to collect some statistical information from some queues and I did some tests with JMX integration in my java application and It worked fine. Some days ago I updated my application to Activemq 5.3.2 and I found it was possible to collect the same information using

Re: ActiveMQ and Jetty 7.0.2

that's good news. I saw a snapshot, so I guess I can use that for testing purpose for now. rgds, canal From: Rob Davies To: users@activemq.apache.org Sent: Wed, May 19, 2010 1:02:20 PM Subject: Re: ActiveMQ and Jetty 7.0.2 Jetty 7 will be supported in releas

RE: How to post message to a certain queue consumer?

I wrote code to test multiple consumers with same selector under P2P. The message from producer will be sent to different consumers by turns. Cristian Botiza wrote: > > On a different note... > The original post mentioned P2P (that is Queues), the examples are about > Topics (pub sub). > In the

Re: How to post message to a certain queue consumer?

Thanks for your help! Sebastian Rodriguez-2 wrote: > > Hi alan, > For the Selectors in C#, you can find the following snippet: > <--- start producer side code --> > /// > /// True if the publisher has a selector. False otherwise > /// > /// > /// true i

RE: How to post message to a certain queue consumer?

Got it! Thank you very much! Cristian Botiza wrote: > > Session session = ...; > MessageProducer producer = session.createProducer(destination); > > producer.setTimeToLive(timeToLiveInMilliseconds); //use the producer API > to set TTL > > Message message = session.create...Message(...); > >

Durable Topics consumer in ActiveMQ

Hi, I've a network-of-brokers/clusters which are statically defined(e.g.Broker-A, Broker-B) which has a durable Topic(Topic-A). Both Broker-A and Broker-B are publishing message to the durable topic-Topic A. There is a problem of missing message, that when Broker-B is restarted, the messages pub

Re: How to post message to a certain queue consumer?

Oups, my bad, I didn't realize it was for queues. I'm not really experienced when it comes to queues, but if it works similarly than with the topics, the message will go to the first consumer that can consume the message. On 19 May 2010 16:46, Cristian Botiza wrote: > On a different note... > Th

RE: How to post message to a certain queue consumer?

On a different note... The original post mentioned P2P (that is Queues), the examples are about Topics (pub sub). In the case of P2P there is at most one receiver that gets the message anyways. Was wondering if selectors are trully useful in this case, especially with multiple consumers. When Act

Re: How to post message to a certain queue consumer?

Hi alan, For the Selectors in C#, you can find the following snippet: <--- start producer side code --> /// /// True if the publisher has a selector. False otherwise /// /// /// true if this instance is selector; otherwise, false. /// publ

RE: How to post message to a certain queue consumer?

Session session = ...; MessageProducer producer = session.createProducer(destination); producer.setTimeToLive(timeToLiveInMilliseconds); //use the producer API to set TTL Message message = session.create...Message(...); producer.send(message); TTL has nothing to do with message selectors; I fo

Re: Help with mutual authentication using ActiveMQ 5.3

Hi Mohan, can you send your entire activemq.xml ? I think it could be caused by Jetty connecting to activemq for the admin webapp. Firstly could you try and disable Jetty completely and see if the problem goes way. cheers, James. -- On 19 May 2010 00:19, mvtiru wrote: > > Hi, > I am trying t

Re: Duplicate messages with a Durable Subscriber with networked brokers

hi, do you face any problems with the network of brokers, when the brokers get disconnected and then gets reconnected again?. in a 2 nodes, network-of-brokers when the 2 brokers gets disconnected due to a communication failure, will each of the brokers acquire the lock to become the master..late