I'm hoping someone here will be able to aid me with my struggles with integration with ActiveMQ from C#. Here's what I did so far: using Apache.NMS; using Apache.NMS.ActiveMQ; namespace JMSTest { class Program { static void Main(string[] args) { IConnectionFactory factory = new ConnectionFactory("tcp://localhost:61616/"); ...
I have several servers that produce xml files from Python and some other servers that consume those xmls using Java. I've only recently looked into JMS and ActiveMQ and decided to try using it to pass the xml files. So I set up ActiveMQ daemons on the consumer servers and figured I'd implement some cycling method on the produces to dist...
Has anyone used the Message Grouping feature in ActiveMQ? http://activemq.apache.org/message-groups.html This would be a really useful feature for a project I'm working on, but I'm curious how well this feature scales and performs. In our system, we would need to group messages into groups of about 3-5 messages, so we would be continu...
We'd be interested to hear any experiences with the pros and cons of ActiveMQ vs RabbitMQ vs ZeroMQ. Information about any other interesting message queues is also welcome. ...
I'm investigating using ActiveMQ as an embedded in-process message queue in my application, but I'm a bit stuck on how I go about starting such an application up. I envision it like so (pseudocode, of course): configureBroker () broker.start () createProducer (broker) producer.start () for each desired consumer createConsumer (br...
Tomorrow I am presenting my rationale for choosing an in-process message queue implementation, and I'm unable to articulate my reasoning. My co-designers are proposing that we implement a simple asynchronous queue using just a basic list of jobs and a mutex to control access, where I'm suggesting ActiveMQ in embedded mode. I've persona...
I am sending messages to an active mq queue through mule. I want that only latest message to remain in the queue and not any previous one. how can this be achieved? thanks. ...
First off, I am a newbie when it comes to JMS & ActiveMQ. I have been looking into a messaging solution to serve as middleware for a message producer that will insert XML messages into a queue via HTTP POST. The producer is an existing system written in C++ that cannot be modified (so Java and the C++ API are out). Using the "demo" ex...
I have this in activemq config <sslContext> <sslContext keyStore="file:/home/alex/work/amq/broker.ks" keyStorePassword="password" trustStore="file:${activemq.base}/conf/broker.ts" trustStorePassword="password"/> </sslContext> I have a pair of x509 cert and a key file How do I import those two to be used in ssl and ssl+st...
Hi, I'm new to JMS and I am working on setting up ActiveMQ with Tomcat 6 and Spring. I have most of the basic things configured however I'm a little bit confused with the Message Listener Containers that Spring provides. Reading the documentation it sounds like the Message Listener Container is used to "handle" subscribing (I'm worki...
We're considering a messaging platform to integrate two core systems in a banking environment. We're looking at open source options. Which products have you used and can you share experiences? ...
Hi, I am currently setting up a Tomcat Server that is running an embedded ActiveMQ broker. I'm using Spring to configure JMS. I wrote a test application to listen to topics and when I exit the test application the ActiveMQ broker throws a SocketException. Here is the exception: 2009-06-09 13:12:48,005 DEBUG Transport:229 - Transpor...
this is driving me insane. I'm simply trying to run activemq on Mac OSX 10.5.7. I have java version 1.5.0_19 and activemq 5.2.0. Below is the exception I get when running bin/activemq. It seems to be unable to find log4j which is odd considering it comes with activemq and is definitely in the lib/optionals directory. The only thing ...
Hello, I'm facing a bit of difficulties implementing the HA for my ActiveMQ service. Right now, I've correctly implemented the Master / Slave brokers of Active MQ, so if the master dies, the slave takes over the message delivery transparently. They both share a Microsoft SQL database to store the messages. I wanted to add another level...
Hello, I want to start an application which will use ajax push, however the web server should be configured properly and i don't know how to start on server side components. I wanted to start with dojo's cometd and then read some blogs saying that activeMQ is older and flag carrier on ajax push thing, but there was also another blog sa...
Hi, many weeks ago recommended me for send emails, ActiveMQ. So i search information about this, but i don't understand totally how this works. Could someone explain me why i should use ActiveMQ for send emails ? ...
I'm planning on using Apache NMS for ActiveMQ messaging, and am wondering what serialization method is going to be used on the objects I send? XML/Binary? What controls the serialization and how can I customize it? Does anyone have experience doing this with C# objects? Are there any pitfalls that you know of? ...
What messaging platform would be the best choice for asynchronous message queuing (publish, consume) between PHP and Java apps? I have looked at RabbitMQ, ActiveMQ, OpenAMQ, Tibco Rendezvous, and Websphere MQ. Persistence is required. I love the idea of AMQP and using an open protocol, but I've heard of stability issues with RabbitMQ, wh...
Hello, I'm setting up a notification service using ActiveMQ, in C#. My ActiveMQ topology is a network of brokers: I've a pool of brokers and my clients use the failover uri to randomly connect to any of them. My question is rather simple but I was not able to find the answer: I want to debug to which broker the messages are originally s...
Hi, I have tried and tested the JMX API and it is pretty simple to use and provides a vast number of statistics required for monitoring ActiveMQ. But the problem is, i dont want to monitor my ActiveMQ remotely and also i dont want to use another API.To be more precise, i want to use the JMS API itself to get statistics related to vario...