org.mule.transport.stdio

Class StdioMessageReceiver

  • java.lang.Object
    • org.mule.transport.AbstractTransportMessageHandler
      • org.mule.transport.AbstractMessageReceiver
        • org.mule.transport.AbstractPollingMessageReceiver
          • org.mule.transport.stdio.StdioMessageReceiver
  • All Implemented Interfaces:
    org.mule.api.lifecycle.Disposable, org.mule.api.lifecycle.Initialisable, org.mule.api.lifecycle.Lifecycle, org.mule.api.lifecycle.LifecycleStateEnabled, org.mule.api.lifecycle.Startable, org.mule.api.lifecycle.Stoppable, org.mule.api.source.MessageSource, org.mule.api.transport.Connectable, org.mule.api.transport.MessageReceiver


    public class StdioMessageReceiverextends org.mule.transport.AbstractPollingMessageReceiver
    StdioMessageReceiver is a listener for events from Mule components which then simply passes the events on to the target components.
    • Field Summary

      Fields 
      Modifier and TypeField and Description
      static intDEFAULT_BUFFER_SIZE 
      • Fields inherited from class org.mule.transport.AbstractPollingMessageReceiver

        DEFAULT_POLL_FREQUENCY, DEFAULT_POLL_TIMEUNIT, DEFAULT_STARTUP_DELAY, schedules
      • Fields inherited from class org.mule.transport.AbstractMessageReceiver

        defaultInboundTransformers, defaultResponseTransformers, flowConstruct, listener, receiverKey, replyToHandler
      • Fields inherited from class org.mule.transport.AbstractTransportMessageHandler

        connected, defaultMessageInfoMapping, endpoint, lifecycleManager, logger, muleMessageFactory, retryTemplate
      • Fields inherited from interface org.mule.api.lifecycle.Initialisable

        PHASE_NAME
      • Fields inherited from interface org.mule.api.lifecycle.Startable

        PHASE_NAME
      • Fields inherited from interface org.mule.api.lifecycle.Stoppable

        PHASE_NAME
      • Fields inherited from interface org.mule.api.lifecycle.Disposable

        PHASE_NAME
    • Constructor Summary

      Constructors 
      Constructor and Description
      StdioMessageReceiver(org.mule.api.transport.Connector connector, org.mule.api.construct.FlowConstruct flowConstruct, org.mule.api.endpoint.InboundEndpoint endpoint, long checkFrequency) 
    • Method Summary

      Methods 
      Modifier and TypeMethod and Description
      voiddoConnect() 
      voiddoDisconnect() 
      protected voiddoDispose() 
      intgetBufferSize() 
      InputStreamgetInputStream() 
      voidpoll() 
      voidsetBufferSize(int bufferSize) 
      voidsetInputStream(InputStream inputStream) 
      • Methods inherited from class org.mule.transport.AbstractPollingMessageReceiver

        createWork, disableNativeScheduling, doStart, doStop, getBatchSize, getFrequency, getTimeUnit, performPoll, pollOnPrimaryInstanceOnly, schedule, setFrequency, setTimeUnit, unschedule
      • Methods inherited from class org.mule.transport.AbstractMessageReceiver

        applyInboundTransformers, applyResponseTransformers, connectHandler, createExecutionTemplate, createLifecycleManager, createMuleEvent, doStartHandler, getConnectEventId, getConnectionDescription, getEndpoint, getEndpointURI, getFlowConstruct, getReceiverKey, getReplyToHandler, getWorkManager, handleUnacceptedFilter, initialise, processMessage, propagateRootMessageIdProperty, routeEvent, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setEndpoint, setListener, setReceiverKey, shouldConsumeInEveryNode, toString, warnIfMuleClientSendUsed
      • Methods inherited from class org.mule.transport.AbstractTransportMessageHandler

        activate, connect, createMuleMessage, createMuleMessage, createMuleMessage, createMuleMessageFactory, createNullMuleMessage, disconnect, dispose, disposeAndLogException, doInitialise, getConnectEventId, getConnector, getLifecycleState, initializeMessageFactory, initializeRetryPolicy, isConnected, isDoThreading, isStarted, isStarting, isStopped, isStopping, passivate, setEndpoint, start, stop, validate, validateConnection
      • Methods inherited from interface org.mule.api.transport.MessageReceiver

        createMuleMessage, createMuleMessage
      • Methods inherited from interface org.mule.api.transport.Connectable

        connect, disconnect, isConnected, validateConnection
      • Methods inherited from interface org.mule.api.lifecycle.Startable

        start
      • Methods inherited from interface org.mule.api.lifecycle.Stoppable

        stop
      • Methods inherited from interface org.mule.api.lifecycle.Disposable

        dispose
    • Field Detail

    • Constructor Detail

      • StdioMessageReceiver

        public StdioMessageReceiver(org.mule.api.transport.Connector connector,                    org.mule.api.construct.FlowConstruct flowConstruct,                    org.mule.api.endpoint.InboundEndpoint endpoint,                    long checkFrequency)                     throws org.mule.api.lifecycle.CreateException
        Throws:
        org.mule.api.lifecycle.CreateException
    • Method Detail

      • doDispose

        protected void doDispose()
        Overrides:
        doDispose in class org.mule.transport.AbstractMessageReceiver
      • doConnect

        public void doConnect()               throws Exception
        Overrides:
        doConnect in class org.mule.transport.AbstractTransportMessageHandler
        Throws:
        Exception
      • doDisconnect

        public void doDisconnect()                  throws Exception
        Overrides:
        doDisconnect in class org.mule.transport.AbstractTransportMessageHandler
        Throws:
        Exception
      • poll

        public void poll()
        Specified by:
        poll in class org.mule.transport.AbstractPollingMessageReceiver
      • setInputStream

        public void setInputStream(InputStream inputStream)
      • getBufferSize

        public int getBufferSize()
      • setBufferSize

        public void setBufferSize(int bufferSize)

Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.



NOTHING
NOTHING
Add the Maven Dependecy to your project: maven dependecy for com.amazonaws : aws-java-sdk : 1.3.14