Re: ActiveMQ admin command

Hi, According to my understanding: When I run " *activemq-admin query --view InactiveDurableTopicSubscribers --jmxurl service:jmx:rmi:///jndi/rmi://amqbroker:8887/jmxrmi --jmxuser guest --jmxpassword activemq * where queryAddObjects will be null but queryViews will not be null. So *List addMBea

Re: Current Connection Count for ActiveMQ broker

Hi, I think here you mean embedded broker by "broker in the same java process as clients" ? I have access to the broker's API. But I am *not using *embedded broker. I am using broker in a different java process and clients are connecting from other places. But still this API is showing the corr

Re: I want a queue allows only one consumer , can I do that ?

There is an option with ActiveMQ for exclusive consumption like this: queue = new ActiveMQQueue("TEST.QUEUE?consumer.exclusive=true"); For more details, see here: http://activemq.apache.org/exclusive-consumer.html This does not force close an existing consumer on connecting a new one though.

Re: why only one thread working?

I found the problem. I have only 160 messages and all are dispatched to a single worker. how to avoid this? On Thu, Jan 23, 2014 at 11:27 AM, Li Li wrote: > I modified it to use multithreads, but still only one work. > I use jstack and find other threads are blocked by Message msg = > receiver.re

Can I delete a message from a queue in c# code ?

I want to set a unique guid for each message in message head , then if I want , I could delete a specific message if I want to. Is there any api in NMS could help me deleting the message ? I am using ActiveMQ 5.9.0 and NMS 1.6.1 Thanks in advance. -- View this message in context: http://acti

Re: why only one thread working?

I modified it to use multithreads, but still only one work. I use jstack and find other threads are blocked by Message msg = receiver.receive(); public class Worker extends Thread{ public Worker() throws Exception{ recvConnFactory = new ActiveMQConnectionFactory( queueC

Re: why only one thread working?

Because you have only one thread -- main thread, no more threads created. Beijing,China Kimm King skype: kimmking github.com/kimmking -- View this message in context: http://activemq.2283324.n4.nabble.com/why-only-one-thread-working-tp4676688p4676689.html Sent from the ActiveMQ - User m

why only one thread working?

public class Worker implements MessageListener{ public Worker() throws Exception{ recvConnFactory = new ActiveMQConnectionFactory( queueConnString); recvQConn = recvConnFactory.createQueueConnection(); recvQConn.start(); recvSession = recvQConn.cr

I want a queue allows only one consumer , can I do that ?

I want there is only zero or one consumer connected to a queue , if a new consumer want to connect to this queue , the previous consumer's connection will be closed and the new consumer will connect to this queue. How can I do that ? Thanks for any help in advance. -- View this message in conte

Re: Java Options

Solution: export ACTIVEMQ_HOME=/opt/apache-activemq-5.8.0 export ACTIVEMQ_BASE=$ACTIVEMQ_BASE ACTIVEMQ_OPTS_MEMORY="-Xms1G -Xmx1G" export ACTIVEMQ_OPTS="$ACTIVEMQ_OPTS_MEMORY -XX:-UseParallelGC" ${ACTIVEMQ_HOME}/bin/activemq "$*" VM Flags: -Xms1G -Xmx1G -XX:-UseParallelGC -Dcom.sun.management.

Re: Java Options

I've tried and I got the same error: The command: ${ACTIVEMQ_HOME}/bin/activemq -XX:UseParallelGC "$*" The error: INFO: Unrecognized option: -XX:UseParallelGC Regards El ene 22, 2014 2:02 PM, "Jose María Zaragoza" escribió: > 2014/1/22 Rodrigo Ramos : > > 5.8.0 > > > > > > 2014/1/22 Claus

Timer already cancelled and KahaDB: Recovering checkpoint thread after death

I´m getting this error from my brokers: 10.142.176.106:40672@61617 2014-01-21 19:52:00,507 | WARN | Transport Connection to: tcp:// 10.142.176.106:40701 failed: java.io.IOException: Unexpected error occured: java.lang.IllegalStateException: Timer already cancelled. | org.apache.activemq.broker.T

Re: [Apollo 1.6] Websocket connection closed after 5 seconds

Please upload logs on Apollo side. I will look into it. -- View this message in context: http://activemq.2283324.n4.nabble.com/Apollo-1-6-Websocket-connection-closed-after-5-seconds-tp4676273p4676668.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Java Options

2014/1/22 Rodrigo Ramos : > 5.8.0 > > > 2014/1/22 Claus Ibsen > >> What version of ActiveMQ are you using? >> >> On Wed, Jan 22, 2014 at 7:37 PM, Rodrigo Ramos >> wrote: >> > Hello Everybody >> > >> > I want to change how to GC perform into in activemq. I have edited the >> > starting shell and I

Deploy issues in Karaf/Blueprint

I'm attempting to hot deploy a Camel route using the ActiveMQComponent into Karaf via the deploy folder using a blueprint xml file but I'm running into dependency issues. When Karaf attempts to start the created bundle I see this error: 2014-01-22 13:41:51,092 | ERROR | -SNAPSHOT/deploy | Blu

Re: Java Options

5.8.0 2014/1/22 Claus Ibsen > What version of ActiveMQ are you using? > > On Wed, Jan 22, 2014 at 7:37 PM, Rodrigo Ramos > wrote: > > Hello Everybody > > > > I want to change how to GC perform into in activemq. I have edited the > > starting shell and I have seen some memory variables. > > > >

Re: Java Options

What version of ActiveMQ are you using? On Wed, Jan 22, 2014 at 7:37 PM, Rodrigo Ramos wrote: > Hello Everybody > > I want to change how to GC perform into in activemq. I have edited the > starting shell and I have seen some memory variables. > > If I edit the starting shell with follow parameter

How to use master/slaver(HA) and load balance in the same time

hi all, so far as I know, when need to build HA message system, we can use master/slaver mechanism, when need to build load balance,we can use Networks of Brokers to build cluster, is there one way I can use HA and load balance in the same time? thanks, luoping -- View this message in conte

Java Options

Hello Everybody I want to change how to GC perform into in activemq. I have edited the starting shell and I have seen some memory variables. If I edit the starting shell with follow parameters: export ACTIVEMQ_HOME=/opt/apache-activemq-5.8.0 export ACTIVEMQ_BASE=$ACTIVEMQ_BASE export ACTIVEMQ_OP

Re: producer is getting stuck

Note that out-of-memory does not guarantee a JVM exit; in fact, it won't cause one itself, but the throwing of OutOfMemory exceptions oftens leads to applications forcing the JVM to terminate. JVM's will continue to try to operate indefinitely even with no heap or permgen space left. Also note th

Re: ActiveMQ 5.5.1 - Connections stuck in CLOSE_WAIT state, reaching file descriptor limit

For the broker memory - is that looking at the Heap Size and Permgen Size, checking for broker producer-flow-contorl-messages, or something else? Not being able to connect JMX is a typical symptom of a JVM that's out of Heap or Permgen space. If you connect jconsole, visualvm, or the like before

Persistent messages moving to DLQ when consumer not active

Hi, I have an issue where persistent messages on a queue are being moved to the DLQ when there is no active consumer on the queue. I am not sure if this is an issue with activeMQ or Camel. The set-up is as follows: messages or put onto a queue in an embedded broker which is bridged to a standalon

Re: Mqtt messages

Yes, it will use the same persistence store that activemq uses for persistent messages. Default is http://activemq.apache.org/kahadb.html On Wed, Jan 22, 2014 at 8:18 AM, Andrew Shobotenko wrote: > In what Persistence I can find MQTT messages? Does it write to any bases or > jornals? > > > > > --

Re: Create Activemq Instance

Makes sense. So follow what I said in my previous post if not using your installer, but ultimately what torsten said is what you're looking for... that is... you'll have to figure out what your installer is doing. On Wed, Jan 22, 2014 at 8:46 AM, Chirag Pujara wrote: > I am trying to setup active

Re: ActiveMQ admin command

According to this: http://activemq.apache.org/maven/5.9.0/apidocs/org/apache/activemq/console/filter/MBeansObjectNameQueryFilter.html#queryMBeans(javax.management.ObjectName,%20java.lang.String) the JMX querying (so broker side) is not supported. The filtering happens at this line when it tries

Re: Create Activemq Instance

I am trying to setup activemq with leveldb and thats what documentation is saying. Keep all broker name same in "Replicated LevelDB Store Properties" section in this link http://activemq.apache.org/replicated-leveldb-store.html Can I have diff. name for this type of setup.? thanks, chirag On We

Mqtt messages

In what Persistence I can find MQTT messages? Does it write to any bases or jornals? -- View this message in context: http://activemq.2283324.n4.nabble.com/Mqtt-messages-tp4676645.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Create Activemq Instance

ActiveMQ comes with scripts that allow you to "create" new brokers that all point to the same base installation. ./bin/activemq create if you keep the brokerName the same (and change the path) the brokers would end up with the same name. eg. ./bin/activemq create ./bin/activemq create ./bin/a

Re: Current Connection Count for ActiveMQ broker

Sure, that's one way if you're using an embedded broker and have direct access to the broker's API. You could also use JMX to query the stats. You could also subscribe to the connection advisory topic and count how many messages about started connections you get back. On Wed, Jan 22, 2014 at 7:4

Re: ActiveMQ 5.5.1 - Connections stuck in CLOSE_WAIT state, reaching file descriptor limit

The broker wasn't at its memory limit at the time when this had occurred, but it wouldn't allow for JMX connections. I'd assume I was able to collect a heapdump before ActiveMQ was restarted and it does mention the Server Transport thread mentioned earlier. I'm not able to identify the thread to

Current Connection Count for ActiveMQ broker

Hi, I want to know current connection count for ActiveMQ broker. I am using below APIs for this: --- BrokerService brokerService = getBrokerService(); connectors = brokerService.getTransportConnectors(); for (int i = 0 ; i < 3; i++) {

Re: multithreads share a session problem

JMS specifications JMS session objects are single threaded and can only be used by single thread that created them. An attempt to use them from another thread would result in an exception or some very strange errors. Beijing,China Kimm King skype: kimmking github.com/kimmking From: Li Li

multithreads share a session problem

hi all I want to share a session among many threads and after do real work the message is acknowledged: class Dispatcher implements MessageListener{ Thread[] workers; public void init(){ session = connection.createQueueSession(false, Session.CLIENT_ACKNOWLEDGE);

Re: Create Activemq Instance

By default the broker name is hardcoded in your conf/activemq.xml. http://activemq.apache.org/schema/core"; brokerName=“localhost” … > So the broker name should not change automatically when creating a new installation. Does perhaps your auto installer change this name? Regards, Torsten M