# Path: servicebus/pika/amqp_object.py
# class AMQPObject(object):
# class Class(AMQPObject):
# class Method(AMQPObject):
# class Properties(AMQPObject):
#     NAME = 'AMQPObject'
#     INDEX = None
#     NAME = 'Unextended Class'
#     NAME = 'Unextended Method'
#     NAME = 'Unextended Properties'
#     def __repr__(self):
#     def _set_content(self, properties, body):
#     def get_properties(self):
#     def get_body(self):
# 
# Path: servicebus/pika/data.py
# def encode_short_string(pieces, value):
#     def decode_short_string(encoded, offset):
#     def decode_short_string(encoded, offset):
# def encode_table(pieces, table):
# def encode_value(pieces, value):
# def decode_table(encoded, offset):
# def decode_value(encoded, offset):


import struct
from servicebus.pika import amqp_object
from servicebus.pika import data
from servicebus.pika.compat import str_or_bytes, unicode_type

    INDEX = 0x0055  # 85
    NAME = 'Confirm'

    class Select(amqp_object.Method):

        INDEX = 0x0055000A  # 85, 10; 5570570
        NAME = 'Confirm.Select'

        def __init__(self, nowait=False):
            self.nowait = nowait

        @property
        def synchronous(self):
            return True

        def decode(self, encoded, offset=0):
            bit_buffer = struct.unpack_from('B', encoded, offset)[0]
            offset += 1
            self.nowait = (bit_buffer & (1 << 0)) != 0
            return self

        def encode(self):
            pieces = list()
            bit_buffer = 0
            if self.nowait:
                bit_buffer = bit_buffer | (1 << 0)
            pieces.append(struct.pack('B', bit_buffer))
            return pieces


# Path: servicebus/pika/amqp_object.py
# class AMQPObject(object):
# class Class(AMQPObject):
# class Method(AMQPObject):
# class Properties(AMQPObject):
#     NAME = 'AMQPObject'
#     INDEX = None
#     NAME = 'Unextended Class'
#     NAME = 'Unextended Method'
#     NAME = 'Unextended Properties'
#     def __repr__(self):
#     def _set_content(self, properties, body):
#     def get_properties(self):
#     def get_body(self):
# 
# Path: servicebus/pika/data.py
# def encode_short_string(pieces, value):
#     def decode_short_string(encoded, offset):
#     def decode_short_string(encoded, offset):
# def encode_table(pieces, table):
# def encode_value(pieces, value):
# def decode_table(encoded, offset):
# def decode_value(encoded, offset):


# Path: servicebus/pika/spec.py
import struct
from servicebus.pika import amqp_object
from servicebus.pika import data
from servicebus.pika.compat import str_or_bytes, unicode_type


    INDEX = 0x0055  # 85
    NAME = 'Confirm'

    class Select(amqp_object.Method):

        INDEX = 0x0055000A  # 85, 10; 5570570
        NAME = 'Confirm.Select'

        def __init__(self, nowait=False):
            self.nowait = nowait

        @property
        def synchronous(self):
            return True

        def decode(self, encoded, offset=0):
            bit_buffer = struct.unpack_from('B', encoded, offset)[0]
            offset += 1
            self.nowait = (bit_buffer & (1 << 0)) != 0
            return self

        def encode(self):
            pieces = list()
            bit_buffer = 0
            if self.nowait:
                bit_buffer = bit_buffer | (1 << 0)
            pieces.append(struct.pack('B', bit_buffer))
            return pieces


    class SelectOk(amqp_object.Method):