Questions for ActiveMQResourceAdapter.getXAResources method in ActiveMQ RA module

2010-12-27 Thread Ivan
Hi, I am learning the ActiveMQ RA module, and could not understand some codes in the getXAResources method of ActiveMQResourceAdapter class, please help to give some comments, thanks. a. The implementation class of XAResource is org.apache.activemq.TransactionContext, and it holds a referen

Re: Distributed ActiveMQ Brokers

2010-12-27 Thread Dirk Fröhner
Evening, the probability to receive useful replies on your questions correlates with the amount of details of your use case you are willing to reveal... :-) Glück auf! Dirk On Dec 27, 2010, at 5:38 PM, Petrucci Andreas wrote: > > yes, in the default case i can't , but in my case i have a dis

Re: Your favorite AMQ monitoring tool?

2010-12-27 Thread edan
rliguori wrote: > > What is the most commonly used monitoring tool with ActiveMQ... JConsole, > HermesJMS, the AMQ web console... or something other? > We already had Hyperic HQ in place, and I find its tracking of broker stats (dequeue count / minute, enqueue count / minute) invaluable. I be

Can round robin dispatching wait for consumer acks?

2010-12-27 Thread edan
I have 600+ queues in a single ActiveMQ 5.3.2 broker connected to 4 webMethods consumers using the flag "?consumer.exclusive=true" in order to guarantee FIFO-ness / strict ordering of each queue across the 4 consumers. We may have other troubles with respect to trying to process hundreds of queue

RE: Distributed ActiveMQ Brokers

2010-12-27 Thread Petrucci Andreas
yes, in the default case i can't , but in my case i have a distributed filesystem underneath so i have to play with activemq so as to achieve it. That's what i want to do. > Date: Mon, 27 Dec 2010 17:21:46 +0100 > Subject: Re: Distributed ActiveMQ Brokers > From: de...@nighttale.net > To: users

Re: Distributed ActiveMQ Brokers

2010-12-27 Thread Dejan Bosanac
You can't achieve that in distributed environment and different producers. And what's the FIFO anyway in that case? You can probably use Camel Resequencer (http://camel.apache.org/resequencer.html) to arrange messages according to some of your app specific property. Cheers -- Dejan Bosanac --

RE: Distributed ActiveMQ Brokers

2010-12-27 Thread Petrucci Andreas
yes but what i cannot understand is how their FIFO property is preserved in queues. I mean a queue is distributed in two or more brokers of the network. How is it possible for a queue say TEST.FOO queue to preserve its FIFO property when its messages are distributed at two or more brokers???

Re: Interceptor to get messages text

2010-12-27 Thread Dejan Bosanac
I didn't realize that you want to intercept messages before they are added to the broker. In case you just want to "log" all the messages that comes to the destination, you can use Camel to easily do that. For queues, you can use "mirrored queues" http://activemq.apache.org/mirrored-queues.html C

Re: Distributed ActiveMQ Brokers

2010-12-27 Thread Dejan Bosanac
Sure they can. Messages stays on the broker where they are produced until consumer arrives, when they are delivered to it. Cheers -- Dejan Bosanac - FuseSource - The experts in open source integration and messaging. Email: dej...@fusesource.com Web: http://fusesource.com Twitter:  

ActiveMQ unique features

2010-12-27 Thread rliguori
Can anyone provide a short itemize list of the primary and unique ActiveMQ features that exist outside of those defined by the core JMS specification? Thanks! -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-unique-features-tp3165115p3165115.html Sent from the Act

Re: JMSPriority implemented in AMQ 5.4.1?

2010-12-27 Thread rliguori
Yes, that is what I was missing... Tim addressed it in this thread, and I adjusted my code. I do have one outstanding question though, assuming that I get my messages priorities to the producer... "Are the priority algorithm(s) applied by default or do the queues need to be configured as in th

RE: Distributed ActiveMQ Brokers

2010-12-27 Thread Petrucci Andreas
thanks for the reply, i'm aware of the network-of-brokers solution but i doubt if 2 distinct producers can produce messages for the SAME queue at 2 different brokers of the network. Yes, in my setup i really need multiple brokers but i think that what i ask for (i think that it) cannot be prov

Re: Distributed ActiveMQ Brokers

2010-12-27 Thread Dirk Fröhner
Afternoon, As far as I understand your use case, you can set up a so called network of brokers to achieve this. A NWOB is a collection of brokers that know about each other. Destinations are distributed on the participating nodes as far as they're involved. Clients can connect to any of the nod

RE: Interceptor to get messages text

2010-12-27 Thread Petrucci Andreas
Two questions: what do you mean better ways??? Is there a way to intercept a message just before it is permanently stored? I mean can i intercept messages just when the lock is aquired and are ready to permanently stored in amq or kahadb?? thnx, Petrucci > Date: Wed, 22 Dec 2010 17:30:46 +

Distributed ActiveMQ Brokers

2010-12-27 Thread Petrucci Andreas
Hello there, all i want ot ask is there there is a specific setup of activemq brokers such that we will have multiple brokers in our network that can serve clients that are producing (just producing) messages for one ( just one) queue. As far as i can see , there is no way to achieve that. Am I

Re: How to setup multiple queues

2010-12-27 Thread Dejan Bosanac
1099 is default port used by platform JMX. Take a look at this article on more info how to configure it http://activemq.apache.org/jmx.html Cheers -- Dejan Bosanac - FuseSource - The experts in open source integration and messaging. Email: dej...@fusesource.com Web: http://fuseso

Re: How to setup multiple queues

2010-12-27 Thread archa
In our application we are using the JMXConnectorFactory which is used to connect to the JmxURL which is service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi When I start activemq, and checkout netstat, I sometimes find application on 1099, sometimes there is no application. After starting my tomc