qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chuck Rolke <cro...@redhat.com>
Subject Re: Reading HornetQ messages using Proton and Messaging API (.net)
Date Tue, 18 Aug 2015 20:49:11 GMT
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" <hrobison@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-unsubscribe@qpid.apache.org
> For additional commands, e-mail: users-help@qpid.apache.org
> 
> 

---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org


Mime
View raw message