I'm sending MapMessages in Java to ActiveMQ and retrieving them using Stomp in PHP. My message creation code looks like this: MapMessage message = session.createMapMessage(); message.setInt("id", 42); message.setInt("status", 42); message.setString("result", "aString"); When I retrieve them in PHP, the array that's created looks like ...
Fellow StackOverflowers, is there a way for me to remove a queue or a topic in ActiveMQ programatically? I am using ActiveMQ's standard persistency, and my application requires that, on startup, all new queues be dynamically re-created (unless there are messages stored in the queue, in which case, the queue should remain to exist). I am...
I am using Active MQ for integration testing my application. I have defined an active-mq broker in a spring config like so: <amq:broker useJmx="false" persistent="false" deleteAllMessagesOnStartup="true" useShutdownHook="true"> <amq:transportConnectors> <amq:transportConnector uri="tcp://...
Background I have two services that need to communicate with each other over a message queue. One is a legacy service written in PHP and the other is in Java. Sooner than later, the PHP service will be rewritten in Java. The current way they communicate with each other is to write to a shared database, which the other service polls. Thi...
Latest version of both, can not see how to enable ActiveMQ as an endpoint in Glassfish. Would like to use ActiveMq as the JMS provider in Glassfish, the stuff I found on google does not make sense. Any advise welcome. Is it possible to just use the JMS connector and poitn at ActiveMQ - believe not but have I just configured wrong ? T...
I am trying to create a deamon to denormalize my Database. I use ActiveMQ as queue manager I have 2 data bases: Relational one (write + replication), and denormalized one (for reads) My question is what's the best practice to denormalize my real DB I have some ideas: MySQL proxy (with lua) which reads the Queue (is this possible) Tri...
Hello all. I'm trying to consume messages on an ActiveMQ topic from a C# application. I'm using the 1.3 .net release, and I don't receive any messages. I have existing code that uses older libraries (and libraries built on top of libraries that I don't want to use or upgrade) that work fine, so I know messages are travelling along the ...
Well, lets say I'm building ActiveMQ based chat application. It's pretty simple. Having only one QUEUE.IN and one TOPIC.OUT. All messages are simply routed right away from QUEUE.IN to TOPIC.OUT. Clients are producing their chat messages to QUEUE.IN and consuming from TOPIC.OUT. That's all. Now, I wanna cluster it. Don't need something ...
I'm working on an application where we want to monitor logon/logoff of clients. Since ActiveMQ contains Advisory Topics that alert you of new connections and removal of connections, the idea was to use this advisory messages ( ActiveMQ.Advisory.Connection). This worked fine during development but now, when we are going to production in o...
I am using Embedded ActiveMQ for sending messages from Server to Client using NetworkConnector using a static address and using a local Broker URL to connect to this Network Connector. This is working fine when Network Connectivity betweeen Local Machine(local URL) and NetworkConnector URL is present. However, when connectivity fails bet...
How can I achieve reliability of web service in CXF ? It is used in financial domain and involved in payment system, so requirement is that it must be 100% reliable and secure. for security I have added username/password authentication using ws-security (intercepter). Do I need to use any Middleware (ActiveMQ) for transprot so that MQ ...
I have a springframework web application that uses JBoss, MySQL and ActiveMQ. At the moment, I have to install and configure JBoss, MySQL and ActiveMQ and JBoss manually. What is the best way to package the application so a user can maybe do a one click install (on Linux platform, maybe Windows too?) ...
On JBoss 5.1.0 I have Datasource (PostgreSQL 8.3.11) configured using *-ds.xml (standard jboss DS). It uses XADataSource (PGXADataSource). I also have ActiveMQ broker (right now it runs as in-VM, under JBoss, but it will be on separate server latter). What I want to do is to make ActiveMQ Connection Factory and Datasource to participate...
Hi all ActiveMQ experts! I had a look via WireShark what's happening under the hood when ActiveMQ "/examples" producer sends messages and it revealed that every TextMessage shorter than 1000 bytes is padded with spaces (' ' or HEX 20) until it fills exactly 1000 bytes. (using the ActiveMQ's "native" transport - TCP "OpenWire") Wonder w...
How can I get to know that queue is deleted. ...
hi guys, can anybody point out a reference on how to implement a single consumer multiple producer in activemq Or could give a very simple implementation this will be very helpful. tnx ...
Hi, I have implemented application client-server with spring blazeDs message services using JMS message destination. The idea is a producer declared in Java send message using activeMQ and consumer declared in Flex receives them. I have configured the AMFChannel with a polling interval 0, but I have seen when the consumer subscribes t...
Hi, I use ActiveMQ as a broker to deliver messages. Theses messages are intented to be written in a dabatase. Sometimes, the database is unreachable or down. In that case, I want to rollback my message to retry later this message and I want to continue reading other messages. This code works fine, except one point : the rollbacked mess...
I am running win7 professional 64-bit. I have already installed java, and am trying to install ActiveMQ. The install worked perfectly on a Windows Server 2003 machine but now it is giving me issues on my win7 machine. I download ActiveMQ 5.3.2 extract the files and then try to run the installservice.bat file as administrator and it gi...
Details of generating message id are not specified by JMS specification. But when troubleshooting issues with specific JMS implementation, it is useful to know what happens. So I am trying to figure out source of excessive duplicates on our system (activemq 4.1 -- yes, ancient version, but this is production and can't be replaced on shor...