# How to send process Data from Logstash to RabbitMQ?

**URL:** <https://discuss.elastic.co/t/how-to-send-process-data-from-logstash-to-rabbitmq/293336>\
**Category:** Logstash\
**Created:** [January 3, 2022, 9:56am UTC](https://discuss.elastic.co/t/how-to-send-process-data-from-logstash-to-rabbitmq/293336 "2022-01-03T09:56:19Z")\
**Posts on this page:** 4\
**Page:** 1

<div class="post-metadata">

**Author:** ![padamrai](https://avatars.discourse-cdn.com/v4/letter/p/3da27b/32.png) [@padamrai](https://discuss.elastic.co/u/padamrai)\
**Post date:** [January 3, 2022, 9:56am UTC](https://discuss.elastic.co/t/how-to-send-process-data-from-logstash-to-rabbitmq/293336/1 "2022-01-03T09:56:19Z")

</div>

How to send json format data from logstash to Rabbitmq. I have tried but getting error. Currently I am using local Rabbitmq  
My config output file,

```auto
if "_grokparsefailure" in [tags]{
        rabbitmq{
            host => "localhost"
            port => 5672
            user => "guest"
            password => "guest"
            durable => true
            exchange => "LOGSTASH_TO_RABBITMQ.TEST"
            exchange_type => "direct"
            # queue => "LOGSTASH_TO_RABBITMQ"
            # codec =>"plain"
            type => "json"
        }
    }

```

I am getting this error:  
Failed to execute action {:action=\>LogStash::PipelineAction::Create/pipeline\_id:main, :exception=\>"Java::JavaLang::IllegalStateException", :message=\>"Unable to configure plugins: (ConfigurationError) The setting `type` in plugin `rabbitmq` is obsolete and is no longer available. You can achieve this same behavior with the new conditionals, like: `if [type] == \"sometype\" { rabbitmq { ... } }` .

---

<div class="post-metadata">

**Author:** ![padamrai](https://avatars.discourse-cdn.com/v4/letter/p/3da27b/32.png) [@padamrai](https://discuss.elastic.co/u/padamrai)\
**Post date:** [January 3, 2022, 10:13am UTC](https://discuss.elastic.co/t/how-to-send-process-data-from-logstash-to-rabbitmq/293336/2 "2022-01-03T10:13:40Z")

</div>

I find out error becuase of type=\>"json" after commenting this line error is gone. Now I am not getting any error but also not getting any message in rabbitmq when \_grokeparsefailure occurs.

---

<div class="post-metadata">

**Author:** ![padamrai](https://avatars.discourse-cdn.com/v4/letter/p/3da27b/32.png) [@padamrai](https://discuss.elastic.co/u/padamrai)\
**Post date:** [January 3, 2022, 10:31am UTC](https://discuss.elastic.co/t/how-to-send-process-data-from-logstash-to-rabbitmq/293336/3 "2022-01-03T10:31:13Z")

</div>

I am not mentioning routing key.  
key =\> "key1234"

---

<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:** [January 31, 2022, 10:32am UTC](https://discuss.elastic.co/t/how-to-send-process-data-from-logstash-to-rabbitmq/293336/4 "2022-01-31T10:32:04Z")

</div>

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