You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by mi...@apache.org on 2019/07/18 13:24:34 UTC
[activemq-nms-amqp] branch master updated: AMQNET-592: Text
messages are received without payload
This is an automated email from the ASF dual-hosted git repository.
michaelpearce pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-nms-amqp.git
The following commit(s) were added to refs/heads/master by this push:
new 5dd8186 AMQNET-592: Text messages are received without payload
new 9c1d2f1 Merge pull request #7 from HavretGC/text_message_is_delivered_without_payload
5dd8186 is described below
commit 5dd81861902f02afe414800f6985e5f2c6cb407a
Author: Havret <h4...@gmail.com>
AuthorDate: Thu Jul 18 14:21:37 2019 +0200
AMQNET-592: Text messages are received without payload
---
src/NMS.AMQP/Provider/Amqp/Message/AmqpNmsMessageFacade.cs | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/src/NMS.AMQP/Provider/Amqp/Message/AmqpNmsMessageFacade.cs b/src/NMS.AMQP/Provider/Amqp/Message/AmqpNmsMessageFacade.cs
index 8e14526..e40a1d4 100644
--- a/src/NMS.AMQP/Provider/Amqp/Message/AmqpNmsMessageFacade.cs
+++ b/src/NMS.AMQP/Provider/Amqp/Message/AmqpNmsMessageFacade.cs
@@ -436,6 +436,12 @@ namespace Apache.NMS.AMQP.Provider.Amqp.Message
target.destination = destination;
target.replyTo = replyTo;
+ // Workaround for https://github.com/Azure/amqpnetlite/pull/364
+ if (Message.BodySection is AmqpValue value)
+ {
+ var _ = value.Value;
+ }
+
ByteBuffer buffer = Message.Encode();
target.Message = global::Amqp.Message.Decode(buffer);
target.InitializeHeader();