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. --- Oytun Tez *M O T A W O R D* The World's Fastest Human Translation Platform. oy...@motaword.com — www.motaword.com On Tue, Apr 23, 2019 at 12:37 PM Soheil Pourbafrani <soheil.i...@gmail.com> 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? >
