This is an automated email from the ASF dual-hosted git repository. astitcher pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/qpid-proton.git
The following commit(s) were added to refs/heads/main by this push: new da94d935f PROTON-2676: Make server example behave better if no relay da94d935f is described below commit da94d935f644320d72da69cb0dfe3064d70dc95b Author: Andrew Stitcher <astitc...@apache.org> AuthorDate: Wed Feb 22 18:07:45 2023 +0000 PROTON-2676: Make server example behave better if no relay We'll now close the connection with an error and exit with a non-zero exit code if ANONYMOUS-RELAY isn't offered by the connected broker. --- python/examples/server.py | 14 +++++++++++--- 1 file changed, 11 insertions(+), 3 deletions(-) diff --git a/python/examples/server.py b/python/examples/server.py index 3ecd6063b..403ceec00 100755 --- a/python/examples/server.py +++ b/python/examples/server.py @@ -19,10 +19,12 @@ # import optparse -from proton import Message, Url +import sys +from proton import Message, Url, Condition from proton.handlers import MessagingHandler from proton.reactor import Container +exit_status = 0 class Server(MessagingHandler): def __init__(self, url, address): @@ -40,8 +42,12 @@ class Server(MessagingHandler): self.receiver = event.container.create_receiver(self.conn, self.address) self.server = self.container.create_sender(self.conn, None) else: - print("Server needs a broker which supports ANONYMOUS-RELAY") - event.connection.close() + global exit_status + print("Server needs a broker which supports ANONYMOUS-RELAY", file=sys.stderr) + exit_status = 1 + c= event.connection + c.condition = Condition('amqp:not-implemented', description="ANONYMOUS-RELAY required") + c.close() def on_message(self, event): print("Received", event.message) @@ -60,3 +66,5 @@ try: Container(Server(url, url.path)).run() except KeyboardInterrupt: pass + +sys.exit(exit_status) --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org