diff --git a/docs/Examples/GettingStarted/Program.cs b/docs/Examples/GettingStarted/Program.cs index a812142..83fb6ec 100644 --- a/docs/Examples/GettingStarted/Program.cs +++ b/docs/Examples/GettingStarted/Program.cs @@ -53,7 +53,7 @@ IConsumer consumer = await connection.ConsumerBuilder().Queue(queueName).MessageHandler( (context, message) => { - Trace.WriteLine(TraceLevel.Information, $"[Consumer] Message: {message.Body()} received"); + Trace.WriteLine(TraceLevel.Information, $"[Consumer] Message: {message.BodyAsString()} received"); context.Accept(); return Task.CompletedTask; } @@ -68,15 +68,15 @@ switch (pr.Outcome.State) { case OutcomeState.Accepted: - Trace.WriteLine(TraceLevel.Information, $"[Publisher] Message: {message.Body()} confirmed"); + Trace.WriteLine(TraceLevel.Information, $"[Publisher] Message: {message.BodyAsString()} confirmed"); break; case OutcomeState.Released: - Trace.WriteLine(TraceLevel.Information, $"[Publisher] Message: {message.Body()} Released"); + Trace.WriteLine(TraceLevel.Information, $"[Publisher] Message: {message.BodyAsString()} Released"); break; case OutcomeState.Rejected: Trace.WriteLine(TraceLevel.Error, - $"[Publisher] Message: {message.Body()} Rejected with error: {pr.Outcome.Error}"); + $"[Publisher] Message: {message.BodyAsString()} Rejected with error: {pr.Outcome.Error}"); break; default: throw new ArgumentOutOfRangeException(); diff --git a/docs/Examples/Rpc/Program.cs b/docs/Examples/Rpc/Program.cs index a3dd733..4144445 100644 --- a/docs/Examples/Rpc/Program.cs +++ b/docs/Examples/Rpc/Program.cs @@ -45,7 +45,7 @@ { try { - Trace.WriteLine(TraceLevel.Information, $"[Server] Message received: {message.Body()} "); + Trace.WriteLine(TraceLevel.Information, $"[Server] Message received: {message.BodyAsString()} "); IMessage reply = context.Message($"pong_{DateTime.Now}"); return Task.FromResult(reply); } @@ -68,7 +68,7 @@ { IMessage reply = await rpcClient.PublishAsync( new AmqpMessage($"ping_{DateTime.Now}")); - Trace.WriteLine(TraceLevel.Information, $"[Client] Reply received: {reply.Body()}"); + Trace.WriteLine(TraceLevel.Information, $"[Client] Reply received: {reply.BodyAsString()}"); } catch (Exception e) {