Class GenericEventBasedConsumer


  • public abstract class GenericEventBasedConsumer
    extends Object
    • Field Detail

      • PARAM_INBOUND_ENDPOINT_BEHAVIOR_EVENT_BASED

        public static final String PARAM_INBOUND_ENDPOINT_BEHAVIOR_EVENT_BASED
        See Also:
        Constant Field Values
      • synapseEnvironment

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

        protected String injectingSeq
      • onErrorSeq

        protected String onErrorSeq
      • coordination

        protected boolean coordination
      • sequential

        protected boolean sequential
    • Constructor Detail

      • GenericEventBasedConsumer

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

      • listen

        public abstract void listen()
        This methods needs to be implemented when implementing the custom inbound
      • destroy

        public abstract void destroy()
        This methods needs to be implemented when terminating the inbound
      • injectMessage

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

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

        public static boolean isEventBasedInboundEndpoint​(org.apache.synapse.inbound.InboundProcessorParams inboundParameters)
        States whether generic endpoint is a eventBased Return true; if eventBased
        Parameters:
        inboundParameters - Inbound Parameters for endpoint
        Returns:
        boolean