From 3d95d132b219f270f46ff6464ddc75e4fcc859e5 Mon Sep 17 00:00:00 2001 From: Gabriele Santomaggio Date: Thu, 8 May 2025 11:36:01 +0200 Subject: [PATCH] update python documentation based on: https://github.com/rabbitmq/rabbitmq-amqp-python-client/pull/63 Signed-off-by: Gabriele Santomaggio --- client-libraries/amqp-client-libraries.md | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/client-libraries/amqp-client-libraries.md b/client-libraries/amqp-client-libraries.md index ab5a9e910e..58ec1fcabc 100644 --- a/client-libraries/amqp-client-libraries.md +++ b/client-libraries/amqp-client-libraries.md @@ -352,7 +352,8 @@ PublishResult pr = await publisher.PublishAsync(message); ```python title="Publishing a message" # create the message -message = Message(body="Hello") +# body is a byte array. You can use the Converter utility class +message = Message(body=Converter.string_to_bytes("Hello")) # publish the message and deal with broker feedback # The result is synchronous status = publisher.publish(Message(message) @@ -662,6 +663,9 @@ class MyMessageHandler(AMQPMessagingHandler): def on_message(self, event: Event): # ... + # event.message.body is a byte array. If you have string + # you can use Converter utility class, like: + # my_body_string=Converter.bytes_to_string(event.message.body) self.delivery_context.accept(event)# settle the message