[rabbitmq-discuss] Publisher confirms

Wed Jan 9 15:51:54 GMT 2013

Hi Michael,

On 09/01/13 15:24, Michael Klishin wrote:
>
> 2013/1/9 Chris Duncan <chris.d at frugalit.co.uk 
> <mailto:chris.d at frugalit.co.uk>>
>
>     I'm wondering whether my expectations are correct or not. If my
>     expectations are correct, is there something that I've failed to do?
>
>
> Chris,
>
> Can you please post your code and, if possible, what tshark output 
> looks like when you run it
> as
>
> tshark -i lo0 -O amqp -R amqp
>
> (you will need to update the interface argument if RabbitMQ is not 
> running on localhost).
> -- 
> MK
Please find my code and tshark output attached. I run the consumer 
first. My version of wireshark doesn't recognise AMQP method class 85 
(confirm.select and confirm.select-ok) but they do appear in the output.

Cheers,

Chris
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130109/5dbd7dae/attachment.htm>
-------------- next part --------------
A non-text attachment was scrubbed...
Name: hello_world_consumer.rb
Type: application/x-ruby
Size: 482 bytes
Desc: not available
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130109/5dbd7dae/attachment.rb>
-------------- next part --------------
A non-text attachment was scrubbed...
Name: hello_world_publisher_confirms.rb
Type: application/x-ruby
Size: 220 bytes
Desc: not available
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130109/5dbd7dae/attachment-0001.rb>
-------------- next part --------------
Frame 8: 401 bytes on wire (3208 bits), 401 bytes captured (3208 bits)
Ethernet II, Src: 00:00:00_00:00:00 (00:00:00:00:00:00), Dst: 00:00:00_00:00:00 (00:00:00:00:00:00)
Internet Protocol Version 4, Src: 127.0.0.1 (127.0.0.1), Dst: 127.0.0.1 (127.0.0.1)
Transmission Control Protocol, Src Port: amqp (5672), Dst Port: 39165 (39165), Seq: 1, Ack: 9, Len: 335
Advanced Message Queueing Protocol
    Type: Method (1)
    Channel: 0
    Length: 327
    Class: Connection (10)
    Method: Start (10)
    Arguments
        Version-Major: 0
        Version-Minor: 9
        Server-Properties
            capabilities (field table): ...
            copyright (string): Copyright (C) 2007-2012 VMware, Inc.
            information (string): Licensed under the MPL.  See http://www.rabbitmq.com/
            platform (string): Erlang/OTP
            product (string): RabbitMQ
            version (string): 3.0.1
        Mechanisms: 504c41494e20414d51504c41494e
        Locales: 656e5f5553

Frame 10: 376 bytes on wire (3008 bits), 376 bytes captured (3008 bits)
Ethernet II, Src: 00:00:00_00:00:00 (00:00:00:00:00:00), Dst: 00:00:00_00:00:00 (00:00:00:00:00:00)
Internet Protocol Version 4, Src: 127.0.0.1 (127.0.0.1), Dst: 127.0.0.1 (127.0.0.1)
Transmission Control Protocol, Src Port: 39165 (39165), Dst Port: amqp (5672), Seq: 9, Ack: 336, Len: 310
Advanced Message Queueing Protocol
    Type: Method (1)
    Channel: 0
    Length: 302
    Class: Connection (10)
    Method: Start-Ok (11)
    Arguments
        Client-Properties
            capabilities (field table): ...
            product (string): Bunny
            platform (string): ruby 1.9.3p362 (2012-12-25 revision 38607) [i686-linux]
            version (string): 0.9.0.pre5
            information (string): http://github.com/ruby-amqp/bunny
        Mechanism: PLAIN
        Response: 006775657374006775657374
        Locale: en_GB

Frame 11: 86 bytes on wire (688 bits), 86 bytes captured (688 bits)
Ethernet II, Src: 00:00:00_00:00:00 (00:00:00:00:00:00), Dst: 00:00:00_00:00:00 (00:00:00:00:00:00)
Internet Protocol Version 4, Src: 127.0.0.1 (127.0.0.1), Dst: 127.0.0.1 (127.0.0.1)
Transmission Control Protocol, Src Port: amqp (5672), Dst Port: 39165 (39165), Seq: 336, Ack: 319, Len: 20
Advanced Message Queueing Protocol
    Type: Method (1)
    Channel: 0
    Length: 12
    Class: Connection (10)
    Method: Tune (30)
    Arguments
        Channel-Max: 0
        Frame-Max: 131072
        Heartbeat: 600

Frame 12: 86 bytes on wire (688 bits), 86 bytes captured (688 bits)
Ethernet II, Src: 00:00:00_00:00:00 (00:00:00:00:00:00), Dst: 00:00:00_00:00:00 (00:00:00:00:00:00)
Internet Protocol Version 4, Src: 127.0.0.1 (127.0.0.1), Dst: 127.0.0.1 (127.0.0.1)
Transmission Control Protocol, Src Port: 39165 (39165), Dst Port: amqp (5672), Seq: 319, Ack: 356, Len: 20
Advanced Message Queueing Protocol
    Type: Method (1)
    Channel: 0
    Length: 12
    Class: Connection (10)
    Method: Tune-Ok (31)
    Arguments
        Channel-Max: 0
        Frame-Max: 131072
        Heartbeat: 600

Frame 14: 82 bytes on wire (656 bits), 82 bytes captured (656 bits)
Ethernet II, Src: 00:00:00_00:00:00 (00:00:00:00:00:00), Dst: 00:00:00_00:00:00 (00:00:00:00:00:00)
Internet Protocol Version 4, Src: 127.0.0.1 (127.0.0.1), Dst: 127.0.0.1 (127.0.0.1)
Transmission Control Protocol, Src Port: 39165 (39165), Dst Port: amqp (5672), Seq: 339, Ack: 356, Len: 16
Advanced Message Queueing Protocol
    Type: Method (1)
    Channel: 0
    Length: 8
    Class: Connection (10)
    Method: Open (40)
    Arguments
        Virtual-Host: /
        Capabilities: 
        .... ...0 = Insist: False

Frame 16: 79 bytes on wire (632 bits), 79 bytes captured (632 bits)
Ethernet II, Src: 00:00:00_00:00:00 (00:00:00:00:00:00), Dst: 00:00:00_00:00:00 (00:00:00:00:00:00)
Internet Protocol Version 4, Src: 127.0.0.1 (127.0.0.1), Dst: 127.0.0.1 (127.0.0.1)
Transmission Control Protocol, Src Port: amqp (5672), Dst Port: 39165 (39165), Seq: 356, Ack: 355, Len: 13
Advanced Message Queueing Protocol
    Type: Method (1)
    Channel: 0
    Length: 5
    Class: Connection (10)
    Method: Open-Ok (41)
    Arguments
        Known-Hosts: 

Frame 17: 79 bytes on wire (632 bits), 79 bytes captured (632 bits)
Ethernet II, Src: 00:00:00_00:00:00 (00:00:00:00:00:00), Dst: 00:00:00_00:00:00 (00:00:00:00:00:00)
Internet Protocol Version 4, Src: 127.0.0.1 (127.0.0.1), Dst: 127.0.0.1 (127.0.0.1)
Transmission Control Protocol, Src Port: 39165 (39165), Dst Port: amqp (5672), Seq: 355, Ack: 369, Len: 13
Advanced Message Queueing Protocol
    Type: Method (1)
    Channel: 1
    Length: 5
    Class: Channel (20)
    Method: Open (10)
    Arguments
        Out-Of-Band: 

Frame 18: 82 bytes on wire (656 bits), 82 bytes captured (656 bits)
Ethernet II, Src: 00:00:00_00:00:00 (00:00:00:00:00:00), Dst: 00:00:00_00:00:00 (00:00:00:00:00:00)
Internet Protocol Version 4, Src: 127.0.0.1 (127.0.0.1), Dst: 127.0.0.1 (127.0.0.1)
Transmission Control Protocol, Src Port: amqp (5672), Dst Port: 39165 (39165), Seq: 369, Ack: 368, Len: 16
Advanced Message Queueing Protocol
    Type: Method (1)
    Channel: 1
    Length: 8
    Class: Channel (20)
    Method: Open-Ok (11)
    Arguments
        Channel-Id: <MISSING>

Frame 19: 79 bytes on wire (632 bits), 79 bytes captured (632 bits)
Ethernet II, Src: 00:00:00_00:00:00 (00:00:00:00:00:00), Dst: 00:00:00_00:00:00 (00:00:00:00:00:00)
Internet Protocol Version 4, Src: 127.0.0.1 (127.0.0.1), Dst: 127.0.0.1 (127.0.0.1)
Transmission Control Protocol, Src Port: 39165 (39165), Dst Port: amqp (5672), Seq: 368, Ack: 385, Len: 13
Advanced Message Queueing Protocol
    Type: Method (1)
    Channel: 2
    Length: 5
    Class: Channel (20)
    Method: Open (10)
    Arguments
        Out-Of-Band: 

Frame 20: 82 bytes on wire (656 bits), 82 bytes captured (656 bits)
Ethernet II, Src: 00:00:00_00:00:00 (00:00:00:00:00:00), Dst: 00:00:00_00:00:00 (00:00:00:00:00:00)
Internet Protocol Version 4, Src: 127.0.0.1 (127.0.0.1), Dst: 127.0.0.1 (127.0.0.1)
Transmission Control Protocol, Src Port: amqp (5672), Dst Port: 39165 (39165), Seq: 385, Ack: 381, Len: 16
Advanced Message Queueing Protocol
    Type: Method (1)
    Channel: 2
    Length: 8
    Class: Channel (20)
    Method: Open-Ok (11)
    Arguments
        Channel-Id: <MISSING>

Frame 21: 79 bytes on wire (632 bits), 79 bytes captured (632 bits)
Ethernet II, Src: 00:00:00_00:00:00 (00:00:00:00:00:00), Dst: 00:00:00_00:00:00 (00:00:00:00:00:00)
Internet Protocol Version 4, Src: 127.0.0.1 (127.0.0.1), Dst: 127.0.0.1 (127.0.0.1)
Transmission Control Protocol, Src Port: 39165 (39165), Dst Port: amqp (5672), Seq: 381, Ack: 401, Len: 13
Advanced Message Queueing Protocol
    Type: Method (1)
    Channel: 2
    Length: 5
    Class: Unknown (85)
    [Expert Info (Error/Protocol): Unknown method class 85]
        [Message: Unknown method class 85]
        [Severity level: Error]
        [Group: Protocol]

Frame 22: 78 bytes on wire (624 bits), 78 bytes captured (624 bits)
Ethernet II, Src: 00:00:00_00:00:00 (00:00:00:00:00:00), Dst: 00:00:00_00:00:00 (00:00:00:00:00:00)
Internet Protocol Version 4, Src: 127.0.0.1 (127.0.0.1), Dst: 127.0.0.1 (127.0.0.1)
Transmission Control Protocol, Src Port: amqp (5672), Dst Port: 39165 (39165), Seq: 401, Ack: 394, Len: 12
Advanced Message Queueing Protocol
    Type: Method (1)
    Channel: 2
    Length: 4
    Class: Unknown (85)
    [Expert Info (Error/Protocol): Unknown method class 85]
        [Message: Unknown method class 85]
        [Severity level: Error]
        [Group: Protocol]

Frame 23: 107 bytes on wire (856 bits), 107 bytes captured (856 bits)
Ethernet II, Src: 00:00:00_00:00:00 (00:00:00:00:00:00), Dst: 00:00:00_00:00:00 (00:00:00:00:00:00)
Internet Protocol Version 4, Src: 127.0.0.1 (127.0.0.1), Dst: 127.0.0.1 (127.0.0.1)
Transmission Control Protocol, Src Port: 39165 (39165), Dst Port: amqp (5672), Seq: 394, Ack: 413, Len: 41
Advanced Message Queueing Protocol
    Type: Method (1)
    Channel: 1
    Length: 33
    Class: Exchange (40)
    Method: Declare (10)
    Arguments
        Ticket: 0
        Exchange: hello-exchange
        Type: direct
        .... ...0 = Passive: False
        .... ..1. = Durable: True
        .... .0.. = Auto-Delete: False
        .... 0... = Internal: False
        ...0 .... = Nowait: False
        Arguments

Frame 24: 78 bytes on wire (624 bits), 78 bytes captured (624 bits)
Ethernet II, Src: 00:00:00_00:00:00 (00:00:00:00:00:00), Dst: 00:00:00_00:00:00 (00:00:00:00:00:00)
Internet Protocol Version 4, Src: 127.0.0.1 (127.0.0.1), Dst: 127.0.0.1 (127.0.0.1)
Transmission Control Protocol, Src Port: amqp (5672), Dst Port: 39165 (39165), Seq: 413, Ack: 435, Len: 12
Advanced Message Queueing Protocol
    Type: Method (1)
    Channel: 1
    Length: 4
    Class: Exchange (40)
    Method: Declare-Ok (11)
    Arguments

Frame 25: 101 bytes on wire (808 bits), 101 bytes captured (808 bits)
Ethernet II, Src: 00:00:00_00:00:00 (00:00:00:00:00:00), Dst: 00:00:00_00:00:00 (00:00:00:00:00:00)
Internet Protocol Version 4, Src: 127.0.0.1 (127.0.0.1), Dst: 127.0.0.1 (127.0.0.1)
Transmission Control Protocol, Src Port: 39165 (39165), Dst Port: amqp (5672), Seq: 435, Ack: 425, Len: 35
Advanced Message Queueing Protocol
    Type: Method (1)
    Channel: 1
    Length: 27
    Class: Basic (60)
    Method: Publish (40)
    Arguments
        Ticket: 0
        Exchange: hello-exchange
        Routing-Key: hola
        .... ...0 = Mandatory: False
        .... ..0. = Immediate: False

Frame 27: 135 bytes on wire (1080 bits), 135 bytes captured (1080 bits)
Ethernet II, Src: 00:00:00_00:00:00 (00:00:00:00:00:00), Dst: 00:00:00_00:00:00 (00:00:00:00:00:00)
Internet Protocol Version 4, Src: 127.0.0.1 (127.0.0.1), Dst: 127.0.0.1 (127.0.0.1)
Transmission Control Protocol, Src Port: 39165 (39165), Dst Port: amqp (5672), Seq: 470, Ack: 425, Len: 69
Advanced Message Queueing Protocol
    Type: Content header (2)
    Channel: 1
    Length: 41
    Class ID: Basic (60)
    Weight: 0
    Body size: 12
    Property flags: 0x9800
    Properties
        Content-Type: application/octet-stream
        Delivery-Mode: 2
        Priority: 0
Advanced Message Queueing Protocol
    Type: Content body (3)
    Channel: 1
    Length: 12
    Payload: 54657374206d657373616765