perry2of5 commented on code in PR #44675:
URL: https://github.com/apache/airflow/pull/44675#discussion_r1881167025
##########
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:
Ah, you mean under the top-level docs folder. It never occurred to me that
the providers would be documented outside the top-level providers folder. I'm
happy to move things over. I'll try to get to that later this week.
--
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
