Logstash RabbitMQ input with lazy queue


I would like to load data from RabbitMQ with Logstash with the following pipeline:
input {
rabbitmq {
host => "xxx.xxx.xxx.xxx"
port => 5672
user => "guest"
password => "guest"
queue => "test_queue"
durable => true
filter {
output {
stdout {
codec => rubydebug

file {
codec => json
path => "/data/rabbit/test-%{+YYYY-MM-dd}.json"

I receive the following error in the logstash-plain.log:
Error while setting up connection for rabbitmq input! Will retry. {:message=>"#method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - inequivalent arg 'x-queue-mode' for queue 'test_queue' in vhost '/': received none but current is the value 'lazy' of type 'longstr', class-id=50, method-id=10)"

Please help me with this pipeline!

I was stupid!
The answer is:
arguments => {
"x-queue-mode" => "lazy"

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.