Eventhough the queue is emptied frequently ActiveMQ throws OutOfMemoryException

Hi All, I am Using Mule and ActiveMQ for a messaging system My problem is : Eventhough the queue is emptied frequently by some listeners,after a certain limit of messages ActiveMQ throws OutOfMemoryException.After this we are not able to put or take from Q.And also the jconsole goes down. Cur

Re: jaas security

Hi Joe, Yup it solved that problem but im now gettin these errors: javax.jms.JMSException: User name or password is invalid. at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:49) Caused by: java.lang.SecurityException: User name or password is invalid.

Hot tip for gigantic queues + MySQL

Running 4.1.1, journaled-jdbc on MySQL 5.0, I have a 10GB ACTIVEMQ_MSGS table with ~100k messages. I found the default "deleteOldMessagesStatement" was performing very poorly. This is due to a known issue on MySQL with correlated subqueries. To address the problem, I created the following sto

trying to combine failover and prefetchPolicy

Hey guys - I'm using ActiveMQ through Spring, with the client configured through my spring xml files. I'm trying to get a client to connect to a broker with two features enabled: a) I want failover turned on as the network between the client/server is slightly flakey, and b) I want to set my q

Re: Is ActiveMQ suitable for this Store-And-Forward scenario?

There are two basic deployment configurations for ActiveMQ brokers: embedded and standalone. An embedded broker executes within the same JVM process as the client(s) that is using its services. The client communicates with the embedded broker via direct method invocation. Standalone brokers do

Re: Is ActiveMQ suitable for this Store-And-Forward scenario?

Thanks for replying, Joe. The client application won't be transitory, but I wonder what you mean by standalone broker. Do you mean developing it from scratch? That would require to implement all the polling to the server and the persistance feature among other things. My idea is to leverage existi

Re: Is ActiveMQ suitable for this Store-And-Forward scenario?

Yes, ActiveMQ will meet your requirements. You can have the ActiveMQ message broker, on your local client machine, persist the XML messages so that when the network is available it can forward the messages on to the ActiveMQ broker that you have deployed on the server machine. If your client app

Re: Stop Thread / Stop Listening

Not sure I understand your question exactly. Are you looking to simply use the threading classes in your own program or are you asking about how to shutdown a connection? If the latter, you simply have to do a connection.close(). If you're looking to use ActiveMQ-CPP's threading classes in your

Is ActiveMQ suitable for this Store-And-Forward scenario?

Good afternoon. I'm currently evaluating existing JMS Servers in order to fulfill the following requirement: A Java client application must send XML messages to JMS on the application server, but the network is not available most of the time. XML messages must be persisted in the local client mac

Networked brokers and durable bridges

I'm working with a configuration of three networked brokers each with a bridge to the other two. The purpose is to provide redundancy as well as load balancing. It works as expected for Queues and non-durable topic subscriptions. Durable topic subscriptions though seem to be exhibiting a proble

Stop Thread / Stop Listening

With the threading capabilities provided by ActiveMQ-CPP, is it possible to stop a thread? For example, if one thread starts listening for messages, is it possible for a second thread, say a command prompt to stop and shutdown the listener thread when the user types "quit" or "exit"? Thanks, mrh

Re: BLOB messages

Yes, in fact we're just about to start the ball rolling on 2.1.1. Should have an official release soon. Nate On 10/25/07, appi03 <[EMAIL PROTECTED]> wrote: > > > I was just wondering if you guys were working on it. I am not sure if we > will > need but it would be a cool feature to have. > > Btw

is this a bug?

I will try to explain it as well as i can. Producer box( Windows - running a broker - Producer configuration: persistent messages) Consumer box(Linux - with durable topics for persistence) Configuration is attached. Behavior: I ran the producer and made my consumer stop in between so that not

persistent topics

Has anyone gotten persistent topics working on activemq-cpp-2.1. i just can't seem to figure that one out. I do think that my messages are being persisted because my RAM usage keeps increasing but when my consumer goes down and i bring it up again. I don't receive any messages that were persisted

RE: features in CPP client

Thanks for the information. Mittler, Nathan wrote: > > FWIW, we're do have SSL support in our roadmap for the 2.2 release. In > fact, we've already received a patch that does add some level of SSL > support (for *nix platforms). See this issue for more info > http://issues.apache.org/active

Re: BLOB messages

I was just wondering if you guys were working on it. I am not sure if we will need but it would be a cool feature to have. Btw, do you know if there any plans of dropping a new version of the cpp client. tabish121 wrote: > > There are currently no plans to support BLOB messages. You could cr

RE: features in CPP client

FWIW, we're do have SSL support in our roadmap for the 2.2 release. In fact, we've already received a patch that does add some level of SSL support (for *nix platforms). See this issue for more info http://issues.apache.org/activemq/browse/AMQCPP-140 Regards, Nate > -Original Message- >

Re: BLOB messages

There are currently no plans to support BLOB messages. You could create an issue requesting it and we will hopefully get to it at some point. I still haven't found anyone to pay me to work on this full time :) so we get to what we can as fast as we can. Regards Tim. On Thu, 2007-10-25 at 12:2

Re: features in CPP client

TCP is the only transport that we currently support, sorry no SSL. The cpp client supports durable consumers just as the java client does. The policies are set at the broker not in the client. Regrads Tim. On Thu, 2007-10-25 at 12:20 -0700, appi03 wrote: > Just a quick question about what is sup

RE: c++ client doesn't receive on all topic consumers

Hmm .. Sounds fishy. Anyway, I'm glad you got things working. Thanks for the update! > -Original Message- > From: Scott the Red [mailto:[EMAIL PROTECTED] > Sent: Thursday, October 25, 2007 3:22 PM > To: users@activemq.apache.org > Subject: Re: c++ client doesn't receive on all topic c

BLOB messages

I know blob messages is a new feature of 5.0 but just wondering if anyone knows if it will also be part of activemq-cpp. -- View this message in context: http://www.nabble.com/BLOB-messages-tf4693020s2354.html#a13413990 Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: c++ client doesn't receive on all topic consumers

Hm. I seem to have fixed the problem by merely moving the ActiveMQ connection out of my consumer's constructor, and into a separate "start" method. Everything seems to be working properly now. There don't appear to be any variable lifecycle issues (like a local or argument being referen

features in CPP client

Just a quick question about what is supported on ActiveMq-CPP client. I believe the only protocol that I can use right now is TCP, correct? Can i use SSL? What subscription recovery policies are available for cpp client. The website has good explanation on this but I am not sure if I would be ab

Re: c++ client doesn't receive on all topic consumers

nmittler wrote: > > Which version of ActiveMQ-CPP are you using and against which ActiveMQ > broker version? Also, platform might be helpful. > ActiveMQ 4.1.1 ActiveMQ CPP 2.1 Fedora Linux nmittler wrote: > > Could it be that this first consumer was started at or after the time the > me

JMX "browse" functions return empty

My customer has ActiveMQ 4.1.1. They asked me to create a custom http://www.jmanage.org/ jManage dashboard for them to easily inspect their queues. The dashboard basically shows two things - the current queue size as returned by getQueueSize(); a list of all the messages in the queue as return

Re: jaas security

Clear out your brokers data directory (i.e., ../activemq-data/). I believe the exception is being hurled because there is a destination in the data directory that was previously created w/out the security credentials that you're now trying to use. I was getting the same exception and clearing ou

Re: Problem using MySql as data source for Persistance Adapter

the only difference is that journaledJDBC is now using built in journal before writing to the db directly.A lot faster but as far as i know not so failsave in a clustering solution. If you changed that config something like this: this will use directly the db. Which is a lot slower but more reli

Camel Route from one broker to other

Hi, I'm having a little bit of trouble creating a camel route to send messages from a queue on one activemq broker to other. Here's my situation. I have two instances of activemq brokers running whose names are qm1 and qm2. I have a queue on qm1 called example.A and a queue on qm2 called example

Messages are not getting persisted in database table.(jdbcPersistenceAdapter>

Hi, Im using the following configuration for persisting messages into oracle database. Ultimately When I start activemq the tables (activemq_acks, activemq_lock, activemq_msgs) are created but it is not holding any message in table named 'activemq_msgs'. When I post messages into Broker, msg stay

ActiveMQ-CPP consumer client hanging after receiving 32767 messages.

Hi, I was stress-testing an ActiveMQ-CPP consumer client by transmitting to it a large burst of messages (100 per second). I realised that the client hangs after receiving 32767 messages and the broker has a log message INFO PrefetchSubscription - Could not correlate acknowledgment with dispat

Re: c++ client doesn't receive on all topic consumers

Which version of ActiveMQ-CPP are you using and against which ActiveMQ broker version? Also, platform might be helpful. > I'm creating a C++ adapter class to represent a message consumer > connecting > to ActiveMQ. > > Unfortunately, the consumers are not reliably receiving messages. Some > rec

Re: Problem using MySql as data source for Persistance Adapter

Thanks for your reply. Its working now. Hope I can manage without master-slave model for now, but I think going forward I'll also need to use 5.0. I have the following config now: I did not find the 'jdbcPersistenceAdapter' tag in my config file which you mentioned. Think it mak

Re: Problem using MySql as data source for Persistance Adapter

hello, i guess you are using 4.1.1 there seems to be a problem with this release. If this will be the only broker that you will use(no master slave) add the useDatabaseLock="false" on http://www.nabble.com/Problem-using-MySql-as-data-source-for-Persistance-Adapter-tf4688504s2354.html#a13403331 S

JDBC Master Slave & MySql

Hello, i am trying to get the JDBC M/s Configuration working using mysql. There was a locking issue on mysql with activemq 4.x so i am using the latest 5.0-SNAPSHOT. In my testcase, Master boots up just fine but when the slave is booting it is trying to insert some data into the db but it cannot a

Persistence in ActiveMQ

Hi, Im using apache-activemq-5.0.0.2-fuse. I would like to persist all messages which im sending and receiving. Could anyone please help me how this works and what configuration I have to make. I would use either jdbcjournel or pure database persitence. Please help me to accomplish this,,, -Navne

Message resending at message broker restart

Hi, We currently seem to be hit by an effect described here: http://osdir.com/ml/java.activemq.user/2006-05/msg00300.html In short: when restarting the broker, some messages seems to be resent - in pour case our system imports some data which it already imported, and sometimes it overwrites new,

Re: jaas security

Hi Tom Thanks for taking time to help me out. Here's a snippet of my config: