Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@activemq.apache.org
Received-SPF: pass (athena.apache.org: domain of bruce.snyder@gmail.com
 designates 209.85.218.221 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:in-reply-to:references:date:message-id:subject:from:to
         :content-type:content-transfer-encoding;
        b=GNNyS0juRr8xQZ/WjHXpnS7K/MQWeH+VgImZFJ4srHG2y2MBJHLD/wzstU0sZIeK1J
         iL/fdcicirZmmrIRcQi7jHOEiSB1g411tTNJ9uoG0uNXQ1SSzjD7D95WLTUSFTebqO1i
         mvDxFzcIzyRl5KQhTz6wyl5T4XQZLXl5F0Df4=
MIME-Version: 1.0
In-Reply-To: <23457831.post@talk.nabble.com>
References: <23457831.post@talk.nabble.com>
Date: Sat, 9 May 2009 07:51:44 -0600
Message-ID: <7b3355cb0905090651j6a627163l6562154795d9816@mail.gmail.com>
Subject: Re: ActiveMQ load test with Jmeter
From: Bruce Snyder <bruce.snyder@gmail.com>
To: dev@activemq.apache.org
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

On Sat, May 9, 2009 at 12:52 AM, yogesh.patel229
<yogesh.patel229@gmail.com> wrote:
>
> In our application we have used ActiveMQ5.2 with Spring JMSTemplate.we ar=
e
> using Queue.when i am giving thousands of threads through JMeter its givi=
ng
> error like
> (1)."(Transport:229): Transport failed:
> org.apache.activemq.transport.InactivityIOException: Channel was inactive
> for too long: /127.0.0.1:2488
> org.apache.activemq.transport.InactivityIOException: Channel was inactive
> for too long: /127.0.0.1:2488
> =A0 =A0 =A0 =A0at
> org.apache.activemq.transport.InactivityMonitor$4.run(InactivityMonitor.j=
ava:164)
> =A0 =A0 =A0 =A0at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(=
Unknown Source)
> =A0 =A0 =A0 =A0at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unkn=
own Source)
> =A0 =A0 =A0 =A0at java.lang.Thread.run(Unknown Source)"
> (2)."java.io.IOException: Wire format negotiation timeout: peer did not s=
end
> his wire format.
> =A0 =A0 =A0 =A0at
> org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegot=
iator.java:94)
> =A0 =A0 =A0 =A0at
> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:4=
0)
> =A0 =A0 =A0 =A0at
> org.apache.activemq.broker.TransportConnection.dispatch(TransportConnecti=
on.java:1207)
> =A0 =A0 =A0 =A0at
> rg.apache.activemq.broker.TransportConnection.processDispatch(TransportCo=
nnection.java:793)
> =A0 =A0 =A0 =A0at
> org.apache.activemq.broker.TransportConnection.iterate(TransportConnectio=
n.java:830)
> =A0 =A0 =A0 =A0at
> org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java=
:122)
> =A0 =A0 =A0 =A0at
> org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:4=
3)
> =A0 =A0 =A0 =A0at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(=
Unknown Source)
> =A0 =A0 =A0 =A0at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unkn=
own Source)
> =A0 =A0 =A0 =A0at java.lang.Thread.run(Unknown Source) "
>
> (3)."Transport failed: java.io.IOException: Wire format negotiation timeo=
ut:
> peer did not send his wire format.
> java.io.IOException: Wire format negotiation timeout: peer did not send h=
is
> wire format.
> =A0 =A0 =A0 =A0at
> org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegot=
iator.java:94)
> =A0 =A0 =A0 =A0at
> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:4=
0)
> =A0 =A0 =A0 =A0at
> org.apache.activemq.broker.TransportConnection.dispatch(TransportConnecti=
on.java:1207)
> =A0 =A0 =A0 =A0at
> rg.apache.activemq.broker.TransportConnection.processDispatch(TransportCo=
nnection.java:793)
> =A0 =A0 =A0 =A0at
> org.apache.activemq.broker.TransportConnection.iterate(TransportConnectio=
n.java:830)
> =A0 =A0 =A0 =A0at
> org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java=
:122)
> =A0 =A0 =A0 =A0at
> org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:4=
3)
> =A0 =A0 =A0 =A0at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(=
Unknown Source)
> =A0 =A0 =A0 =A0at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unkn=
own Source)
> =A0 =A0 =A0 =A0at java.lang.Thread.run(Unknown Source)"
>
> can you please tell me why this errors occurs and how to solve this error=
s.

What URI are the clients using to connect to the broker? Also, are you
using a pooled or cached connection for the JMSTemplate? Please see
the following info about the JMSTemplate:

http://activemq.apache.org/jmstemplate-gotchas.html

Bruce
--=20
perl -e 'print unpack("u30","D0G)U8V4\@4VYY9&5R\"F)R=3D6-E+G-N>61E<D\!G;6%I=
;\"YC;VT*"
);'

ActiveMQ in Action: http://bit.ly/2je6cQ
Blog: http://bruceblog.org/
Twitter: http://twitter.com/brucesnyder