Re: global transaction jboss/spring/activemq

Hi, resending with subject changed. I am able to get things to work without global transaction. With JBOSS I am getting "javax.jms.JMSException: Session's XAResource has not been enlisted in a distributed transaction." using the spring config as below: =

Re: physical queue cannot be resolved using jndi / spring

Hi, I am able to get things to work without global transaction. With JBOSS I am getting "javax.jms.JMSException: Session's XAResource has not been enlisted in a distributed transaction." using the spring config as below: = org.apache.acti

URI for Queue

Hi,    I have installed ActiveMQ 5.3 and created a test queue called 'mytest'. I want to HTTP POST to this queue from my java application(J2SE) directly using java.net.httpurlconnection. My questions are, [1] What is the URL for this queue? [2] What is the credentials(if any) to POST to this que

Re: How to "activate" an interceptor

On Mon, Nov 23, 2009 at 8:48 AM, moreno9000 wrote: > > Yes, > when a procuder calls send() method, I'd like to intercept > the request, verify number of messages in destination queue, > throw an exception if number of msg, after this last send(), > exceed a predefined limit. Does this mean that y

Re: How to "activate" an interceptor

Re: deterministic memory usage, could you try a 5.4-SNAPSHOT. Usage should be deterministic in your case. If the behavior persists with a current snapshot, could you raise a jira issue and attach your test case. thanks? 2009/11/23 moreno9000 > > Yes, > when a procuder calls send() method, I'd li

Re: How to "activate" an interceptor

Yes, when a procuder calls send() method, I'd like to intercept the request, verify number of messages in destination queue, throw an exception if number of msg, after this last send(), exceed a predefined limit. In AMQ 5.3 I can define a memoryLimit for a queue but there are two "problems". 1)

Re: How to "activate" an interceptor

Yes, when a procuder calls send() method, I'd like to intercept the request, verify number of messages in destination queue, throw an exception if number of msg, after this last send(), exceed a predefined limit. In AMQ 5.3 I can define a memoryLimit for a queue but there are two "problems". 1)

Re: How to "activate" an interceptor

On Mon, Nov 23, 2009 at 8:02 AM, moreno9000 wrote: > > Thank you, Bruce. > > For my control (number of messages in a queue) > do I need to override a specific method? > > Which one? > > send() method? So you're trying to control the number of messages in a queue at any given time. Are you trying

Re: How to "activate" an interceptor

Thank you, Bruce. For my control (number of messages in a queue) do I need to override a specific method? Which one? send() method? Thanks again, Moreno bsnyder wrote: > > On Mon, Nov 23, 2009 at 7:15 AM, moreno9000 > wrote: > > You already registered your BrokerPlugin via the ActiveMQ X

Re: How to "activate" an interceptor

On Mon, Nov 23, 2009 at 7:15 AM, moreno9000 wrote: > > Hi, > I'd like to write an interceptor that controls the size of a queue > (number of messages in the queue) and throws an exception > if the queue has reached a predefined limit. > > I wrote two classes. > The first one (ItlPlugin class) impl

How to "activate" an interceptor

Hi, I'd like to write an interceptor that controls the size of a queue (number of messages in the queue) and throws an exception if the queue has reached a predefined limit. I wrote two classes. The first one (ItlPlugin class) implements BrokerPlugin. The second one (ItlBroker class) extends Brok

Usage Manager memory limit reached for topic. Producer hangs

Hi, My setup is: - single AMQ 5.3 broker, with no persistence (persitent="false") - useDedicatedTaskRunner=false - two nio producers - around 70 tcp consumer - 5000 topics total with lastImageSubscriptionRecoveryPolicy and constantPendingMessageLimitStrategy=10 - producers do asyncSend - no prod

Re: physical queue cannot be resolved using jndi / spring

Hi, try using queue.TEST.Q1 for JNDI name 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 Mon, Nov 23, 2009 at 2:34 PM, miten wrote: > > Hi, > > I create

Re: Producers blocking

Hi, regarding your problem no 2. Can you change the policy entry from to and try it gregory.guibert wrote: > > Hello, > > I am setting up a configuration of activemq with a network of brokers (4 > brokers instances) and I am facing several problems. I am using 5.2.0 > release, java

physical queue cannot be resolved using jndi / spring

Hi, I created physical queue using: Using admin view I can see the queue (queue://TEST.Q1) and send message and read using console. I am trying to read using MDB in spring and I cannot get jndi lookup to identify the queue. Probably some config below needs correction. Pl

Re: What happens where a consumer is not present ?

Hi Gregory Thank you for your reply. As far as I am concerned, I will try to reduce the number of non present consumers to see if the global freeze continues to appear, or appear later. (I will have to wait about one week to have first results). It will be a good thing to exchange our results.