Class JPAConsumer

  • All Implemented Interfaces:
    org.apache.synapse.message.MessageConsumer

    public class JPAConsumer
    extends Object
    implements org.apache.synapse.message.MessageConsumer
    • Constructor Detail

      • JPAConsumer

        public JPAConsumer()
    • Method Detail

      • receive

        public org.apache.synapse.MessageContext receive()
        Specified by:
        receive in interface org.apache.synapse.message.MessageConsumer
      • ack

        public boolean ack()
        Specified by:
        ack in interface org.apache.synapse.message.MessageConsumer
      • cleanup

        public boolean cleanup()
        Specified by:
        cleanup in interface org.apache.synapse.message.MessageConsumer
      • isAlive

        public boolean isAlive()
        Specified by:
        isAlive in interface org.apache.synapse.message.MessageConsumer
      • setAlive

        public void setAlive​(boolean isAlive)
        Set availability of connectivity with the message store
        Specified by:
        setAlive in interface org.apache.synapse.message.MessageConsumer
        Parameters:
        isAlive - connection availability.
      • setId

        public void setId​(int i)
        Specified by:
        setId in interface org.apache.synapse.message.MessageConsumer
      • getId

        public String getId()
        Specified by:
        getId in interface org.apache.synapse.message.MessageConsumer