perry2of5 commented on code in PR #44675:
URL: https://github.com/apache/airflow/pull/44675#discussion_r1880807495
##########
providers/src/airflow/providers/microsoft/azure/operators/asb.py:
##########
@@ -650,3 +653,189 @@ def execute(self, context: Context) -> None:
self.log.info("Topic %s deleted.", self.topic_name)
else:
self.log.info("Topic %s does not exist.", self.topic_name)
+
+
+class AzureServiceBusRequestReplyOperator(BaseOperator):
+ """
+ Implement request-reply pattern using Azure Service Bus.
+
+ Send a message to an Azure Service Bus Queue and receive a reply by
correlation id from an Azure Service
+ Bus Topic. This implements the Request-Reply pattern from Enterprise
Integration Patterns, Hohpe, Woolf,
+ Addison-Wesley, 2003:
https://www.enterpriseintegrationpatterns.com/patterns/messaging/RequestReply.html
+
+ Steps are:
+ 1. Generate a unique ID for the message. The subscription needs to
exist before the request message is
Review Comment:
That seems fair. I'm not sure where to move it to though. I don't see
documentation outside of the docstrings. Sorry if I'm missing something
obvious....not really a python dev.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@airflow.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
