his.session.createConsumer(this.session.createQueue(queueName));
>
> this.consumer.setMessageListener(this);
> }
> catch(final Exception e){e.printStackTrace();}
> }
>
> @Override
> public void onMessage(final Message message_)
> {
> try
> {
> if(message_.getStringProperty("END") == null)
> {
>System.out.println("Received messaage #" + this.msgNumber);
>
>this.msgNumber++;
> }
> else
> {
>if(this.consumer != null)
>{
> try{this.consumer.close();}
> catch(final JMSException e){e.printStackTrace();}
>}
>
>if(this.session != null)
>{
> try{this.session.close();}
> catch(final JMSException e){e.printStackTrace();}
>}
>
>if(this.connection != null)
>{
> try{this.connection.close();}
> catch(final JMSException e) {e.printStackTrace();}
>}
> }
> }
> catch(final JMSException e2){e2.printStackTrace();}
> }
> }
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Messages-not-being-removed-from-networked-queue-tp3936864p3936864.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
.close();}
catch(final JMSException e){e.printStackTrace();}
}
if(this.connection != null)
{
try{this.connection.close();}
catch(final JMSException e) {e.printStackTrace();}
}
}
}
catch(final JMSException e2){e2.printStackTrace();}
}
}
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Messages-not-being-removed-from-networked-queue-tp3936864p3936864.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
