class AvalancheMQ::HeadersExchange
- AvalancheMQ::HeadersExchange
 - AvalancheMQ::Exchange
 - Reference
 - Object
 
Defined in:
avalanchemq/exchange/headers.crConstructors
Instance Method Summary
- #bind(destination : Queue, routing_key, headers)
 - #bind(destination : Exchange, routing_key, headers)
 - #do_exchange_matches(routing_key, headers = nil, &blk : Exchange -> )
 - #do_queue_matches(routing_key, headers = nil, &blk : Queue -> )
 - #type : String
 - #unbind(destination : Queue, routing_key, headers)
 - #unbind(destination : Exchange, routing_key, headers)
 
Instance methods inherited from class AvalancheMQ::Exchange
  
  
    
      alternate_exchange : String?
    alternate_exchange, 
    
  
    
      apply_policy(policy : Policy)
    apply_policy, 
    
  
    
      arguments : Hash(String, AMQ::Protocol::Field)
    arguments, 
    
  
    
      auto_delete : Bool
    auto_delete, 
    
  
    
      bind(destination : Queue, routing_key : String, headers : Hash(String, AMQP::Field) | Nil)bind(destination : Exchange, routing_key : String, headers : Hash(String, AMQP::Field) | Nil) bind, binding_details(key, destination) binding_details, bindings_details bindings_details, clear_policy clear_policy, delayed? : Bool delayed?, details_tuple details_tuple, do_exchange_matches(routing_key : String, headers : AMQP::Table | Nil, &blk : Exchange -> _) do_exchange_matches, do_queue_matches(routing_key : String, headers : AMQP::Table | Nil, &blk : Queue -> _) do_queue_matches, durable : Bool durable, exchange_bindings : Hash({String, Hash(String, AMQ::Protocol::Field)?}, Set(AvalancheMQ::Exchange)) exchange_bindings, exchange_matches(routing_key : String, headers = nil, &blk : Exchange -> _) exchange_matches, handle_arguments handle_arguments, in_use? in_use?, internal : Bool internal, match?(type, durable, auto_delete, internal, arguments)
match?(frame : AMQP::Frame) match?, name : String name, persistent? persistent?, policy : Policy | Nil policy, publish_in_count : UInt64 publish_in_count, publish_in_count=(publish_in_count : UInt64) publish_in_count=, publish_out_count : UInt64 publish_out_count, publish_out_count=(publish_out_count : UInt64) publish_out_count=, queue_bindings : Hash({String, Hash(String, AMQ::Protocol::Field)?}, Set(AvalancheMQ::Queue)) queue_bindings, queue_matches(routing_key : String, headers = nil, &blk : Queue -> _) queue_matches, referenced_sps(referenced_sps) : Nil referenced_sps, stats_details stats_details, type : String type, unbind(destination : Queue, routing_key : String, headers : Hash(String, AMQP::Field) | Nil)
unbind(destination : Exchange, routing_key : String, headers : Hash(String, AMQP::Field) | Nil) unbind, unroutable_count : UInt64 unroutable_count, unroutable_count=(unroutable_count : UInt64) unroutable_count=, update_rates update_rates, vhost : AvalancheMQ::VHost vhost
Constructor methods inherited from class AvalancheMQ::Exchange
  
  
    
      new(vhost : VHost, name : String, durable : Bool = false, auto_delete : Bool = false, internal : Bool = false, arguments : Hash(String, AMQ::Protocol::Field) = Hash(String, AMQP::Field).new)
    new
    
  
    
  
    
  Instance methods inherited from module Observable
  
  
    
      notify_observers(event : Symbol, data : Object | Nil = nil)
    notify_observers, 
    
  
    
      register_observer(observer : Observer)
    register_observer, 
    
  
    
      unregister_observer(observer : Observer)
    unregister_observer
    
  
    
    
  
    
  Instance methods inherited from module AvalancheMQ::SortableJSON
  
  
    
      details_tuple
    details_tuple, 
    
  
    
      to_json(json : JSON::Builder)
    to_json
    
  
    
    
  
    
    
    
  
    
  Instance methods inherited from module AvalancheMQ::PolicyTarget
  
  
    
      apply_policy(p : Policy)
    apply_policy, 
    
  
    
      clear_policy
    clear_policy, 
    
  
    
      policy : Policy | Nil
    policy
    
  
    
    
  
    
    
    
  
    
    
    
  
Constructor Detail
        
        def self.new(vhost : VHost, name : String, durable = false, auto_delete = false, internal = false, arguments = Hash(String, AMQP::Field).new)
        #