public class PromptStdioConnector extends StdioConnector
PromptStdioConnector
connects to the System streams in and out by
default and add some basic fuctionality for writing out prompt messages.inputStream, outputStream, STDIO, STREAM_SYSTEM_ERR, STREAM_SYSTEM_IN, STREAM_SYSTEM_OUT
createMultipleTransactedReceivers, DEFAULT_NUM_CONCURRENT_TX_RECEIVERS, dispatcherFactory, dispatcherPoolFactory, dispatchers, initialStateStopped, lifecycleManager, logger, muleContext, muleMessageFactory, name, numberOfConcurrentTransactedReceivers, PROPERTY_POLLING_FREQUENCY, receivers, requesterFactory, requesters, serviceDescriptor, serviceOverrides, sessionHandler, startOnConnect
INT_VALUE_NOT_SET
PHASE_NAME
Constructor and Description |
---|
PromptStdioConnector(MuleContext context) |
Modifier and Type | Method and Description |
---|---|
protected void |
doConnect()
Template method where any connections should be made for the connector
|
protected void |
doDisconnect()
Template method where any connected resources used by the connector should be
disconnected
|
protected void |
doDispose()
Template method to perform any work when destroying the connectoe
|
protected void |
doInitialise() |
void |
doStart()
Template method to perform any work when starting the connectoe
|
Connector |
getConnector() |
InputStream |
getInputStream() |
long |
getMessageDelayTime() |
String |
getOutputMessage() |
String |
getOutputMessageCode() |
OutputStream |
getOutputStream() |
OutputStream |
getOutputStream(ImmutableEndpoint endpoint,
MuleMessage message) |
String |
getPromptMessage() |
String |
getPromptMessageCode() |
String |
getResourceBundle() |
void |
setMessageDelayTime(long messageDelayTime) |
void |
setOutputMessage(String outputMessage) |
void |
setOutputMessageCode(String outputMessageCode) |
void |
setPromptMessage(String promptMessage) |
void |
setPromptMessageCode(String promptMessageCode) |
void |
setResourceBundle(String resourceBundle) |
createReceiver, doStop, getProtocol, registerListener, setInputStream, setOutputStream
borrowDispatcher, clearDispatchers, clearRequesters, configureDispatcherPool, connect, createDefaultRedeliveryPolicy, createDispatcherMessageProcessor, createMuleMessageFactory, createOperationResource, createScheduler, destroyReceiver, disconnect, dispose, disposeReceivers, disposeWorkManagers, doUnregisterListener, fireNotification, getCanonicalURI, getConnectEventId, getConnectionDescription, getDefaultExchangePattern, getDefaultInboundTransformers, getDefaultOutboundTransformers, getDefaultResponseTransformers, getDispatcherFactory, getDispatcherPoolFactory, getDispatcherThreadingProfile, getDispatcherWorkManager, getInboundExchangePatterns, getLifecycleState, getMaxDispatchersActive, getMaxRequestersActive, getMaxTotalDispatchers, getMuleContext, getMuleMessageFactory, getName, getNumberOfConcurrentTransactedReceivers, getOperationResourceFactory, getOutboundExchangePatterns, getOutputStream, getReceiver, getReceiverKey, getReceivers, getReceivers, getReceiverThreadingProfile, getReceiverWorkManager, getReplyToHandler, getRequesterFactory, getRequesterThreadingProfile, getRequesterWorkManager, getRetryPolicyTemplate, getScheduler, getServiceDescriptor, getServiceOverrides, getSessionHandler, getSupportedProtocols, getTransactionalResource, handleWorkException, initFromServiceDescriptor, initialise, initialiseFromUrl, initWorkManagers, isConnected, isConnecting, isCreateMultipleTransactedReceivers, isDisposed, isEnableMessageEvents, isInitialised, isInitialStateStopped, isResponseEnabled, isStarted, isStarting, isStopped, isStopping, isValidateConnections, lookupReceiver, registerSupportedMetaProtocol, registerSupportedProtocol, registerSupportedProtocolWithoutPrefix, request, request, returnDispatcher, setConnected, setConnecting, setCreateMultipleTransactedReceivers, setDispatcherFactory, setDispatcherPoolFactory, setDispatcherPoolMaxWait, setDispatcherPoolWhenExhaustedAction, setDispatcherThreadingProfile, setDynamicNotification, setInitialStateStopped, setMaxDispatchersActive, setMaxRequestersActive, setName, setNumberOfConcurrentTransactedReceivers, setReceiverThreadingProfile, setRequesterFactory, setRequesterPoolMaxWait, setRequesterPoolWhenExhaustedAction, setRequesterThreadingProfile, setRetryPolicyTemplate, setServiceOverrides, setSessionHandler, setSupportedProtocols, setupDispatchReturn, setupRequestReturn, setValidateConnections, shutdownScheduler, start, startAfterConnect, stop, supportsProtocol, toString, unregisterListener, unregisterSupportedProtocol, updateCachedNotificationHandler, validateConnection, workAccepted, workCompleted, workRejected, workStarted
public PromptStdioConnector(MuleContext context)
protected void doInitialise() throws InitialisationException
doInitialise
in class AbstractConnector
InitialisationException
protected void doDispose()
AbstractConnector
doDispose
in class StdioConnector
protected void doConnect() throws Exception
AbstractConnector
doConnect
in class AbstractConnector
Exception
protected void doDisconnect() throws Exception
AbstractConnector
doDisconnect
in class AbstractConnector
Exception
public InputStream getInputStream()
getInputStream
in class StdioConnector
public void doStart()
AbstractConnector
doStart
in class StdioConnector
public OutputStream getOutputStream()
getOutputStream
in class StdioConnector
public String getPromptMessage()
public void setPromptMessage(String promptMessage)
promptMessage
- The promptMessage to set.public String getPromptMessageCode()
public void setPromptMessageCode(String promptMessageCode)
promptMessageCode
- The promptMessageCode to set.public String getResourceBundle()
public void setResourceBundle(String resourceBundle)
resourceBundle
- The resourceBundle to read the message from. This property is
only needed in conjunction with promptMessageCode or outputMessageCode.public String getOutputMessage()
public void setOutputMessage(String outputMessage)
outputMessage
- The outputMessage to set.public String getOutputMessageCode()
public void setOutputMessageCode(String outputMessageCode)
outputMessageCode
- The outputMessageCode to set.public Connector getConnector()
public long getMessageDelayTime()
public void setMessageDelayTime(long messageDelayTime)
public OutputStream getOutputStream(ImmutableEndpoint endpoint, MuleMessage message) throws MuleException
MuleException
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.