[rabbitmq-discuss] Using pika - PRECONDITION_FAILED - unknown delivery tag 1
Ezequiel Golub
ezequiel.golub at gmail.com
Mon Mar 5 17:25:07 GMT 2012
Hey guys, i was wondering if any of you could lend me a hand with
getting my rabbitmq project off the ground.
I need to have multiple queues, with strong but not absolute
guarantees that message will be delivered only once and redelivered if
not ack is sent.
I took the code examples in
http://www.rabbitmq.com/tutorials/tutorial-two-python.html and
modified just a little, and i'm getting the following failure after a
number of messages are received (emphasis added):
[root at localhost rabbit_tests]# python test_consumer.py
suscribing
[x] Received 'hello world 0'
Sleeping for 5 seconds
Sending delivery tag = 1
[x] Received 'hello world 1'
Sleeping for 5 seconds
Sending delivery tag = 2
[x] Received 'hello world 2'
Sleeping for 5 seconds
Sending delivery tag = 3
[x] Received 'hello world 3'
Sleeping for 5 seconds
Sending delivery tag = 4
[x] Received 'hello world 4'
Sleeping for 5 seconds
!!!!!!!!**** Sending delivery tag = 5 *****!!!!!!!!!
Traceback (most recent call last):
File "test_consumer.py", line 28, in <module>
main()
File "test_consumer.py", line 25, in main
channel.start_consuming()
File "/usr/lib/python2.6/site-packages/pika/adapters/blocking_connection.py",
line 293, in start_consuming
self.transport.connection.process_data_events()
File "/usr/lib/python2.6/site-packages/pika/adapters/blocking_connection.py",
line 94, in process_data_events
self._handle_read()
File "/usr/lib/python2.6/site-packages/pika/adapters/base_connection.py",
line 162, in _handle_read
self._on_data_available(data)
File "/usr/lib/python2.6/site-packages/pika/connection.py", line
589, in _on_data_available
frame) # Args
File "/usr/lib/python2.6/site-packages/pika/callback.py", line 124, in process
callback(*args, **keywords)
File "/usr/lib/python2.6/site-packages/pika/adapters/blocking_connection.py",
line 269, in _on_remote_close
frame.method.reply_text)
pika.exceptions.AMQPChannelError: (406, 'PRECONDITION_FAILED - unknown
delivery tag 1')
here's the code i use to create this test.
---- test_producer.py ----
#!/usr/bin/env python
import pika, sys, json, time
date = '2012030505'
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
connection.set_backpressure_multiplier(100)
channel = connection.channel()
channel.exchange_declare(exchange="main", type="direct",
durable=True,auto_delete=False,)
channel.queue_declare(queue='queue_%s' % date, durable=True,
exclusive=False, auto_delete=False)
channel.queue_bind(queue='queue_%s' % date, exchange="main", routing_key=date)
channel.tx_select()
for i in range(0,10):
message = 'hello world %s' % i
channel.basic_publish(exchange='main',
routing_key= date,
properties=pika.BasicProperties(
delivery_mode = 2, # make message persistent
),
body=message)
print " [x] Sent %s:'%s'" % (date,message)
channel.tx_commit()
time.sleep(1)
---- test_consumer.py ----
import pika, time
def consume(ch, method, properties, body):
print " [x] Received %r" % (body,)
# print method
# print properties
# print ch
# simulate we're doing something
print "Sleeping for 5 seconds"
time.sleep(5)
print "Sending delivery tag = %s " % method.delivery_tag
ch.basic_ack(delivery_tag = method.delivery_tag)
def main():
connection =
pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.exchange_declare(exchange="main", type="direct",
durable=True,auto_delete=False,)
print "suscribing"
channel.basic_qos(prefetch_count=0)
channel.basic_consume(consume,
queue='queue_2012030505',
no_ack=True,
)
channel.start_consuming()
if __name__ == "__main__":
main()
--- Here's what rabbitmqctl reports ----
[root at localhost brandsafe]# /usr/lib/rabbitmq/bin/rabbitmqctl status
Status of node rabbit at localhost ...
[{pid,18510},
{running_applications,[{rabbit,"RabbitMQ","2.7.1"},
{mnesia,"MNESIA CXC 138 12","4.4.7"},
{os_mon,"CPO CXC 138 46","2.1.8"},
{sasl,"SASL CXC 138 11","2.1.5.4"},
{stdlib,"ERTS CXC 138 10","1.15.5"},
{kernel,"ERTS CXC 138 10","2.12.5"}]},
{os,{unix,linux}},
{erlang_version,"Erlang (BEAM) emulator version 5.6.5 [source]
[64-bit] [async-threads:30] [hipe] [kernel-poll:true]\n"},
{memory,[{total,29090512},
{processes,14184944},
{processes_used,10892640},
{system,14905568},
{atom,1064009},
{atom_used,1046693},
{binary,90552},
{code,11672579},
{ets,877768}]},
{vm_memory_high_watermark,0.3999999999458532},
{vm_memory_limit,1477464883}]
...done.
[root at localhost brandsafe]# /usr/lib/rabbitmq/bin/rabbitmqctl environment
Application environment of node rabbit at localhost ...
[{auth_backends,[rabbit_auth_backend_internal]},
{auth_mechanisms,['PLAIN','AMQPLAIN']},
{backing_queue_module,rabbit_variable_queue},
{cluster_nodes,[]},
{collect_statistics,none},
{collect_statistics_interval,5000},
{default_permissions,[<<".*">>,<<".*">>,<<".*">>]},
{default_user,<<"guest">>},
{default_user_tags,[administrator]},
{default_vhost,<<"/">>},
{delegate_count,16},
{error_logger,{file,"/var/log/rabbitmq/rabbit at localhost.log"}},
{frame_max,131072},
{hipe_compile,false},
{included_applications,[]},
{msg_store_file_size_limit,16777216},
{msg_store_index_module,rabbit_msg_store_ets_index},
{queue_index_max_journal_entries,262144},
{sasl_error_logger,{file,"/var/log/rabbitmq/rabbit at localhost-sasl.log"}},
{server_properties,[]},
{ssl_listeners,[]},
{ssl_options,[]},
{tcp_listen_options,[binary,
{packet,raw},
{reuseaddr,true},
{backlog,128},
{nodelay,true},
{exit_on_close,false}]},
{tcp_listeners,[5672]},
{trace_vhosts,[<<"/">>]},
{vm_memory_high_watermark,0.4}]
...done.
[root at localhost brandsafe]# /usr/lib/rabbitmq/bin/rabbitmqctl report
Reporting server status on {{2012,3,5},{17,22,44}}
Status of node rabbit at localhost ...
[{pid,18510},
{running_applications,[{rabbit,"RabbitMQ","2.7.1"},
{mnesia,"MNESIA CXC 138 12","4.4.7"},
{os_mon,"CPO CXC 138 46","2.1.8"},
{sasl,"SASL CXC 138 11","2.1.5.4"},
{stdlib,"ERTS CXC 138 10","1.15.5"},
{kernel,"ERTS CXC 138 10","2.12.5"}]},
{os,{unix,linux}},
{erlang_version,"Erlang (BEAM) emulator version 5.6.5 [source]
[64-bit] [async-threads:30] [hipe] [kernel-poll:true]\n"},
{memory,[{total,28940936},
{processes,14026016},
{processes_used,10733712},
{system,14914920},
{atom,1064817},
{atom_used,1046833},
{binary,90552},
{code,11672579},
{ets,877768}]},
{vm_memory_high_watermark,0.3999999999458532},
{vm_memory_limit,1477464883}]
Cluster status of node rabbit at localhost ...
[{nodes,[{disc,[rabbit at localhost]}]},{running_nodes,[rabbit at localhost]}]
Application environment of node rabbit at localhost ...
[{auth_backends,[rabbit_auth_backend_internal]},
{auth_mechanisms,['PLAIN','AMQPLAIN']},
{backing_queue_module,rabbit_variable_queue},
{cluster_nodes,[]},
{collect_statistics,none},
{collect_statistics_interval,5000},
{default_permissions,[<<".*">>,<<".*">>,<<".*">>]},
{default_user,<<"guest">>},
{default_user_tags,[administrator]},
{default_vhost,<<"/">>},
{delegate_count,16},
{error_logger,{file,"/var/log/rabbitmq/rabbit at localhost.log"}},
{frame_max,131072},
{hipe_compile,false},
{included_applications,[]},
{msg_store_file_size_limit,16777216},
{msg_store_index_module,rabbit_msg_store_ets_index},
{queue_index_max_journal_entries,262144},
{sasl_error_logger,{file,"/var/log/rabbitmq/rabbit at localhost-sasl.log"}},
{server_properties,[]},
{ssl_listeners,[]},
{ssl_options,[]},
{tcp_listen_options,[binary,
{packet,raw},
{reuseaddr,true},
{backlog,128},
{nodelay,true},
{exit_on_close,false}]},
{tcp_listeners,[5672]},
{trace_vhosts,[<<"/">>]},
{vm_memory_high_watermark,0.4}]
Connections:
pid address port peer_address peer_port ssl peer_cert_subject peer_cert_issuer peer_cert_validity auth_mechanism ssl_protocol ssl_key_exchange ssl_cipher ssl_hash protocol user vhost timeout frame_max client_properties recv_oct recv_cnt send_oct send_cnt send_pend state channels
<rabbit at localhost.1.6488.0> 127.0.0.1 5672 127.0.0.1 49132 false PLAIN {0,9,1} guest / 0 131072 [{"product","Pika
Python AMQP Client Library"}] 237 8 426 7 0 running 1
Channels:
pid connection number user vhost transactional confirm consumer_count messages_unacknowledged messages_unconfirmed messages_uncommitted acks_uncommitted prefetch_count client_flow_blocked
<rabbit at localhost.1.6492.0> <rabbit at localhost.1.6488.0> 1 guest / false false 1 0 0 0 0 0 false
Queues on /:
pid name durable auto_delete arguments owner_pid slave_pids synchronised_slave_pids exclusive_consumer_pid exclusive_consumer_tag messages_ready messages_unacknowledged messages consumers memory backing_queue_status
<rabbit at localhost.1.383.0> amq.gen-OmspSdOAO9n0MBZ4Zx6DlA== true false [] 0 0 0 0 34528 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,0}, {q4,0},
{len,0}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,0},
{persistent_count,0}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
<rabbit at localhost.1.384.0> amq.gen-0loSvlps1uXisVryOaGgnw== true false [] 0 0 0 0 34528 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,0}, {q4,0},
{len,0}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,0},
{persistent_count,0}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
<rabbit at localhost.1.385.0> amq.gen-RZxh+lukh03mUutFuCm/Aw== true false [] 0 0 0 0 34528 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,0}, {q4,0},
{len,0}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,0},
{persistent_count,0}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
<rabbit at localhost.1.387.0> po_box true false [] 0 0 0 0 34528 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,0}, {q4,0},
{len,0}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,0},
{persistent_count,0}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
<rabbit at localhost.1.386.0> amq.gen-/o9D5DstK79QnRkLYqtrbw== true false [] 2 0 2 0 34528 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,2}, {q4,0},
{len,2}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,16384},
{persistent_count,2}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
<rabbit at localhost.1.388.0> amq.gen-jewfcXKPDUc6Sqg5jgs0tQ== true false [] 0 0 0 0 34528 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,0}, {q4,0},
{len,0}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,0},
{persistent_count,0}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
<rabbit at localhost.1.389.0> task_queue true false [] 0 0 0 0 34528 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,0}, {q4,0},
{len,0}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,0},
{persistent_count,0}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
<rabbit at localhost.1.390.0> amq.gen-76kfx4BIaFdeX+sLtvDGMQ== true false [] 1 0 1 0 34528 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,1}, {q4,0},
{len,1}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,16384},
{persistent_count,1}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
<rabbit at localhost.1.391.0> amq.gen-lr+7aeYKj4gjFw5VFeKajQ== true false [] 5 0 5 0 34528 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,5}, {q4,0},
{len,5}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,16384},
{persistent_count,5}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
<rabbit at localhost.1.392.0> queue_2012030209 true false [] 20 0 20 0 55200 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,20}, {q4,0},
{len,20}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,16384},
{persistent_count,20}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
<rabbit at localhost.1.393.0> amq.gen-Jvf89t5Zr2B6NoJbh22vjw== true false [] 3 0 3 0 34528 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,3}, {q4,0},
{len,3}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,16384},
{persistent_count,3}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
<rabbit at localhost.1.394.0> amq.gen-JCxGTsOTUVU0eccre4BLqg== true false [] 7 0 7 0 55200 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,7}, {q4,0},
{len,7}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,16384},
{persistent_count,7}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
<rabbit at localhost.1.395.0> amq.gen-DbMT7q0fyWDMdaNhqNh+FA== true false [] 0 0 0 0 34528 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,0}, {q4,0},
{len,0}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,0},
{persistent_count,0}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
<rabbit at localhost.1.396.0> queue_2012030115 true false [] 0 0 0 0 34528 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,0}, {q4,0},
{len,0}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,0},
{persistent_count,0}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
<rabbit at localhost.1.397.0> amq.gen-d4bX+YjWwIBvwkEYUpfEKQ== true false [] 2 0 2 0 34528 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,2}, {q4,0},
{len,2}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,16384},
{persistent_count,2}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
<rabbit at localhost.1.398.0> queue_2012030210 true false [] 0 0 0 0 34528 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,0}, {q4,0},
{len,0}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,0},
{persistent_count,0}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
<rabbit at localhost.1.399.0> amq.gen-95KpPW7AC/nOUSYzEfAnsQ== true false [] 2 0 2 0 34528 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,2}, {q4,0},
{len,2}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,16384},
{persistent_count,2}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
<rabbit at localhost.1.400.0> amq.gen-4NVkRy5k5dzhygSohpnRSw== true false [] 0 0 0 0 34528 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,0}, {q4,0},
{len,0}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,0},
{persistent_count,0}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
<rabbit at localhost.1.401.0> amq.gen-Tuie11PiAM4wHTwxNyK0Hw== true false [] 8 0 8 0 55200 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,8}, {q4,0},
{len,8}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,16384},
{persistent_count,8}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
<rabbit at localhost.1.403.0> algo true false [] 0 0 0 0 34528 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,0}, {q4,0},
{len,0}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,0},
{persistent_count,0}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
<rabbit at localhost.1.402.0> amq.gen-R/qSTZLK8Z8Ovm97MDwquw== true false [] 0 0 0 0 34528 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,0}, {q4,0},
{len,0}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,0},
{persistent_count,0}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
<rabbit at localhost.1.404.0> queue_2012030505 true false [] 0 0 0 1 34600 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,0}, {q4,0},
{len,0}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,91},
{persistent_count,0}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
<rabbit at localhost.1.405.0> amq.gen-BPFYbLliOy3wWIwlMEYgGw== true false [] 0 0 0 0 34528 [{q1,0},
{q2,0}, {delta,{delta,undefined,0,undefined}}, {q3,0}, {q4,0},
{len,0}, {pending_acks,0}, {target_ram_count,infinity},
{ram_msg_count,0}, {ram_ack_count,0}, {next_seq_id,0},
{persistent_count,0}, {avg_ingress_rate,0.0}, {avg_egress_rate,0.0},
{avg_ack_ingress_rate,0.0}, {avg_ack_egress_rate,0.0}]
Exchanges on /:
name type durable auto_delete internal arguments
amq.rabbitmq.trace topic true false false []
amq.rabbitmq.log topic true false false []
amq.match headers true false false []
main direct true false false []
amq.headers headers true false false []
sorting_room direct true false false []
amq.topic topic true false false []
amq.direct direct true false false []
amq.fanout fanout true false false []
direct true false false []
Bindings on /:
source_name source_kind destination_name destination_kind routing_key arguments
exchange algo queue algo []
exchange amq.gen-/o9D5DstK79QnRkLYqtrbw== queue amq.gen-/o9D5DstK79QnRkLYqtrbw== []
exchange amq.gen-0loSvlps1uXisVryOaGgnw== queue amq.gen-0loSvlps1uXisVryOaGgnw== []
exchange amq.gen-4NVkRy5k5dzhygSohpnRSw== queue amq.gen-4NVkRy5k5dzhygSohpnRSw== []
exchange amq.gen-76kfx4BIaFdeX+sLtvDGMQ== queue amq.gen-76kfx4BIaFdeX+sLtvDGMQ== []
exchange amq.gen-95KpPW7AC/nOUSYzEfAnsQ== queue amq.gen-95KpPW7AC/nOUSYzEfAnsQ== []
exchange amq.gen-BPFYbLliOy3wWIwlMEYgGw== queue amq.gen-BPFYbLliOy3wWIwlMEYgGw== []
exchange amq.gen-DbMT7q0fyWDMdaNhqNh+FA== queue amq.gen-DbMT7q0fyWDMdaNhqNh+FA== []
exchange amq.gen-JCxGTsOTUVU0eccre4BLqg== queue amq.gen-JCxGTsOTUVU0eccre4BLqg== []
exchange amq.gen-Jvf89t5Zr2B6NoJbh22vjw== queue amq.gen-Jvf89t5Zr2B6NoJbh22vjw== []
exchange amq.gen-OmspSdOAO9n0MBZ4Zx6DlA== queue amq.gen-OmspSdOAO9n0MBZ4Zx6DlA== []
exchange amq.gen-R/qSTZLK8Z8Ovm97MDwquw== queue amq.gen-R/qSTZLK8Z8Ovm97MDwquw== []
exchange amq.gen-RZxh+lukh03mUutFuCm/Aw== queue amq.gen-RZxh+lukh03mUutFuCm/Aw== []
exchange amq.gen-Tuie11PiAM4wHTwxNyK0Hw== queue amq.gen-Tuie11PiAM4wHTwxNyK0Hw== []
exchange amq.gen-d4bX+YjWwIBvwkEYUpfEKQ== queue amq.gen-d4bX+YjWwIBvwkEYUpfEKQ== []
exchange amq.gen-jewfcXKPDUc6Sqg5jgs0tQ== queue amq.gen-jewfcXKPDUc6Sqg5jgs0tQ== []
exchange amq.gen-lr+7aeYKj4gjFw5VFeKajQ== queue amq.gen-lr+7aeYKj4gjFw5VFeKajQ== []
exchange po_box queue po_box []
exchange queue_2012030115 queue queue_2012030115 []
exchange queue_2012030209 queue queue_2012030209 []
exchange queue_2012030210 queue queue_2012030210 []
exchange queue_2012030505 queue queue_2012030505 []
exchange task_queue queue task_queue []
main exchange queue_2012030209 queue 2012030209 []
main exchange queue_2012030505 queue 2012030505 []
sorting_room exchange po_box queue mailme []
Consumers on /:
queue_name channel_pid consumer_tag ack_required
queue_2012030505 <rabbit at localhost.1.6492.0> ctag0 false
Permissions on /:
user configure write read
guest .* .* .*
End of server status report
...done.
Thanks a million!
--
Ezequiel Golub
More information about the rabbitmq-discuss
mailing list