class LavinMQ::Policy

• LavinMQ::Policy
• Reference
• Object

Included Modules

• JSON::Serializable
• LavinMQ::SortableJSON

Direct Known Subclasses

• LavinMQ::OperatorPolicy

Defined in:

lavinmq/policy.cr

Constant Summary

SUPPORTED_POLICIES = {"max-length", "max-length-bytes", "message-ttl", "expires", "overflow", "dead-letter-exchange", "dead-letter-routing-key", "federation-upstream", "federation-upstream-set", "delivery-limit", "max-age", "alternate-exchange", "delayed-message"}

Constructors

• .new(name : String, vhost : String, pattern : Regex, apply_to : Target, definition : Hash(String, JSON::Any), priority : Int8)
• .new(pull : JSON::PullParser)

Class Method Summary

• .merge_definitions(p1 : Policy, p2 : Policy) : Hash(String, JSON::Any)
• .merge_definitions(p1 : Nil, p2 : Policy) : Hash(String, JSON::Any)
• .merge_definitions(p1 : Policy, p2 : Nil) : Hash(String, JSON::Any)
• .merge_definitions(p1 : Nil, p2 : Nil) : Hash(String, JSON::Any)

Instance Method Summary

• #apply_to : Target
• #definition : Hash(String, JSON::Any)
• #details_tuple
• #match?(resource : Queue)
• #match?(resource : Exchange)
• #name : String
• #pattern : Regex
• #priority : Int8
• #vhost : String

Constructor Detail

Class Method Detail

Instance Method Detail