Skip to content

Commit 2bc3342

Browse files
committed
Add argumentsMap when declaring the queue during service attach
1 parent fd4449b commit 2bc3342

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

native/src/main/java/io/ballerina/stdlib/rabbitmq/util/ListenerUtils.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -206,7 +206,7 @@ private static void declareQueueIfNotExists(BObject service, Channel channel) th
206206
}
207207

208208
// declare queue with user given values or default set
209-
channel.queueDeclare(queueName, durable, exclusive, autoDelete, null);
209+
channel.queueDeclare(queueName, durable, exclusive, autoDelete, argumentsMap);
210210
RabbitMQMetricsUtil.reportNewQueue(channel, queueName);
211211
}
212212

0 commit comments

Comments
 (0)