struct AMQ::Protocol::Properties

Defined in:

amq/protocol/properties.cr

Constant Summary

FLAG_APP_ID = 8_u16
FLAG_CONTENT_ENCODING = 16384_u16
FLAG_CONTENT_TYPE = 32768_u16
FLAG_CORRELATION_ID = 1024_u16
FLAG_DELIVERY_MODE = 4096_u16
FLAG_EXPIRATION = 256_u16
FLAG_HEADERS = 8192_u16
FLAG_INVALID = 3_u16
FLAG_MESSAGE_ID = 128_u16
FLAG_PRIORITY = 2048_u16
FLAG_REPLY_TO = 512_u16
FLAG_RESERVED1 = 4_u16
FLAG_TIMESTAMP = 64_u16
FLAG_TYPE = 32_u16
FLAG_USER_ID = 16_u16

Constructors

Class Method Summary

Instance Method Summary

Constructor Detail

def self.from_bytes(bytes : Bytes, format : IO::ByteFormat) : self #

[View source]
def self.from_io(io, format, flags = UInt16.from_io(io, format)) : self #

[View source]
def self.from_json(data : JSON::Any) : self #

[View source]
def self.new(content_type : String | Nil = nil, content_encoding : String | Nil = nil, headers : Table | Nil = nil, delivery_mode : UInt8 | Nil = nil, priority : UInt8 | Nil = nil, correlation_id : String | Nil = nil, reply_to : String | Nil = nil, expiration : String | Nil = nil, message_id : String | Nil = nil, timestamp : Time | Int64 | Nil = nil, type : String | Nil = nil, user_id : String | Nil = nil, app_id : String | Nil = nil, reserved1 : String | Nil = nil) #

[View source]

Class Method Detail

def self.skip(io, format) : Int64 #

[View source]

Instance Method Detail

def ==(other : self) #

def app_id : String? #

[View source]
def app_id=(app_id : Nil | String) #

[View source]
def bytesize #

[View source]
def clone #

[View source]
def content_encoding : String? #

[View source]
def content_encoding=(content_encoding : Nil | String) #

[View source]
def content_type : String? #

[View source]
def content_type=(content_type : Nil | String) #

[View source]
def correlation_id : String? #

[View source]
def correlation_id=(correlation_id : Nil | String) #

[View source]
def delivery_mode : UInt8? #

[View source]
def delivery_mode=(delivery_mode : UInt8 | Nil) #

[View source]
def expiration : String? #

[View source]
def expiration=(expiration : Nil | String) #

[View source]
def hash(hasher) #
Description copied from struct Struct

See Object#hash(hasher)


def headers : AMQ::Protocol::Table? #

[View source]
def headers=(headers : AMQ::Protocol::Table | Nil) #

[View source]
def message_id : String? #

[View source]
def message_id=(message_id : Nil | String) #

[View source]
def priority : UInt8? #

[View source]
def priority=(priority : UInt8 | Nil) #

[View source]
def reply_to : String? #

[View source]
def reply_to=(reply_to : Nil | String) #

[View source]
def reserved1 : String? #

[View source]
def reserved1=(reserved1 : Nil | String) #

[View source]
def timestamp : Time | Nil #

Parse the timestamp_raw value into a Time. Assume it's in seconds since epoch, according to spec. If that fails assume it's stored as milliseconds. Else raise AMQ::Protocol::Error::DecodeFrame error.


[View source]
def timestamp=(value : Time | Nil) : Nil #

[View source]
def timestamp_raw : Int64 | Nil #

[View source]
def timestamp_raw=(timestamp_raw : Int64 | Nil) #

[View source]
def to_io(io, format) #

[View source]
def to_json(json : JSON::Builder) #

[View source]
def type : String? #

[View source]
def type=(type : Nil | String) #

[View source]
def user_id : String? #

[View source]
def user_id=(user_id : Nil | String) #

[View source]