File tree 2 files changed +8
-8
lines changed
sdk/servicebus/azure-servicebus/samples
2 files changed +8
-8
lines changed Original file line number Diff line number Diff line change 22
22
23
23
24
24
async def process_message (message ):
25
- print (message )
25
+ print (str ( message ) )
26
26
27
27
28
28
def example_create_servicebus_client_async ():
@@ -206,14 +206,14 @@ async def example_send_and_receive_async():
206
206
async with servicebus_receiver :
207
207
messages = await servicebus_receiver .peek_messages ()
208
208
for message in messages :
209
- print (message )
209
+ print (str ( message ) )
210
210
# [END peek_messages_async]
211
211
212
212
# [START receive_async]
213
213
async with servicebus_receiver :
214
214
messages = await servicebus_receiver .receive_messages (max_wait_time = 5 )
215
215
for message in messages :
216
- print (message )
216
+ print (str ( message ) )
217
217
await message .complete ()
218
218
# [END receive_async]
219
219
@@ -240,7 +240,7 @@ async def example_receive_deferred_async():
240
240
messages = await servicebus_receiver .receive_messages (max_wait_time = 5 )
241
241
for message in messages :
242
242
deferred_sequenced_numbers .append (message .sequence_number )
243
- print (message )
243
+ print (str ( message ) )
244
244
await message .defer ()
245
245
246
246
received_deferred_msg = await servicebus_receiver .receive_deferred_messages (
Original file line number Diff line number Diff line change 18
18
19
19
20
20
def process_message (message ):
21
- print (message )
21
+ print (str ( message ) )
22
22
23
23
24
24
def example_create_servicebus_client_sync ():
@@ -213,7 +213,7 @@ def example_send_and_receive_sync():
213
213
with servicebus_receiver :
214
214
messages = servicebus_receiver .peek_messages ()
215
215
for message in messages :
216
- print (message )
216
+ print (str ( message ) )
217
217
# [END peek_messages_sync]
218
218
219
219
# [START auto_lock_renew_message_sync]
@@ -232,7 +232,7 @@ def example_send_and_receive_sync():
232
232
with servicebus_receiver :
233
233
messages = servicebus_receiver .receive_messages (max_wait_time = 5 )
234
234
for message in messages :
235
- print (message )
235
+ print (str ( message ) )
236
236
message .complete ()
237
237
# [END receive_sync]
238
238
@@ -269,7 +269,7 @@ def example_receive_deferred_sync():
269
269
messages = servicebus_receiver .receive_messages (max_wait_time = 5 )
270
270
for message in messages :
271
271
deferred_sequenced_numbers .append (message .sequence_number )
272
- print (message )
272
+ print (str ( message ) )
273
273
message .defer ()
274
274
275
275
received_deferred_msg = servicebus_receiver .receive_deferred_messages (
You can’t perform that action at this time.
0 commit comments