class MessageQueue
- MessageQueue
- Reference
- Object
Defined in:
privateparlor/queue/message_queue.crConstructors
Instance Method Summary
-
#add_to_queue(cached_msid : Int64 | Array(Int64), sender_id : Int64 | Nil, receiver_ids : Array(Int64), reply_msid : Nil, func : MessageProc) : Nil
Creates a new
QueuedMessageand pushes it to the back of the queue. -
#add_to_queue(cached_msid : Int64 | Array(Int64), sender_id : Int64 | Nil, receiver_ids : Array(Int64), reply_msids : Hash(Int64, Int64), func : MessageProc) : Nil
Creates a new
QueuedMessagewith a reply and pushes it to the back of the queue. -
#add_to_queue_priority(receiver_id : Int64, reply_msid : Int64 | Nil, func : MessageProc) : Nil
Creates a new
QueuedMessageand pushes it to the front of the queue. - #get_message : QueuedMessage | Nil
- #queue : Deque(QueuedMessage)
- #queue_mutex : Mutex
- #reject_messsages(&) : Nil
Constructor Detail
Instance Method Detail
def add_to_queue(cached_msid : Int64 | Array(Int64), sender_id : Int64 | Nil, receiver_ids : Array(Int64), reply_msid : Nil, func : MessageProc) : Nil
#
Creates a new QueuedMessage and pushes it to the back of the queue.
def add_to_queue(cached_msid : Int64 | Array(Int64), sender_id : Int64 | Nil, receiver_ids : Array(Int64), reply_msids : Hash(Int64, Int64), func : MessageProc) : Nil
#
Creates a new QueuedMessage with a reply and pushes it to the back of the queue.
def add_to_queue_priority(receiver_id : Int64, reply_msid : Int64 | Nil, func : MessageProc) : Nil
#
Creates a new QueuedMessage and pushes it to the front of the queue.