struct AMQ::Protocol::Properties
- AMQ::Protocol::Properties
- Struct
- Value
- Object
Defined in:
amq/protocol/properties.crConstant 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
- .from_bytes(bytes : Bytes, format : IO::ByteFormat) : self
- .from_io(io, format, flags = UInt16.from_io(io, format)) : self
- .from_json(data : JSON::Any) : 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)
Class Method Summary
Instance Method Summary
- #==(other : self)
- #app_id : String?
- #app_id=(app_id : Nil | String)
- #bytesize
- #clone
- #content_encoding : String?
- #content_encoding=(content_encoding : Nil | String)
- #content_type : String?
- #content_type=(content_type : Nil | String)
- #correlation_id : String?
- #correlation_id=(correlation_id : Nil | String)
- #delivery_mode : UInt8?
- #delivery_mode=(delivery_mode : UInt8 | Nil)
- #expiration : String?
- #expiration=(expiration : Nil | String)
-
#hash(hasher)
See
Object#hash(hasher)
- #headers : AMQ::Protocol::Table?
- #headers=(headers : AMQ::Protocol::Table | Nil)
- #message_id : String?
- #message_id=(message_id : Nil | String)
- #priority : UInt8?
- #priority=(priority : UInt8 | Nil)
- #reply_to : String?
- #reply_to=(reply_to : Nil | String)
- #reserved1 : String?
- #reserved1=(reserved1 : Nil | String)
-
#timestamp : Time | Nil
Parse the timestamp_raw value into a
Time
. - #timestamp=(value : Time | Nil) : Nil
- #timestamp_raw : Int64 | Nil
- #timestamp_raw=(timestamp_raw : Int64 | Nil)
- #to_io(io, format)
- #to_json(json : JSON::Builder)
- #type : String?
- #type=(type : Nil | String)
- #user_id : String?
- #user_id=(user_id : Nil | String)
Constructor Detail
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)
#
Class Method Detail
Instance Method Detail
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.