Sinking messages in RabbitMQ

[Soheil Pourbafrani]

I'm using Flink RabbitMQ Connector for Sinking Data but using the RMQConnectionConfig object I couldn't find any method to set the type of the exchange (Fanout, Topic, Direct). And also the RMQSink get just name of the queue as the parameter. Is there any way to specify the exchange type?

[Oytun Tez]

I think you should exchangeDeclare when you open the sink. When invoked, you can channel.basicPublish(exchangeName).

Would this work? We have a single exchange, so didn't explore this method.

On Tue, Apr 23, 2019 at 12:37 PM Soheil Pourbafrani <[hidden email]> wrote:

I'm using Flink RabbitMQ Connector for Sinking Data but using the RMQConnectionConfig object I couldn't find any method to set the type of the exchange (Fanout, Topic, Direct). And also the RMQSink get just name of the queue as the parameter. Is there any way to specify the exchange type?