question about ActiveMQ, jdbcPersistenceAdapter and MasterSlave

We are using activemq in jdbc master slave configuration. extract pasted below - The messages are posted to queues and consumers are registered to these queues. MessageProducer producer = session.createProducer(destination); producer.setDeliveryMode(De

Remote Queue to Local Many quques or Local Topic

I have a remote queue behind firewall ( from active MQ broker ). I have no control of that broker and this remote queue is read only for me. I cannot get that remote queue converted to topic. Only a particular port is opened for firewall connections to this queue from my own network. In my networ

Re: ActiveMQ 5.6 stomp object transformation

Hello Dejan, I'm already using xstream to serialize the objects, however instead of annotations I'm using an XStream instance configured for each object (although the default serialization is just enough). This way I could avoid using a Xstream dependency on the POJO that could not be compatible w

Re: php/topic subscribe?

hip hip hurraaa... :) I took the 5.7 snapshot at that did it. It works - its a topic, I can see the subscribers as durable in the admin and so on and ofcause a mesg. send to the topic is getting to all clients I have running. Cool and thanks. Now we can start trying out our ideas. -- View this

Re: ActiveMQ 5.6 stomp object transformation

Hi Gabriel, take a look at http://xstream.codehaus.org/annotations-tutorial.html I'm not sure your code uses annotations to convert Java objects, so that might not be related. But without more info, I can't help you more. The best course of action is to try creating some kind of a test case that

Re: php/topic subscribe?

On Tue, 2012-06-26 at 08:29 -0700, jana wrote: > per my post we have: > > define('_MQ_TOPIC_SEARCH', '/topic/mytopicname'); > > so unless its not supposed to work with implicit created topic we do have > /topic/ in front. > > -- > View this message in context: > http://activemq.2283324.n

Re: ActiveMQ 5.6 stomp object transformation

Hello again, Maybe this is a very basic question but how can I do the class mapping set configuration in an embedded broker without using the xml file to set this: org.apache.activemq.transport. stomp.SamplePojo On the version 5.4 I was capable of configure the embedded broker without us

Re: php/topic subscribe?

per my post we have: define('_MQ_TOPIC_SEARCH', '/topic/mytopicname'); so unless its not supposed to work with implicit created topic we do have /topic/ in front. -- View this message in context: http://activemq.2283324.n4.nabble.com/php-topic-subscribe-tp4653564p4653585.html Sent from th

Re: php/topic subscribe?

Prefix the topic name with /topic/ Sent from my iPhone On Jun 26, 2012, at 5:45 AM, jana wrote: > I should add - thats the producer but this does not result in a topic on the > MQ but rather a queue. From java if I ask for the queue "mytopicname" I get > the msg. posted by the php code but if I

Exceptions: Cannot lookup a consumer from a connection that had not been registered / The subscription does not exist

Hi all, I run an ActiveMQ 5.5.1 broker with two queues. Clients produce messages (varying from many small to some of significant size) and put them into queue 1, from where consumers take the messages from the queue by pulling them at their speed (message prefetch = 0). Messages are sent in transa

Re: Problem with TransactDatabaseLocker's lock statement

The lock implementation is picked up from the driver name but there is currently no variant that does not use the "FOR UPDATE" If one particular statement is causing problems, you can override the default to drop the 'FOR UPDATE' using xml config:

Re: Adding nodes to Cluster without restarting

It is a junit test case. Have a look at the code to see how it sets up brokers and validates connection/reconnection and rebalance. if you download the activemq trunk source[1] you can modify it at will and run it with: mvn clean install -Dtest=FailoverComplexClusterTest [1] http://activemq.apac

Re: Adding nodes to Cluster without restarting

Hi, I am indeed using ActiveMQ 5.6 with randomize=true on my connection string. But not sure if it's the same issue. What exactly is that test case and how do I use it? Thanks. -- View this message in context: http://activemq.2283324.n4.nabble.com/Adding-nodes-to-Cluster-without-restarting-tp4

Re: php/topic subscribe?

I should add - thats the producer but this does not result in a topic on the MQ but rather a queue. From java if I ask for the queue "mytopicname" I get the msg. posted by the php code but if I ask for a topic with that name from java I dont get any msg. and again, two php consumers subscribing t

Re: php/topic subscribe?

connect(); $producer->send( _MQ_TOPIC_SEARCH, $message, array('persistent'=>'true') ); $producer->disconnect(); ?> -- View this message in context: http://activemq.2283324.n4.nabble.com/php-topic-subscribe-tp4653564p4653566.html Sent from the ActiveMQ - User mailing lis

Re: php/topic subscribe?

It'd be good if you can share your test code. Topics should be working fine with PHP Stomp impl. Regards -- Dejan Bosanac Senior Software Engineer | FuseSource Corp. dej...@fusesource.com | fusesource.com skype: dejan.bosanac | twitter: @dejanb blog: http://www.nighttale.net ActiveMQ in Action: ht

php/topic subscribe?

Hi Im trying to get a small testsetup running where I need to post msg. to a TOPIC from PHP and read them from java later. For now, to test, I simply use php both on the producer and consumer side. Its based on http://stomp.fusesource.org/documentation/php/book.html but its not really working. Its