Clever Geek Handbook

AMQPのデバッグ例

奇跡的に最初の部分に入らなかったのは......



$queue = new AMQPQueue($cnn, 'Habrauser')

1257461452685: conn#74 ch#1 -> {#method<queue.declare>(ticket=0,queue=Habrauser,passive=false,durable=false,exclusive=false,auto-delete=true,nowait=false,arguments={}),null,""}

1257461452686: conn#74 ch#1 <- {#method<queue.declare-ok>(queue=Habrauser,message-count=0,consumer-count=0),null,""}







キューのアナウンスが成功しました：メッセージの数message-count = 0、サブスクライバーなし：consumer-count = 0



キュー通知オプション：





$queue->bind("ex_2", '12345');



1257461452703: conn#74 ch#1 -> {#method<queue.bind>(ticket=0,queue=Habrauser,exchange=ex_test2,routing-key=12345,nowait=false,arguments={}),null,""}

1257461452703: conn#74 ch#1 <- {#method<queue.bind-ok>(),null,""}







メッセージを送る：

$mag='messsage 0';

$exchange = new Exchange('ex_2');

$exchange->publish( $msg, '12345' );



1257461452704: conn#74 ch#1 -> {#method<basic.publish>(ticket=0,exchange=ex_2,routing-key=12345,mandatory=false,immediate=false),#contentHeader(content-type=text/plain, content-encoding=null, headers=null, delivery-mode=null, priority=null, correlation-id=null, reply-to=null, expiration=null, message-id=null, timestamp=null, type=null, user-id=null, app-id=null, cluster-id=null),"messsage 0"}



: , ,

:

exchange=ex_2, routing-key=12345, mandatory=false, immediate=false

- ,

.



:



1257461452713: conn#74 ch#1 <- {#method<basic.deliver>(consumer-tag=amq.ctag-hnDha3s6i5xnJkkf0kB1DQ==,delivery-tag=6,redelivered=false,exchange=ex_test2,routing-key=12345),#contentHeader(content-type=text/plain, content-encoding=null, headers=null, delivery-mode=null, priority=null, correlation-id=null, reply-to=null, expiration=null, message-id=null, timestamp=null, type=null, user-id=null, app-id=null, cluster-id=null),"messsage 4"}



:

consumer-tag=amq.ctag-hnDha3s6i5xnJkkf0kB1DQ==, - ( )

delivery-tag=6 - .



, .



AMQP amqp-xml-doc0-8



.







$mag='messsage 0';

$exchange = new Exchange('ex_2');

$exchange->publish( $msg, '12345' );



1257461452704: conn#74 ch#1 -> {#method<basic.publish>(ticket=0,exchange=ex_2,routing-key=12345,mandatory=false,immediate=false),#contentHeader(content-type=text/plain, content-encoding=null, headers=null, delivery-mode=null, priority=null, correlation-id=null, reply-to=null, expiration=null, message-id=null, timestamp=null, type=null, user-id=null, app-id=null, cluster-id=null),"messsage 0"}



: , ,

:

exchange=ex_2, routing-key=12345, mandatory=false, immediate=false

- ,

.



:



1257461452713: conn#74 ch#1 <- {#method<basic.deliver>(consumer-tag=amq.ctag-hnDha3s6i5xnJkkf0kB1DQ==,delivery-tag=6,redelivered=false,exchange=ex_test2,routing-key=12345),#contentHeader(content-type=text/plain, content-encoding=null, headers=null, delivery-mode=null, priority=null, correlation-id=null, reply-to=null, expiration=null, message-id=null, timestamp=null, type=null, user-id=null, app-id=null, cluster-id=null),"messsage 4"}



:

consumer-tag=amq.ctag-hnDha3s6i5xnJkkf0kB1DQ==, - ( )

delivery-tag=6 - .



, .



AMQP amqp-xml-doc0-8



.









More articles:


All Articles