Re: Multiple consumers/producers on same host

Can you post the junit test to a pastebin.com or other clipboard? Thanks Matt Pavlovich On Aug 20, 2010, at 12:37 PM, ReC0iL wrote: > > Hi all, > > I've just started to use ActiveMQ and I'm trying to build a distributed > workflow and I'm trying to get an end-to-end integration test up and >

Multiple consumers/producers on same host

Hi all, I've just started to use ActiveMQ and I'm trying to build a distributed workflow and I'm trying to get an end-to-end integration test up and running. However, I'm running into some problems. Are there any known issues with running multiple consumers/producers listening on the same broker

Re: LDAP Authorization

We are also trying to use LDAP for user authentication and message authorization. A co-worker of mine found a mismatch between the code and documentation [1]. After assorted code and configuration tweaks, he has arrived at what seems like a reasonable set of changes and also has a way to author

Subscribing with a selector over stomp isn't working

I'm using PHP with Stomp for connectivity. Where $o is my Stomp client: $o->subscribe("/queue/message.status.outbox", array("selector" => "AccountId = 21211")); Leaves the following trace: 2010-08-20 16:20:54,362 [127.0.0.1:44882] TRACE StompTransportFilter - Received: CONNECT passcode:

Re: How to get the consumer or producer's ip address?

The following code is in connections.jsp , it can get the RemoteAddress -- Connection ${requestContext.connectionQuery.connectionID} Connection ID

Re: Method setMessagePrioritySupported(true) called on ActiveMQConnectionFactory doesn't work

priority support needs to be enabled for a destination with a policy entry, prioritizedMessages see: http://activemq.apache.org/per-destination-policies.html The new (5.4) attributes are in red. To see the programatic setup check out the source of the one of the priority tests: http://svn.apache.o

Re: Where is ProducerInfo+ConsumerInfo data structure for Advisory Msgs?

The tests should always be the first port of call for example code you can depend on: for advisory support look at http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/advisory/AdvisoryTests.java?view=markup and the other tests in that directory. Typically yo

Re: How to forward a full message received in Java by onMessage() into another queue?

you need to think of each jms message as a fire and forget entity, immutable once sent. The properties whose name begin with "JMS" are for use by the JMS implementation so they will be set by the sender JMS implementation code to what ever is needed by the implementation. An application is in cont

Where is ProducerInfo+ConsumerInfo data structure for Advisory Msgs?

On page http://activemq.apache.org/advisory-message.html data structures named ProducerInfo + ConsumerInfo are mentioned. Where do I find these data structures explained (resp. which fields they contain in detail) ? Furthermore I wonder how I can detect wether an incoming msg on an Advisorc top

Method setMessagePrioritySupported(true) called on ActiveMQConnectionFactory doesn't work

Hi, According to activeMQ website, the latest, 5.4 version supports message priority handling: http://activemq.apache.org/new-features-in-54.html What's more, according to this website https://issues.apache.org/activemq/browse/AMQ-2790 handling priorities takes place by calling the setMessagePri

Re: How to forward a full message received in Java by onMessage() into another queue?

Hmm, this is interesting. If I set in a new JMS message the destination Queue to "aaa" with the method setJMSDestination() but sent the JMS Msg to another queue "bbb" then the JMS header field JMSdestination will will be brutally overwritten with "bbb". I can imagine that this happens with the