com.botscrew.messengercdk.domain.internal

Class LockingQueue<T>

java.lang.Object

com.botscrew.messengercdk.domain.internal.LockingQueue<T>

Type Parameters:

T -

public class LockingQueue<T>
extends Object

Queue wrapper for specific needs inside messenger module Main idea is the ability to define if some consumer is already working with this queue, so another will not start working with it. In result we have queues that can be used only with one thread Usecase is sending messages to a user in the correct order, how they was added to the queue. If we will send next message only when previous was delivered and response returned, we will have correct order of messages delivered to a user.

Constructor Summary

Constructors

Constructor and Description
LockingQueue()

Method Summary

Modifier and Type	Method and Description
void	clear()
Optional<T>	getNextOrUnlock() Uses internal lock to be sure that this method cannot be used in the same time as other which also using internal lock (f.e isLocked)
boolean	isLocked() Uses internal lock to be sure that this method cannot be used in the same time as other which also using internal lock (f.e getNextOrUnlock)
void	push(T t)
boolean	tryLock()
void	unlock()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LockingQueue

public LockingQueue()

Method Detail

push

public void push(T t)

tryLock

public boolean tryLock()

isLocked

public boolean isLocked()

Uses internal lock to be sure that this method cannot be used in the same time as other which also using internal lock (f.e getNextOrUnlock)

Returns:

if this queue is being used or not

getNextOrUnlock

public Optional<T> getNextOrUnlock()

Uses internal lock to be sure that this method cannot be used in the same time as other which also using internal lock (f.e isLocked)

Returns:

Optional wrapper for next object in a queue

clear

public void clear()

unlock

public void unlock()