Class JDBCProducer

    • Constructor Detail

      • JDBCProducer

        public JDBCProducer​(JDBCMessageStore store)
        Initialize producer
        Parameters:
        store - - JDBC message store
    • Method Detail

      • storeMessage

        public boolean storeMessage​(MessageContext synCtx)
        Add a message to the end of the table. If fetching success return true else false
        Specified by:
        storeMessage in interface MessageProducer
        Parameters:
        synCtx - message to insert
        Returns:
        - success/failure of fetching
      • cleanup

        public boolean cleanup()
        Cleanup the producer
        Specified by:
        cleanup in interface MessageProducer
        Returns:
        true Since no producer specific things
      • setId

        public void setId​(int id)
        Set producer id
        Specified by:
        setId in interface MessageProducer
        Parameters:
        id - ID
      • getId

        public String getId()
        Get producer id
        Specified by:
        getId in interface MessageProducer
        Returns:
        producerId - Producer identifier