qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gordon Sim <g...@redhat.com>
Subject Re: Stress C++ broker without flow control
Date Tue, 03 Mar 2009 09:53:40 GMT
Stephen wrote:
> Hi all,
> 
> I am stressing C++ broker with Java Client
> In each test, the Java Client sends 50000 continuously.
> If the deliverymode is msg.setJMSDeliveryMode(DeliveryMode.NON_PERSISTENT), the receiver
looks OK.
> but if using msg.setJMSDeliveryMode(DeliveryMode.PERSISTENT), the broker console throws
the following exception

Were there any errors prior to these in the broker log, or were these
the only ones?

> 
> 
> 2009-mar-03 16:13:11 error Channel exception: not-attached: receiving Frame[BEbe; channel=1;
{ExchangeDeclareBody: exchange=development; type=direct; alternate-exchange=; arguments={};
}]: channel 1 is not attached (qpid/amqp_0_10/SessionHandler.cpp:79)
> 2009-mar-03 16:13:11 error Channel exception: not-attached: receiving Frame[BEbe; channel=1;
{QueueDeclareBody: queue=admin_in; alternate-exchange=; durable=1; arguments={}; }]: channel
1 is not attached (qpid/amqp_0_10/SessionHandler.cpp:79)
> 2009-mar-03 16:13:11 error Channel exception: not-attached: receiving Frame[BEbe; channel=1;
{ExchangeBindBody: queue=admin_in; exchange=development; binding-key=admin_in; arguments={x-match:V2:3:str16(any)};
}]: channel 1 is not attached (qpid/amqp_0_10/SessionHandler.cpp:79)
> 2009-mar-03 16:13:11 error Channel exception: not-attached: receiving Frame[BEbe; channel=1;
{MessageSubscribeBody: queue=admin_in; destination=2; accept-mode=0; acquire-mode=0; resume-id=;
resume-ttl=0; arguments={}; }]: channel 1 is not attached (qpid/amqp_0_10/SessionHandler.cpp:79)
> 2009-mar-03 16:13:11 error Channel exception: not-attached: receiving Frame[BEbe; channel=1;
{MessageSetFlowModeBody: destination=2; flow-mode=1; }]: channel 1 is not attached (qpid/amqp_0_10/SessionHandler.cpp:79)
> 2009-mar-03 16:13:11 error Channel exception: not-attached: receiving Frame[BEbe; channel=1;
{MessageFlowBody: destination=2; unit=1; value=4294967295; }]: channel 1 is not attached (qpid/amqp_0_10/SessionHandler.cpp:79)
> 2009-mar-03 16:13:11 error Channel exception: not-attached: receiving Frame[BEbe; channel=1;
{MessageFlowBody: destination=2; unit=0; value=5000; }]: channel 1 is not attached (qpid/amqp_0_10/SessionHandler.cpp:79)
> 
> and the client side sees the following error
> 
> Any suggestion?
> 
> Regards,
> Stephen
> 
> -----Java Client Exception-----
> 
> 161349.447 INFO  QueueSender error at 32459
> org.springframework.jms.UncategorizedJmsException: Uncategorized exception occured during
JMS processing; nested exception is javax.jms.JMSException:
>  Exception when sending message; nested exception is org.apache.qpid.transport.SessionException:
timed out waiting for session to become open (state=
> DETACHED)
>         at org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsUtils.java:308)
>         at org.springframework.jms.support.JmsAccessor.convertJmsAccessException(JmsAccessor.java:168)
>         at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:474)
>         at org.springframework.jms.core.JmsTemplate.send(JmsTemplate.java:539)
>         at com.inode.message.SimpleSender.send(SimpleSender.java:34)
>         at com.inode.test.QueueSender.testSend(QueueSender.java:34)
>         at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>         at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
>         at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
>         at java.lang.reflect.Method.invoke(Method.java:597)
>         at org.springframework.test.context.junit4.SpringTestMethod.invoke(SpringTestMethod.java:198)
>         at org.springframework.test.context.junit4.SpringMethodRoadie.runTestMethod(SpringMethodRoadie.java:274)
>         at org.springframework.test.context.junit4.SpringMethodRoadie$2.run(SpringMethodRoadie.java:207)
>         at org.springframework.test.context.junit4.SpringMethodRoadie.runBeforesThenTestThenAfters(SpringMethodRoadie.java:254)
>         at org.springframework.test.context.junit4.SpringMethodRoadie.runWithRepetitions(SpringMethodRoadie.java:234)
>         at org.springframework.test.context.junit4.SpringMethodRoadie.runTest(SpringMethodRoadie.java:204)
>         at org.springframework.test.context.junit4.SpringMethodRoadie.run(SpringMethodRoadie.java:146)
>         at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.invokeTestMethod(SpringJUnit4ClassRunner.java:151)
>         at org.junit.internal.runners.JUnit4ClassRunner.runMethods(JUnit4ClassRunner.java:59)
>         at org.junit.internal.runners.JUnit4ClassRunner$1.run(JUnit4ClassRunner.java:52)
>         at org.junit.internal.runners.ClassRoadie.runUnprotected(ClassRoadie.java:34)
>         at org.junit.internal.runners.ClassRoadie.runProtected(ClassRoadie.java:44)
>         at org.junit.internal.runners.JUnit4ClassRunner.run(JUnit4ClassRunner.java:50)
>         at org.apache.maven.surefire.junit4.JUnit4TestSet.execute(JUnit4TestSet.java:62)
>         at org.apache.maven.surefire.suite.AbstractDirectoryTestSuite.executeTestSet(AbstractDirectoryTestSuite.java:140)
>         at org.apache.maven.surefire.suite.AbstractDirectoryTestSuite.execute(AbstractDirectoryTestSuite.java:127)
>         at org.apache.maven.surefire.Surefire.run(Surefire.java:177)
>         at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>         at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
>         at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
>         at java.lang.reflect.Method.invoke(Method.java:597)
>         at org.apache.maven.surefire.booter.SurefireBooter.runSuitesInProcess(SurefireBooter.java:338)
>         at org.apache.maven.surefire.booter.SurefireBooter.main(SurefireBooter.java:997)
> Caused by: javax.jms.JMSException: Exception when sending message
>         at org.apache.qpid.client.BasicMessageProducer_0_10.sendMessage(BasicMessageProducer_0_10.java:177)
>         at org.apache.qpid.client.BasicMessageProducer.sendImpl(BasicMessageProducer.java:489)
>         at org.apache.qpid.client.BasicMessageProducer.sendImpl(BasicMessageProducer.java:444)
>         at org.apache.qpid.client.BasicMessageProducer.send(BasicMessageProducer.java:313)
>         at org.springframework.jms.connection.CachedMessageProducer.send(CachedMessageProducer.java:117)
>         at org.springframework.jms.core.JmsTemplate.doSend(JmsTemplate.java:597)
>         at org.springframework.jms.core.JmsTemplate.doSend(JmsTemplate.java:574)
>         at org.springframework.jms.core.JmsTemplate$3.doInJms(JmsTemplate.java:541)
>         at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:471)
>         ... 30 more
> Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 64.566 sec


---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org


Mime
View raw message