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

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, socketFactory, UDP

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

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

MulticastConnector()

Method Summary

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, 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

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