Re: Unable to consume all messages from the existing connection

2016-02-10 Thread Timothy Bish
On 02/10/2016 04:53 PM, Ramababu Bendalam wrote: > HI Tim, > > Thank you for your reply. I have tried using pooled connections, but i do > not find any option to get the existing connections. If you have any code > related to that can you share it. Also please let me know how to use the > reference

Re: Unable to consume all messages from the existing connection

2016-02-10 Thread Ramababu Bendalam
HI Tim, Thank you for your reply. I have tried using pooled connections, but i do not find any option to get the existing connections. If you have any code related to that can you share it. Also please let me know how to use the reference of the existing connection using code. -- View this mess

Re: Unable to consume all messages from the existing connection

2016-02-10 Thread Timothy Bish
On 02/10/2016 04:01 PM, Tim Bain wrote: > If you have a reference to an existing Connection and you want to reuse it, > just use that instead of calling connectionFactory.createConnection() to > create a new connection (as stated right in the method name). Nothing > requires you to create a new Co

Re: Unable to consume all messages from the existing connection

2016-02-10 Thread Tim Bain
If you have a reference to an existing Connection and you want to reuse it, just use that instead of calling connectionFactory.createConnection() to create a new connection (as stated right in the method name). Nothing requires you to create a new Connection if you already have one that will meet

Re: Unable to consume all messages from the existing connection

2016-02-10 Thread Ramababu Bendalam
Connection connection; Destination queue; Consumer consumer; ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://:61616"); connection = connectionFactory.createConnection(); connection.start(); session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); cons

Re: Unable to consume all messages from the existing connection

2016-02-09 Thread Timothy Bish
On 02/09/2016 01:07 PM, Ramababu Bendalam wrote: > Hi All, > > Below is my scenario. > > >From consumer side, I already have a connector. When I am using > connectionfactory to consume messages, it creates a new connection with my > local host name. Due to this the messages consumed are distributed