org.mule.transport.udp
Class UdpMessageRequester
java.lang.Object
org.mule.transport.AbstractTransportMessageHandler
org.mule.transport.AbstractMessageRequester
org.mule.transport.udp.UdpMessageRequester
- All Implemented Interfaces:
- Disposable, Initialisable, Lifecycle, LifecycleStateEnabled, Startable, Stoppable, Connectable, MessageRequester, MessageRequesting
public class UdpMessageRequester
- extends AbstractMessageRequester
Responsible for requesting MuleEvents as UDP packets on the network
Methods inherited from class org.mule.transport.AbstractTransportMessageHandler |
activate, connect, createMuleMessage, createMuleMessage, createMuleMessage, createMuleMessageFactory, createNullMuleMessage, disconnect, dispose, disposeAndLogException, doInitialise, doStart, doStop, getConnectEventId, getConnectionDescription, getConnector, getLifecycleState, initializeMessageFactory, initializeRetryPolicy, isConnected, isDoThreading, isStarted, isStarting, isStopping, passivate, setEndpoint, start, stop, toString, validate |
Methods inherited from interface org.mule.api.lifecycle.Startable |
start |
Methods inherited from interface org.mule.api.lifecycle.Stoppable |
stop |
connector
protected final UdpConnector connector
UdpMessageRequester
public UdpMessageRequester(InboundEndpoint endpoint)
doConnect
protected void doConnect()
throws Exception
- Overrides:
doConnect
in class AbstractTransportMessageHandler
- Throws:
Exception
validateConnection
public RetryContext validateConnection(RetryContext retryContext)
- Description copied from interface:
Connectable
- Test whether the connector is able to connect to its resource(s).
This will allow a retry policy to go into effect in the case of failure. Implementations must
call either:
Callers should then check for
RetryContext.isOk()
. The failure, if any, will be
provided via the RetryContext.getLastFailure()
.
- Specified by:
validateConnection
in interface Connectable
- Overrides:
validateConnection
in class AbstractTransportMessageHandler
- Returns:
- same retry context with status info set and any failures populated
doDisconnect
protected void doDisconnect()
throws Exception
- Overrides:
doDisconnect
in class AbstractTransportMessageHandler
- Throws:
Exception
doRequest
protected MuleMessage doRequest(long timeout)
throws Exception
- Make a specific request to the underlying transport
- Specified by:
doRequest
in class AbstractMessageRequester
- Parameters:
timeout
- the maximum time the operation should block before returning.
The call should return immediately if there is data available. If
no data becomes available before the timeout elapses, null will be
returned
- Returns:
- the result of the request wrapped in a MuleMessage object. Null will be
returned if no data was avaialable
- Throws:
Exception
- if the call to the underlying protocal cuases an exception
doDispose
protected void doDispose()
- Overrides:
doDispose
in class AbstractTransportMessageHandler
Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.