hraab opened a new issue, #1737:
URL: https://github.com/apache/camel-kafka-connector/issues/1737
Hey, the RabbitMQ sink connector has no config options to enable publisher
confirms mode (wait for ack/nack). As far as I see this requires to configure
Springs CachingConnectionFactory (property `publisherConfirmType`) at least.
My proposal would be to add the following options to the kamelet.
```yaml
definition
...
properties:
...
confirm:
title: Confirm
type: string
enum: [ "auto", "enabled", "disabled" ]
default: "auto"
description: Controls whether to wait for confirms. The connection
factory must be configured for publisher confirms and this method. auto = Camel
detects if the connection factory uses confirms or not. disabled = Confirms is
disabled. enabled = Confirms is enabled.
confirmTimeout:
title: Confirm timeout
type: long
default: 5000
description: Specify the timeout in milliseconds to be used when
waiting for a message sent to be confirmed by RabbitMQ when doing send only
messaging (InOnly). The default value is 5 seconds. A negative value indicates
an indefinite timeout.
confirmType:
title: Confirm type
type: string
enum: ["SIMPLE", "CORRELATED", "NONE"]
default: "NONE"
publisherReturns:
title: Publisher returns
type: boolean
default: false
...
template:
beans:
- name: connectionFactory
type:
"#class:org.springframework.amqp.rabbit.connection.CachingConnectionFactory"
properties:
...
publisherConfirmType: '{{confirmType}}'
publisherReturns: '{{publisherReturns}}'
from:
uri: "kamelet:source"
steps:
- to:
uri: "spring-rabbitmq://{{exchangeName}}"
parameters:
...
confirm: "{{confirm}}"
confirmTimeout: "{{confirmTimeout}}"
```
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
