public class OldHttpMessageReceiver extends TcpMessageReceiver
HttpMessageReceiver
is a simple http server that can be used to
listen for HTTP requests on a particular port.Modifier and Type | Class and Description |
---|---|
protected class |
OldHttpMessageReceiver.HttpWorker |
TcpMessageReceiver.TcpWorker
disposing
defaultInboundTransformers, defaultResponseTransformers, flowConstruct, listener, receiverKey, replyToHandler
connected, connector, endpoint, lifecycleManager, logger, muleMessageFactory, retryTemplate
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
OldHttpMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected javax.resource.spi.work.Work |
createWork(Socket socket) |
protected void |
doConnect() |
static MessageReceiver |
findReceiverByStem(Map<Object,MessageReceiver> receivers,
String uriStr) |
protected MessageReceiver |
getTargetReceiver(MuleMessage message,
ImmutableEndpoint ep) |
protected MuleMessage |
handleUnacceptedFilter(MuleMessage message) |
protected void |
initializeMessageFactory()
Subclasses can override this method to create a custom
MuleMessageFactory instead
of re-using the instance from the connector. |
protected String |
processRelativePath(String contextPath,
String path) |
protected boolean |
shouldConnect() |
protected HttpResponse |
transformResponse(Object response,
MuleEvent event) |
doDisconnect, doDispose, doStart, doStop, getServerSocket, release, run
applyInboundTransformers, applyResponseTransformers, connectHandler, createExecutionTemplate, createLifecycleManager, createMuleEvent, doStartHandler, getConnectEventId, getConnectionDescription, getEndpoint, getEndpointURI, getFlowConstruct, getReceiverKey, getReplyToHandler, getWorkManager, initialise, processMessage, propagateRootMessageIdProperty, routeEvent, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setEndpoint, setListener, setReceiverKey, shouldConsumeInEveryNode, toString, warnIfMuleClientSendUsed
activate, connect, createMuleMessage, createMuleMessage, createMuleMessage, createMuleMessageFactory, createNullMuleMessage, disconnect, dispose, disposeAndLogException, doInitialise, getConnectEventId, getConnector, getLifecycleState, initializeRetryPolicy, isConnected, isDoThreading, isStarted, isStarting, isStopped, isStopping, passivate, setEndpoint, start, stop, validate, validateConnection
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
createMuleMessage, createMuleMessage
connect, disconnect, isConnected, validateConnection
dispose
public OldHttpMessageReceiver(Connector connector, FlowConstruct flowConstruct, InboundEndpoint endpoint) throws CreateException
CreateException
protected javax.resource.spi.work.Work createWork(Socket socket) throws IOException
createWork
in class TcpMessageReceiver
IOException
protected void doConnect() throws ConnectException
doConnect
in class TcpMessageReceiver
ConnectException
protected boolean shouldConnect()
protected MessageReceiver getTargetReceiver(MuleMessage message, ImmutableEndpoint ep) throws ConnectException
ConnectException
protected HttpResponse transformResponse(Object response, MuleEvent event) throws MuleException
MuleException
public static MessageReceiver findReceiverByStem(Map<Object,MessageReceiver> receivers, String uriStr)
protected void initializeMessageFactory() throws InitialisationException
AbstractTransportMessageHandler
MuleMessageFactory
instead
of re-using the instance from the connector.initializeMessageFactory
in class AbstractTransportMessageHandler
InitialisationException
protected MuleMessage handleUnacceptedFilter(MuleMessage message)
handleUnacceptedFilter
in class AbstractMessageReceiver
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.