class
   LavinMQ::AMQP::StreamQueue
  
  - LavinMQ::AMQP::StreamQueue
 - LavinMQ::AMQP::DurableQueue
 - LavinMQ::AMQP::Queue
 - LavinMQ::Queue
 - Reference
 - Object
 
Defined in:
lavinmq/amqp/queue/stream_queue.crlavinmq/amqp/queue/stream_queue_message_store.cr
Constructors
Instance Method Summary
- #ack(sp : SegmentPosition) : Nil
 - #apply_policy(policy : Policy | Nil, operator_policy : OperatorPolicy | Nil)
 - 
        #basic_get(no_ack, force = false, & : Envelope -> Nil) : Bool
        
          
Stream queues does not support basic_get, so always returns
false - #consume_get(consumer : AMQP::StreamConsumer, & : Envelope -> Nil) : Bool
 - #find_offset(*args, **options)
 - #find_offset(*args, **options, &)
 - #last_offset(*args, **options)
 - #last_offset(*args, **options, &)
 - #new_messages(*args, **options)
 - #new_messages(*args, **options, &)
 - 
        #publish(msg : Message) : Bool
        
          
save message id / segment position
 - #reject(sp : SegmentPosition, requeue : Bool)
 - #store_consumer_offset(consumer_tag : String, offset : Int64) : Nil
 
Instance methods inherited from class LavinMQ::AMQP::DurableQueue
  
  
    
      durable?
    durable?
    
  
      
      
      
    
      
  Instance methods inherited from class LavinMQ::AMQP::Queue
  
  
    
      ack(sp : SegmentPosition) : Nil
    ack, 
    
  
    
      ack_count : UInt64
    ack_count, 
    
  
    
      add_consumer(consumer : Client::Channel::Consumer)
    add_consumer, 
    
  
    
      apply_policy(policy : Policy | Nil, operator_policy : OperatorPolicy | Nil)
    apply_policy, 
    
  
    
      arguments : AMQ::Protocol::Table
    arguments, 
    
  
    
      auto_delete? : Bool
    auto_delete?, 
    
  
    
      basic_get(no_ack, force = false, & : Envelope -> Nil) : Bool
    basic_get, 
    
  
    
      basic_get_unacked : Deque(LavinMQ::UnackedMessage)
    basic_get_unacked, 
    
  
    
      bindings
    bindings, 
    
  
    
      close : Bool
    close, 
    
  
    
      closed? : Bool
    closed?, 
    
  
    
      confirm_count : UInt64
    confirm_count, 
    
  
    
      consume_get(consumer, & : Envelope -> Nil) : Bool
    consume_get, 
    
  
    
      consumer_count
    consumer_count, 
    
  
    
      consumer_timeout : UInt64 | Nil
    consumer_timeout, 
    
  
    
      consumers : Array(LavinMQ::Client::Channel::Consumer)
    consumers, 
    
  
    
      current_stats_details
    current_stats_details, 
    
  
    
      dedup_count : UInt64
    dedup_count, 
    
  
    
      delete : Bool
    delete, 
    
  
    
      deliver_count : UInt64
    deliver_count, 
    
  
    
      deliver_get_count : UInt64
    deliver_get_count, 
    
  
    
      details_tuple
    details_tuple, 
    
  
    
      durable?
    durable?, 
    
  
    
      empty? : Bool
    empty?, 
    
  
    
      empty_change : ::Channel(Bool)
    empty_change, 
    
  
    
      exclusive? : Bool
    exclusive?, 
    
  
    
      get_count : UInt64
    get_count, 
    
  
    
      get_no_ack_count : UInt64
    get_no_ack_count, 
    
  
    
      has_exclusive_consumer? : Bool
    has_exclusive_consumer?, 
    
  
    
      has_priority_consumers? : Bool
    has_priority_consumers?, 
    
  
    
      immediate_delivery?
    immediate_delivery?, 
    
  
    
      in_use?
    in_use?, 
    
  
    
      inspect(io : IO)
    inspect, 
    
  
    
      match?(durable, exclusive, auto_delete, arguments)match?(frame) match?, message_count message_count, message_count_log : Deque(UInt32) message_count_log, name : String name, notify_observers(event : LavinMQ::QueueEvent, data : Object | Nil = nil) notify_observers, operator_policy : OperatorPolicy | Nil operator_policy, pause! pause!, paused? : Bool paused?, paused_change : Channel(Bool) paused_change, policy : Policy | Nil policy, publish(msg : Message) : Bool publish, publish_count : UInt64 publish_count, purge(max_count : Int = UInt32::MAX) : UInt32 purge, read(sp : SegmentPosition) : Envelope read, redeclare redeclare, redeliver_count : UInt64 redeliver_count, register_observer(observer : LavinMQ::Observer(LavinMQ::QueueEvent)) register_observer, reject(sp : SegmentPosition, requeue : Bool) reject, reject_count : UInt64 reject_count, resume! resume!, return_unroutable_count : UInt64 return_unroutable_count, rm_consumer(consumer : Client::Channel::Consumer) rm_consumer, single_active_consumer : Client::Channel::Consumer | Nil single_active_consumer, single_active_consumer_change : Channel(LavinMQ::Client::Channel::Consumer) single_active_consumer_change, state : LavinMQ::QueueState state, stats_details stats_details, to_json(json : JSON::Builder, consumer_limit : Int32 = -1) to_json, unacked_bytesize : UInt64 unacked_bytesize, unacked_count : UInt32 unacked_count, unacked_count_log : Deque(UInt32) unacked_count_log, unacked_messages unacked_messages, unregister_observer(observer : LavinMQ::Observer(LavinMQ::QueueEvent)) unregister_observer, update_rates : Nil update_rates, vhost : LavinMQ::VHost vhost
Constructor methods inherited from class LavinMQ::AMQP::Queue
  
  
    
      new(vhost : VHost, name : String, exclusive : Bool = false, auto_delete : Bool = false, arguments : AMQ::Protocol::Table = AMQP::Table.new)
    new
    
  
      
  Class methods inherited from class LavinMQ::AMQP::Queue
  
  
    
      generate_name
    generate_name
    
  
      
    
      
  Instance methods inherited from module LavinMQ::SortableJSON
  
  
    
      details_tuple
    details_tuple, 
    
  
    
      search_match?(value : String)search_match?(value : Regex) search_match?, to_json(json : JSON::Builder) to_json
Macros inherited from module LavinMQ::Stats
  
  
    
      rate_stats(stats_keys, log_keys = [] of ::String)
    rate_stats
    
  
    
      
      
      
      
    
      
  Instance methods inherited from module LavinMQ::PolicyTarget
  
  
    
      apply_policy(policy : Policy | Nil, operator_policy : OperatorPolicy | Nil)
    apply_policy, 
    
  
    
      clear_policy
    clear_policy, 
    
  
    
      operator_policy : OperatorPolicy | Nil
    operator_policy, 
    
  
    
      policy : Policy | Nil
    policy
    
  
      
      
      
    
      
      
      
      
    
      
  Instance methods inherited from module LavinMQ::SortableJSON
  
  
    
      details_tuple
    details_tuple, 
    
  
    
      search_match?(value : String)search_match?(value : Regex) search_match?, to_json(json : JSON::Builder) to_json
Constructor Detail
        
        def self.new(vhost : VHost, name : String, exclusive = false, auto_delete = false, arguments = AMQP::Table.new)
        #
      
      
      Instance Method Detail
Stream queues does not support basic_get, so always returns false