How to disable advisory for --> topic://ActiveMQ.Advisory.TempQueue ?

Hi, In jconsole, I see that we have advisory topics for TempQueue created for subscription (topic://ActiveMQ.Advisory.TempQueue) even if we have added the option advisorySupport="false" in the broker definition. Is it possible to disable them ? Regards, Charles M. - Charles Moulliard SOA A

Re: create queue using command line

Queues and topics are > automatically created when first producer or consumer connects to the > destination. So, strictly speaking, all you need to create a queue is to > connect consumer or producer to that queue. > > -- > Denis Bazhenov > FarPost. > > > > >

Re: create queue using command line

httale.net > > > > On Tue, Aug 10, 2010 at 9:30 AM, cmoulliard wrote: >> >> Hi, >> >> Is there a way to create/delete/purge a queue using command line tool ? >> >> >> >> - >> Charles Moulliard >> SOA Architect >&

create queue using command line

Hi, Is there a way to create/delete/purge a queue using command line tool ? - Charles Moulliard SOA Architect My Blog : http://cmoulliard.blogspot.com/ http://cmoulliard.blogspot.com/ -- View this message in context: http://old.nabble.com/create-queue-using-command-line-tp29394994p29

Re: Confusion about How KahaDB works !!!

No. rajdavies wrote: > > Hi charles - are you using transactions? > On 1 Jul 2010, at 15:12, cmoulliard wrote: > >> >> Hi, >> >> I'm confused and try to understand How ActiveMq works with KahaDB. My >> activemq broker 5.3.0 is configured to

Confusion about How KahaDB works !!!

Hi, I'm confused and try to understand How ActiveMq works with KahaDB. My activemq broker 5.3.0 is configured to be non persistent and messages send are also delivered as NON persistent but KhaDB files growths !! This is strange as normally, only files should be created under tmp_storage Ther

KahaDB storage - corruption risk

What are the risks that a client could be faced regarding to the kahadb storage (synchronisation of index, lost of index or data, ...) ? Is there a way to restore the storage in case of such a problem or do we have to consider that all the persistent messages and/or index files are lost and we mu

activemq.conf - import xml tags using XInclude

Hi, Is it possible to import activemq xml tags from other xml files ? I try to use XI:include but activemq generates the following error ERROR: java.lang.Exception: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'org.apache.activemq.xbean.XBeanBrokerServ

Pure Master Slave scenario - questions

Hi, In a pure master slave running on the same machine / server, are we oblige to activate persistence like that ? Master http://activemq.apache.org/schema/core"; brokerName="master" waitForSlave="true" shutdownOnSlaveFailure="true" persistent="true" dataDirectory="${activemq.base}/datamaster"

JMSXGroupID and customer client dies !!

Hi, In a topology using JMSXGroupID with two client customers, messages generated and associated to a group will be send to one of the two customers. If during the consumption of the messages from one of my customer AND before the end of the group messages processing, this customer client dies, t

Re: Does amq:connectionFactory use PooledConnectionFactory?

You can use also the PooledConnectionFactory like that if you use ActiveMq with Camel jms component : KR, Charles acec acec wrote: > > Hi, all > According to the following articles, I should use P

Re: Does amq:connectionFactory use PooledConnectionFactory?

No, Check Bruce Snyder blog for more info about to setup this : http://bsnyderblog.blogspot.com/2010/02/using-spring-jmstemplate-to-send-jms.html KR, Charles acec acec wrote: > > Hi, all > According to the following articles, I should use PooledConnectionFactory > to avoid the performance i

Strange behavior with VirtualTopic and loadbalancing

Hi, I have configured an ActiveMq server 5.3.2 to use VirtualTopic : I have two consumers connected to the following queues : Consumer.A.VirtualTopic.Orders Consumer.B.VirtualTopic.Order

Re: Working C example?

> either platform... I think you're right that OpenWire is the most recent > and (possibly?) the most stable. > > Bryan > > > > cmoulliard wrote: >> >> Hi, >> >> Have you checked this web page of ActiveMq wiki site >> >> http://a

Re: Working C example?

Hi, Have you checked this web page of ActiveMq wiki site http://activemq.apache.org/c-integration.html http://activemq.apache.org/openwire-c-client.html KR, Charles bcmoney wrote: > > Hi, looking in the http://activemq.apache.org/c-integration.html C > cross-client implementations > ht

Re: Transport protocol "jms-tcp" - how to use?

Hi Matthes, There is no jms protocol. JMS is a specification allowing to produce/consume messages from a broker. ActiveMQ provides different protocol to communicate to the broker. If your application runs inside the same virtual machine that ActiveMq, you can use vm:// protocol otherwise tcp://.

Re: KahaDB failure with Active MQ 5.4 snapshot

Hi Christian, I'm not quite sure that this is an excellent idea to switch from 5.3 to 5.4-SNAPSHOT on a "production" environment. It should be a better idea to have a network of brokers with br1 = activeMq 5.3 and br2 = activemq 5.4. Using a network of broker between br1 to br2, you will recreate

Re: How can avoid that the broker master loadbalance messages equitably between two brokers ?

on as it addresses its prefetch limit issue. > > Joe > ActiveMQ Ref Guide - http://bit.ly/AMQRefGuide > > > cmoulliard wrote: >> >> Hi, >> >> I would like to know if it is possible when we have created a bridge >> between two brokers (br1 and

Re: KahaDBPersistenceAdapter (Master) - memoryPersistenceAdapter (Slave)

Forget my question, there was an error in my config. cmoulliard wrote: > > Hi, > > I have created a bridge between two brokers (called master and slave) > where persistence is disabled but I see that : > > KahaDBPersistenceAdapter is created by defa

Re: How can avoid that the broker master loadbalance messages equitably between two brokers ?

. > With the default prefetch of 1000, and 500 messages, there will be > equitable delivery of messages as the slowness is only visible when the > prefetch is reached (and there have been no acks). > > On 27 May 2010 12:10, cmoulliard wrote: > >> >> Hi, >> &

How can avoid that the broker master loadbalance messages equitably between two brokers ?

Hi, I would like to know if it is possible when we have created a bridge between two brokers (br1 and br2) and where we have a fast consumer connected on br2 and a slow on br1 that the broker br1 send more messages to the br2 instead to balance them equitably ? For the moment, If I produce 500 m

KahaDBPersistenceAdapter (Master) - memoryPersistenceAdapter (Slave)

Hi, I have created a bridge between two brokers (called master and slave) where persistence is disabled but I see that : KahaDBPersistenceAdapter is created by default on the master and memoryPersistenceAdapter on the slave Is it a normal behavior ? http://activemq.apache.org/schema/core"

Re: Dispatch queue - Consumer(s) (question)

ses a shared pool depends on the dedicatedTaskRunner broker > property. > > With consumers, with the default asyncDispatch, the dispatch is handled by > the shared connection dispatcher task, with asyncDispatch=false, the > destination dispatcher does the work. > > On 27

How the messages are ACKnowledged by broker when using ProducerFlowControl + asyncSend ?

Hi, I would like to know how the messages are ACKnowledged by broker when using ProducerFlowControl + asyncSend ? AsyncSend is now the default mode when a producer send messages to a broker. In the case that ProducerFlowControl is enable, messages are send to the broker (and of course to a desti

Dispatch queue - Consumer(s) (question)

Hi, I would like to know : 1) if we have one dispatch queue by queue/topic created or a dispatch queue is assigned to a group of queues ? 2) In the case we have several consumers connected to a queue, do they use the same the dispatch queue or do we have a dispatch queue created by consumer ? K

ActiveMQ - JMX - Queue with "READ" access define

Hi, I have been able to stop the vm:// connector created by ActiveMq 5.x and used by JMX/Jconsole to communicate with the broker simply by posting a message from JConsole on a queue defined with "READ" access Here is a part of the config :

No data/files created in folder data-master ??

Hi, I have configured my Fuse 5.3.0 broker like this : http://www.springframework.org/schema/beans"; xmlns:amq="http://activemq.apache.org/schema/core"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springf

Question about replication with master/slave

Hi, In a pure master / slave configuration (without SAN, RDBMS), the information about the journal is synchronized between the master and the slave. But are the messages created in the queues of the master also replicated to the slave (if persistence is defined as false) ? If the messages are rep

What is put in data directory when persistence is off

Hi, I would like to know which kind of info is put in data directory by ActiveMq when persistence is defined as off. I see what is placed in the journal files (session info, ACK, ...) but for the data directory, I'm not quite sure ? Are the journal files stored in data directory or in a seperate

org.apache.activemq.pool.PooledConnectionFactoryBean is not assignable to interface javax.jms.ConnectionFactory

I have discovered a problem with activemq and pooling engine when using activemq 5.3.1 on karaf 1.4 Error Exception in thread "SpringOsgiExtenderThread-12" org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'org.springframework.os gi.service.exporter.support.O

Unable to enlist XA resource manager !!

Hi, I have configured ActiveMq on SMX4 to use Geronimo Transaction Manager and ActiveMq Pooling but get this error when connection occurs on topics of activemq advisory messages 09:46:47,125 | WARN | tenerContainer-8 | Transaction | nsaction.manager.TransactionImpl 213 | U

Re: Advisory Messages & Camel Route & BodyNull

d regards, Charles tjsnell wrote: > > > On Mar 10, 2010, at 2:19 PM, cmoulliard wrote: > >> I have defined a camel route to read messages published in the topics for >> advisory >> >> ex : >> >>

Re: WARN : AMQPersistenceAdapter - The ReferenceStore is not valid - recovering

rajdavies wrote: > > this happens when AMQ Store is not shutdown cleanly - the references have > to be rebuilt from the transaction logs. Nothing to worry about - but > would recommend KahadB is 5.3/5.3.1 > > On 11 Mar 2010, at 12:14, cmoulliard wrote: > >> >> Hi,

WARN : AMQPersistenceAdapter - The ReferenceStore is not valid - recovering

Hi, How can we interpret this WARN message : 2010-03-04 11:16:34,652 WARN AMQPersistenceAdapter - Waiting to Lock the Store /mnt/export/activemq/data 2010-03-04 11:18:36,960 WARN AMQPersistenceAdapter - The ReferenceStore is not valid - recovering Is there any issue beh

Advisory Messages & Camel Route & BodyNull

Hi, I have defined a camel route to read messages published in the topics for advisory ex : Surprisingly, the body receive is null 18:43:17,937 | INFO | tenerContainer-1 | elca | rg.apache.camel.processor.Logger

AverageEnqueueTime (milliSeconds) ?

Hi, Is this value expressed in milliseconds (AverageEnqueueTime) ? Kind regards, Charles - Charles Moulliard SOA Architect My Blog : http://cmoulliard.blogspot.com/ http://cmoulliard.blogspot.com/ -- View this message in context: http://old.nabble.com/AverageEnqueueTime-%28milliSecon

Message production / consumption process explained

Hi, I try to figure out How ActiveMQ works since the creation of a message till its consumption by a client. Is there a sequence diagram or something similar showing what ActiveMq do to store the message in the queue, update or create index, keep cursor information, keep info in storage for persi

Re: activemq-broker.xml file and plugins !!!!

://www.manning.com/snyder/ > Blog - http://www.nighttale.net > > > On Tue, Mar 9, 2010 at 9:43 AM, cmoulliard wrote: > >> >> Hi Dejan, >> >> I use Spring 2.5.6 and activemq-broker.xml is deployed in Fuse SMX 4.2. >> >> I have placed plugins afte

Re: activemq-broker.xml file and plugins !!!!

//www.manning.com/snyder/ > Blog - http://www.nighttale.net > > > On Tue, Mar 9, 2010 at 9:26 AM, cmoulliard wrote: > >> >> Hi, >> >> I try to configure the plugins in the activemq-broker.xml file but I get >> an >> error. >> >

activemq-broker.xml file and plugins !!!!

Hi, I try to configure the plugins in the activemq-broker.xml file but I get an error. dleXmlApplicationContext(bundle=activemq-broker.xml, config=osgibundle:/META-INF/spring/*.xml)) org.springframework.beans.factory.xml.XmlBeanDefinitionStoreException: Line 113 in XML document from URL [bundle

Clarification requested for slow - consumers - matched messages

Hi, Im' sorry but I don't understand what is the purpose of the matched (???) and discarded messages and How we can avoid slow customers by using such a strategy (http://activemq.apache.org/slow-consumer-handling.html) ? "Currently we have a strategy that lets you configure the maximum number o

Re: Protocol to be used in a broker topolgy (same JVM)

You are right. My question concerns an hypothetical network of broker and it makes no sense to use it in such. Charles bsnyder wrote: > > On Mon, Mar 8, 2010 at 1:55 AM, cmoulliard wrote: >> >> Hi, >> >> I presume that when we create a network of 2 brokers

Protocol to be used in a broker topolgy (same JVM)

Hi, I presume that when we create a network of 2 brokers running in the same jvm, it makes more sense to use the vm:// as the protocol to interconnect the master broker with the slave ? So, we can boost performance for transferring messages from one broker to anot

Re: AMQ (5.3.0) with CMS-3.01 -> consumes all memory and stops clients and producers

consumers = several clients or same client using several threads for consuming messages from broker Charles lucious wrote: > > Ohh I got it ;) thanks a lot!!! BTW. What is competitors consumers? > > M. > > > > cmoulliard wrote: >> >> Hi Marcin, >> >

Re: Move from ActiveMq Message Store to KahaDB

) > On 6 Mar 2010, at 10:08, cmoulliard wrote: > >> >> Hi Dejan, >> >> Thanks for the tip. In fact I will create a network of brokers with by >> example two static url. The old one pointing to the old. As messages need >> to >> be consumed on the

Re: Move from ActiveMq Message Store to KahaDB

le.net > > > On Fri, Mar 5, 2010 at 4:06 PM, cmoulliard wrote: > >> >> Hi, >> >> Can we migrate the content of an ActiveMQ Message Store to a KahaDB store >> if >> we decide to go from Apache ActiveMQ 5.1 to 5.3 ? It this is not possible >> what

Re: AMQ (5.3.0) with CMS-3.01 -> consumes all memory and stops clients and producers

competitor consumers = several clients or same client using several threads for consuming messages from broker Charles Ohh I got it ;) thanks a lot!!! BTW. What is competitors consumers? M. cmoulliard wrote: > > Hi Marcin, > > I think that too much messages are produced and co

Message not forwared in a network broker - ActiveMQ 5.3 & SMX4

Hi, I run ActiveMq 5.3 in embedded mode in two SMX4 instances. I have defined a forward network topology to formard messages from master to slave when a client is connected to the slave. No messages are forwarded ? Where is the issue ? Config of Master http://activemq.apache.org/schema/core

Re: AMQ (5.3.0) with CMS-3.01 -> consumes all memory and stops clients and producers

Hi Marcin, I think that too much messages are produced and consumers does not have enough time/memory to consume them. So the memory consumption continue to growth till to reach a limit. As you have configured the vm for the MessageCursor (http://activemq.apache.org/message-cursors.html), this be

Move from ActiveMq Message Store to KahaDB

Hi, Can we migrate the content of an ActiveMQ Message Store to a KahaDB store if we decide to go from Apache ActiveMQ 5.1 to 5.3 ? It this is not possible what is the migration path proposed ? Kind regards, Charles - Charles Moulliard SOA Architect My Blog : http://cmoulliard.blogspot.co

Identify root cause of out of memory issue, slow consumer

Hi, Does the use of ActiveMq advisory messages (http://activemq.apache.org/advisory-message.html) can help to identify in production environment which client consume slowly messages, what is the root cause of out of memory issues, ... ? Kind regards, Charles - Charles Moulliard SOA Archite

Re: ActiveMq Master/Slave & ServiceMix 4

ot see the queue 'IN' + messages. I can see the following components : - broker - connector - openwire - MasterConnector IT SEEMS THAT THE JCONSOLE DOES NOT DISPLAY THE CORRECT INFO. If I use a JMS client, it works fine as I'm able to get the messages from the queue IN. Kind regards,

Re: ActiveMq Master/Slave & ServiceMix 4

like u have > persistence turned off! > Or is the message non persistent? > > On 4 March 2010 16:35, cmoulliard wrote: > >> >> Hi, >> >> I have created a Master/Slave configuration of ActiveMq through 2 >> instances of ServiceMix 4 (so ActiveMq is in em

ActiveMq Master/Slave & ServiceMix 4

Committer * blog : http://cmoulliard.blogspot.com twitter : http://twitter.com/cmoulliard Linkedlin : http://www.linkedin.com/in/charlesmoulliard Apache Camel Group : http://www.linkedin.com/groups?home=&gid=2447439&trk=anet_ug_hm - Charles Moulliard SOA Architec

Network of Broker - Can a client consume a message ?

Hi, I try to understand how the topology of brokers works with ActiveMq and I have the following question When a JMS producer creates a message which is placed in a queue (of a broker making part of a network of broker), can this message be immediately consumed by the JMS consumer client or does

JDBC Master/Slave question

Hi, I have a question concerning the HA approach of the JDBC Master/Slave or the Shared Filesystem Master-Slave. When the master is not longer available and that the client switches to one of the slave, are the messages created by the master in the queues lost for the slave or available ? Rega

Can 2 different machines running each one 2 SMX instances share the same queueing engine ?

Hi, Can 2 different machines running each one 2 ServiceMix 4.x instances share the same queueing engine ? ex : - Machine 1 : SMX A & SMX B - Machine 2 : SMX C & SMX D My idea is that the instances SMX A, B and SMX C, D contain Camel routes running in parrallel and reading or placing messages i

Re: java.io.IOException: Transport Connector could not be registered in JMX: Failed to bind to server socket: tcp://0.0.0.0:61616 due to: java.ne t.BindException: Address already in use: JVM_Bind

t; double-check the JMX uri > > Cheers > -- > Dejan Bosanac - http://twitter.com/dejanb > > Open Source Integration - http://fusesource.com/ > ActiveMQ in Action - http://www.manning.com/snyder/ > Blog - http://www.nighttale.net > > > On Fri, Jan 8, 2010 at 3

Re: java.io.IOException: Transport Connector could not be registered in JMX: Failed to bind to server socket: tcp://0.0.0.0:61616 due to: java.ne t.BindException: Address already in use: JVM_Bind

o your ActiveMQ instance? > > Cheers > -- > Dejan Bosanac - http://twitter.com/dejanb > > Open Source Integration - http://fusesource.com/ > ActiveMQ in Action - http://www.manning.com/snyder/ > Blog - http://www.nighttale.net > > > On Fri, Jan 8, 2010 at 2:12 PM, cm

Re: java.io.IOException: Transport Connector could not be registered in JMX: Failed to bind to server socket: tcp://0.0.0.0:61616 due to: java.ne t.BindException: Address already in use: JVM_Bind

more details > > Cheers > -- > Dejan Bosanac - http://twitter.com/dejanb > > Open Source Integration - http://fusesource.com/ > ActiveMQ in Action - http://www.manning.com/snyder/ > Blog - http://www.nighttale.net > > > On Fri, Jan 8, 2010 at 12:08 PM, cmoulliard

java.io.IOException: Transport Connector could not be registered in JMX: Failed to bind to server socket: tcp://0.0.0.0:61616 due to: java.ne t.BindException: Address already in use: JVM_Bind

mq-broker.xml files and responsible of this error ? If I remove this file from the WAR, can the activemq web console work ? Regards, Charles Moulliard Senior Enterprise Architect Apache Camel Committer * blog : http://cmoulliard.blogspot.com twitter : http://twitter.com/cmou

Re: ActiveMQ - HTTP - Remoting

, Charles Moulliard Senior Enterprise Architect Apache Camel Committer * blog : http://cmoulliard.blogspot.com twitter : http://twitter.com/cmoulliard Dejan Bosanac wrote: > > Hi Charles, > > http transport should work just like a regular tcp transport. The

ActiveMQ - HTTP - Remoting

Does it make sense to design a topology like this between different osgi servers to propose remote services though an ActiveMq queue playing the role of osgi server integrator ? 1) Bundle A This bundle contains a spring DSL xml file with routes defined like this : from(). .to() .to() .to(Active

Is it possible to select messages from a queue ?

Hi, I would like to know if it is possible to select messages from a queue ? I don't want to remove the messages from a queue but like a select performed on a DB table, I would like at a certain moment to perform a query to a queue in order to detect by example "How many messages are processed ?"

Difference between MessageServlet & MessageListenerServlet (AJAX)

Hi, What is the difference between the MessageServlet & MessageListenerServlet and which one must be used for a AJAX project ? I'm confused because the documentation mentions that we must use the MessageListenerServlet for a Ajax project BUT the web.xml config file of the demo project use the ot

Ajax - MessageListener Servlet : help requested !!!

Hi, I try to implement the portfolio example provided under the sub-project activemq-web et demo but unfortunately, I cannot receive any result from the MessageListener Servlet working with my Ajax web client browser ? Remark : - The only modification that I made to the code is to by pass the Po

How to trace communication between AJAX web browser and jetty/ActiveMq ?

Hi, I have adapted the existing code of the example Portfolio but unfortunately when my browser send HTTP requests to the servlet through AJAX javascript api it do not receive any response ? So my question are : - How can I trace the traffice between the browser and jetty web application server

Re: Where the Message object (javascript) of amq.js is defined ?

whole Ajax JavaScript logic > here > > http://svn.apache.org/viewvc/activemq/trunk/activemq-web/src/main/resources/org/apache/activemq/web/_amq.js?view=markup > > Cheers > > -- > Dejan Bosanac > > > http://www.ttmsolutions.com - get a free ActiveM

Re: Where the Message object (javascript) of amq.js is defined ?

Hi, Additional question : What is the javascript class of the message returned (DOM, XMLHTTPResuest, ) ? The existing doc does not help us because in the two example, we saw that we can use message.getAttribute or message.getChildNodes[0], ... ? KR, Charles Moulliard cmoulliard wrote

Where the Message object (javascript) of amq.js is defined ?

Hi, I would like to know where the javascript object Message used by AJAX/ActiveMq in a HTML page is defined ? I see in the portfolio example that we can use the following method "message.getAttribute('stock')" to access part of the xml message returned by the queue engine through the MessageList

ActiveMq - AJAX - JMX & Camel

Hi, 1) I would like to know if it is possible to activate JMX with the MessageListenerServlet used by AJAX ? In the web.xml configuration file, the only two parameters that we can configurate are the following : org.apache.activemq.brokerURL tcp

Some links of the page (http://activemq.apache.org/ajax.html) are not correct. Can someone update them please ?

Hi, I have discovered that some links in the page http://activemq.apache.org/ajax.html does not work. "The ajax featues of amq are provided on the client side by the _amq.js script. This script depends on behaviour and prototype. All of these scripts can be loaded with the single script amq.js a

NotSerializableException with ActiveMQObjectMessage.storeContent !!!!!

Hi, When I unmarshall a xml file using Camel/Jaxb and that I send the result to an ActiveMq queue, I receive the following error : 1) Error GRAVE: Failed delivery for exchangeId: ID-dell-charles/1108-1214228785562/0-2. On delivery attempt: 0 caught: java.lang.RuntimeException: com.company.soft.