Class RedisDocumentMessageConsumer

    • Constructor Detail

      • RedisDocumentMessageConsumer

        public RedisDocumentMessageConsumer​(String consumerId,
                                            String redisPrefix)
    • Method Detail

      • accept

        public void accept​(DocumentMessage message)
        Description copied from interface: Consumer
        Consume a message.
      • getProperties

        protected String getProperties​(DocumentMessage message)
                                throws com.fasterxml.jackson.core.JsonProcessingException
        Throws:
        com.fasterxml.jackson.core.JsonProcessingException
      • bytes

        protected byte[] bytes​(String val)
      • begin

        public void begin()
        Description copied from interface: Consumer
        Begin a batch of messages.
      • commit

        public void commit()
        Description copied from interface: Consumer
        End of the batch message.