Hi,
I'm new to ActiveMQ and having problem with durable subscription, following
code based on example code,
===================================================================
public void run() throws JMSException {
ActiveMQConnectionFactory factory = new
ActiveMQConnectionFactory(url);
connection = factory.createConnection();
connection.setClientID("myClient");
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
topic = session.createTopic("topictest.messages");
control = session.createTopic("topictest.control");
TopicSubscriber consumer =
session.createDurableSubscriber(topic,"myDurable1");
//MessageConsumer consumer = session.createConsumer(topic);
consumer.setMessageListener(this);
producer = session.createProducer(control);
System.out.println("Waiting for messages...");
connection.start();
}
=================================================================
is causing exceptions on broker side and client side, below are the
exceptions
broker side:
ERROR Service - Async error occurred:
java.lang.NullPointerException
java.lang.NullPointerException
at
org.apache.activemq.broker.TransportConnection.processAddProducer(TransportConnection.java:479)
at
org.apache.activemq.command.ProducerInfo.visit(ProducerInfo.java:105)
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:292)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:180)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:143)
at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:206)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:196)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:183)
at java.lang.Thread.run(Thread.java:619)
client side:
Exception in thread "ActiveMQ Session Task"
java.util.concurrent.RejectedExecutionException
at
java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(Unknown
Source)
at java.util.concurrent.ThreadPoolExecutor.reject(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor.execute(Unknown Source)
at
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:144)
at
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown
Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)
Any idea? Thanks in advance!
--
View this message in context:
http://www.nabble.com/having-problem-with-durable-subscription-tp17813954p17813954.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
