Package org.wso2.carbon.inbound.endpoint.protocol.generic

Class GenericPollingConsumer

java.lang.Object
org.wso2.carbon.inbound.endpoint.protocol.generic.GenericPollingConsumer
public abstract class GenericPollingConsumer extends Object

  • Field Details

    • properties

      protected Properties properties

    • name

      protected String name

    • 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 Details

    • GenericPollingConsumer

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

  • Method Details

    • poll

      public abstract Object poll()

    • resume

      public void resume()

    • destroy

      public void destroy()

    • injectMessage

      protected boolean injectMessage(String strMessage, String contentType)

    • injectMessage

      protected boolean injectMessage(InputStream in, String contentType)

    • getInboundProperties

      protected Properties getInboundProperties()