# Rabbitmq output plugin with 'x-delayed-message' exchange

**URL:** <https://discuss.elastic.co/t/rabbitmq-output-plugin-with-x-delayed-message-exchange/326182>\
**Category:** Logstash\
**Created:** [February 22, 2023, 1:04pm UTC](https://discuss.elastic.co/t/rabbitmq-output-plugin-with-x-delayed-message-exchange/326182 "2023-02-22T13:04:07Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![yilmazbuhar](https://avatars.discourse-cdn.com/v4/letter/y/46a35a/32.png) [@yilmazbuhar](https://discuss.elastic.co/u/yilmazbuhar)\
**Post date:** [February 22, 2023, 1:04pm UTC](https://discuss.elastic.co/t/rabbitmq-output-plugin-with-x-delayed-message-exchange/326182/1 "2023-02-22T13:04:07Z")

</div>

Hi all,

Can i send a message to "x-delayed-message" exchange with logstash. When i try this, getting error like this

```auto
  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

```auto
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.

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [March 22, 2023, 1:04pm UTC](https://discuss.elastic.co/t/rabbitmq-output-plugin-with-x-delayed-message-exchange/326182/2 "2023-03-22T13:04:59Z")

</div>

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