[
https://issues.apache.org/jira/browse/CAMEL-17671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17505291#comment-17505291
]
MattV commented on CAMEL-17671:
-------------------------------
i had started to take a look at how to do it, it's been slow as I'm not that
familiar with reactive programming. It's worth noting though, in the
documentation it states that the default behavior is exactly what is expected:
[Azure ServiceBus :: Apache
Camel|https://camel.apache.org/components/3.15.x/azure-servicebus-component.html#_component_option_disableAutoComplete]
"By default, a successfully processed message is \{completed}. If an error
happens when the message is processed, it is \{abandoned}"
> camel-azure - Add transaction support to Azure ServiceBus
> ---------------------------------------------------------
>
> Key: CAMEL-17671
> URL: https://issues.apache.org/jira/browse/CAMEL-17671
> Project: Camel
> Issue Type: New Feature
> Components: camel-azure
> Reporter: Tom Cassimon
> Priority: Major
> Fix For: 3.17.0
>
>
> I would like to see the feature of transactions in the azure servicebus when
> using queues.
> The use case I would like to have is that when a message is processed in a
> route with an azure servicebus consumer and an error occurs during
> processing, that the message is not aknowledged to the azure servicebus
> broker, resulting in the message to re-appear on the queue and can be
> processed by the same or another listener instance on the queue.
> If i scroll to the configuration in Azure of the service bus I see a max
> delivery count setting, so i presume the feature is possible in the service
> bus component but not used in the camel service bus component.
> An simple example of a route that should not aknowledge the message on the
> ServiceBus component, and should lead to the message to re-appear on the
> queue for a redelivery attempt.
> {code:java}
> from("azure-servicebus://<redacted>")
> .autoStartup(true)
> .transacted()
> .throwException(new RuntimeException())
> .end(); {code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
