nection.setClientID("myClient");
>>> > session = connection.createSession(false,
>>> > Session.AUTO_ACKNOWLEDGE);
>>> > topic = session.createTopic("topictest.messages");
>>> > control = session.createTopic("t
>> >
>> > TopicSubscriber consumer =
>> > session.createDurableSubscriber(topic,"myDurable1");
>> > //MessageConsumer consumer = session.createConsumer(topic);
>> > consumer.setMessage
producer = session.createProducer(control);
> >
> > System.out.println("Waiting for messages...");
> > connection.start();
> > }
> >
> ----
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&qu
t; Exception in thread "ActiveMQ Session Task"
>> java.util.concurrent.RejectedExecutionException
>>at
>>
>> java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(Unknown
>> Source)
>>at java.util.concurrent.ThreadPoolExecutor.rej
ROTECTED]> wrote:
>
> Hi,
>
> I'm new to ActiveMQ and having problem with durable subscription, following
> code based on example code,
>
> ===
> public void run() throws JMSException {
>
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
ActiveMQConnectionFa
