more readable example

Signed-off-by: Elena Kolevska <elena@kolevska.com>
dapr · Sep 23, 2024 · f64334f · f64334f
1 parent daad173
commit f64334f
Showing 1 changed file with 14 additions and 19 deletions.
diff --git a/examples/pubsub-streaming/subscriber.py b/examples/pubsub-streaming/subscriber.py
@@ -17,25 +17,20 @@ def main():
 
         try:
             for i in range(5):
-                try:
-                    message = subscription.next_message()
-                    if message is None:
-                        print('No message received within timeout period.')
-                        continue
-
-                    # Process the message
-                    response_status = process_message(message)
-
-                    if response_status == 'success':
-                        subscription.respond_success(message)
-                    elif response_status == 'retry':
-                        subscription.respond_retry(message)
-                    elif response_status == 'drop':
-                        subscription.respond_drop(message)
-
-                except Exception as e:
-                    print(f'Error getting message: {e}')
-                    break
+                message = subscription.next_message()
+                if message is None:
+                    print('No message received within timeout period.')
+                    continue
+
+                # Process the message
+                response_status = process_message(message)
+
+                if response_status == 'success':
+                    subscription.respond_success(message)
+                elif response_status == 'retry':
+                    subscription.respond_retry(message)
+                elif response_status == 'drop':
+                    subscription.respond_drop(message)
 
         finally:
             subscription.close()