PubSub example

awsimple/pubsub.py

@@ -273,7 +273,7 @@ def publish(self, message: dict) -> None:
     @typechecked()
     def get_messages(self) -> List[Dict[str, Any]]:
         """
-        Get all available messages. Muse set sub_poll=True when creating the PubSub object to use this function.
+        Get all available messages. Use set sub_poll=True when creating the PubSub object to use this function.
 
         :return: list of messages as dictionaries
         """

examples/make_venv.bat

@@ -1,5 +1,5 @@
 rmdir /S /Q venv
-c:"\Program Files\Python39\python.exe" -m venv --clear venv
+c:"\Program Files\Python314\python.exe" -m venv --clear venv
 venv\Scripts\python.exe -m pip install --upgrade pip
 venv\Scripts\pip3 install -U setuptools
 venv\Scripts\pip3 install -U -r requirements-examples.txt

examples/pubsub/pub_app.py

@@ -0,0 +1,7 @@
+from awsimple import Pub
+
+pub = Pub("awsimple_pubsub_example")
+pub.start()
+while input_message := input(f"Message to publish (or Enter to exit):").strip():
+    pub.publish({"message": input_message})
+pub.request_exit()

examples/pubsub/pubsub.bat

@@ -0,0 +1,2 @@
+start "pub" ..\venv\Scripts\python.exe pub_app.py
+start "sub" ..\venv\Scripts\python.exe sub_app.py

examples/pubsub/sub_app.py

@@ -0,0 +1,6 @@
+from awsimple import Sub
+
+sub = Sub("awsimple_pubsub_example", sub_callback=print)
+sub.start()
+input("Press Enter to exit...\n")
+sub.request_exit()