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/08/01 15:44:16 UTC
[activemq-nms-amqp] branch master updated: AMQNET-592: Text
messages are received without payload - revert
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 c4fcc9d AMQNET-592: Text messages are received without payload - revert
new 0b53d44 Merge pull request #10 from Havret/revert_text_message_is_delivered_without_payload
c4fcc9d is described below
commit c4fcc9d9333a30e1d4d66719114771c174e78039
Author: Havret <h4...@gmail.com>
AuthorDate: Sun Jul 28 21:08:45 2019 +0200
AMQNET-592: Text messages are received without payload - revert
---
src/NMS.AMQP/Apache-NMS-AMQP.csproj | 2 +-
src/NMS.AMQP/Provider/Amqp/Message/AmqpNmsMessageFacade.cs | 6 ------
2 files changed, 1 insertion(+), 7 deletions(-)
diff --git a/src/NMS.AMQP/Apache-NMS-AMQP.csproj b/src/NMS.AMQP/Apache-NMS-AMQP.csproj
index 33ee9bf..2558784 100644
--- a/src/NMS.AMQP/Apache-NMS-AMQP.csproj
+++ b/src/NMS.AMQP/Apache-NMS-AMQP.csproj
@@ -74,7 +74,7 @@ with the License. You may obtain a copy of the License at
<ItemGroup>
<!-- AMQPNetLite.Core is .NET Standard 1.3 package -->
- <PackageReference Include="AMQPNetLite.Core" Version="2.1.7"/>
+ <PackageReference Include="AMQPNetLite.Core" Version="2.1.8"/>
<PackageReference Include="Apache.NMS" Version="1.8.0"/>
<PackageReference Include="System.Threading.Tasks.Dataflow" Version="4.9.0"/>
</ItemGroup>
diff --git a/src/NMS.AMQP/Provider/Amqp/Message/AmqpNmsMessageFacade.cs b/src/NMS.AMQP/Provider/Amqp/Message/AmqpNmsMessageFacade.cs
index e40a1d4..8e14526 100644
--- a/src/NMS.AMQP/Provider/Amqp/Message/AmqpNmsMessageFacade.cs
+++ b/src/NMS.AMQP/Provider/Amqp/Message/AmqpNmsMessageFacade.cs
@@ -436,12 +436,6 @@ 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();