eladkal commented on code in PR #44675:
URL: https://github.com/apache/airflow/pull/44675#discussion_r1880484135
##########
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:
Most of what you write here needs to be in the docs not in the class doc
string
--
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
