|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.mule.transport.AbstractTransportMessageHandler
org.mule.transport.AbstractMessageReceiver
org.mule.transport.erlang.ErlangMessageReceiver
public class ErlangMessageReceiver
The ErlangMessageReceiver
creates a single worker listening to an OtpMbox (which can only be consumed by
a single thread) but delegates the routing of incoming messages to workers.
Field Summary |
---|
Fields inherited from class org.mule.transport.AbstractMessageReceiver |
---|
defaultInboundTransformers, defaultResponseTransformers, flowConstruct, listener, receiverKey, replyToHandler |
Fields inherited from class org.mule.transport.AbstractTransportMessageHandler |
---|
connected, 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 | |
---|---|
ErlangMessageReceiver(org.mule.api.transport.Connector connector,
org.mule.api.construct.FlowConstruct flowConstruct,
org.mule.api.endpoint.InboundEndpoint endpoint)
|
Method Summary | |
---|---|
void |
doConnect()
|
void |
doDisconnect()
|
void |
doDispose()
|
protected void |
doStart()
|
protected void |
doStop()
|
void |
respondToErlangProcess(com.ericsson.otp.erlang.OtpErlangPid pid,
com.ericsson.otp.erlang.OtpErlangObject message)
|
Methods inherited from class org.mule.transport.AbstractMessageReceiver |
---|
applyInboundTransformers, applyResponseTransformers, createLifecycleManager, createMuleEvent, getConnectEventId, getConnectionDescription, getEndpoint, getEndpointURI, getFlowConstruct, getReceiverKey, getReplyToHandler, getWorkManager, handleUnacceptedFilter, initialise, routeMessage, routeMessage, routeMessage, routeMessage, setEndpoint, setListener, setReceiverKey, toString |
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, isStopping, passivate, setEndpoint, start, stop, validate, validateConnection |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
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 |
Constructor Detail |
---|
public ErlangMessageReceiver(org.mule.api.transport.Connector connector, org.mule.api.construct.FlowConstruct flowConstruct, org.mule.api.endpoint.InboundEndpoint endpoint) throws org.mule.api.lifecycle.CreateException
org.mule.api.lifecycle.CreateException
Method Detail |
---|
public void doConnect() throws org.mule.transport.ConnectException
doConnect
in class org.mule.transport.AbstractTransportMessageHandler
org.mule.transport.ConnectException
protected void doStart() throws org.mule.api.MuleException
doStart
in class org.mule.transport.AbstractTransportMessageHandler
org.mule.api.MuleException
protected void doStop() throws org.mule.api.MuleException
doStop
in class org.mule.transport.AbstractTransportMessageHandler
org.mule.api.MuleException
public void doDisconnect() throws org.mule.transport.ConnectException
doDisconnect
in class org.mule.transport.AbstractTransportMessageHandler
org.mule.transport.ConnectException
public void doDispose()
doDispose
in class org.mule.transport.AbstractMessageReceiver
public void respondToErlangProcess(com.ericsson.otp.erlang.OtpErlangPid pid, com.ericsson.otp.erlang.OtpErlangObject message)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |