struct Contract::Queue

• Contract::Queue
• Contract::Interface
• Struct
• Value
• Object

Defined in:

contract/queue.cr

Constructors

• .new(pull : JSON::PullParser)

Instance Method Summary

• #arguments : Hash(String, String | UInt32)
• #arguments=(arguments : Hash(String, String | UInt32))
• #auto_delete=(auto_delete : Bool)
• #auto_delete? : Bool
• #consumers : UInt32
• #consumers=(consumers : UInt32)
• #durable=(durable : Bool)
• #durable? : Bool
• #effective_policy_definition : EffectivePolicyDefinition
• #effective_policy_definition=(effective_policy_definition : EffectivePolicyDefinition)
• #exclusive=(exclusive : Bool)
• #exclusive? : Bool
• #exclusive_consumer_tag : String | Nil
• #exclusive_consumer_tag=(exclusive_consumer_tag : String | Nil)
• #first_message_timestamp : UInt32 | Nil
• #first_message_timestamp=(first_message_timestamp : UInt32 | Nil)
• #internal=(internal : Bool | Nil)
• #internal? : Bool | Nil
• #last_message_timestamp : UInt32 | Nil
• #last_message_timestamp=(last_message_timestamp : UInt32 | Nil)
• #message_stats : MessagesStatsQueue
• #message_stats=(message_stats : MessagesStatsQueue)
• #messages : UInt32
• #messages=(messages : UInt32)
• #name : String
• #name=(name : String)
• #policy : String | Nil
• #policy=(policy : String | Nil)
• #ready : UInt32
• #ready=(ready : UInt32)
• #ready_avg_bytes : UInt32
• #ready_avg_bytes=(ready_avg_bytes : UInt32)
• #ready_bytes : UInt32
• #ready_bytes=(ready_bytes : UInt32)
• #state : String
• #state=(state : String)
• #unacked : UInt32
• #unacked=(unacked : UInt32)
• #unacked_avg_bytes : UInt32
• #unacked_avg_bytes=(unacked_avg_bytes : UInt32)
• #unacked_bytes : UInt32
• #unacked_bytes=(unacked_bytes : UInt32)
• #vhost : String
• #vhost=(vhost : String)

Constructor Detail

Instance Method Detail