Class InMemoryStore

    • Constructor Detail

      • InMemoryStore

        public InMemoryStore()
    • Method Detail

      • getProducer

        public MessageProducer getProducer()
        Description copied from interface: MessageStore
        Returns a Message Producer for this message store.
        Returns:
        A non-null message producer that can produce messages to this message store.
      • getConsumer

        public MessageConsumer getConsumer()
        Description copied from interface: MessageStore
        Returns a Message Consumer for this message store.
        Returns:
        A non-null message consumer that can read messages from this message store.
      • size

        public int size()
        Description copied from interface: MessageStore
        Returns the number of Messages in this store.
        Specified by:
        size in interface MessageStore
        Overrides:
        size in class AbstractMessageStore
        Returns:
        the number of Messages in this Store
      • clear

        public void clear()
        Description copied from interface: MessageStore
        Delete all the Messages in the Message Store
      • remove

        public MessageContext remove​(String messageID)
        Description copied from interface: MessageStore
        Delete and return the MessageContext with given Message id
        Parameters:
        messageID - message id of the Message
        Returns:
        MessageContext instance
      • get

        public MessageContext get​(int index)
        Description copied from interface: MessageStore
        Return the Message in given index position (this may depend on the implementation)
        Parameters:
        index - position of the message
        Returns:
        Message in given index position
      • getAll

        public List<MessageContext> getAll()
        Description copied from interface: MessageStore
        Get the All messages in the Message store without removing them from the queue
        Returns:
        List of all Messages
      • get

        public MessageContext get​(String messageId)
        Description copied from interface: MessageStore
        Get the Message with the given ID from the Message store without removing it
        Parameters:
        messageId - A message ID string
        Returns:
        Message with given ID
      • getQLock

        public Object getQLock()