Re: How many connections does an AMQ client really need to the broker ?

2013-07-25 Thread Christian Posta
There are no hard and fast rules. Guess it depends on the complexity of the app, the number of consumers/producers, message throughput requirements, etc. One connection can support lots of sessions and each session can support lots of producers and consumers... On Thu, Jul 25, 2013 at 5:14 PM,

Re: Reliably calculate time spent in broker

2013-07-25 Thread kristof sajdak
Hi Dejan, Thanks for your reply. I had a look at the plugin feature and I agree it could be a viable solution. However it does seem that I have to take extra considerations into account to make the solution robust. If I keep the message timings in memory similar to the other plugin implementati

Re: Ativemq instance will not shutdown gracefully.

2013-07-25 Thread Chirag Pujara
I think I figured out issue. It was user problem. I started process with diff. user and was trying to shutdown as root user. thanks, chirag On Thu, Jul 25, 2013 at 2:50 PM, Chirag Pujara wrote: > Hello, > > when I try to shutdown activemq instance it throws exception that it > cannot connect to

How many connections does an AMQ client really need to the broker ?

2013-07-25 Thread Oleg Dulin
Can I have a single connection for the entire application ? Is there an argument for multiple ? What's the right approach ? -- Regards, Oleg Dulin http://www.olegdulin.com

Re: Odd network of broker behavior with 5.8

2013-07-25 Thread Oleg Dulin
Yes, I am reconfiguring my environment and going to set up a test situation again. I'll keep you posted, thanks! On 2013-07-22 23:08:40 +, Christian Posta said: --089e0160c406d911ae04e221c15a Content-Type: text/plain; charset=ISO-8859-1 can you take a stack trace of the broker when it

Ativemq instance will not shutdown gracefully.

2013-07-25 Thread Chirag Pujara
Hello, when I try to shutdown activemq instance it throws exception that it cannot connect to jmxUrl for process. and then kills the process after 30 secs. Here is stack strace: 14:34:39 # */opt/gwx/apache-activemq-5.8.0/activemq_8300/bin/activemq_8300 stop "-Dactivemq.jmx.url=service:jmx:rmi://

Re: activemq-5.8.0 error executing examples

2013-07-25 Thread jaguado5
Thank you for your respose :) I think my distro is OK, as you say the error points to a conflict in the classpath. I installed activemq downloading the binary and uncompressing it. I set the ACTIVEMQ_HOME environment variable pointing to the activemq installation directory. In the ./lib folder

Re: Active MQ - Message Groups

2013-07-25 Thread Christian Posta
strict message ordering is always going to be at odds with performance. what you're trying to do might be better accomplished with: http://activemq.apache.org/exclusive-consumer.html On Wed, Jul 24, 2013 at 4:05 PM, MB wrote: > After reading ActiveMQ Message Groups feature > (http://activemq.

Re: cursor memory usage/limit vs memory usage/limit

2013-07-25 Thread Christian Posta
I have written a little about this.. maybe check out: http://www.christianposta.com/blog/?p=273 On Wed, Jul 24, 2013 at 11:34 AM, Jake Choi wrote: > Hi, > > Using activemq-core-5.7.0 (embedded broker), I noticed that there is the > separate memory usage/limit called "cursor memory usage/limit"

Re: Some of active consumers have pending messages in prefetch buffers but consume none of them

2013-07-25 Thread Christian Posta
You'll have to take stack traces/thread dumps of the consumers to see what they're doing, and why they aren't consuming. On Thu, Jul 25, 2013 at 12:21 AM, minglin wrote: > No one has some advice? > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/Some-of-active-c

Re: activemq-5.8.0 error executing examples

2013-07-25 Thread Christian Posta
I responded to this a couple days ago when you asked: "I just tried, and it works for me. Make sure the distro isn't corrupted? Or the classpath is not being overridden somehow. What version of slf4j-api is in your ./lib folder?" The error you're getting points to a conflict on the classpath. ho

activemq-5.8.0 error executing examples

2013-07-25 Thread jaguado5
Hi all, I've just download activemq-5.8.0 and I'm trying to execute the example: ./bin/activemq console xbean:conf/activemq-demo.xml and I get the following error: Failed to execute main task. Reason: java.lang.NoSuchMethodError: org.slf4j.spi.LocationAwareLogger.log(Lorg/slf4j/Marker;Ljav

Re: ActiveMQ in OSGI Equinox

2013-07-25 Thread Christian Schneider
The easiest way is to use the activemq feature for Apache Karaf. http://activemq.apache.org/osgi-integration.html Christian 2013/7/25 Leonardo Torres > Good morning, > > how can I use activemq as a bundle ? > > Thank´s > > -- > Obrigado > Leonardo Torres. > -- -- Christian Schneider http:

ActiveMQ in OSGI Equinox

2013-07-25 Thread Leonardo Torres
Good morning, how can I use activemq as a bundle ? Thank´s -- Obrigado Leonardo Torres.

Re: HTTP transport

2013-07-25 Thread moodboom
dejanb wrote > Hi, > > there's a difference between Camel http component and ActiveMQ http > transport. Both are solid for what they've been designed to do. Thanks dejanb, and a huge thanks for all the mailing list answers over the years, they've helped me get started. Can I ask for a quick nudg

Re: controling CompositeTaskRunner and DedicatedTaskRunner threads

2013-07-25 Thread Timothy Bish
On 07/24/2013 12:43 PM, nnr_2k wrote: Hi, Could you please tell me is there a way to control the number of threads spawned by activemq? Basically, we are using IOtransport Configuration. By going through the pstack, we have many threads for the process. Like: IOtransport::run(), TimerImpl::run(

Re: Average ActiveMQ Enqueue Time is displayed as negative value in the jconsole

2013-07-25 Thread cghersi
Hi, I'm having the same problem with a network of broker. All the servers are synchronized via NTP using time.nist.gov The same applies laso if a query this time programmatically using this code: String jmxUrl = "service:jmx:rmi:///jndi/rmi://" + myBrokerUri + ":1098/jmxrmi"; JMXServiceURL url =

Re: Is there any method to get the list of active connections and sessions using broker service.

2013-07-25 Thread Gary Tully
there is no session view mbean but you can extrapolate sessions from consumer/producers because they are all composed from the connection id. The transportConnector view gives a list of connections on a given transport and there is an MBean per connection. use broker.getManagementContext().queryN

Re: ActiveMQ CPP Issue with createCMSConnectionFactory

2013-07-25 Thread spam trap
On Tue, 23 Jul 2013 08:42:34 -0700 (PDT), dpatel wrote: >I just upgraded from activemqcpp version 3.6 to 3.7.0. After the upgrade when >I try to execute the following line in release config the dll crashes. > >cms::ConnectionFactory *conn_factory = >cms::ConnectionFactory::createCMSConnectionFact

Re: Some of active consumers have pending messages in prefetch buffers but consume none of them

2013-07-25 Thread minglin
No one has some advice? -- View this message in context: http://activemq.2283324.n4.nabble.com/Some-of-active-consumers-have-pending-messages-in-prefetch-buffers-but-consume-none-of-them-tp4669669p4669694.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Is there any method to get the list of active connections and sessions using broker service.

2013-07-25 Thread karraj84
Hi, I am trying to get the list of available connections and sessions from a activemq server using broker service. I am seeing method for getting list of subscribers, producers/consumers using QueueViewMBean object but not for connections or sessions. Any suggestions will be truly appreciated.

Some of active consumers have pending messages in prefetch buffers but consume none of them

2013-07-25 Thread minglin
I have a activemq consumer client written using spring JMS. It uses a PooledConnectionFactory and DefaultMessageListenerContainer to pool consumers as follows:

controling CompositeTaskRunner and DedicatedTaskRunner threads

2013-07-25 Thread nnr_2k
Hi, Could you please tell me is there a way to control the number of threads spawned by activemq? Basically, we are using IOtransport Configuration. By going through the pstack, we have many threads for the process. Like: IOtransport::run(), TimerImpl::run(), DedicatedTaskRunner::run(), Composite