Thanks Rob for the Quick response I'll check with the latest RC. In my case
i m using Qpid v 0.10
regards,
Charith
On Fri, May 11, 2012 at 3:02 PM, Rob Godfrey <rob.j.godf...@gmail.com>wrote:
> Hi Charith,
>
> can you confirm which release version of the Java Broker you are using
> (it's always worth trying the latest version - in this case I'd grab
> the latest 0.16 RC that Justin posted a couple of days ago - though
> I'm not aware of any bugs that would cause this error)?
>
> It would also help if you could send full broker log files that are
> generated when this occurs - the best way is to raise a JIRA and
> attach the log file there (stripped of any confidential information it
> might contain - obviously).
>
> Cheers,
> Rob
>
> On 11 May 2012 11:24, Charith Wickramarachchi
> <charith.dhanus...@gmail.com> wrote:
> > Hi,
> >
> > I m using qpid java jms client to publish and consume messages from a
> queue
> > in Qpid java broker.
> > When my application polling messages from a queue. Broker gives out a
> > warning :
> >
> > WARN
> >
> {org.apache.qpid.server.subscription.ExplicitAcceptDispositionChangeListener}
> > - MessageAccept received for message which has not been acquired (likely
> > client error)
> >
> > And if continue this publish poll scenario for some time i can see
> > following log in the Broker logs.
> >
> > {org.apache.qpid.transport.network.mina.MINANetworkDriver} - Exception
> > thrown and no ProtocolEngine to handle it
> > org.apache.qpid.transport.ProtocolViolationException: Received frames for
> > an already dettached session
> > at
> > org.apache.qpid.transport.Connection.dispatch(Connection.java:408)
> > at
> >
> org.apache.qpid.transport.ConnectionDelegate.handle(ConnectionDelegate.java:64)
> >
> > at
> >
> org.apache.qpid.transport.ConnectionDelegate.handle(ConnectionDelegate.java:40)
> >
> > at
> >
> org.apache.qpid.transport.MethodDelegate.sessionKnownCompleted(MethodDelegate.java:95)
> >
> > at
> >
> org.apache.qpid.transport.SessionKnownCompleted.dispatch(SessionKnownCompleted.java:96)
> >
> > at
> >
> org.apache.qpid.transport.ConnectionDelegate.control(ConnectionDelegate.java:49)
> >
> > at
> >
> org.apache.qpid.transport.ConnectionDelegate.control(ConnectionDelegate.java:40)
> >
> > at org.apache.qpid.transport.Method.delegate(Method.java:163)
> > at
> > org.apache.qpid.transport.Connection.received(Connection.java:369)
> > at
> >
> org.apache.qpid.server.transport.ServerConnection.received(ServerConnection.java:196)
> >
> > at
> >
> org.apache.qpid.server.transport.ServerConnection.received(ServerConnection.java:53)
> >
> > at
> > org.apache.qpid.transport.network.Assembler.emit(Assembler.java:95)
> > at
> > org.apache.qpid.transport.network.Assembler.assemble(Assembler.java:181)
> > at
> > org.apache.qpid.transport.network.Assembler.frame(Assembler.java:129)
> > at
> org.apache.qpid.transport.network.Frame.delegate(Frame.java:133)
> > at
> > org.apache.qpid.transport.network.Assembler.received(Assembler.java:100)
> > at
> > org.apache.qpid.transport.network.Assembler.received(Assembler.java:42)
> > at
> >
> org.apache.qpid.transport.network.InputHandler.next(InputHandler.java:187)
> > at
> >
> org.apache.qpid.transport.network.InputHandler.received(InputHandler.java:103)
> >
> > at
> >
> org.apache.qpid.transport.network.InputHandler.received(InputHandler.java:42)
> >
> > at
> >
> org.apache.qpid.server.protocol.MultiVersionProtocolEngine.received(MultiVersionProtocolEngine.java:102)
> >
> > at
> >
> org.apache.qpid.server.protocol.MultiVersionProtocolEngine.received(MultiVersionProtocolEngine.java:36)
> >
> > at
> >
> org.apache.qpid.transport.network.mina.MINANetworkDriver.messageReceived(MINANetworkDriver.java:337)
> >
> > at
> >
> org.apache.mina.common.support.AbstractIoFilterChain$TailFilter.messageReceived(AbstractIoFilterChain.java:703)
> >
> > at
> >
> org.apache.mina.common.support.AbstractIoFilterChain.callNextMessageReceived(AbstractIoFilterChain.java:362)
> >
> > at
> >
> org.apache.mina.common.support.AbstractIoFilterChain.access$1200(AbstractIoFilterChain.java:54)
> >
> > at
> >
> org.apache.mina.common.support.AbstractIoFilterChain$EntryImpl$1.messageReceived(AbstractIoFilterChain.java:800)
> >
> > at
> >
> org.apache.mina.filter.executor.ExecutorFilter.processEvent(ExecutorFilter.java:243)
> >
> > at
> >
> org.apache.mina.filter.executor.ExecutorFilter$ProcessEventsRunnable.run(ExecutorFilter.java:305)
> >
> > at
> >
> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1061)
> >
> > at
> >
> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:575)
> >
> > at java.lang.Thread.run(Thread.java:662)
> >
> >
> >
> > My Polling message logic looks like :
> >
> > Connection con = // create Connection
> > Session session =
> con.createSession(false,Session.AUTO_ACKNOWLEDGE);
> > Destination destination = context.lookup(name);
> > MessageConsumer consumer =session.createConsumer(destination);
> > Object msg = consumer.receive(1000);
> >
> >
> > Any idea on whats happening and how to overcome this issue is highly
> > appreciated.
> >
> >
> > thanks,
> > Charith
> >
> >
> >
> >
> > --
> > Charith Dhanushka Wickramarachchi
> > http://charithwiki.blogspot.com/
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: dev-unsubscr...@qpid.apache.org
> For additional commands, e-mail: dev-h...@qpid.apache.org
>
>
--
Charith Dhanushka Wickramarachchi
http://charithwiki.blogspot.com/
