activemq

Benefits of Commercial Messaging Middleware vs Open Source

I've been evaluating several opensource message queue technologies, such as RabbitMQ, ActiveMQ, OpenAMQ, etc. My question is, what benefits are gained by using a commercial technology such as Tibco EMS, WebSphereMQ, Sonic, etc. instead of something like Active or Rabbit? PHP will be the primary language involved, although Java systems wi...

Tomcat, ActiveMQ, Swing and a stand alone Java Server

I would probably say this is more of a general posting asking for advice rather than a direct solution request. I am currently in the process of laying down the design and infrastructure for a startup with a colleague of mine, nevertheless, my experience lays in the realm of Java Swing development and JavaScript/Ajax worlds as well as s...

How to restrict access to JMX API of ActiveMQ to only localhost/intranet?

I have just started using JMX to monitor activemq,i have enabled remote monitoring. Now the question is,How do i allow only localhost have access to JMX API? Or is there a way i can use JMX API without enabling remote monitoring.. ...

ActiveMQ message content is truncated

We have an ActiveMQ topic into which a Java program inserts messages, where a C# client retrieves them. This has been working fine for a long time, with most of our messages around 1 - 2K. Recently we had a message closer to 10K (9,910 bytes); we take the message, wrap it with some XML, and send it to the topic. When the C# application ...

activemq consumer enumeration

Is it possible to use an activemq consumer (in .NET) like this? foreach (var msg in consumer) { // process message } such that the enumeration loop stops, without consuming CPU, until a message is available? Effectively it would be an infinite loop unless something goes wrong. ...

How can a .Net application become a subscriber to a JMS (ActiveMQ) topic?

Please lay out the various ways for a .Net application to become a JMS (ActiveMQ) topic subscriber. Detailed and production-quality solutions would of course be best. ...

How do I create a queue browser (preview not consume) in C# for an ActiveMQ queue?

I'm using the NMS API for reading/writing ActiveMQ in C#, and I cannot find a way to preview the messages on a queue. I could read and rollback - but that'll make them DLQ eventually. In my previous life, TIBCO had a QueueBrowser object that could be used, and I think JMS had IQueueBrowser as well. I cannot find an ActiveMQ .NET equiv...

How do you specify an ActiveMQ binding in a config file?

I get the impression, that ActiveMQ can be consumed as a WCF binding, but examples are hard to come by. Can anyone point out an example where ActiveMQ is used as the protocol for a WCF service? I found this link, but no answers.... http://stackoverflow.com/questions/490799/apache-nms-wcf --- UPDATE --- Ok, I am getting closer. But no...

Sun JMS bridge to ActiveMQ to .NET

I have Sun's Message Queue 4.3. Default installation on localhost using imqbroker daemon. Opened one queue. I want to consume messages written to the queue above from .NET. I understood there is ActiveMQ solution, version 5.3. Checked ActiveMQ for .NET (version 1.1) and it works OK for ActiveMQ queues which are similar to Sun JMS. My ...

ActiveMQ Consumer / Producer Connection Listener

I can't seem to find a way to listen for new producer and consumer connections (or connection interrupts) in ActiveMQ (Java Version). I want to be able to tell the consumers (or they can find out themselves) that the producer's connection dropped. The other way around (the producer finding out that a certain consumer disconnected) is als...

How do I turn on JMX in ActiveMQ 5.2

Whats the proper way to enable JMX in ActiveMQ 5.2? I've seen conflicting documents, so I was wondering if anyone out there knows what the proper config file change should be. I think I might have it working by changing the batch file I use to start ActiveMQ, but I don't really know. ...

What do some of the fields returned from ActiveMQ.Agent query mean?

I'm trying to do some kind of administration on our activemq process, and I'd like to know what some of the fields mean that I get back. Specifically, What is InFlightCount? Is that the number of messages that the producer has sent but not What is AverageEnqueueTime measured in? Seconds? What are EnqueueCount and DequeueCount? What is...

ActiveMQ store-and-forward broker hangs after failover of master-slave pair

Hi all, I'm encountering some problem with ActiveMQ 5.3. We have the following setup: - A master-slave pair ('master' and 'slave') - A broker ('broker') that forwards messages to either 'master' or 'slave', depending on who is active The symptom I see: When I start 'master', 'slave' and 'broker' messaging works as expected: When I publ...

What does the last digit in the ActiveMQ message ID represent?

I have a system that seems to be working fine, but when a certain process writes a message, I get 10 messages appear in the queue. They are all almost duplicates, but the last section of the message id is incremented. Example: c6743810-65e6-4bcd-b575-08174f9cae73:1:1:1 c6743810-65e6-4bcd-b575-08174f9cae73:1:1:2 c6743810-65e6-4bcd-b575...

What kind of message can be transported through ActiveMQ?

We are building a distributed system, maybe a c# app will talk to a c++ app, and maybe some jpeg image will ben send between, is this possible with Activemq? ...

How to optimize activemq

I'm using ActiveMQ on a simulation of overloading servers in Java. And mainly it goes ok, but when I get over 600 requests the thing just go WTF! I think the bottleneck is my Master Server which is this guy below. I'm already reusing the connection and creating various sessions to consume messages from clients. Like I said, I'm using a...

ActiveMQ OutOfMemory Can't create more threads

I'm simulating a overload of a server and I'm getting this error: java.lang.OutOfMemoryError: unable to create new native thread I've read in this page http://activemq.apache.org/javalangoutofmemory.html, that I can increase the memory size. But how do I do that? Which file I need to modify,? I tried to pass the arguments by the bin/a...

Feedback about ActiveMQ. How about it? Is it worth?

Hi, we are evaluating ActiveMQ and I whould like to know what you think about it. Any feedback is welcome. EDIT: actually, I need to know things like: how does it scale? What about stability? Is it stable enough for production environments? Memory consumption, etc. ...

Anyone using multicast with ActiveMQ

I'm having trouble setting up multicast transport using ActiveMQ. I noticed with version 5.2 there is a bug that prevents it from even building the correct factory (fixed in 5.3). The fact this bug exists makes me wonder if anyone is using multicast at all. How can this be tested when it only recently has been enabled? Just knowing that...

ActiveMQ: how to dequeue older messages?

Hi, I'm learning how to use ActiveMQ and now we are facing the following problem. Suppose that I have a topic named topic.test on ActiveMQ which have two subscribers. In a given moment, I have only one of those subscribers waiting for messages, and a producer send a message for the topic I mentioned above. Ok, the connected subscriber...