de.hybris.platform.cluster.udp

Class UnicastBroadcastMethod

java.lang.Object

de.hybris.platform.cluster.AbstractBroadcastMethod

de.hybris.platform.cluster.udp.UnicastBroadcastMethod

All Implemented Interfaces:

BroadcastMethod

public class UnicastBroadcastMethod
extends AbstractBroadcastMethod

The Unicast UDP based broadcasting method.

Field Summary

Fields

Modifier and Type	Field and Description
static int	KIND_NODES

Constructor Summary

Constructors

Constructor and Description
UnicastBroadcastMethod()

Method Summary

Modifier and Type	Method and Description
protected boolean	accept(RawMessage msg)
Collection<InetSocketAddress>	getClusterNodes()
protected ConfigIntf	getConfig()
UnicastBroadcastMethodConfiguration	getConfiguration()
InetSocketAddress	getServerAddress()
Map<String,String>	getSettings() Provides generic access to method specific settings
void	init(BroadcastService service) Called once when the messaging method has been registered
protected boolean	isOwnAddress(InetSocketAddress nodeAddress)
boolean	isSyncNodesEnabled()
protected void	notifyMessgageReceived(RawMessage message)
protected void	processDatagramPacket(DatagramPacket packet)
protected void	readConfig()
protected void	registerConfigChangeListener()
protected void	removeConfigChangeListener()
protected InetSocketAddress	resolveAddress(InetSocketAddress unresolvedAddress)
protected Set<InetSocketAddress>	resolveAddresses(Collection<InetSocketAddress> unresolvedAddresses)
void	send(RawMessage message) Sends the given RawMessage.
protected void	sendPacket(DatagramPacket packet)
void	setConfiguration(UnicastBroadcastMethodConfiguration cfg)
void	shutdown() Called before system shutdown
protected void	start()
protected void	startServer()
protected DatagramSocket	startSocket()

Methods inherited from class de.hybris.platform.cluster.AbstractBroadcastMethod

getListeners, registerProcessor, unregisterProcessor

Methods inherited from class java.lang.Object

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

Field Detail

KIND_NODES

public static final int KIND_NODES

See Also:

Constant Field Values

Constructor Detail

UnicastBroadcastMethod

public UnicastBroadcastMethod()

Method Detail

getConfiguration

public UnicastBroadcastMethodConfiguration getConfiguration()

setConfiguration

public void setConfiguration(UnicastBroadcastMethodConfiguration cfg)

getServerAddress

public InetSocketAddress getServerAddress()

getSettings

public Map<String,String> getSettings()

Description copied from interface: BroadcastMethod

Provides generic access to method specific settings

Specified by:

getSettings in interface BroadcastMethod

Overrides:

getSettings in class AbstractBroadcastMethod

init

public void init(BroadcastService service)

Description copied from interface: BroadcastMethod

Called once when the messaging method has been registered

Specified by:

init in interface BroadcastMethod

Overrides:

init in class AbstractBroadcastMethod

getConfig

protected ConfigIntf getConfig()

registerConfigChangeListener

protected void registerConfigChangeListener()

removeConfigChangeListener

protected void removeConfigChangeListener()

send

public void send(RawMessage message)

Sends the given RawMessage. If this message exceed the UDPBroadcastMethodConfiguration.getPacketSize() the message will be splitted up.

Parameters:

message - the message to be send

isSyncNodesEnabled

public boolean isSyncNodesEnabled()

getClusterNodes

public Collection<InetSocketAddress> getClusterNodes()

isOwnAddress

protected boolean isOwnAddress(InetSocketAddress nodeAddress)

shutdown

public void shutdown()

Description copied from interface: BroadcastMethod

Called before system shutdown

Specified by:

shutdown in interface BroadcastMethod

Overrides:

shutdown in class AbstractBroadcastMethod

readConfig

protected void readConfig()

resolveAddresses

protected Set<InetSocketAddress> resolveAddresses(Collection<InetSocketAddress> unresolvedAddresses)

resolveAddress

protected InetSocketAddress resolveAddress(InetSocketAddress unresolvedAddress)

start

protected void start()

startServer

protected void startServer()

startSocket

protected DatagramSocket startSocket()

sendPacket

protected void sendPacket(DatagramPacket packet)

notifyMessgageReceived

protected void notifyMessgageReceived(RawMessage message)

Overrides:

notifyMessgageReceived in class AbstractBroadcastMethod

accept

protected boolean accept(RawMessage msg)

processDatagramPacket

protected void processDatagramPacket(DatagramPacket packet)