Package com.codeheadsystems.queue

Interface Queue

All Known Implementing Classes:
QueueImpl
public interface Queue
The interface Queue.

  • Method Details

    • enqueue

      Optional<Message> enqueue(String messageType, String payload)
      Enqueue message.
      Parameters:
      messageType - the message type
      payload - the payload
      Returns:
      the message if it could be enqueued.

    • getState

      Optional<State> getState(Message message)
      Gets state.
      Parameters:
      message - the message
      Returns:
      the state if it is found.

    • getMessageStateCounts

      Map<State,Long> getMessageStateCounts()
      Provides the list of messages enqueued within the system for each state.
      Returns:
      map list.

    • clearAll

      void clearAll()
      Clear all.

    • clear

      void clear(Message message)
      Clear.
      Parameters:
      message - the message