Skip to content

Instantly share code, notes, and snippets.

@natritmeyer

natritmeyer/get_messages_off_rabbitmq.rb

Last active February 16, 2024 13:52
Download ZIP

Revisions

  1. natritmeyer revised this gist Jul 15, 2013. 1 changed file with 1 addition and 1 deletion.
    2 changes: 1 addition & 1 deletion get_messages_off_rabbitmq.sh
    View file
    Original file line number Diff line number Diff line change
    @@ -1 +1 @@
    curl -i -X POST -u guest:guest http://192.168.0.1:55672/api/queues/%2f/my_queue/get -H "Content-Type: application/json" -d'{"count":5,"requeue":true,"encoding":"auto","truncate":50000}'
    curl -i -X POST -u guest:guest http://192.168.0.1:55672/api/queues/%2f/my_queue/get -H "Content-Type: application/json" -d '{"count":5,"requeue":true,"encoding":"auto","truncate":50000}'
  2. natritmeyer revised this gist Jul 15, 2013. 1 changed file with 2 additions and 2 deletions.
    4 changes: 2 additions & 2 deletions get_messages_off_rabbitmq.rb
    View file
    Original file line number Diff line number Diff line change
    @@ -4,13 +4,13 @@
    class QueueInspector
    include HTTParty
    basic_auth "guest", "guest"
    base_uri "http://33.33.33.10:55672"
    base_uri "http://192.168.0.1:55672"

    def messages
    body = {'count' => 5,'requeue' => true, 'encoding' => 'auto', 'truncate' => 50000}.to_json
    headers = {"Content-Type" => "application/json"}
    options = {body: body, headers: headers}
    self.class.post "/api/queues/%2f/cdm.mio/get", options
    self.class.post "/api/queues/%2f/my_queue/get", options
    end
    end

  3. natritmeyer revised this gist Jul 15, 2013. 1 changed file with 19 additions and 0 deletions.
    19 changes: 19 additions & 0 deletions get_messages_off_rabbitmq.rb
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,19 @@
    require 'httparty'
    require 'json'

    class QueueInspector
    include HTTParty
    basic_auth "guest", "guest"
    base_uri "http://33.33.33.10:55672"

    def messages
    body = {'count' => 5,'requeue' => true, 'encoding' => 'auto', 'truncate' => 50000}.to_json
    headers = {"Content-Type" => "application/json"}
    options = {body: body, headers: headers}
    self.class.post "/api/queues/%2f/cdm.mio/get", options
    end
    end

    response = QueueInspector.new.messages
    puts response.code
    puts response.body
  4. natritmeyer created this gist Jul 10, 2013.
    1 change: 1 addition & 0 deletions get_messages_off_rabbitmq.sh
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1 @@
    curl -i -X POST -u guest:guest http://192.168.0.1:55672/api/queues/%2f/my_queue/get -H "Content-Type: application/json" -d'{"count":5,"requeue":true,"encoding":"auto","truncate":50000}'