activemq

Why does ActiveMQ hold messages that should be deleted from Topic?

I use ActiveMQ as Notification System(Pub/Sub model). On server: if any changes of data occur, Server send this updated data (File) to Topic using BlobMessages. There are few Clients, that subscribe on this Topic and get updated File if it exsist in Topic. The problem is that all of BlobMessages, that were sent to Topic, are hold by A...

Which persistent & lightweight queue messaging for cross domain (> 2) data exchange with rails integration ?

Hi all, I'm looking for the right messaging system for my needs. Can you help me ? For now, there won't be a huge amount of data to process, but I don't want to be limited later ... The machines are not just web servers, so the messaging tool should be lightweight, even if processing is not very speed. When some data change on a serve...

Creating JMS Queues at runtime.

I am working on an application where the app user can create / delete queues . Also , he would be able to move a message from 1 queue to another, delete a message , rearrange the messages in the queue based on some filter. One possible design is to use activemq for queues and apache camel for various other operations having integrated ...

HOWTO: disable jmx in activemq network of brokers (spring, xbean)

Since I've struggled a lot with this problem, I am posting my solution. Disabling jmx in an activemq network of brokers removes race conditions about the registration of the jmx connector. When starting multiple activemq servers on the same machine: Failed to start jmx connector: Cannot bind to URL [rmi://localhost:1099/jmxrmi]: javax.n...

fire and forget compared to http request

I'm looking for opinion from you all. I have a web application that need to records data into another web application database. I not prefer to use HTTP request GET on 2nd application because of latency issue. I looking for fast way to save records on 2nd application quickly, I came across the idea of "fire and forget" , will JMS suit fo...

Run ActiveMQ offline?

Is there a way to run ActiveMq offline? ...

Routing an ActiveMq topic to an external broker.

Hi All, I have an ActiveMq topic which I wish to transform and share with an external broker. At present I have the following which performs the transformation: <camelContext id="camel" xmlns="http://activemq.apache.org/camel/schema/spring"&gt; <route> <from uri="activemq:topic:OriginalTopic"/> <to uri="xslt:f...

how to associate the activemq-core.xsd url with the activemq.xsd found in the jar file?

Hello, Somebody knows how to associate the activemq-core.xsd url with the activemq.xsd found in the jar file (activemq-core-5.2.0.jar)? I dig some solution in internet but didn't work. I'm getting this error: Caused by: org.springframework.beans.factory.xml.XmlBeanDefinitionStoreException: Line 19 in XML document from class path res...

how to add conditional activemq connection property?

Our application uses activemq for one of its modules and depending upon the customer, it should either uses the activemq for message publishing/subscribing or not use it. We have the activemq connection property like the activemq url and port etc. coming from a DB. For customers not using that module, it is empty. We have defined the c...

Servicemix ActiveMQ performance issue

Hi. I am using apache servicemix and apache activeMQ in my product. Here in case of HttpConnector i found a performance issue. If i increase number of total request at a time then as the number will increase exchange queue gets stuck on any of the component. After all the requests start processing, most of the exchange gets stuck at th...

How do I take advantage of Connection Pooling with Apache Active MQ?

I'd like to know how to properly use connection pooling with Active MQ. Currently I have a Connection Factory that creates a new connection every time I want to send a message. I'd like to be able to pool Connections so I don't incur the overhead of connecting every time. ...

ActiveMQ & Camel - How to create dependency in routing paths

I have a message routing to implement, which has routes that vary according to the message content. Some strands of the route are dependent on other. If for example I have Data_A which has Task_A and Task_B to be performed on it. Whereas Data_B has only Task_B to be performed on it. Here each Task has a queue served by consumers. If T...

Can I use Pub/Sub model with Many Publishers and Only One Subscriber?

I need to send some files from different machines to only one Server. As I understand, I can use JMS api + (for example) ActiveMQ as broker. There are two models: p2p and pub/sub. I would like to use pub/sub model, but the problem is that I haven`t few subscribers, I have only one Subscriber(Server) and many Publishers. The question is t...

Active MQ showing more than one (ghost) consumer

We have a system that uses ActiveMQ (Queues) - and have exactly one producer and one consumer (implemented as a Windows Service in .NET). Over the weekend, the infrastructure team had a reboot of the servers on the network, and from then on we noticed that there are more than one ghost consumer appearing that listens to the queue and we ...

Can I configure Apache ActiveMQ to use the STOMP protocol over UDP?

I'm developing a STOMP binding for Ada, which is working fine utilizing TCP/IP as the transport between the client and an ActiveMQ server configured as a STOMP broker. I thought to support UDP as well (i.e. STOMP over UDP), however, the lack of pertinent information in the ActiveMQ documentation or in web searches suggests to me that thi...

Java Messaging : Difference between ActiveMQ, Mule, ServiceMix and Camel

Hi, I am new to Messaging and want to know the difference between ActiveMQ, Mule, ServiceMix and Camel Anyone knows how each of these product is different? Thanks in advance ! EDIT: Also would like to know any good place/resource to learn these things. ...

Implementing a client for ActiveMQ events

I can listen to events from a certain topic in an ActiveMQ server using a simple asynchronous listener and print the incoming events to the console (code to that actually comes as an example in the activemq-cpp library). I would like to create clients on other machines that will listen to these events and update their displays. My quest...

ActiveMQ AJax Client

I try to write a simple Ajax client to send and receive messages. It's successfully deployed but I have never received msg from the client. I am beating myself to think out what I am missing, but still can't make it work. Here is my code: I creat a dynamic web application named: ActiveMQAjaxService and put activemq-web.jar and all n...

Open Source Queuing Solutions for peek, mark as done and then remove

I am looking at open source queuing platforms that allow me do the following: I have multiple producers, multiple consumers putting data into a queue in a multithreaded environment with the specific use case: I want the ability for consumers to be able do the following Peek at a message from the queue(which should mark as the message ...

activemq-maven-plugin ignore files in classpath?

I have been trying to get activemq-maven-plugin to run activemq with configuration in classpath of the bundle. However, I don't have much luck. It seems that the activemq-maven-plugin just ignore resources (resources/main/conf/activemq.properties) the local bundle. I checked the jar and target/classes and they are built into the right l...