You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@qpid.apache.org by Rajith Attapattu <ra...@gmail.com> on 2006/12/06 20:37:30 UTC
[java]Connection to the broker hangs
Hi All,
The connection to the broker hangs.
I suspect a recent changes to security might have caused this.
Any ideas ???
This is the log message I see
[java] (client.AMQConnection 177 )
Connection:amqp://guest:guest@clientid
/testpath?brokerlist='tcp://localhost:5672'
[java] (transport.TransportConnection 128 ) Using Mina NIO
[java] (transport.SocketTransportConnection 80 ) send-buffer-size =
32768
[java] (transport.SocketTransportConnection 82 ) recv-buffer-size =
32768
[java] (transport.SocketTransportConnection 85 ) Attempting connection
to localhost/127.0.0.1:5672
[java] (security.CallbackHandlerRegistry 66 ) Available SASL
mechanisms: CRAM-MD5 PLAIN
Regards,
Rajith
Re: [java]Connection to the broker hangs
Posted by Gordon Sim <gs...@redhat.com>.
Rajith Attapattu wrote:
> Can u guys test and let me know.
I have run the serviceProvidingClient and a serviceRequestingClient
without any problems if that helps.
Re: [java]Connection to the broker hangs
Posted by Rajith Attapattu <ra...@gmail.com>.
I did a thread dump and here are the results and thanks robert for trying to
slove this.
[java] "main" prio=1 tid=0x09c0b820 nid=0xde7 in Object.wait()
[0xbfd55000..0xbfd55e08]
[java] at java.lang.Object.wait(Native Method)
[java] - waiting on <0x890bc4c0> (a java.lang.Object)
[java] at java.lang.Object.wait(Object.java:474)
[java] at
org.apache.qpid.client.state.StateWaiter.waituntilStateHasChanged(
StateWaiter.java:60)
[java] - locked <0x890bc4c0> (a java.lang.Object)
[java] at org.apache.qpid.client.state.AMQStateManager.attainState(
AMQStateManager.java:223)
[java] at
org.apache.qpid.client.protocol.AMQProtocolHandler.attainState(
AMQProtocolHandler.java:385)
[java] at org.apache.qpid.client.AMQConnection.makeBrokerConnection
(AMQConnection.java:309)
[java] at org.apache.qpid.client.AMQConnection.<init>(
AMQConnection.java:206)
[java] at
org.apache.qpid.client.AMQConnectionFactory.createConnection(
AMQConnectionFactory.java:264)
[java] at
org.apache.qpid.client.AMQConnectionFactory.createTopicConnection(
AMQConnectionFactory.java:296)
On the server side there were no problems as far as I can see (after
enablinf DEBUG)
I tested with ServiceProvidingClient and have pasted the log and partial
thread dump.
ain 2006-12-06 06:59:23,641 DEBUG [apache.qpid.framing.AMQDataBlockEncoder]
Encoded frame byte-buffer is
'0x0100010000000f003c00140000055155455545013109ce'
AnonymousIoService-16 2006-12-06 06:59:23,646 DEBUG [
qpid.client.protocol.AMQProtocolHandler] Sent frame Frame channelId: 1,
bodyFrame: class org.apache.qpid.framing.BasicConsumeBody Class: 60 Method:
20 ticket: 0 queue: QUEUE consumerTag: 1 noLocal: true noAck: false
exclusive: false nowait: true
main 2006-12-06 06:59:23,806 DEBUG [apache.qpid.client.BasicMessageConsumer]
Message listener set for destination
direct://amq.direct/QUEUE/QUEUE?durable='true'
main 2006-12-06 06:59:23,808 INFO [
apache.qpid.requestreply1.ServiceProvidingClient] Waiting...
Full thread dump Java HotSpot(TM) Client VM (1.5.0_09-b03 mixed mode):
"DestroyJavaVM" prio=1 tid=0x0a018e28 nid=0x11a1 waiting on condition
[0x00000000..0xbf936c70]
"Dispatcher-Channel-1" daemon prio=1 tid=0x0a3b6f00 nid=0x11e0 waiting on
condition [0xa8519000..0xa8519f30]
at sun.misc.Unsafe.park(Native Method)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:118)
at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(
AbstractQueuedSynchronizer.java:1767)
at java.util.concurrent.LinkedBlockingQueue.take(
LinkedBlockingQueue.java:359)
at org.apache.qpid.client.util.FlowControllingBlockingQueue.take(
FlowControllingBlockingQueue.java:74)
at org.apache.qpid.client.AMQSession$Dispatcher.run(AMQSession.java:133)
Can u guys test and let me know.
thanks,
Rajith
On 12/6/06, Rajith Attapattu <ra...@gmail.com> wrote:
>
> The connection thread will then time out.
>
> Rajith
>
> On 12/6/06, Rajith Attapattu <ra...@gmail.com> wrote:
> >
> > Hi All,
> >
> > The connection to the broker hangs.
> > I suspect a recent changes to security might have caused this.
> >
> > Any ideas ???
> > This is the log message I see
> >
> >
> > [java] (client.AMQConnection 177 )
> > Connection:amqp://guest:guest@clientid
> > /testpath?brokerlist='tcp://localhost:5672'
> > [java] (transport.TransportConnection 128 ) Using Mina NIO
> > [java] (transport.SocketTransportConnection 80 ) send-buffer-size
> > = 32768
> > [java] (transport.SocketTransportConnection 82 ) recv-buffer-size
> > = 32768
> > [java] (transport.SocketTransportConnection 85 ) Attempting
> > connection to localhost/127.0.0.1:5672
> > [java] (security.CallbackHandlerRegistry 66 ) Available SASL
> > mechanisms: CRAM-MD5 PLAIN
> >
> >
> >
> > Regards,
> >
> > Rajith
> >
>
>
Re: [java]Connection to the broker hangs
Posted by Rajith Attapattu <ra...@gmail.com>.
The connection thread will then time out.
Rajith
On 12/6/06, Rajith Attapattu <ra...@gmail.com> wrote:
>
> Hi All,
>
> The connection to the broker hangs.
> I suspect a recent changes to security might have caused this.
>
> Any ideas ???
> This is the log message I see
>
>
> [java] (client.AMQConnection 177 )
> Connection:amqp://guest:guest@clientid
> /testpath?brokerlist='tcp://localhost:5672'
> [java] (transport.TransportConnection 128 ) Using Mina NIO
> [java] (transport.SocketTransportConnection 80 ) send-buffer-size =
> 32768
> [java] (transport.SocketTransportConnection 82 ) recv-buffer-size =
> 32768
> [java] (transport.SocketTransportConnection 85 ) Attempting
> connection to localhost/127.0.0.1:5672
> [java] (security.CallbackHandlerRegistry 66 ) Available SASL
> mechanisms: CRAM-MD5 PLAIN
>
>
>
> Regards,
>
> Rajith
>