public class UDPDiscoveryReceiver extends java.lang.Object implements java.lang.Runnable, IShutdownObserver
Modifier and Type | Class and Description |
---|---|
class |
UDPDiscoveryReceiver.MessageHandler
Separate thread run when a command comes into the UDPDiscoveryReceiver.
|
Modifier and Type | Field and Description |
---|---|
protected ICacheEventLogger |
cacheEventLogger
The event logger.
|
protected IElementSerializer |
elementSerializer
The serializer.
|
protected UDPDiscoveryService |
service
Service to get cache names and hande request broadcasts
|
Constructor and Description |
---|
UDPDiscoveryReceiver(UDPDiscoveryService service,
java.lang.String multicastAddressString,
int multicastPort,
ICompositeCacheManager cacheMgr,
ICacheEventLogger cacheEventLogger,
IElementSerializer elementSerializer)
Constructor for the LateralUDPReceiver object.
|
Modifier and Type | Method and Description |
---|---|
int |
getCnt() |
void |
run()
Main processing method for the LateralUDPReceiver object
|
void |
setCnt(int cnt) |
void |
shutdown()
Shuts down the socket.
|
java.lang.Object |
waitForMessage()
Highly unreliable.
|
protected UDPDiscoveryService service
protected ICacheEventLogger cacheEventLogger
protected IElementSerializer elementSerializer
public UDPDiscoveryReceiver(UDPDiscoveryService service, java.lang.String multicastAddressString, int multicastPort, ICompositeCacheManager cacheMgr, ICacheEventLogger cacheEventLogger, IElementSerializer elementSerializer) throws java.io.IOException
We determine out own host using InetAddress
service
- multicastAddressString
- multicastPort
- cacheMgr
- cacheEventLogger
- elementSerializer
- java.io.IOException
public java.lang.Object waitForMessage() throws java.io.IOException
java.io.IOException
public void run()
run
in interface java.lang.Runnable
public void setCnt(int cnt)
cnt
- The cnt to set.public int getCnt()
public void shutdown()
shutdown
in interface IShutdownObserver
Copyright © 2002-2013 Apache Software Foundation. All Rights Reserved.