update documentation for rstream 0.40.0 (#692)

Gsantomaggio · web-flow · commit c24784b471be · 2025-11-14T09:50:18.000+01:00
Signed-off-by: Gabriele Santomaggio &lt;G.santomaggio@gmail.com&gt;
diff --git a/python-stream/offset_tracking_receive.py b/python-stream/offset_tracking_receive.py
@@ -30,7 +30,7 @@ async def on_message(msg: AMQPMessage, message_context: MessageContext):
         first_offset = offset
 
     consumer = message_context.consumer
-    stream = message_context.consumer.get_stream(message_context.subscriber_name)
+    stream = message_context.stream
 
     # store the offset after every 10 messages received
     message_count = message_count + 1
diff --git a/python-stream/receive.py b/python-stream/receive.py
@@ -20,8 +20,7 @@ async def receive():
         )
 
         async def on_message(msg: AMQPMessage, message_context: MessageContext):
-            stream = message_context.consumer.get_stream(message_context.subscriber_name)
-            print("Got message: {} from stream {}".format(msg, stream))
+            print("Got message: {} from stream {}".format(msg, message_context.stream))
 
         print("Press control + C to close")
         await consumer.start()

Original file line number	Diff line number	Diff line change
`@@ -20,8 +20,7 @@ async def receive():`
`20`	`20`	`)`
`21`	`21`
`22`	`22`	`async def on_message(msg: AMQPMessage, message_context: MessageContext):`
`23`		`- stream = message_context.consumer.get_stream(message_context.subscriber_name)`
`24`		`- print("Got message: {} from stream {}".format(msg, stream))`
	`23`	`+ print("Got message: {} from stream {}".format(msg, message_context.stream))`
`25`	`24`
`26`	`25`	`print("Press control + C to close")`
`27`	`26`	`await consumer.start()`