Re: Resources not getting deallocated after receiving messages

I have an asynchronous sender and receiver. After sending about 200k messages I am getting 'OutOfMemory' are you closing all connection after you send from producer? rby wrote: > > Hi, > > Same here, I have an obvious memory leak with activemq 5.1-snapshot. > I hope someone will respond at l

ActiveMQConnection:1653 - Async exception with no exception listener: java.net.SocketException: socket closed

Did somebody see this Warning exception while using active MQ 5 when sending asynchronous messages? this is exception i am getting on producer class after some time of its running. the url for broker is : tcp://localhost:61616?trace=true&wireFormat.maxInactivityDuration=-1 10:44:44,427 WARN Ac

Re: Consumers not always being released

Hi Mike, Thanks for your time. I am a bit confused here. The config that you have sent me seeems to be of a broker network rather than a Master/Slave topology. Shouldn't we be setting the shared datastore like this: Is /data in your config the shared directory? Thanks, Ramit Mik

Could I get user name and password of JDBC connection in config file

Dear All: After checking out all API all day, I still has no idea how to get user name and password of JDBC connection in config file. Do I need to user ConnectionContext or ConnectionInfo classes?? How could I get these info from BrokerService??? Please help me to figure it out~ Sincerely, J

Re: Shared Filesystem Master/Slave doesn't work even on 5.1 SNAPSHOT

Hi, Replying to my own message, the problem may be due to the following whenever I start a broker (or if a slave becomes a master): INFO AMQPersistenceAdapter - Aquired lock for AMQ Store/shared/activemq INFO AMQPersistenceAdapter - AMQStore starting using directory: /shared/a

SQL Exception after failover using shared filesystem master/slave

Hi, We are having two boxes, with 4 brokers each, which are responsible for one queue. Failover works most of the time, but sometimes after a broker shuts down, the one, which is waiting for the lock throws following exception: java.io.IOException: Failed to start database 'derbydb', see the nex

Re: Message enter ActiveMQ.DLQ after consumer reconnect

Sorry, i can't really help with answering your question, but i though I would also show my interest in this topic.. basically I too am confused as to why messages only get DLQ'd when there active consumers even when the time to live on the message is vasly exceeded, thiamteck wrote: > > Hi, >

Re: Resources not getting deallocated after receiving messages

Ok, I got the problem. The problem was at my sender/receiver components in Mule. Yeah, I was using Mule as a client to connect to ActiveMQ. For more information about this problem with mule go to : http://www.nabble.com/forum/ViewPost.jtp?post=13619403&framed=y http://www.nabble.com/forum/ViewPos

AMQ AjaxServlet in Jetty

I am trying to get a very simple app running using the AMQ AjaxServlet, and I can not seem to get it working. I am running the following: - Java 1.5.0_14 - AMQ v5.0 - Jetty 6.1.8 Some details about my app: - I have a stand along Spring container running my AMQ message broker listening on tcp://l

Re: XAConnectionFactory

Has anything become of this? I'm using ActiveMQ 5 now, if that matters. agabel wrote: > > I use Jboss 4.0.5 and activeMQ 4.1. > > I want to define a XAConnectionFactory. I doesnt find any documentation > about this point. > If I define in the ra.xml following: > >

Re: Consumers not always being released

Yes, the /data is my shared directory. Persistence can be set up either way according to the config examples I have seen. I used the network of brokers to keep the slaves up to date when I was originally having problems with the behavior of the slaves. I am not sure if having this configured is

Re: Consumers not always being released

Hi Mike, Thanks for the reply. I think I understand the way you have set it up now, but doesn't the slave just sit waiting for the lock to be released? As its connectors are not yet started, the store & forward network can't be established. My master keeps complaining that it can't connect to the

Snapshot dependency in released ActiveMQ 5.0.0 must be removed

I moved this morning to ActiveMQ 5.0.0 and encountered problems with the dependency on org.apache.activemq:activeio-core:jar:3.1-SNAPSHOT. This led me to the following thread: http://www.mail-archive.com/users@activemq.apache.org/msg04738.html Using the exclusion fixed my problem. But I what I

Restricting Multicast Discovery

I apologize for asking basic questions! I am trying to configure multicast discovery among brokers on an insecure network. Is this possible or a good idea? I don't know much about multicast, so I don't understand how to restrict which systems get connected. Thanks, A. -- View this message in

AMQ AjaxServlet in Jetty

I am trying to get a very simple app running using the AMQ AjaxServlet, and I can not seem to get it working. I am running the following: - Java 1.5.0_14 - AMQ v5.0 - Jetty 6.1.8 Some details about my app: - I have a stand along Spring container running my AMQ message broker listening on tcp://l

Re: Consumers not always being released

I just checked our logs, and I am seeing the same message about the Master not being able to connect to the slave. I will be removing the Network of Brokers setting form our config. We are using queues, not topics. Thanks for pointing out the Network of Brokers issue! I forgot to check the logs

Re: Consumers not always being released

Yeah, I guess doing it the way the website recommends is the correct method to configure Master/Slave. Thanks, Ramit Mike Miljour wrote: > > I just checked our logs, and I am seeing the same message about the Master > not being able to connect to the slave. I will be removing the Network of >

Re: Resources not getting deallocated after receiving messages

Can you provide information re the memory leak that you've come across? rby wrote: > > Hi, > > Same here, I have an obvious memory leak with activemq 5.1-snapshot. > I hope someone will respond at least to one of these memory related > questions. > > Regards, > Ramzi > > > krv wrote: >> >

Re: Strange StreamMessage problem

After looking at the documentation more closely I think I've answered my own question, and that this behavior is by design. "To read the field value, readBytes should be successively called until it returns a value less than the length of the read buffer. The value of the bytes in the buffer foll

Simple Authentication Plugin

Hi, I am trying to understand ActiveMQ's security feature. I started with simple authentication but seem to be missing something. I have search the forum as well as Google but no luck. My test starts the embedded broker and makes a connection. Based on the users defined, I expect the request t

choosing the right value for networkTTL

In my test setup i have 3 servers which are using multicast discovery to find connections for a network of brokers. Each broker has client listener for topic A. If one of the brokers publishes to the topic, all of them should get it. Would that be possible with the networkTTL value of 1 or do I ne

Re: Message enter ActiveMQ.DLQ after consumer reconnect

My college just told me that the message only enter DLQ after consumer reconnect, if the consumer is same server as the ActiveMQ. Anyway, I not yet test it out myself. PM wrote: > > Sorry, i can't really help with answering your question, but i though I > would also show my interest in this top