org.mule.transport.multicast

Class MulticastConnector

java.lang.Object

org.mule.transport.AbstractConnector

org.mule.transport.udp.UdpConnector

org.mule.transport.multicast.MulticastConnector

All Implemented Interfaces:

ExceptionListener, EventListener, javax.resource.spi.work.WorkListener, MuleContextAware, Disposable, Initialisable, Lifecycle, Startable, Stoppable, NamedObject, Connectable, Connector

public class MulticastConnector
extends UdpConnector

MulticastConnector can dispatch mule events using ip multicasting

Field Summary

Fields

Modifier and Type	Field and Description
static String	MULTICAST

Fields inherited from class org.mule.transport.udp.UdpConnector

broadcast, DEFAULT_BUFFER_SIZE, DEFAULT_SOCKET_TIMEOUT, dispatcherSocketsPool, KEEP_SEND_SOCKET_OPEN_PROPERTY, keepSendSocketOpen, receiveBufferSize, receiveTimeout, sendBufferSize, sendTimeout, UDP

Fields inherited from class org.mule.transport.AbstractConnector

connected, connectedSemaphore, connecting, connectionStrategy, createMultipleTransactedReceivers, DEFAULT_NUM_CONCURRENT_TX_RECEIVERS, dispatcherFactory, dispatchers, disposed, disposing, exceptionListener, initialised, logger, muleContext, name, numberOfConcurrentTransactedReceivers, receivers, requesterFactory, requesters, serviceDescriptor, serviceOverrides, sessionHandler, started, startOnConnect

Fields inherited from interface org.mule.api.transport.Connector

INT_VALUE_NOT_SET

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

Constructors

Constructor and Description
MulticastConnector()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	doInitialise()
String	getProtocol()
protected Object	getReceiverKey(Service service, InboundEndpoint endpoint) The method determines the key used to store the receiver against.
int	getTimeToLive()
boolean	isLoopback()
void	setLoopback(boolean loopback)
void	setTimeToLive(int timeToLive)

Methods inherited from class org.mule.transport.udp.UdpConnector

doConnect, doDisconnect, doDispose, doStart, doStop, getReceiveBufferSize, getReceiveTimeout, getSendBufferSize, getSendTimeout, isBroadcast, isKeepSendSocketOpen, setBroadcast, setKeepSendSocketOpen, setReceiveBufferSize, setReceiveTimeout, setSendBufferSize, setSendTimeout

Methods inherited from class org.mule.transport.AbstractConnector

checkDisposed, connect, createReceiver, destroyReceiver, disconnect, dispatch, dispose, disposeDispatchers, disposeReceivers, disposeRequesters, disposeWorkManagers, exceptionThrown, fireNotification, getConnectedSemaphore, getConnectEventId, getConnectionDescription, getConnectionStrategy, getDefaultInboundTransformers, getDefaultOutboundTransformers, getDefaultResponseTransformers, getDispatcherFactory, getDispatcherThreadingProfile, getDispatcherWorkManager, getExceptionListener, getMaxDispatchersActive, getMaxRequestersActive, getMessageAdapter, getMuleContext, getName, getNumberOfConcurrentTransactedReceivers, getOutputStream, getReceiver, getReceivers, getReceivers, getReceiverThreadingProfile, getReceiverWorkManager, getReplyToHandler, getRequesterFactory, getRequesterThreadingProfile, getRequesterWorkManager, getScheduler, getServiceDescriptor, getServiceOverrides, getSessionHandler, getSupportedProtocols, handleException, handleWorkException, initFromServiceDescriptor, initialise, initialiseFromUrl, initWorkManagers, isConnected, isCreateMultipleTransactedReceivers, isDisposed, isDisposing, isEnableMessageEvents, isRemoteSyncEnabled, isStarted, isSyncEnabled, lookupReceiver, registerListener, registerSupportedProtocol, registerSupportedProtocolWithoutPrefix, request, request, send, setConnectionStrategy, setCreateMultipleTransactedReceivers, setDispatcherFactory, setDispatcherThreadingProfile, setDynamicNotification, setExceptionListener, setMaxDispatchersActive, setMaxRequestersActive, setMuleContext, setName, setNumberOfConcurrentTransactedReceivers, setReceiverThreadingProfile, setRequesterFactory, setRequesterThreadingProfile, setServiceOverrides, setSessionHandler, setSupportedProtocols, setupDispatchReturn, setupRequestReturn, start, stop, supportsProtocol, toString, unregisterListener, unregisterSupportedProtocol, updateCachedNotificationHandler, workAccepted, workCompleted, workRejected, workStarted

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

MULTICAST

public static final String MULTICAST

See Also:

Constant Field Values

Constructor Detail

MulticastConnector

public MulticastConnector()

Method Detail

getProtocol

public String getProtocol()

Specified by:

getProtocol in interface Connector

Overrides:

getProtocol in class UdpConnector

Returns:

the primary protocol name for endpoints of this connector

doInitialise

protected void doInitialise()
                     throws InitialisationException

Overrides:

doInitialise in class UdpConnector

Throws:

InitialisationException

isLoopback

public boolean isLoopback()

setLoopback

public void setLoopback(boolean loopback)

getTimeToLive

public int getTimeToLive()

setTimeToLive

public void setTimeToLive(int timeToLive)

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 UdpConnector

Parameters:

service - the service for which the endpoint is being registered

endpoint - the endpoint being registered for the service

Returns:

the key to store the newly created receiver against