From users-return-16738-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org Fri Oct 31 20:22:21 2008 Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 1673 invoked from network); 31 Oct 2008 20:22:21 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 31 Oct 2008 20:22:21 -0000 Received: (qmail 77546 invoked by uid 500); 31 Oct 2008 20:22:25 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 77530 invoked by uid 500); 31 Oct 2008 20:22:25 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 77519 invoked by uid 99); 31 Oct 2008 20:22:25 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 31 Oct 2008 13:22:25 -0700 X-ASF-Spam-Status: No, hits=-0.0 required=10.0 tests=SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of marcelo@datacom.ind.br designates 200.213.13.18 as permitted sender) Received: from [200.213.13.18] (HELO mail.datacom-telematica.com.br) (200.213.13.18) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 31 Oct 2008 20:21:10 +0000 Received: by mail.datacom-telematica.com.br (Postfix, from userid 65) id F29FA2ACC8; Fri, 31 Oct 2008 18:21:48 -0200 (BRST) Received: from [176.16.10.10] (unknown [176.16.10.10]) by mail.datacom-telematica.com.br (Postfix) with ESMTP id AD0A22ACC6 for ; Fri, 31 Oct 2008 18:21:48 -0200 (BRST) Message-ID: <490B699E.5030207@datacom.ind.br> Date: Fri, 31 Oct 2008 18:25:02 -0200 From: Datacom - Marcelo Reply-To: marcelo@datacom.ind.br User-Agent: Thunderbird 2.0.0.17 (Windows/20080914) MIME-Version: 1.0 To: users@activemq.apache.org Subject: Re: NIO freezes client References: <490B4385.9080703@datacom.ind.br> <3B84533A-A06F-46A0-869A-8F3AF298F22B@gmail.com> In-Reply-To: <3B84533A-A06F-46A0-869A-8F3AF298F22B@gmail.com> Content-Type: text/plain; charset=ISO-8859-1; format=flowed Content-Transfer-Encoding: 7bit X-Virus-Checked: Checked by ClamAV on apache.org After changing clients to tcp and let broker to nio it passes the freeze point but crashes with this log in client: (common.messaging.SessionMessage) is our class not from activemq. ........ [org.apache.activemq.transport.WireFormatNegotiator] DEBUG: Sending: WireFormatInfo { version=3, properties={CacheSize=1024, CacheEnabled=true, SizePrefixDisabled=false, MaxInactivityDurationInitalDelay=10000, TcpNoDelayEnabled=true, MaxInactivityDuration=30000, TightEncodingEnabled=true, StackTraceEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} [31/10/2008 17:21:39] [common.messaging.SessionMessage] DEBUG: Created connection.. [31/10/2008 17:21:39] [org.apache.activemq.transport.tcp.TcpTransport] DEBUG: TCP consumer thread starting [31/10/2008 17:21:49] [org.apache.activemq.transport.InactivityMonitor] DEBUG: Message received since last read check, resetting flag: [31/10/2008 17:21:49] [org.apache.activemq.transport.InactivityMonitor] DEBUG: Message sent since last write check, resetting flag [31/10/2008 17:21:49] [common.messaging.SessionMessage] ERROR: Error initializing Message Client. Will sleep and try again. Retry:1 Verify if JMS server is running. javax.jms.JMSException: Wire format negotiation timeout: peer did not send his wire format. at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62) at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1206) at org.apache.activemq.ActiveMQConnection.ensureConnectionInfoSent(ActiveMQConnection.java:1289) at org.apache.activemq.ActiveMQConnection.createSession(ActiveMQConnection.java:295) at org.apache.activemq.ActiveMQConnection.createTopicSession(ActiveMQConnection.java:998) Rob Davies escreveu: > Use tcp:// for the clients - nio works for the broker only > > On 31 Oct 2008, at 17:42, Datacom - Marcelo wrote: > >> Hi, we are using AMQ 5.1.0 and tried to change from Openwire to NIO >> changing from >> >> > uri="tcp://localhost:61616?wireFormat.maxInactivityDuration=30000"/> >> >> >> to >> >> >> > uri="nio://localhost:61616?wireFormat.maxInactivityDuration=30000"/> >> >> >> the server starts perfectly but all the clients freezes and no >> message is transmited. The client URI changes from: >> "tcp://localhost:61616" to "nio://localhost:61616" >> >> Enabling log in server all lines are identicall in the begining, >> changing in: >> >> WORKING (tcp) >> 2008-10-31 14:24:25,468 [/127.0.0.1:2826] DEBUG >> WireFormatNegotiator - Sending: WireFormatInfo { version=3, >> properties={CacheSize=1024, CacheEnabled=true, >> SizePrefixDisabled=false, MaxInactivityDurationInitalDelay=10000, >> TcpNoDelayEnabled=true, MaxInactivityDuration=30000, >> TightEncodingEnabled=true, StackTraceEnabled=true}, >> magic=[A,c,t,i,v,e,M,Q]} >> >> NON-WORKING (nio) >> >> 2008-10-31 14:20:11,250 [itor WriteCheck] DEBUG >> InactivityMonitor - 10000 ms elapsed since last write >> check. >> >> >> And the client freezes. >> >> Are there any limitation to use nio ? We are using >> publisher/subscriber messages. >> >> Thanks in advance. >> >> -- >> MARCELO Ribeiro >> >> > > -- MARCELO Ribeiro