Large number of messages in the queue

I have around 60K messages in one of my queues that I want to process. The problem is that after around 10 minutes I get an OutOfMemoryError. I get a number of exceptions such as 2009-03-17 23:37:29,354 [VMTransport] ERROR - Failed to page in more queue messages java.lang.OutOfMemoryErro

question on DeadLetterStrategy

Hi, I am using activemq 5.0 and occasionally I see some messages on the DLQ. I was wondering 1. whether there is a default DeadLetterStrategy configured for a broker 2. under what circumstances is a message placed on the DLQ cheers

Strangeness with MemoryPersistenceAdapter

I seem to have stumbled across a memory leak using an embeded broker with MemoryPersistenceAdapter. I'm not sure whether it is the culprit but was wondering whether anyone else has come across a similar issue. Here is the relevant part of the config.

Re: deadlock while publishing a message.

m the broker - what's the broker doing whilst you are doing this ? cheers, Rob 'Go Get Integrated - ride the Camel! - http://activemq.apache.org/camel/' http://rajdavies.blogspot.com/ On Sep 11, 2007, at 11:27 PM, Jim Alateras wrote: I am using activemq 5.0-SNAPSHOT with a

deadlock while publishing a message.

I am using activemq 5.0-SNAPSHOT with a current project and have just come across a situation where a thread blocks indefinitely trying to publish a message. It happens during the session commit The method ActiveMQDispatcherClient.dispatch is synchronized. Here is the stack trace. Thread [poo

error dealing with expired message

Just wondering whether anyone has seen this error before. I am using the ttl facility on some messages in my system. Is it a known bug? 2007-09-04 16:41:57,394 [VMTransport] WARN - Failed to pass expired message to dead letter queue java.lang.NullPointerException at org.apache.acti

Re: clarification between 4.2 and 5.0

Rob, Do you have a date for the 5.0 release? cheers Rob Davies wrote: It was decided that because of the need to use JDK 5.0 - version 4.2 should be re-named as 5.0 - so no difference at all ;) On Jul 17, 2007, at 2:19 PM, Jim Alateras wrote: I was just wondering whether the only

Tests working on W2K not on Linux

Has anybody experienced this problem. I have a series of tests cases for a component that uses activemq. They basically use queues, with send and receiveNoWait. Whereas the tests run without problem on my W2K box I cannot get them to always complete successfully on the Linux box. The problem i

removing log.error

Is it possible to remove the log.error statement in the VMTransport.asyncOneWay method or degrade it to info protected void asyncOneWay(Object command) throws IOException{ try{ synchronized(mutex){ if(messageQueue==null){ messageQueue=n

clarification between 4.2 and 5.0

I was just wondering whether the only difference between the two versions was that the 5.0 was target for JDK 5.x. cheers

Re: UnknownHostException on startup

machine you are using ? On Jul 16, 2007, at 7:13 AM, Jim Alateras wrote: I am starting to see the following exception when starting the XBeanBroker Running au.com.observant.ringocore.dispatcher.service.BlobEntryDispatcherTest 16/07/2007 16:11:29 org.apache.activemq.util.IdGenerator WAR

UnknownHostException on startup

I am starting to see the following exception when starting the XBeanBroker Running au.com.observant.ringocore.dispatcher.service.BlobEntryDispatcherTest 16/07/2007 16:11:29 org.apache.activemq.util.IdGenerator WARNING: could not generate unique stub java.net.UnknownHostException: MERCURY: MERC

Creating MessageConsumer overhead

Just a general question about the overhead on creating MessageConsumer instances. Is it efficient to create MessageConsumers for relatively short conversations. For example a loop which basically checks for a message, executes a policy on the message and then sleeps for some interval. Would it

Re: Is there a problem with selectors on queues

James Strachan wrote: I'm not aware of any issues; I wonder if you could wrap up what you're doing in a little JUnit test case we could tinker with? will do James Am wondering if its one of the JMS gotchas that we all fall for now and again, like not starting the connection, or sending from a

single session multiple consumers and selectors

I have a single session which uses two consumers all within a single thread. This is how i use them 1. consumerA simply does a receiveNoWait on the queue and pops the first message. 2. We then use the firstMessage to construct a new consumer with a specific selector, named consumerB 3. consu

Is there a problem with selectors on queues

I am experiencing some problems with message selectors and was wondering whether there is known issue in activemq and queue message selectors. Prior to publishing a message on a queue i set the propA property message.setIntProperty("propA ", zone.getZoneNumber()); On the consumer side i do

setting a policy on a particular queue

I have a queue which i use to publish the status of the device. The consumer will dequeue the status and send it to a central management system at a configurable frequency. The publisher will publish a new status only when there is a change in the device state. In some circumstances the queue wi

Re: Retrieving stats for a particular queue

James Strachan wrote: On 6/14/07, Jim Alateras <[EMAIL PROTECTED]> wrote: Hi, I can get the TotalXXXCounts statistics from the BrokerView but was wondering how I can retrieve the same stats for a particular queue. Just grab the MBeans from JMX? thxs. is there info on how to go about

EnqueueCounter doesn't seem to be counting correctly.

The TotalEnqueueCounter, in BrokerView class seems to be incrementing even when I don't send messages to the broker. Has anyone else experienced this. The dequeue and queued counters seem to be operating as expected. cheers

Re: Getting the size of a Queue

Marco, I am running an embedded broker and I use org.apache.activemq.brokerBrokerServer.getAdminView() to get access to the counters (enqueue, dequeue and queued count). These counters are at the broker level not the queue level though. hope this helps. cheers MarcoB70 wrote: I would like

Retrieving stats for a particular queue

Hi, I can get the TotalXXXCounts statistics from the BrokerView but was wondering how I can retrieve the same stats for a particular queue. cheers

QueueSender question

If I create a QueueSender QueueSender pub = session.createSender(new ActiveMQQueue("queue1")); I can't seem to use it to publish to another queue. pub.send(new ActiveMQQueue("queue2"), message); when this executes i get the following exception aused by: java.lang.UnsupportedOperationException

Re: Using JManage 2.0

Got it. It is the same uri as i use for jconsole (service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi). I am using the JSR160 Application type to connect/ First impressions of JManage are very positive. cheers Jim Alateras wrote: Hi, I've been able to use jconsole to connect to th

Using JManage 2.0

Hi, I've been able to use jconsole to connect to the JMX instance of my embedded broker but was wondering whether anyone has managed to use JManage 2.0 to manage activemq through it's JMX service offering. I have downloaded JManage 2.0 but have been unsuccessful in getting it to attach to a

Re: Cleaning the database

James Strachan wrote: On 5/17/07, Jim Alateras <[EMAIL PROTECTED]> wrote: What is the best way to clear the database that stores persistent messages? I am using an embedded broker and the mysql database, which is shared with other applications. You can purge individual queues via JMX; o

Cleaning the database

What is the best way to clear the database that stores persistent messages? I am using an embedded broker and the mysql database, which is shared with other applications.

Cleaning the database

What is the best way to clear the database that stores persistent messages? I am using an embedded broker and the mysql database, which is shared with other applications.

EmbeddedDataSource and derby.lo

This is not an activemq specific question. Does anyone know how to configure where to put the 'derby.log' file when running the embedded data source? The default location is the current directory. cheers

Re: Ack'ing persistent messages

James Strachan wrote: Try turning on debug logging. anything specific. If you could provide a JUnit test case for what you're doing it always helps will do early next week cheers

broker configuration

Can someone point me to documentation on configuring the persitence aspects of a broker? When i specify the persistent=true attribute in the broker element it creates the database in the default directory. what element/attribute do i use to locate the database in a psecific location cheers

Re: Ack'ing persistent messages

This doesn't seem to be working. I am using persistent queues in a non-transacted session. What log4j settings should i set to see what is happening. cheers On 4/19/07, James Strachan <[EMAIL PROTECTED]> wrote: On 4/19/07, Jim Alateras <[EMAIL PROTECTED]> wrote: >

Ack'ing persistent messages

If i synchronously retrieve messages of a persistent queue and i only ack the last message will that implicitly ack all the other messages that have come beforeor do i need to ack each message explicitly cheers

Re: embedded broker and persistence delivery

Found this thread on the dev mailing list, which discusses a short term work around to the problem http://www.nabble.com/embedded-broker-using-Spring-2.0-broken!-t3509768s2354.html. cheers

Re: embedded broker and persistence delivery

James, I tried the Spring 2.0 configuration as outlined in the link below but i get the following exception on start up cvc-complex-type.2.4.b: The content of element 'amq:transportConnector' is not complete. It must match '(("http://activemq.org/confi g/1.0":broker){0-1},("http://activemq.o

embedded broker and persistence delivery

Am i able to configure activemq in embedded mode and use persistent queues. In this particular scenario the consumer and producer are in the same vm. cheers

activemq with spring and jetty

Has anyone developed a web application using activemq and spring 2.0 and subsequently deployed it on jetty 6.x? Did u experience any issues? cheers

Re: http tunneling for activemq

James, Thanks for the quick response. Does that also negotiate NAT and firewalls. cheers James Strachan wrote: On 3/6/07, Jim Alateras <[EMAIL PROTECTED]> wrote: I am wondering whether activemq supports http tunneling using a persistent pub-sub model. I want to use pub-sub to aggregat

http tunneling for activemq

I am wondering whether activemq supports http tunneling using a persistent pub-sub model. I want to use pub-sub to aggregate data from distributed sites across the internet. cheers