Package de.hybris.platform.cluster.udp
Class UDPBroadcastMethod
java.lang.Object
de.hybris.platform.cluster.AbstractBroadcastMethod
de.hybris.platform.cluster.udp.UDPBroadcastMethod
- All Implemented Interfaces:
BroadcastMethod
The UDP based broadcasting method.
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionintProvides generic access to method specific settingsvoidinit(BroadcastService service) Called once when the messaging method has been registeredprotected voidprocessDatagramPacket(DatagramPacket packet) protected voidvoidsend(RawMessage message) Sends the givenRawMessage.protected voidsendPacket(DatagramPacket packet) voidvoidshutdown()Called before system shutdownprotected voidstart()protected voidprotected MulticastSocketMethods inherited from class de.hybris.platform.cluster.AbstractBroadcastMethod
getListeners, notifyMessgageReceived, registerProcessor, unregisterProcessor
-
Constructor Details
-
UDPBroadcastMethod
public UDPBroadcastMethod()
-
-
Method Details
-
getConfiguration
-
setConfiguration
-
getMulticastAddress
-
getMulticastPort
public int getMulticastPort() -
getInterfaceAddress
-
getNetworkInterfaceName
-
getSettings
Description copied from interface:BroadcastMethodProvides generic access to method specific settings- Specified by:
getSettingsin interfaceBroadcastMethod- Overrides:
getSettingsin classAbstractBroadcastMethod
-
init
Description copied from interface:BroadcastMethodCalled once when the messaging method has been registered- Specified by:
initin interfaceBroadcastMethod- Overrides:
initin classAbstractBroadcastMethod
-
send
Sends the givenRawMessage. If this message exceed theUDPBroadcastMethodConfiguration.getPacketSize()the message will be splitted up.- Parameters:
message- the message to be send
-
shutdown
public void shutdown()Description copied from interface:BroadcastMethodCalled before system shutdown- Specified by:
shutdownin interfaceBroadcastMethod- Overrides:
shutdownin classAbstractBroadcastMethod
-
readConfig
protected void readConfig() -
start
protected void start() -
startServer
protected void startServer() -
startSocket
-
sendPacket
-
processDatagramPacket
-