This still has an issue with getting a consistent read. I will update this once I figure that piece out… import org.apache.activemq.*; import java.util.*; import org.apache.activemq.advisory.DestinationSource; import javax.jms.*; import javax.naming.*; import org.apache.activemq.*; import org.apache.activemq.command.ActiveMQQueue; public class ListQueues { public static…
Category: ActiveMQ
What happens to topic message if all non durable consumers fail?
No one receives it. “Nondurable subscribers receive messages only when they are actively listening on that topic. Otherwise, the message is gone. In the pub/sub model, there is no real concept of a “topic” holding all of the messages; rather,…
Listing queues and topics in ActiveMQ
This will provide the list of queues and topics managed by an ActiveMQ broker… import javax.jms.*; import java.io.*; import java.util.*; import org.apache.activemq.*; import org.apache.activemq.command.*; import org.apache.activemq.advisory.*; public class GetDestinations { private static String url = ActiveMQConnection.DEFAULT_BROKER_URL; public static void main(String[]…
Testing ActiveMQ with JMeter
Create a normal JMeter test with a ThreadGroup. Add a JMS Point to Point component, as shown below… Add the following configurations, which I couldn’t show in a single window (not enough space). In Apache 2.11, ActiveMQ libraries must already…
Where does ActiveMQ store subscriber information?
After subscribing, you will see an entry in the ACTIVEMQ_ACKS table… SQL> select container,client_id from esb.activemq_acks; CONTAINER CLIENT_ID —————————————- —————————————- topic://testTopic me topic://testTopic mysubscriber topic://testTopic mysubscriber2 SQL> Once unsubscribe has been run on the subscriber… ConnectionFactory connectionFactory=new ActiveMQConnectionFactory(“admin”, “admin”, “tcp://localhost:61616”);…