Re: vm and activemq-data location

On Feb 12, 2008, at 5:40 AM, amq-newbie wrote: I'm completely new to the activemq, so I guess my question is basic. I am using activemq for JUnit testing. Therefore, I set to run it in vm mode since JUnit is ran by third party product that executes unit tests for entire application on

Re: Start/Stop Consumer and duplicate message is received.

On Feb 11, 2008, at 10:30 PM, wha wrote: Hi, I'm using the following version apache- activemq-5.1-20080208.142256-20.zip I have like 500 messages pending in the broker and I have the following consumer: public void run() { //Create a connection

Re: Exception when shutting down broker

James, I'm seeing the same situation in Spring-configured broker. After we switched from 4.0 to 5.0.0, i'm seeing unit tests (withe embedded activemq) give this error: 14:22:47,381 [AcitveMQ Connection Worker: vm://it-oms#4] INFO AdvisoryConsumer - Failed to send remove command:

Re: Consumer not consuming messages

I can't see your entire code. I don't know if you have a setMessageListener(YourConsumerClass) for your consumer. Your consumer class must implement MessageListener. Jeroen van Bergen wrote: The producer is happily producing messages. I can browse them using the web front end

Re: Priority queue/semantics of consumer priority

Thanks, Joe. I'm not sure content-based routing would do what I'm looking for (maybe you can explain further). I'd like the same group of consumers to process messages with different priorities but to give preference in the order of processing to higher priority messages. On Feb 12, 2008 11:01

Re: status -1 when establishing socket connection - SocketException

ActiveMQ CPP no longer uses maven as a build tool. We provide a VS2005 project file to build on windows. As far as I know the code won't build using the VC2003 compiler as MS deems it unnecessary to implement the full C++ ISO standard, and so there are language features that we use that are not

Re: status -1 when establishing socket connection - SocketException

I'm trying to follow this process, but I can't find this win32-msvc folder anywhere. Is it a part of the activemqcpp source distribution? Was it at one point, but now removed? What is this folder? Joe - Lalit Nagpal - wrote: Hi All- Here are my findings for people new to C++ and

Re: Priority queue/semantics of consumer priority

I would say the answer to your first question is 'yes'. Sounds like you're implementing a content-based routing pattern. If you can't use Camel to implement the pattern, then consider configuring the broker with composite destinations in combination with a selector to let the broker do the

Re: Consumer not consuming messages

The producer is happily producing messages. I can browse them using the web front end supplied with ActiveMQ. When I add a QueueBrowser to the consuming class it can see the messages in the queue. The consumer is not picking up any message at all. Have you hit this FAQ entry?

Re: Priority queue/semantics of consumer priority

Thanks for the link, Joe. So it looks like consumer priority is used by the broker to determine which subscriber to choose as the exclusive consumer? Does AMQ support message priorities? This ticket would suggest the answer is no (http://issues.apache.org/activemq/browse/AMQ-122) Does anyone

network of broker performance question

Hi, I am thinking of using embedded brokers in multiple instances of a producer application. These applications primary goal is performance. These embedded brokers will store and forward to another stand alone broker (or cluster of brokers using master slave) across the network where some high

Issue with Windows Binary Zip - Won't open

I have been trying to download the windows binary zip file from several of the mirrors and the backup site. When the download finishes, the zip will not open. Is anyone else having this issue? -- View this message in context:

Re: Priority queue/semantics of consumer priority

Oops, sorry. When I saw this statement, I thought you wanted a message routed to a particular queue based on its priority. Put the messages with different priorities into different queues If that is the case, then I think you can have the broker - using composite destinations and selectors -

Re: vm and activemq-data location

That's exactly what I've tried but I cannot get message from queue. I can only send it. For my unit test I need to send message to custom object that generates specific format and then sends it to the queue. Once done I need unit test to go and get the message from queue and compare the format of

Re: Subscriber hangs when broker shutsdown

You may want to try using the 'failover' transport. With the example below, if the broker fails the transport will begin retrying the connection to the broker. You may want to use a different maxReconnectDelay. failover://(tcp://localhost:61616)?maxReconnectDelay=1000 Joe www.ttmsolutions.com

Re: Priority queue/semantics of consumer priority

Hi Roger, I'd disregard the consumer priority feature; it does not function as described in the consumer priority page. Here's the exclusive consumer web page. http://activemq.apache.org/exclusive-consumer.html Joe www.ttmsolutions.com Roger Hoover wrote: I want to implement a

Re: Priority queue/semantics of consumer priority

That would get the messages into their respective queues. I still need a solution for the STOMP consumers to subscribe to multiple queues and process messages from them in priority order. I think the select() based approach I mentioned previously will work. I wanted to see if there were other

Re: Consumer not consuming messages

wha wrote: I can't see your entire code. I don't know if you have a setMessageListener(YourConsumerClass) for your consumer. Your consumer class must implement MessageListener. What I gathered from the JMS API documentation is that a call to receive() of a Consumer (as defined in the