Computer sync issue

I have an application that uses ActiveMQ. ActiveMQ is in it's own JVM on computer 1. The core application has producers and consumers and also runs on computer 1. There is a UI portion that consumes and produces messages as well. The UI and core communicate via ActiveMQ. If the UI runs on the same

Re: Stopped waiting for space in pendingMessage cursor messages

Below is the config file. I don't have persistence set to true and the ActiveMQ heap size is 1024mb. http://www.springframework.org/schema/beans"; xmlns:amq="http://activemq.apache.org/schema/core"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="http://www.springframewo

Re: Stopped waiting for space in pendingMessage cursor messages

I had this message 35 minutes prior to the flood of other messages. But why would it take 35 minutes for the other messages to occur after the OOM? We use non-durable topics so I don't believe temp memory would be used, would it? ActiveMQ has since been restarted so I can't check the JMX stats. j

Stopped waiting for space in pendingMessage cursor messages

For about 26 minutes I received approximately 500,000 of the following messages: 2012-10-28 11:19:00,877 | WARN | TopicSubscription: consumer=ID:CR--49190-1351302775232-0:1:4:1, destinations=1, dispatched=32766, delivered=2728701, matched=29318, discarded=0: stopped waiting for space in pendi

Re: 5.7 doesn't consume on queue

Thanks for the validation. Will this be the case from now on? For example, if one was 5.6 and the other 5.7 would that still be a problem or is it just a problem between mixing 5.5.1 and earlier versions with 5.6 or later? The reason we use a network of brokers is to allow communications between

Re: 5.7 doesn't consume on queue

pBroker in this case isn't relative because it is used for intercommunication between server components. The server fBroker networking with the client fBroker is the issue. The network connector xx.xxx.x.xxx (i.e. 173.194.77.147) setting indicates the client fBroker IP to connect to. -- View thi

Re: 5.7 doesn't consume on queue

activemq.xml is on server side which sends a message on the START queue to the remote broker defined by jms.xml and listens for ACK message. The server using the act

Re: 5.7 doesn't consume on queue

This is over a networked broker and according to JMX the ack queue does exist. I also tried using 5.6 and that too doesn't work. Without changing any code and using the same config file, 5.5.1 works but 5.6 and 5.7 do not. I didn't see any logs on the issue. I don't understand why it doesn't work.

5.7 doesn't consume on queue

I'm in the process of updating from 5.5.1 to 5.7.0 but have an issue. The app being updated sends a message on one queue and listens on a different queue. The message is successfully sent and received by a Spring based app running in Tomcat and using ActiveMQ 5.5.1. The Tomcat app places the ack me

Finding a hung consumer

We have an application that sometimes runs out of memory. It has five topics that multiple consumers and producers interact with. I believe that one of the consumers may be getting hung causing ActiveMQ to hang on to the messages and fill the buffer. I would like to know if there is a way to determ

Memory question

I'm using 5.5.1 and have several non-durable topics. A snippet of my config file is below. I have a few questions: 1) Is the limit for each topic is 100kb? 2) If I don't set a memory limit in the policy entry, does it use the systemUsage, memoryUsage value of 1mb? 3) If the memory limit is reached

Finding a slow consumer

I've been dealing with Out Of Memory issues and I believe it may be due to a slow or hung consumer. The software has about five different Topics with multiple producers/consumers for each topic. I've been playing around with it and simulated a slow consumer which caused the problem to occur. I noti

Re: storeUsage not working

I was able to correct the problem when I changed producerFlowControl from true to false. I also added the journalMaxFileLength attribute to the kahaDB tag. -- View this message in context: http://activemq.2283324.n4.nabble.com/storeUsage-not-working-tp4314236p4325599.html Sent from the ActiveMQ -

Re: storeUsage not working

Thanks. I was under the assumption that messages sent to a queue were persistent by default. -- View this message in context: http://activemq.2283324.n4.nabble.com/storeUsage-not-working-tp4314236p4320660.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

storeUsage not working

I'm trying to setup ActiveMQ to store a large number of messages sent to a queue but it seems to only use the memory limit and not the store limit. If I view the queue via jConsole it shows that cursorMemoryUsage reaches 1.5mb at which point it throws an Exception indicating memory limit reached. I

Queue appearing on network broker

I have a system that will consist of a broker (server broker) that will be connected via networkConnection from multiple different brokers (client brokers). While doing some testing I noticed that a queue created on one client broker (i.e. A) showed up on another client broker (i.e. B) as well as s

Messages not being removed from networked queue

I have two activemq brokers networked together. The producer broker (has static network xml tag) shows enqueued and dequeued values matching when consumer broker consumes the message, but the dequeued value on the consumer broker shows zero and if I rerun the consumer it receives all the messages a

Understanding Networking and JMX

I setup a test system to better understand how networked brokers interact and messages, etc. are seen via JMX. The receiving broker is receiving the messages sent by the transmit broker but when I view it via JMX it shows that the messages were not dequeued. I've ran a network test before and viewe

Inactive queue

The link http://activemq.apache.org/delete-inactive-destinations.html talks about deleting destinations that are inactive for a period of time. At what point does it become inactive? -- View this message in context: http://activemq.2283324.n4.nabble.com/Inactive-queue-tp3913110p3913110.html Sent

Queues not showing up using JMX

I'm trying to delete a dynamically created queue programmatically. My research seems to indicate that JMX is the best way to do this. I have successfully created producer, consumers and queues. I can see the queues using the web console http://localhost:8161/admin/queues.jsp but I can't see any qu

How to get broker in code?

I have the following spring file that defines my JMS setup. I want to get the Broker or BrokerService object from within my code so I can delete a dynamically created queue. I can wire in the jmsTemplate but how do I get the Broker? http://www.springframework.org/schema/beans"; xmlns:amq="

Different version compatibility

Currently we have a product that uses ActiveMQ 5.3. We are now creating a separate product that will communicate with the current product. I would like to set the new product up to use ActiveMQ 5.5. Would this be a problem? Our intent is to have the two products contain their own broker and netwo

onMessage Threading Question

I have several listeners each of which I want to listen on there own thread, but it doesn't seem to be creating separate threads. I have one connection which creates a session for each listener. The sessions are each created in there own thread and within that thread for each session a consumer is

Setting request and response destinations to same topic name

I've got a request/reply messaging system set between two applications where the topic name is the same for request and response. I'm now getting an endless loop where messages are processed by both client and server onMessage methods. Is this because the topic names are the same or am I doing so

Re: Unable to receive topic message

I found my problem. I didn't have a good understanding of what an embedded broker is. Embedded brokers only work for messages within the same app and I was sending the message externally. -- View this message in context: http://activemq.2283324.n4.nabble.com/Unable-to-receive-topic-message-tp369

Unable to receive topic message

I've implemented a modified version of an example from the "ActiveMQ in Action" book and don't understand why I'm not receiving a message. The code is running on tomcat as embedded broker and to test it I'm using ActiveMQ's web console to send a message via link http://localhost:8161/admin/send.js

JMS Communications

Below is a sample program on Tomcat that uses ActiveMQ JMS example code. The code runs and per my messages sends a message and is listening, but doesn't receive the message. I would appreciate if someone could review and let me know what I've done wrong in or outside of this code or if I need to a

Re: Namespace not found

Resolved problem by adding xbean-spring-3.6.jar in the ActiveMQ/lib/optional directory to my path. -- View this message in context: http://activemq.2283324.n4.nabble.com/Namespace-not-found-tp3686564p3687090.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.