Class GenericPollingConsumer


  • public abstract class GenericPollingConsumer
    extends Object
    • Field Detail

      • synapseEnvironment

        protected org.apache.synapse.core.SynapseEnvironment synapseEnvironment
      • scanInterval

        protected long scanInterval
      • injectingSeq

        protected String injectingSeq
      • onErrorSeq

        protected String onErrorSeq
      • coordination

        protected boolean coordination
      • sequential

        protected boolean sequential
    • Constructor Detail

      • GenericPollingConsumer

        public GenericPollingConsumer​(Properties properties,
                                      String name,
                                      org.apache.synapse.core.SynapseEnvironment synapseEnvironment,
                                      long scanInterval,
                                      String injectingSeq,
                                      String onErrorSeq,
                                      boolean coordination,
                                      boolean sequential)
    • Method Detail

      • poll

        public abstract Object poll()
      • destroy

        public void destroy()
      • injectMessage

        protected boolean injectMessage​(String strMessage,
                                        String contentType)
      • injectMessage

        protected boolean injectMessage​(InputStream in,
                                        String contentType)
      • getInboundProperties

        protected Properties getInboundProperties()