Re: [ANNOUNCE] Apache Qpid Proton 0.10 released
On 17/08/15 21:57 +0100, Robbie Gemmell wrote: On 17 August 2015 at 21:11, Flavio Percoco fla...@redhat.com wrote: [snip] Is that something we can change in qpid-proton ? I'm entirely on board personally with including the extra digit all the time (and actually using it to do more regular point releases; when I did 0.9.1 that was really the first time any of the components have ever had one). I have been using x.y.z format versions for the JMS client releases from the start for precisely the reasons you covered, so a thumbs up from me. Sounds great to me. I'd assume it's not fixable for 0.10, is it? If it can be done for 0.10, I'd be happy to see it happening. Otherwise, I guess we should just keep it in mind for 0.11. Cheers, Flavio -- @flaper87 Flavio Percoco pgpgGLJiEusFD.pgp Description: PGP signature
Re: Reading HornetQ messages using Proton and Messaging API (.net)
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 hrobi...@industrialdefender.com To: users@qpid.apache.org 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: users-unsubscr...@qpid.apache.org For additional commands, e-mail: users-h...@qpid.apache.org - To unsubscribe, e-mail: users-unsubscr...@qpid.apache.org For additional commands, e-mail: users-h...@qpid.apache.org
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: users-unsubscr...@qpid.apache.org For additional commands, e-mail: users-h...@qpid.apache.org