Skip to content

Commit da186cb

Browse files
committed
Change the message interface from object to
byte array. Change the Message body section from AMQPValue to Data. It is better for cross protocol use cases Signed-off-by: Gabriele Santomaggio <[email protected]>
1 parent ec078cc commit da186cb

File tree

3 files changed

+3
-5
lines changed

3 files changed

+3
-5
lines changed

RabbitMQ.AMQP.Client/IMessage.cs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -97,10 +97,9 @@ public interface IMessage
9797
public IMessage Annotation(string key, object value);
9898

9999
public byte[] Body();
100-
100+
101101
public string BodyAsString();
102-
103-
102+
104103
public IMessage Body(object body);
105104

106105
IMessageAddressBuilder ToAddress();

RabbitMQ.AMQP.Client/Impl/AmqpMessage.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -269,7 +269,7 @@ public string BodyAsString()
269269
{
270270
throw new InvalidOperationException("Body is not an Application Data");
271271
}
272-
272+
273273
}
274274

275275
public IMessage Body(object body)

Tests/Amqp091/FromToAmqp091Tests.cs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,6 @@ public async Task ToAmqp091()
3838
Assert.Equal(OutcomeState.Accepted, result.Outcome.State);
3939
}
4040

41-
4241
var factory = new ConnectionFactory();
4342
var connection = await factory.CreateConnectionAsync();
4443
var channel = await connection.CreateChannelAsync();

0 commit comments

Comments
 (0)