class LavinMQ::StreamQueue
- LavinMQ::StreamQueue
- LavinMQ::DurableQueue
- LavinMQ::Queue
- Reference
- Object
Defined in:
lavinmq/queue/stream_queue.crlavinmq/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 : Client::Channel::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)
Instance methods inherited from class LavinMQ::DurableQueue
durable?
durable?
Instance methods inherited from class LavinMQ::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,
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,
delete : Bool
delete,
deliver_count : UInt64
deliver_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,
last_get_time : Time::Span
last_get_time,
match?(durable, exclusive, auto_delete, arguments)match?(frame) match?, message_count message_count, message_count_log : Deque(UInt32) message_count_log, name : String name, 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, purge_and_close_consumers : UInt32 purge_and_close_consumers, read(sp : SegmentPosition) : Envelope read, redeclare redeclare, redeliver_count : UInt64 redeliver_count, 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, update_rates : Nil update_rates, vhost : LavinMQ::VHost vhost
Constructor methods inherited from class LavinMQ::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::Queue
generate_name
generate_name
Instance methods inherited from module LavinMQ::SortableJSON
details_tuple
details_tuple,
to_json(json : JSON::Builder)
to_json
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 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
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