Re: Pausing a consumer

Oh, and in case it matters, I am using pyactivemq (Python wrapper for ActiveMQ-CPP). Thanks in advance. -- View this message in context: http://www.nabble.com/Pausing-a-consumer-tp16043150s2354p16044462.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Pausing a consumer

Hello, Is there a way to temporarily pause or throttle messages received by a consumer using a messageListener? I'm writing a program that takes messages from a queue and sends them to a process on a remote server using a proprietary TCP protocol. Unfortunately, the protocol/remote server handles

timeStampingBrokerPlugin and Time to live

I have set the producer time to live value to expire messages after 10 sec. However, if the sys clock on the producer is different than the brokers, chances are high that this 10 sec window will never be realized and ALL messages will be considered expired. I saw the timeStampingBrokerPlugin is th

Re: Constantly adding and removing consumer

I have seen this same behaviour an am interested in any info on this! david.la wrote: > > Hi, > > I'm using activemq with camel and when i turn the debug logs, I'm seeing > activity every second or so. It's adding and removing consumer. > > I'd like to know what is that for may be i'm miscon

Re: Consumers not always being released

FYI - patchfile submitted. https://issues.apache.org/activemq/browse/AMQ-1511 Joe Goto www.ttmsolutions.com for a free ActiveMQ user guide toxicafunk wrote: > > That'll be great. > > Thx, > Eric > > ttmdev wrote: >> I'm testing out a patch. If all goes well, I'll submit it in the next day

Constantly adding and removing consumer

Hi, I'm using activemq with camel and when i turn the debug logs, I'm seeing activity every second or so. It's adding and removing consumer. I'd like to know what is that for may be i'm misconfiguring my activemq because even if there is no external activity, it's still happening. I recently f

Using MessageBroker to start AMQ programmatically

Does anyone have a C++ snippet I can use to start the ActiveMQ message broker using this MessageBroker class? Thanks in advance! Beeeph -- View this message in context: http://www.nabble.com/Using-MessageBroker-to-start-AMQ-programmatically-tp16036636s2354p16036636.html Sent from the ActiveMQ

Re: Start ActiveMQ programmatically

When it comes to deployment, using the service wrapper may be an issue if the computer doesn't allow services to be setup from the installer. So I'm really looking for an approach that starts the service from the code. I see a lot of people using this MessageBroker class, but I'm not entirely su

Re: Consumers not always being released

That'll be great. Thx, Eric ttmdev wrote: I'm testing out a patch. If all goes well, I'll submit it in the next day or so... Joe Goto www.ttmsolutions.com for a free ActiveMQ user guide toxicafunk wrote: This seems to be exactly the problem. I will try the shared master/slave configuration

Specifying Subnet for Multicast

If I want to use discovery only on a private subnet my systems are connected to, how do adjust the multicast URI? I'm currently using: http://activemq.org/config/1.0"; dataDirectory="${data.directory}" persistent="true">

NC_testBroker_outbound already connected from

What does this message actually indicate? 13:33:36 WARN [ActiveMQ Transport: tcp://plank.local/172.16.2.251:61818] network.DemandForwardingBridge| Network connection between vm://testBroker#20 and tcp://plank.local/172.16.2.251:61818 shutdown due to a remote error: javax.jms.InvalidClientIDExcept

Re: Consumers not always being released

I'm testing out a patch. If all goes well, I'll submit it in the next day or so... Joe Goto www.ttmsolutions.com for a free ActiveMQ user guide toxicafunk wrote: > > This seems to be exactly the problem. I will try the shared master/slave > configuration but is this bug fixable and if so whe

Re: Unable to comile C++ client on VC++ 2003

Update VC++ 2003 (_MSC_VER 1310) and activemq-cpp 2.1.3. Got the activemq example compiled and linked and it ran fine using a solaris activemq server.:clap: Finished compiling and linking our VC 2003 project it worked also. So if you do as I say, activemq-2.1.3 will compile and work in VC++ 20

Undequeued Messages

Hallo, I spotted out mysterious values for a topic. Here are the values: * ConsumerCount:1 * DequeueCount: 1 * DispatchCount:2 * EnqueueCount: 2 * QueueSize:0 And here is my question: How is it possible that own message is not dequeued but no message is

Re: Problem with Master/Slave, how to configure it? (I'm using Servicemix)

Thank you toxicafunk, I didn't realize that. Anyway, I follow the instructions for recovery master/slave topology but not resolve my problem. Finally, I changed configuration in activemq.xml master and it worked ok: Before (master): Now (master): toxicafunk wrote:

Outof memory using temp queus in active MQ- 5.1

Hi. I have the out of memory problems using active MQ 5.1 (activemq-all-5.1-SNAPSHOT.jar) In my application I use many temp queues, delete them after usage. I see that they are deleted, but in addition i see many Advisor objects defined and not deleted. After a few hours i get out of memory exce