Package com.codeheadsystems.queue.impl

Class QueueImpl

java.lang.Object

com.codeheadsystems.queue.impl.QueueImpl

All Implemented Interfaces:

Queue

@Singleton
public class QueueImpl
extends Object
implements Queue

The type Queue.

Constructor Summary

Constructors

Constructor	Description
QueueImpl(MessageManager messageManager, QueueConfigurationFactory queueConfigurationFactory, com.codeheadsystems.metrics.Metrics metrics)	Instantiates a new Queue.

Method Summary

Modifier and Type	Method	Description
void	clear(Message message)	Clear.
void	clearAll()	Clear all.
Optional<Message>	enqueue(String messageType, String payload)	Enqueue message.
Map<State,Long>	getMessageStateCounts()	Provides the list of messages enqueued within the system for each state.
Optional<State>	getState(Message message)	Gets state.

Methods inherited from class java.lang.Object

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

Constructor Details

QueueImpl

@Inject
public QueueImpl(MessageManager messageManager,
 QueueConfigurationFactory queueConfigurationFactory,
 com.codeheadsystems.metrics.Metrics metrics)

Instantiates a new Queue.

Parameters:

messageManager - the message manager

queueConfigurationFactory - the queue configuration factory

metrics - the metrics

Method Details

enqueue

public Optional<Message> enqueue(String messageType,
 String payload)

Description copied from interface: Queue

Enqueue message.

Specified by:

enqueue in interface Queue

Parameters:

messageType - the message type

payload - the payload

Returns:

the message if it could be enqueued.

getState

public Optional<State> getState(Message message)

Description copied from interface: Queue

Gets state.

Specified by:

getState in interface Queue

Parameters:

message - the message

Returns:

the state if it is found.

getMessageStateCounts

public Map<State,Long> getMessageStateCounts()

Description copied from interface: Queue

Provides the list of messages enqueued within the system for each state.

Specified by:

getMessageStateCounts in interface Queue

Returns:

map list.

clearAll

public void clearAll()

Description copied from interface: Queue

Clear all.

Specified by:

clearAll in interface Queue

clear

public void clear(Message message)

Description copied from interface: Queue

Clear.

Specified by:

clear in interface Queue

Parameters:

message - the message