qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Stephen" <regis...@inode.serveftp.com>
Subject Stress C++ broker without flow control
Date Tue, 03 Mar 2009 08:41:17 GMT
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


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
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message