Even Java Spout Example is giving the following exception while running with
c++ broker.
*Queue Config:*
que --durable --file-size=100 --file-count=8 --max-queue-size=2242880
--max-queue-count=10 --limit-policy=flow-to-disk
*Spout Config:*
-b=guest:guest@<host>:5672 -c=100000
--content=PersistencePersistencePersistencePersistencePersistencePersistencePersistencePersistencePersistencePersistencePersistencePersistencePersistencePersistencePersistencePersistencePersistencePersistencePersistencePersistencePersistencePersistencePersistencePersistencePersistencePersistence
'que'
====================================================
*Exception Log:*
Exception in thread "main" javax.jms.JMSException: Exception when sending
message
at
org.apache.qpid.client.BasicMessageProducer_0_10.sendMessage(BasicMessageProducer_0_10.java:240)
at
org.apache.qpid.client.BasicMessageProducer.sendImpl(BasicMessageProducer.java:501)
at
org.apache.qpid.client.BasicMessageProducer.sendImpl(BasicMessageProducer.java:456)
at
org.apache.qpid.client.BasicMessageProducer.send(BasicMessageProducer.java:283)
at org.apache.qpid.example.Spout.<init>(Spout.java:98)
at org.apache.qpid.example.Spout.main(Spout.java:146)
Caused by: org.apache.qpid.transport.SessionException: timed out waiting for
completion
at org.apache.qpid.transport.Session.invoke(Session.java:688)
at org.apache.qpid.transport.Session.invoke(Session.java:559)
at
org.apache.qpid.transport.SessionInvoker.messageTransfer(SessionInvoker.java:96)
at
org.apache.qpid.client.BasicMessageProducer_0_10.sendMessage(BasicMessageProducer_0_10.java:226)
... 5 more
====================================================
Regards,
Parkirat Bagga.
--
View this message in context:
http://qpid.2158936.n2.nabble.com/C-broker-0-14-java-client-flow-to-disk-not-happening-tp7395366p7450903.html
Sent from the Apache Qpid users mailing list archive at Nabble.com.
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
