title: RABBITMQ send messages to LOGSTASH
body: <p>can you help me with RabbitMQ input in logstash.
  My application sending versions of code to rabbitmq and then it go to store in elastic stack.
  For app in rabbitmq was created queue
  name: app_version_queue;
  type: classic;
  durable: true</p>
  <p>Then logstash was configured with that config:</p>
  <pre><code>input {
    rabbitmq {
      id =&gt; &quot;rabbitmyq_id&quot;
      # connect to rabbit
      host =&gt; &quot;localhost&quot;
      port =&gt; 5672
      vhost =&gt; &quot;/&quot;
      # INPUT - PRODUCERS
      key =&gt; &quot;app_version_queue&quot;
      # OUTPUT - CONSUMER
      # queue for logstash
      queue =&gt; &quot;logstash&quot;
      auto_delete =&gt; false
      # Exchange for logstash
      exchange =&gt; logstash
      exchange_type =&gt; direct
      durable =&gt; &quot;true&quot;
      # No ack will boost your perf
      ack =&gt; false
    }
  }
  
  output {
    elasticsearch {
      hosts =&gt; [ &quot;elasticsearch:9200&quot; ]
      index =&gt; &quot;app_version-%{+YYYY.MM.dd}&quot;
    }
  }
  </code></pre>
  <p>It's worked, but now, in RabbitMQ console, i see in table Queued messages
  Ready: 914,444
  Unacked: 0
  Total: 914,444</p>
  <p>And my disk space on rabbitmq cluster go to full in 3 days.
  After rebooting rabbitmq server, all space is free.</p>
  <p>UPDATED:
  All reason, why i do that, i want to remove NIFI from that chain app=&gt;rabbit=&gt;nifi=&gt;elastic
  I want to do: app=&gt;rabbit=&gt;logstash=&gt;elastic</p>
  <ol>
  <li>Queue: app_version
  My application send messages to nifi=&gt;ELASTIC
  <a href="https://i.stack.imgur.com/hWGEo.png" rel="nofollow noreferrer">Queue1 - app_version_queue</a></li>
  <li>Queue: logstash, what i created with logstash
  <a href="https://i.stack.imgur.com/3076J.png" rel="nofollow noreferrer">Queue2 - logstash</a></li>
  </ol>
  <p>I try to stop NIFI sending, but messages not leaving.</p>