FAQ Database Discussion Community


Apache Camel; How to route all message from queue destinations matching a pattern

routing,apache-camel,activemq
I am trying to route all messages that are received to queue destinations that match pattern like "amq:events:*", where * is the wild card. <camel:route id="event-route" > <camel:from uri="amq:events:*" /> <camel:to uri="file:work/jms/all-events" /> </camel:route> Messages can be sent to amq:events:dest1 or amq:events:dest2 etc. Is there a way to do this...

Error in setExceptionListener in sending message via JmsTemplate to ActivemQ (as external broker of Jboss-eap)

spring,jms,activemq,spring-jms,jboss-eap-6
Based on this article, I've connected Jboss eap 6.2 to an external ActivemQ 5.9.0. For sending/receiving message i'm using JmsTemplate and DefaultMessageListenerContainer in spring-jms 4.1.1. Receiving message is working fine, but in sending message i get this error: 11:33:37,059 ERROR [stderr] java.lang.reflect.InvocationTargetException 11:33:37,060 ERROR [stderr] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 11:33:37,060 ERROR...

ApacheCamel + ActiveMQ to JBOSS Fuse, what is the best approach?

apache-camel,activemq,osgi-bundle,spring-dm
I have ApacheCamel + ActiveMQ up and running at work with about 8 different routes. It started nicely when we had 2 routes. The number of routes is growing (currently 10) and the process of adding new route involves updating the existing routes code, testing, deployment..etc. What I really want...

ActiveMQ - How to retrive consumerId from message from ActiveMQ.Advisory.MessageConsumed

activemq
is it possible to retrive consumerId from message received from "ActiveMQ.Advisory.MessageConsumed.Queue.[queue-name]" topic? When a consumer consumes a message from a queue, an advisory message is placed in topic ActiveMQ.Advisory.MessageConsumed.Queue.[queue-name]. After I checked a message retrieved from ActiveMQ.Advisory.MessageConsumed.Queue.[queue-name] I realised that there is no consumerId. My custom MessageListener for ActiveMQ.Advisory.MessageConsumed.Queue.[queue-name] has...

How to use log4j2 JMSAppender with ActiveMQ

java,jms,activemq,jndi,log4j2
I am struggling to write a simple POC program that logs messages to a Queue. All tutorials and Q&As I find (here and here) use log4j version 1.2 and they put messages onto a Topic and not onto a queue. My requirement is to log to a queue. I followed...

In ActiveMQ clustering, how to find the consumer who picked a particular message or set of messages?

activemq,cluster-computing
We have set of queues and camel routes have been written to consume messages from the queue - queues live in an ActiveMQ server and camel routes in Apache Karaf. We have put up a cluster with multiple karaf nodes; problem is that these messages get read by camel routes...

JMS Broker receives the message as null

jms,activemq,broker
I have a C++ component which passes message to JMS broker via tcp using ActiveMQ. My broker is written in JAVA. I want these two to communicate; to C++ component send messages to the JAVA broker. On C++ side what I am doing is creating a message (using protocol buffer),...

ActiveMQ http connection refused

java,http,activemq,connect
I am trying to connect my java client application to ActiveMQ over http, but keep getting an error: Failed to perform GET on: http://localhost:8080 as response was: Connection refused: connect This connections works why I connect with: tcp://localhost:61616 activemq.xml <broker> ... <transportConnectors> <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/> <transportConnector name="http" uri="http://0.0.0.0:8080"/> </transportConnectors>...

Connect Activemq using iiop

java,spring,jms,activemq
I am successfully sending/receiving messages to ActiveMQ using TCP brokerURL as: tcp://localhost:61616 How can I sending/receiving messages to ActiveMQ using IIOP?...

Correct ActiveMQ producers concurrency

java,multithreading,activemq,producer
ActiveMQ documentation states that Session and MessageProducer objects are not thread-safe. If I have a set of threads that can produce persistent messages then how to send them to ActiveMQ correctly being aware of whether a particular send operation is successful or not? Have a separate Session/MessageProducer for each worker...

Cannot concurrently consume from ActiveMQ embedded broker

java,jms,activemq
I'm looking for a way to publish 10 messages to an ActiveMQ embedded broker and, at the same VM, concurrently consume they using JMS API. The code below has some kind of race, because sometimes it consumes 2, 4, 8 messages in parallel, and hangs until timeout at the latch.await...

Why my ActiveMQ is shutting down my Tomcat?

java,tomcat,activemq
I have a dummy webapp in a Tomcat container that uses ActiveMQ. The problem I'm having is that out of nowhere the ActiveMQ shuts down and forces my Tomcat to shutdown as well. This is the log from catalina.log: INFO 2015-01-21 17:35:04,072 - ActiveMQ Message Broker (localhost, ID:app-46388-1421875096431-0:1) is shutting...

ActiveMQ offline message transfer on database level

jdbc,activemq
we are running an in-house EAI system using ActiveMQ as the message broker using JDBC persistence. There we have a cold-standby failover solution each one having an own database schema (due to several reasons). Now if the primary goes down and we want to startup the backup we would like...

Camel JMS - does it pull messages from queue in a loop?

apache-camel,activemq
I've enabled JMS transactions as described in this document: http://camel.apache.org/transactional-client.html My queue subscriber is registered as follows: from("jms:queue:xyz).to(MyBean.class) There are no messages on this queue, but I can see in Camel log, that it starts and ends multiple JMS transactions and this happens multiple times with different thread id. This...

How to define max queue size using Spring-JMS

java,spring,jms,activemq,spring-jms
I followed Spring-boot article to define local activemq: https://spring.io/guides/gs/messaging-jms/ I would like to set the queue size(for X times). so when producer try to enqueue new times it will get expcetion in case the size is on it's limit How could I define that? thank you....

AMQP 0-9-1 vs 1-0

rabbitmq,activemq,messaging,amqp
I am looking for a messaging service for a new project that will have to interface some C# applications with some Java applications. I really like RabbitMQ because it seems to have amazing support for both technologies. I see in the RabbitMQ specs that at the moment only AMQP 0-9-1...

Websockets - Tomcat+Spring+ActiveMQ vs ActiveMQ on its own

spring,tomcat,websocket,activemq
After creating a websockets server/client implementation with Spring 4.1 using a simple broker, I wanted to add a Messaging Queue to it using the advanced broker. But on investigating ActiveMQ I find it already has built in websocket support. So my question is, does anyone know any data/information that will...

ActiveMQ cosumer connection differ from producer

activemq,failover
The following is my ActiveMQ setup: I have two AMQ broker which are configured with failover. I have 40 producer but only on consumer. Now the problem: From time to time, one of the producer lost the connection to the master broker. The failover reacts and the producer gets a...

How to persist a queue which contains Java Message in Mule ESB?

java,jms,mule,activemq,esb
I am using JMS endpoints and Apache ActiveMQ in my Mule application (I have followed a tutorial and not sure if i am doing the right thing relying on JMS as endpoints) <jms:activemq-connector name="jms-connector" brokerURL="${BrokerURL}" disableTemporaryReplyToDestinations="true" specification="1.1"/> <jms:endpoint connector-ref="jms-connector" exchange-pattern="one-way" name="UnsortedOrders" queue="UnsortedOrders"/> <jms:endpoint connector-ref="jms-connector" exchange-pattern="one-way" name="DestinationEMC"...

I can not run C-OpenWire client for ActiveMQ after compilation

c,ubuntu,activemq
I'm trying to develop client in C for ActiveMQ using OpenWire and after compiling example main for OpenWire ActiveMQ on Ubuntu, when I try to run it I get this error: bash: ./test: cannot execute binary file: Exec format error I've tried it on both ubuntu 32 and 46 bit...

Apache.NMS.ActiveMq ConnectionFactory ignores prefetch set in broker URL

activemq
This is the URL we're using to create/attach to our queue: tcp://localhost:61616?jms.prefetchPolicy.queuePrefetch=1 This defaults the queuePrefetch to 1000: IConnectionFactory connectionFactory = new ConnectionFactory(queueServer); connectionFactory = new SingleConnectionFactory(connectionFactory) { ReconnectOnException = true }; If we use the following code it sets it appropriatly: IConnectionFactory connectionFactory = new ConnectionFactory(queueServer) { PrefetchPolicy =...

Program with Protocol Buffer can't get linked

c++,compilation,linker,activemq,protocol-buffers
I have a cpp file in which I am trying to use the message that I created with protocol buffer. However I keep getting that famous "undefined reference" error as follows: undefined reference to PointMsg::PointMsg() undefined reference to PointMsg::~PointMsg() undefined reference to PointMsg::~PointMsg() Here is the proto file that I...

Camel ProducerTemplate not injected with annotation config

java,spring,apache-camel,activemq
First of all, I know there are very similar questions (Camel producerTemplate is not injected in spring MVC and Initializing camel from Spring annotation config) but they don't help in my case. I have a bean which sends messages with ProducerTemplate: public class SimpleProducer { @Produce(uri = "activemq:queue:simple") private ProducerTemplate...

JMS Prefetch + Cached Consumers + Stuck Messages

java,spring,jms,activemq,spring-jms
I am trying to get JMS Consumers to work towards an ActiveMQ server however I am running into some issues which solution seem to just cause more problems. I am using Spring's DMLC (cacheLeve set to CACHE_CONNECTION) together with a CachingConnectionFactory (cachingConsumers set to true) wrapping Activemq's own ConnectionFactory in...

Does ActiveMQ support multiple transactional consumers?

transactions,apache-camel,activemq,servicemix
I am developing OSGI bundles in ServiceMix to consume from the same queue of ActiveMQ. I need to be sure that the message is dequeued only if every thing goes fine so that I don't lose that message. So I used camel transactional client. I manged to implement it by...

java.lang.NoClassDefFoundError: Files\Apache on launching ActiveMQ

java,apache,exception,jms,activemq
I've downloaded Apache ActiveMQ 5.9.0 and I'm trying to launch it. Following, the command I've typed and the output: c:\Program Files\Apache Software Foundation\apache-activemq-5.9.0>bin\activemq java.lang.NoClassDefFoundError: Files\Apache Caused by: java.lang.ClassNotFoundException: Files\Apache at java.net.URLClassLoader$1.run(URLClassLoader.java:202) at java.security.AccessController.doPrivileged(Native Method) at java.net.URLClassLoader.findClass(URLClassLoader.java:190) at...

How to delay activemq message using Stomp (AMQ_SCHEDULED_DELAY)

node.js,activemq,stomp
i am using sending receiving messages from activemq over stomp using node js stompit library (https://github.com/gdaws/node-stomp). Issue:- There is a case where i want to schedule a message to be send after n minutes. I don't see any way i can set this AMQ_SCHEDULED_DELAY header using this library (or any...

check whether an activemq subscriber is subscribed to a topic or not?

java,activemq,disconnect
I am working on a code in which there are 3 subscribers(non-durable) to a topic in activemq, but something wrong happens and one subscriber gets disconnected from the topic and never connects back again even though the protocol used is failover. So, how can i check the status of a...

Apache Camel failed to create endpoint

apache,maven,apache-camel,activemq
I'm new on Apache Camel and I need to integrate it with Apache ActiveMQ. I tried a basic example, I installed on my computer FileZilla Server and ActiveMQ (works both) and I want to copy a file from the local server to the JMS queue that I created in Active...

Setting up ActiveMQ bridge to connect to different implementations of MOM

jms,activemq,websphere-mq,tibco-ems
I would like to deploy ActiveMQ in order to connect and communicate with other MOM implementations of jms such as WebsphereMQ, Tibco EMS, Oracle WebLogic JMS etc. As far as I have researched online this seems to be possible by building a so-called bridge on top of activemq that will...

Spring Integration with JMS + ActiveMQ: Messages remain in JDBC Message Store after reconnect

java,activemq,spring-integration,spring-jms
I'm trying to configure JMS with Spring Integration and an ActiveMQ Message Broker. My outbound channel should be backed by a JDBC Message Store to prevent data loss e.g. the broker or my application goes offline. My configuration seems to work so far, however the JDBC Message Store does not...

ActiveMQ: enable Web Console in a CXF Project

java,maven,activemq,wildfly-8,hawtio
i'm trying to figure out how to startup a web console for my Apache CXF-Maven project. It's quite messy cause it's not a standard project, i'm actually implementing the wsn\services from the cxf-master SVN or GITHUB developed by the Apache CXF Team. I've read that there's also the hawtio console,...

RabbitMQ and ActiveMQ running on the same machine

rabbitmq,activemq
For testing purposes I need ActiveMQ and RabbitMQ running on the same Windows machine. I have both installed, but I can't run them together: I need to stop one service in order to have the other one running. This is the error I get trying to start RabbitMQ having ActiveMQ...

Logstash + stomp + ActiveMQ

activemq,logstash,stomp
I'm using logstash to read a CSV file and post the information to my ActiveMQ using the stomp protocol. Everything is working great, I only want to add persistence to those messages but I don't know how to tell logstash to do so. The ActiveMQ site say I need to...

Webapp hangs when Active MQ broker is running

spring,jms,activemq,maven-jetty-plugin,jstack
I got a strange problem with my spring webapp (running on local jetty) which connects to a locally running ActiveMQ broker for JMS functionality. As soon as I start the broker the applications becomes incredibly slow, e.g. the startup of the ApplicationContext with active broker takes forever (i.e. > 10mins,...

activemq 5.9 org.apache.activemq.command package missing

java,activemq,slf4j
Originally my project had the activemq-all-5.9.0.jar but due to it including an slf4j binding as a dependency I am trying to use the individual jars instead and not include the slf4j binding. I used the dependency list to determine the required jars http://repo1.maven.org/maven2/org/apache/activemq/activemq-all/5.9.0/activemq-all-5.9.0.pom Included jars thus far (abbreviated) amqp, broker,...

Using topics but not all the consumers take the message

spring,jms,activemq,spring-jms,jmstemplate
I want to create a sender to generate message and the send it to all consumers. I am using topic, but something is wrong, if for example I have 3 consumers, only one takes the message in a random way. I don´t know what is wrog. Here is my server...

How do I auto expire messages that dont have a consumer?

activemq
I need the broker to delete all messages that dont have any consumers waiting. I seem to recall that this should be a default behavior, shouldn't it?

ActiveMQ: Error while loading shared libraries

c++,eclipse,environment-variables,activemq
I have a C++ project that runs standalone, by launching its binary on console. However it does not run when I try on Eclipse, giving the following error: error while loading shared libraries: libactivemq-cpp.so.18: cannot open shared object file: No such file or directory I do know that the error...

Why we need to configure and deploy an ActiveMQ Queue to JBoss?

spring,jboss,activemq
For sending and receiving messages we use apache activemq which is open source.activemq is integrated with jboss to perform this operation.But I want to know without integrating into jboss can we achieve this functionality , secondly why we need to use jboss integration with activemq. I want to refine the...

Confused with Apache Camel and ActiveMQ

jms,apache-camel,activemq
I'm pretty much new to Apache Camel & ActiveMQ and finding it really difficult and confusing to grasp the concept of the same.Infact, I'm new to this whole concept of JMS. I really don't understand how Apache Camel is different from ActiveMQ, because as per my understanding, both serves the...

PooledConnectionFactory in endless reconnect loop

java,jms,activemq
piece of code below factory = new PooledConnectionFactory(brokerURL); connection = factory.createConnection("", ""); connection.start(); Broker URL is a valid host, but the port is not opened. After starting it goes into an infinite reconnection loop [junit] 00:28:54,851 WARN FailoverTransport:1109 - Failed to connect to [SOME_URL] after: 10 attempt(s) continuing to retry....

Message selector options JMSCorrelationID or simple string as a JMS property

jms,activemq
Which message selector option is good ? JMSCorrelationID or simple string as a JMS property to selectively fetch messages from queue ? I believe, in term of performance they are same. Producer side using string property: message = session.CreateTextMessage(msg); message.setString("myfilter", "abc"); producer.sent(message); Producer side using JMSCorrelation ID : message =...

Error while acknowleding stomp message

spring,websocket,activemq,stomp,ack
We are using spring stomp over websockets, backed by ActiveMQ 5.11.1. When the client ACKs a message, I get this exception: "<<< ERROR content-type:text/plain message:Unexpected ACK received for message-id [ID\cjanus-61128-1430365808166-2\c1\c-1\c1\c1] content-length:722 org.apache.activemq.transport.stomp.ProtocolException: Unexpected ACK received for message-id [ID:janus-61128-1430365808166-2:1:-1:1:1] at org.apache.activemq.transport.stomp.ProtocolConverter.onStompAck(ProtocolConverter.java:462) at...

ActiveMQ, WebSocket and Stomp

websocket,activemq,stomp
I cannot manage to code a server that would listen to STOMP messages over WebSocket. My issue lies with the stomp protocol and the creation of the JMS consumers. The following code fails on createConnection class StompDemo { val uri = "ws://localhost:61614" val topicName = "mytopic" val broker = new...

Karaf is unable to resolve bundle depending on ActiveMQ feature due to multiple Joda-Time versions

apache-camel,activemq,apache-karaf
My bundle has a transative bundle dependency on Joda-Time 2.x and gets deployed via a Karaf (3.0.3) feature file. It deployed just fine until I added dependencies to the activemq-broker (5.11.1) and activemq-camel features delivered with Karaf. My bundle now fails resolution because two paths to the package "org.joda.time" are...

Extract data from JSON in vanilla Java/Camel/Spring

apache-camel,activemq,jolokia
I am trying to write a Camel route to get JMX data from an ActiveMQ server through the Jolokia REST API. I was able to successfully get the JSON object from the ActiveMQ server, but I am running into an issue where I cannot figure out how to parse the...

Camel Multicast; Direct and AMQ

java,web-services,soap,apache-camel,activemq
I have a Generic Camel Route which listens to a CXF:Bean(SOAP) Request with DataFormat: POJO. What I want this route to do is multicast the incoming exchange to AMQ JMS Queue, which will be consumed by another internal route at a later point and the other endpoint is a direct:Endpoint...

ActiveMQ: how to programmatically monitor embedded broker

activemq
I want to monitor an embedded ActiveMQ 5.8 broker from inside the code. How can this be done? Do I need a JMX connection? I want to prevent exposing JMX Is there a way of accessing org.apache.activemq.broker.jmx Beans without JMX? Are there Hooks, Listeners, Events, ... that can be attached...

Processing ActiveMQ Messages with Apache Camel and JAVA

java,apache-camel,activemq
I have a problem receiving AMQ-Messages in a JAVA-Method. I'm routing with a Camel-Route in Spring DSL like this: <camel:route> <camel:from uri="activemq:foo.bar?maxConcurrentConsumers=1"/> <camel:to uri="bean:fooService?method=handleBarEvent"/> </camel:route> My JAVA-Code looks like: package my.company.service import org.apache.activemq.Message; import org.apache.log4j.Logger; public class FooService { private static final Logger LOG = Logger.getLogger(FooService.class); public void handleBarEvent(Message in)...

Camel and ActiveMQ

java,jms,apache-camel,activemq
I´m very new on the camel world, that is why I´m asking for your help. Let me tell you what I would like to do: I have this basic Camel standalone project: package maventest1; public class JmsToSql { private Main main; public static void main(String[] args) throws Exception { JmsToSql...

risk of depending software solution to activemq

java,jms,activemq,software-distribution
I'm implementing a distributed software that have two loosely coupled component and they need to send message in a reliable and scalable way. I find activemq as a implementation of jms standard and do some research and sample implementation. my two key requirements is : scalability reliability (not losing messages)...

ActiveMQ - Security exception when creating new topic session

java,java-ee,jms,activemq
I'm learning jms and found a sample Chat application but when i try running it, I get a security exception. It seems i need to pass in username and password when creating a new topic session, but the tutorial does not mention this. Chat app code : package ch02.chat; import...

JMS Message Selector does not work

java,jms,activemq
I have a requirement to filter message based on the Message selector but it seems the consumer with messageSelector is not filtering any message. I have written below code ActiveMQUtil import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; public class ActiveMQUtil { private ConnectionFactory connectionFactory = null; private Connection connection =null; private Session session...

ActiveMQ JDBC persistence trouble: ACTIVEMQ_MSGS is always empty

java,spring,activemq
everybody! I'm trying to use JDBC persistence with ActiveMQ. So, when producer sends message, it should be saved into ACTIVEMQ_MSGS table by default. But when I check this table, it's always empty. I don't understand where the trouble is. Here is Spring XML config <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:amq="http://activemq.apache.org/schema/core"...

Starting ActiveMQ from Tomcat application ,but using a shared datasource among instances

java,spring,apache,apache-camel,activemq
I have a successfully running ActiveMQ 5.9.1 , Camel 2.11 and Tomcat 7.0.50 service layer application with a dependency on ActiveMQ to be started independently. The reason Im using ActiveMQ is to have a shared datastore among 2 same load balanced instances for faster processing. Here is what I want...

IBM MQ ISSUE in Apache Camel because Spring JMS Listener

apache-camel,activemq,ibm,spring-jms
I am new to IBM MQ with Apache camel. below is my configuration <from IBM MQ> <parallel> <to ACTIVE MQ> <to IBM MQ> </parallel> my application is running in Spring Container. some time I am getting this below warning, hence My route is not working ( IBM MQ is not...

How to use ActiveMQ in Meteor?

javascript,meteor,activemq
I'm building a Meteor application that needs to receive JMS or AMQP messages, process them, and store the results in Meteor's MongoDB. I want this all to happen on the server, not the client. I read the ActiveMQ AJAX page and that seems like a promising lead, but I don't...

Concurrent message consumption in ActiveMQ

java,jms,activemq,message-queue,messaging
I use a ActiveMQServer as a broker. Server.java import java.util.HashMap; import java.util.HashSet; import java.util.Map; import org.apache.activemq.api.core.TransportConfiguration; import org.apache.activemq.core.config.Configuration; import org.apache.activemq.core.config.impl.ConfigurationImpl; import org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory; import org.apache.activemq.core.server.ActiveMQServer; import org.apache.activemq.core.server.ActiveMQServers; public class Server { public static void...

MessageHandler for Julia

c,rabbitmq,activemq,julia-lang,message-handlers
I'm looking for a message handler for Julia, because I want to integrate it in a bigger project with other services. The other services are using RabbitMQ, but I have not been able to find any RabbitMQ or ActiveMQ drivers for Julia. Is anyone aware of a message handler driver...

Can the order in which broker's plugins execute be defined?

activemq
I need to implement 2 filters that fit in the amq:discardingDLQBrokerPlugin category, and I need one to be executed before the other. I can implement the two filter's logic in one class, but since the business logic is very different, I would prefer two. I add the filters using two...

DMLC message consumption and acknowledgement

spring,jms,activemq,spring-jms,message-listener
This is a follow up question for Difference between AUTO_ACKNOWLEDGEMENT mode with and without Spring JMS. I am using DMLC and my concurrent consumers count is 1. The prefetch limit is > 1. I received a message and it is acknowledged before listener is executed. So, while the listener is...

Intercept incoming JMS messages to ActiveMQ, reject/approve based on rules

java,jms,apache-camel,activemq
Is there a feature in ActiveMQ, perhaps with Camel, to do the following? intercept incoming message at the broker validate headers and/or body based on arbitrary rules throw exception to sender if message not validated, or.. reroute invalid messages to 'rejection' queue ...

ActiveMQ persistence: some troubles with AMQ Message Store

java,spring,activemq
I'm continuing to learn ActiveMQ, and have some question: I've read a lot ActiveMQ persistence references and docs, and noticed one thing - default message store (as I understand) is AMQ Message Store, that can be configured by such XML code snippet: <broker ...> .... <persistenceAdapter> <amqPersistenceAdapter directory="activemq-data/store" maxFileLength="10mb"/> </persistenceAdapter>...

Returning string from jms

java,jms,listener,activemq
I am writing a stand alone main method which invokes a producer (to push data into a queue), and then invokes a consumer which keeps listening to the topic. I have overridden the onMessage and I am able to get the message from the queue, but I am not able...

WebSocket messages are lost while client is reconnecting

websocket,activemq,stomp,spring-websocket
I use STOMP.js on the front end and ActiveMQ on the back end for sending push notifications to the client. The client first subscribes to a topic with the following code: function stompConnect() { console.log('STOMP: Attempting connection'); // recreate the stompClient to use a new WebSocket var socket = new...

Multiple Connection Factories

java,spring,apache-camel,activemq,javabeans
I'm using spring boot and setting up multiple connection factories (pooled and jms). The issue I'm getting is that it seems to be trying to autowire them to the same object in javax.jms.ConnectionFactory. So its resulting in this exception: Caused by: org.springframework.beans.factory.BeanCreationException: Could not autowire field: private javax.jms.ConnectionFactory org.springframework.boot.autoconfigure.jms.JmsAutoConfiguration.connectionFactory; nested...

How to Produce from MQTT and consume as MQTT and JMS in ActiveMQ

jms,activemq,mqtt
I have a setup where messages are produced as MQTT to ActiveMQ. I have two consumers one as JMS and another MQTT. When I am publishing message as JMS Message to the topic "foo", I am receiving the messages at both JMS and MQTT consumers, but when I am publishing...

ActiveMQ browser needs long time for last .hasMoreElements()

java,activemq
I try to implement a queue browser for ActiveMQ. The code shown below should display the text messages in the queue named 'Q1'. There are two messages in there. In general it works but the last e.hasMoreElements() call needs up to 20 seconds. I wanted to update the list every...

ActiveMQ and prefetch limit

jms,activemq,spring-jms
I want to understand how ApacheMQ's prefetch limit works. Are all the messages sent in one burst? What if there are concurrent consumers, what happens then? What is the difference between prefetch limit of 0 and 1?...

Cross language support in ActiveMQ

java,python,jms,activemq,stomp
I am working with several different services which have been written in Python and Java. I have now come to the point where I need to have these services communicate with each other and ActiveMQ seems to be a sensible choice. However, I am not sure I quite follow the...

Getting spring-batch to work with transactional DMLC?

java,spring,jms,activemq,spring-batch
I am trying to setup jms message listener so that it picks up a certain amount of messages from a JMS broker (ActiveMQ) within the same transaction and should any error occur, the transaction is rolled back so that all message contained within that transaction end up in DLQ, or...

SLF4J Linkage Error

java,jms,activemq,slf4j,websphere-8
I have configured JMS Provide in WebSphere Application Server that will use ActiveMQ. For sending message WebSphere needs "activemq-all-5.9.1.jar" in classpath so I added it. This "activemq-all" contains slf4j classes in it. Now my application contains "slf4j-api-1.7.5.jar". When I start WebSphere it gives Caused by: java.lang.LinkageError: org.slf4j.LoggerFactory at java.lang.ClassLoader.defineClassImpl(Native Method)...

ActiveMQ http connection error

java,http,jms,activemq,producer
I am trying to connect my java client application to ActiveMQ over http, but keep getting an error: (complete error at the bottom) javax.jms.JMSException: Could not post command: ProducerInfo No such field org.apache.activemq.command.ProducerInfo.sentCount Also, there is connection to ActiveMQ, because the server also produces an error: (complete error at the...

Notify ActiveMQ producer if consumer on the destination is down

spring,jms,activemq,spring-jms
I am using ActiveMQ messaging broker and I have a requirement where the producer application would want to know if the consumer application consuming on the particular destination is up or not? How can I achieve this? Thanks!...

How do I limit the amount of times a JMS DefaultMessageListenerContainer will retry a message in ActiveMQ?

spring-boot,activemq
How do I limit the amount of times a JMS DefaultMessageListenerContainer will retry a message with SpringBoot and ActiveMQ.( I know we can achieve this using JMSXDeliveryCount property in IBM MQ messageListener).

Filter / drop duplicate messages from ActiveMQ queue based on custom properties

jms,apache-camel,activemq
Problem When my web application updates an item in the database, it sends a message containing the item ID via Camel onto an ActiveMQ queue, the consumer of which will get an external service (Solr) updated. The external service reads from the database independently. What I want is that if...

What does vm prefix mean in the address line?

java,jms,activemq
I'm going through the Apache ActiveMQ example and faced the vm prefix as follows: ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://localhost"); What does that mean? By the way, when I connect to the mesasge broker I basically use an address like tcp://localhost:61616....