A Qpid Messaging may be revealing. Try: > SET QPID_LOG_ENABLE=trace+ > csharp.example.drain ...
What command line args do you use for drain? ----- Original Message ----- > From: "hcy" <[email protected]> > To: [email protected] > Sent: Tuesday, August 18, 2015 4:28:39 PM > Subject: Reading HornetQ messages using Proton and Messaging API (.net) > > I have downloaded and built qpid-proton-0.10.tar.gz and Qpid Messaging API. > > The goal is to read messages from HornetQ on a Windows environment. > > I am trying to run csharp.example.drain project, I was able to open the > connection and create a session. However, I was never able to read a message > - the console application hang for a while and terminates with the error > "Disconnected (reconnect disabled)". > > Further investigation on HornetQ log, I found the following exceptions and > it was actually triggered by the call *Receiver receiver = > session.CreateReceiver(options.Address)*. Can anyone help? > > 2015-08-18 16:23:33,156 [Thread-86 > (HornetQ-server-HornetQServerImpl::serverUUID=eca59c4c-45bd-11e5-89b0-57e46941877b-1556893158)] > WARN org.hornetq.core.server - HQ222151: removing consumer which did not > handle a message, ....... > java.lang.NumberFormatException: null > at java.lang.Long.parseLong(Unknown Source) ~[na:1.8.0_51] > at java.lang.Long.valueOf(Unknown Source) ~[na:1.8.0_51] > at > org.hornetq.utils.TypedProperties.getLongProperty(TypedProperties.java:307) > ~[hornetq-commons-2.4.5.Final.jar:na] > at > org.hornetq.core.message.impl.MessageImpl.getLongProperty(MessageImpl.java:804) > ~[hornetq-core-client-2.4.5.Final.jar:na] > at > org.hornetq.core.protocol.proton.ProtonUtils$OUTBOUND.transform(ProtonUtils.java:339) > ~[hornetq-amqp-protocol-2.4.5.Final.jar:na] > at > org.hornetq.core.protocol.proton.ProtonConsumer.handleDelivery(ProtonConsumer.java:203) > ~[hornetq-amqp-protocol-2.4.5.Final.jar:na] > at > org.hornetq.core.protocol.proton.ProtonSession.sendMessage(ProtonSession.java:131) > ~[hornetq-amqp-protocol-2.4.5.Final.jar:na] > at > org.hornetq.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:949) > ~[hornetq-server-2.4.5.Final.jar:na] > at > org.hornetq.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:398) > ~[hornetq-server-2.4.5.Final.jar:na] > at > org.hornetq.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:2544) > ~[hornetq-server-2.4.5.Final.jar:na] > at org.hornetq.core.server.impl.QueueImpl.deliver(QueueImpl.java:2137) > ~[hornetq-server-2.4.5.Final.jar:na] > at org.hornetq.core.server.impl.QueueImpl.access$1300(QueueImpl.java:81) > ~[hornetq-server-2.4.5.Final.jar:na] > at > org.hornetq.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:2917) > ~[hornetq-server-2.4.5.Final.jar:na] > at > org.hornetq.utils.OrderedExecutorFactory$OrderedExecutor$1.run(OrderedExecutorFactory.java:104) > [hornetq-core-client-2.4.5.Final.jar:na] > at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) > [na:1.8.0_51] > at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) > [na:1.8.0_51] > at java.lang.Thread.run(Unknown Source) [na:1.8.0_51] > > > > -- > View this message in context: > http://qpid.2158936.n2.nabble.com/Reading-HornetQ-messages-using-Proton-and-Messaging-API-net-tp7629726.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] > > --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
