I have an embedded broker completely configured through java code (no deployable xml files). When I point my browser to the web console I just get a 404, and an lsof shows that nothing is listening on 8161. Is it possible to use the web console with only java code? I'm fine with using the webserver that comes with ActiveMQ, and I'm fine ...
I've been evaluating ActiveMQ as a candidate message broker. I've written some test code to try and get an understanding of ActiveMQ's performance limitations. I can produce a failure state in the broker by sending messages as fast as possible like this: try { while(true) { byte[] payload = new byte[(int) (Math.random() *...
I have an instance of ActiveMQ running on an externally facing server and exposing a STOMP interface. I would like to be able to ensure that externally connected clients can only receive topic notifications, and not send anything to the topic themselves. Any internally connected clients will be able to both receive and send. I was hop...
I'm using ActiveMQ 5.2 and my application requires a large number of topics, somewhere in the neighbourhood of 500,000. When I run my application, after creating only about 1000 topics, ActiveMQ throws an OutOfMemoryException. Is it unreasonable to expect ActiveMQ to support this number of topics? Is there an optimal configuration for...
Well, maybe not with all 4 things, but here's my situation: I have an ActiveMQ backend (running on my desktop Mac). It's a stock Apache ActiveMQ server I have which I am basically using as an echo server to tail the logs and debug my client. The client is an iPhone project with a hacked up Stomp.framework implementation using AsyncSocke...
We've built up an application infrastructure based on ActiveMQ. We can send and receive messages just fine, and for the most part things are pretty fast and OK. However, we've noticed that if we submit a batch of messages "at once", say 5,000 messages - that ActiveMQ will get the messages to the 3rd party application on the other end p...
I am sending messages in JSON format to an ActiveMQ server. I am trying to use JMS Transformation to transform the JSON encoded object into a true Java Object in hopes of being able to use selectors on the data inside. Here is a link to the documentation on Stomp and Message Transformation. Here is a link to a discussion on the patch wh...
I have a .NET service that uses the ActiveMQ client. I have implemented a MessageListener with a transacted connection to consume the messages. Occasionally, I get messages in a different order in which they were put onto the queue. Was it wrong to use a MessageListner? Is there a way to preserve the message order? FYI: There is one...
I've set up a queue by configuring it in activemq.xml (ActiveMQ version 5.2.0) as described in the documentation. <destinations> <queue physicalName="FOO.BAR" /> <queue physicalName="DUMMY" /> </destinations> I'm trying to access it from java (on the same host) with the following code: Hashtable properties = new Hashtable(); ...
I wish to set up a ActiveMQ instance (primarily as a STOMP server) which will service requests from two types of clients: authenticated users which can read and write to topics non-authenticated users which can only read from topics I have been using the SimpleAuthenticationBroker so far and I cannot see anyway to configure the above...
I'm trying to create simply connect with ActiveMQ using JNDI. I have Queue named 'example.A'. According ActiveMQ documentation touching JNDI, if I want to use ConectionFactories and Queues (Topics) via JNDI, I have to place jndi.properties file on my classpath. As I have understood, activeMQ classpath is %activemq%/conf directory by ...
I am an ActiveMQ / Camel noob with a specific scenario in mind, I wonder firstly if it is possible and secondly whether someone might provide a little direction. Basically I need to perform dynamic throttling off the queue. I.E the ability to set at runtime the rate a particular group of messages will be consumed from the queue. So I m...
Just curious if anyone has messed with the Apache.NMS.WCF code at all. For a work project, I've started to try to integrate the Apache.NMS WCF binding with ActiveMQ. I've made some progress, but if anyone has any links or info, I'd greatly appreciate it. ...
I checked out stomper and it didn't look complete. (I'm very new to Python) Is anybody out there using stomper in a production environment? If not, I guess I'll have to roll out my own Twisted Stomp adapter. Thanks in advance! ...
I am going to choose a JMS message broker for a project. It is critical that the JMS server is stable and can handle a high load of messages. I have narrowed down the list to include Active MQ and JBoss Messaging. I was wondering if any of you have any experience with any of these or even better have tried both of them in the same env...
Hi I have been using the STOMP protocol in various guises. I have experienced this phenomenon in the PHP, Python and Objective-C libraries for STOMP. The STOMP specification on the STOMP website is not specific on this point. Basically, the CONNECT function in all three libraries (although the Python one has now fixed this, it was ackn...
I maintain an Eclipse plugin that uses JMS (via the ActiveMQ implementation) to send and receive messages from queues maintained by a hard-coded broker on another machine. One of my user reports that his logs contain messages from JmDNS. I'm trying to figure out if he's getting this through my plugin or from something else. I thought J...
I have several message with properties set. Some of these contain numeric data, although I have made no attempt to declare this explicitly to ActiveMQ while sending the messages. When I try to use arithmetic conditions, ie: <, >, <=, >= and family, I get an error. Is there any way to use arithmetic conditions using selectors via Stomp? ...
I'm using ActiveMQ with the C# client library. I create 10,000 topics with random names as part of a test for evaluation purposes and now I can't get rid of the topics. ActiveMQ grinds to a halt with this number of topics so I need them out of the system. Here is what I have tried so far, and none of it has worked. I'm running Active...
We are experiencing disconnects on our Tomcat/BlazeDS/ActiveMQ stack. Although our BlazeDS StreamingAMFChannel is configured with the default idle-timeout-minutes of 0, it seems to timeout after about 30 minutes of idle time (see log). The client does not do any requests during that time and we are also not pushing messages from the Acti...