Skip to main content
CrystalDocs

    Browse DocsCrystalShardsAbout

    github.com/skuznetsov/amqp-ng

    main

    Types

    • AMQ
      • Protocol
        • Field
        • Properties
        • Table
    • AMQP
      • Client
        • Arguments
        • Channel
          • ClosedException
        • Connection
          • ClosedException
        • DeliverMessage
        • Error
        • Exchange
        • Frame
          • Basic
            • Consume
        • GetMessage
        • Properties
        • Queue
    • Amqp
      • Arguments
      • AuthenticationError
      • Channel
        • CancelCallback
        • CloseCallback
        • ConfirmCallback
        • State
      • ChannelClosedByBroker
      • ChannelClosedByCaller
      • ChannelError
      • ChannelLimitError
      • ChannelRpcTimeoutError
      • ConcurrencyError
      • Config
      • ConfigurationError
      • ConfirmOutcome
        • Kind
      • ConnectError
      • ConnectRefusedError
      • ConnectTimeoutError
      • Connection
        • BlockedCallback
        • State
        • UnblockedCallback
      • ConnectionClosedByBroker
      • ConnectionClosedByCaller
      • ConnectionError
      • DeliverMessage
      • Delivery
      • Error
      • Exchange
      • FieldValue
      • FrameTooLargeError
      • GetMessage
      • HeartbeatTimeoutError
      • Message
      • Persistence
      • PreconditionFailedError
      • PreparedPublisher
      • Properties
        • Persistence
      • ProtocolError
      • ProtocolNegotiationError
      • PublishNackError
      • PublishOutOfOrderError
      • PublishReturnedError
      • PublishTimeoutError
      • Queue
      • QueueDeclareOk
      • QueueInfo
      • Recovery
      • RecoveryExhaustedError
      • RecoveryInProgress
      • ReturnReason
      • ReturnedMessage
      • SocketError
      • Stats
        • Snapshot
      • Subscription
        • Closed
      • SubscriptionClosed
      • TlsConfigError
      • TlsHandshakeError
      • UriError
      • VhostAccessError
      • Wire
        • AmqpZeroNineOne
          • BasicMethods
            • Ack
            • Cancel
            • CancelOk
            • Consume
            • ConsumeOk
            • Deliver
            • Get
            • GetEmpty
            • GetOk
            • Nack
            • Publish
            • Qos
            • QosOk
            • Recover
            • RecoverOk
            • Reject
            • Return
          • BitPack
          • ChannelMethods
            • Close
            • CloseOk
            • Flow
            • FlowOk
            • Open
            • OpenOk
          • ConfirmMethods
            • Select
            • SelectOk
          • ConnectionMethods
            • Blocked
            • Close
            • CloseOk
            • Open
            • OpenOk
            • Start
            • StartOk
            • Tune
            • TuneOk
            • Unblocked
          • ContentHeader
            • Decoded
            • EncodedProperties
          • ExchangeMethods
            • Bind
            • BindOk
            • Declare
            • DeclareOk
            • Delete
            • DeleteOk
            • Unbind
            • UnbindOk
          • QueueMethods
            • Bind
            • BindOk
            • Declare
            • DeclareOk
            • Delete
            • DeleteOk
            • Purge
            • PurgeOk
            • Unbind
            • UnbindOk
          • TxMethods
            • Commit
            • CommitOk
            • Rollback
            • RollbackOk
            • Select
            • SelectOk
          • Types
        • Frame
        • FrameType
    module

    Amqp::Wire::AmqpZeroNineOne::ConnectionMethods

    Instance methods

    write_method_payload(io : IO, method_id : UInt16, & : -> Nil) : Nil

    Helper that writes class-id + method-id then yields for arg encoding.

    Source

    Nested types

    • Amqp::Wire::AmqpZeroNineOne::ConnectionMethods::Blocked
    • Amqp::Wire::AmqpZeroNineOne::ConnectionMethods::Close
    • Amqp::Wire::AmqpZeroNineOne::ConnectionMethods::CloseOk
    • Amqp::Wire::AmqpZeroNineOne::ConnectionMethods::Open
    • Amqp::Wire::AmqpZeroNineOne::ConnectionMethods::OpenOk
    • Amqp::Wire::AmqpZeroNineOne::ConnectionMethods::Start
    • Amqp::Wire::AmqpZeroNineOne::ConnectionMethods::StartOk
    • Amqp::Wire::AmqpZeroNineOne::ConnectionMethods::Tune
    • Amqp::Wire::AmqpZeroNineOne::ConnectionMethods::TuneOk
    • Amqp::Wire::AmqpZeroNineOne::ConnectionMethods::Unblocked

    Advertisement

    Crystal jobs from CrystalGigs

    • Your posting here

      Reach Crystal developers on CrystalGigsFirst party

    CrystalDocs.org - Crystal Shard Documentation Hosting

    GitHubCrystalShardsCrystalGigsCrystalBitsCrystal Language

    The Bushido Collective builds and maintains this site. ยท Licensed under the Apache License 2.0