I have a problem with a durable client on ActiveMQ. I am using stomp.py in Python. conn.start() conn.connect(wait=True, header = {'client-id': 'myhostname' }) conn.subscribe( '/topic/testTopic', ack='auto', headers = { 'activemq.subscriptionName': 'myhostname', 'selector': "cli...
I am already using ActiveMQ in my project. Now I need delay message delivering. AcitveMQ supports this feature (http://activemq.apache.org/delay-and-schedule-message-delivery.html), but as far as I understand this feature supported by JMS clients only. How could I use this feature with ruby? ...
I have the following problem: I have several sites with a local ActiveMQ broker that forwards to a remote broker (in a datacenter). This connection is often unstable, and goes down several times a month for a few minutes or hours at a time. Messages therefore need to wait on the local broker if the remote broker is not accessible at th...
My application does batch processing by reading messages from ActiveMQ. I read using the async JMS API by implementing MessageListener. But I ACK the messages only when the batch processing succeeds by calling message.acknowldge() [1]. What I ideally want is that till the batch processing is going on I do not receive any messages from t...
Has anyone found a work around or seen the issue of admin console not working in ActiveMQ 5.4.1 & 5.4.0? I'm using the out of the box config. I turned on logging at the DEBUG level and I don't see any jetty startup errors, when I go to http://[myIp]:8161/admin I get this HTTP ERROR: 503 Problem accessing /. Reason: Service Una...
I'm working on a solution to make certain data from a large database available to a remote website. My first thought was to simply cook up some soap web services to fetch certain data from the database. This could be done in just a few line, for instance like this, with the user of Zend_Soap_Server: class MyClass { public function ...
Hi, how can I configure OpenEJB to work with an external instance of ActiveMQ? We already tried the configuration on this link http://openejb.apache.org/3.0/jms-resources-and-mdb-container.html but it did'nt work at all. What should we do? ...
Hi all, I need an example on how to read/write to an ActiveMQ queue over HTTP in C or C++ using cURL (or something else, I'm open to anything at this point). I have working code in C#, but it doesn't help. Any help is appreciated, Thank you. ...
Hi All, I'm trying to send a message using JMS from a servlet (running on Apache Tomcat) to ActiveMQ running in a different VM on the same system. Things i have tried: Running ActiveMQ on my system. Wrote a client (Java app) (Producer) to create messages. Wrote a client (Java app) (Consumer) to receive those messages. The above s...
hi, in my web app the database has a blob(an xml file). The user is allowed to change the blob through a web interface. I take the blob show it in a html form, then the user can change some values and save it back. So the user submit request has a db save. For some tracking purpose I want to store the previous and current state of the ...
In the ActiveMQ KahaDB documentation, it mentions that you can archive KahaDB data files so they can be replayed if needed later. Yet, through some searching and looking through their documentation and the draft copy of ActiveMQ in Action, I can't find any example or clues how to actually do the replay of those files. I'm hoping someone...
I have a queue with several consumers and I'd like to disable one from ActiveMQ. I've looked into using JMX but haven't been able to see anything that would allow me to do this. Ideally this would be without changing any of the code at the consumer. ...
I am trying to run a class I made however I get this error: Exception in thread "main" java.lang.NoClassDefFoundError: javax/jms/Destination I don't understand why it's not working even when I include the necessary jars in the classpath: java consumer1 -cp activemq-all-5.3.2.jar ...
Hi, I'd like to set up a publisher-subscriber based communication protocol between a server producing messages and many clients receiving them. After a bit of research, I decided to go with ActiveMQ. I looked at a few tutorials and the ActiveMQ site and set up the broker as follows: BrokerService broker = new BrokerService(); broker.se...
I am using SQL Server 2005... I want to monitor table1 with a trigger for an update. On the occurrence of this update, I will check another table (table2), using the data from table2 I place an item in the queue to execute at a variable date in the future. Could be 10 seconds from now, or 2 hours, this date is determined from checking...
We are in the process of testing OpenEJB solution that embeds ActiveMQ 4.1.1. We observe various problems with messaging (bugs, performance, stability). One option is to upgrade to just released OpenEJB 3.1.3 that comes with later ActiveMQ 5.1.3. But I am trying to evaluate other options in case these problems won't go away. Is it poss...
I'm using Apache.NMS 1.4. I need to be able to programmatically set the maximum number of times a message can be delivered before being placed in the DLQ (Dead Letter Queue). Is there a way to do it? ...
What I'm seeing seems strange to me. Not all consumers of a queue are being delivered the messages. Is there a setting I'm missing? ...
I met problem when use ReceiveNoWait with Apache.NMS & ActiveMQ, really simple scenarios: private static void Send(string text) { var factory = new ConnectionFactory("tcp://localhost:61616/"); using (var connection = factory.CreateConnection()) { connection.Start(); var session = connection.CreateSession(); ...
Hello, I have a web application that runs text processing jobs in the background once a message is received on an ActiveMQ which is listened to by a Spring MessageListener....the problem I"m encountering is that once I process around 30 background jobs, ActiveMQ stops processing any messages, Spring message listener loses its JMS connec...