Hi all,
Can i send a message to "x-delayed-message" exchange with logstash. When i try this, getting error like this
output {
rabbitmq {
# This setting must be a ["fanout", "direct", "topic", "x-consistent-hash", "x-modulus-hash"]
# Expected one of ["fanout", "direct", "topic", "x-consistent-hash", "x-modulus-hash"], got ["x-delayed-message"]
exchange_type => "x-delayed-message"
...
}
}
My config is
output {
rabbitmq {
codec => "json"
host => ""
exchange => ""
exchange_type => "x-delayed-message"
key => ""
durable => "true"
port => ""
user => ""
password => ""
passive => true
arguments => [{"x-delayed-type" => "direct"},{"messages delayed" => "0"}]
}
}
Thanks any help.