org.mule.transport.udp
Class UdpConnector
java.lang.Object
org.mule.transport.AbstractConnector
org.mule.transport.udp.UdpConnector
- All Implemented Interfaces:
- ExceptionListener, EventListener, javax.resource.spi.work.WorkListener, MuleContextAware, Disposable, Initialisable, Lifecycle, Startable, Stoppable, NamedObject, Connectable, Connector
- Direct Known Subclasses:
- MulticastConnector
public class UdpConnector
- extends AbstractConnector
UdpConnector
can send and receive Mule events as Datagram packets.
Fields inherited from class org.mule.transport.AbstractConnector |
connected, createMultipleTransactedReceivers, DEFAULT_NUM_CONCURRENT_TX_RECEIVERS, dispatcherFactory, dispatchers, disposed, exceptionListener, initialised, logger, muleContext, name, numberOfConcurrentTransactedReceivers, receivers, requesterFactory, requesters, serviceDescriptor, serviceOverrides, sessionHandler, started, startOnConnect |
Methods inherited from class org.mule.transport.AbstractConnector |
checkDisposed, connect, createReceiver, destroyReceiver, disconnect, dispatch, dispose, disposeDispatchers, disposeReceivers, disposeRequesters, disposeWorkManagers, exceptionThrown, fireNotification, getConnectEventId, getConnectionDescription, getDefaultInboundTransformers, getDefaultOutboundTransformers, getDefaultResponseTransformers, getDispatcherFactory, getDispatcherThreadingProfile, getDispatcherWorkManager, getExceptionListener, getMaxDispatchersActive, getMaxRequestersActive, getMessageAdapter, getMuleContext, getName, getNumberOfConcurrentTransactedReceivers, getOutputStream, getReceiver, getReceivers, getReceivers, getReceiverThreadingProfile, getReceiverWorkManager, getReplyToHandler, getRequesterFactory, getRequesterThreadingProfile, getRequesterWorkManager, getRetryPolicyTemplate, getScheduler, getServiceDescriptor, getServiceOverrides, getSessionHandler, getSupportedProtocols, handleException, handleException, handleWorkException, initFromServiceDescriptor, initialise, initialiseFromUrl, initWorkManagers, isConnected, isCreateMultipleTransactedReceivers, isDisposed, isEnableMessageEvents, isResponseEnabled, isStarted, isSyncEnabled, isValidateConnections, lookupReceiver, registerListener, registerSupportedProtocol, registerSupportedProtocolWithoutPrefix, request, request, send, setConnected, setCreateMultipleTransactedReceivers, setDispatcherFactory, setDispatcherThreadingProfile, setDynamicNotification, setExceptionListener, setMaxDispatchersActive, setMaxRequestersActive, setMuleContext, setName, setNumberOfConcurrentTransactedReceivers, setReceiverThreadingProfile, setRequesterFactory, setRequesterThreadingProfile, setRetryPolicyTemplate, setServiceOverrides, setSessionHandler, setSupportedProtocols, setupDispatchReturn, setupRequestReturn, setValidateConnections, start, stop, supportsProtocol, toString, unregisterListener, unregisterSupportedProtocol, updateCachedNotificationHandler, validateConnection, workAccepted, workCompleted, workRejected, workStarted |
UDP
public static final String UDP
- See Also:
- Constant Field Values
DEFAULT_SOCKET_TIMEOUT
public static final int DEFAULT_SOCKET_TIMEOUT
- See Also:
- Constant Field Values
DEFAULT_BUFFER_SIZE
public static final int DEFAULT_BUFFER_SIZE
- See Also:
- Constant Field Values
KEEP_SEND_SOCKET_OPEN_PROPERTY
public static final String KEEP_SEND_SOCKET_OPEN_PROPERTY
- See Also:
- Constant Field Values
sendTimeout
protected int sendTimeout
receiveTimeout
protected int receiveTimeout
sendBufferSize
protected int sendBufferSize
receiveBufferSize
protected int receiveBufferSize
keepSendSocketOpen
protected boolean keepSendSocketOpen
broadcast
protected boolean broadcast
dispatcherSocketsPool
protected GenericKeyedObjectPool dispatcherSocketsPool
socketFactory
protected UdpSocketFactory socketFactory
UdpConnector
public UdpConnector()
doInitialise
protected void doInitialise()
throws InitialisationException
- Specified by:
doInitialise
in class AbstractConnector
- Throws:
InitialisationException
doDispose
protected void doDispose()
- Description copied from class:
AbstractConnector
- Template method to perform any work when destroying the connectoe
- Specified by:
doDispose
in class AbstractConnector
doConnect
protected void doConnect()
throws Exception
- Description copied from class:
AbstractConnector
- Template method where any connections should be made for the connector
- Specified by:
doConnect
in class AbstractConnector
- Throws:
Exception
doDisconnect
protected void doDisconnect()
throws Exception
- Description copied from class:
AbstractConnector
- Template method where any connected resources used by the connector should be
disconnected
- Specified by:
doDisconnect
in class AbstractConnector
- Throws:
Exception
doStart
protected void doStart()
throws MuleException
- Description copied from class:
AbstractConnector
- Template method to perform any work when starting the connectoe
- Specified by:
doStart
in class AbstractConnector
- Throws:
MuleException
- if the method fails
doStop
protected void doStop()
throws MuleException
- Description copied from class:
AbstractConnector
- Template method to perform any work when stopping the connectoe
- Specified by:
doStop
in class AbstractConnector
- Throws:
MuleException
- if the method fails
getProtocol
public String getProtocol()
- Returns:
- the primary protocol name for endpoints of this connector
getSendTimeout
public int getSendTimeout()
setSendTimeout
public void setSendTimeout(int timeout)
getReceiveTimeout
public int getReceiveTimeout()
setReceiveTimeout
public void setReceiveTimeout(int timeout)
getSendBufferSize
public int getSendBufferSize()
setSendBufferSize
public void setSendBufferSize(int sendBufferSize)
getReceiveBufferSize
public int getReceiveBufferSize()
setReceiveBufferSize
public void setReceiveBufferSize(int receiveBufferSize)
isBroadcast
public boolean isBroadcast()
setBroadcast
public void setBroadcast(boolean broadcast)
isKeepSendSocketOpen
public boolean isKeepSendSocketOpen()
setKeepSendSocketOpen
public void setKeepSendSocketOpen(boolean keepSendSocketOpen)
getReceiverKey
protected Object getReceiverKey(Service service,
InboundEndpoint endpoint)
- Description copied from class:
AbstractConnector
- The method determines the key used to store the receiver against.
- Overrides:
getReceiverKey
in class AbstractConnector
- Parameters:
service
- the service for which the endpoint is being registeredendpoint
- the endpoint being registered for the service
- Returns:
- the key to store the newly created receiver against
Copyright © 2003-2009 MuleSource, Inc.. All Rights Reserved.