Class InMemoryProducer

    • Constructor Detail

      • InMemoryProducer

        public InMemoryProducer​(InMemoryStore store)
    • Method Detail

      • storeMessage

        public boolean storeMessage​(MessageContext synCtx)
        Description copied from interface: MessageProducer
        Stores the given message to the store associated with this message consumer.
        Specified by:
        storeMessage in interface MessageProducer
        Parameters:
        synCtx - Message to be saved.
        Returns:
        true if storing of the message is successful, false otherwise.
      • cleanup

        public boolean cleanup()
        Description copied from interface: MessageProducer
        Cleans up this message consumer
        Specified by:
        cleanup in interface MessageProducer
        Returns:
        true if clean up is successful, false otherwise.
      • setId

        public void setId​(int id)
        Description copied from interface: MessageProducer
        Sets the ID of this message consumer.
        Specified by:
        setId in interface MessageProducer
        Parameters:
        id - ID