public class UDPDiscoveryReceiver extends Object implements Runnable, IShutdownObserver
Modifier and Type | Class and Description |
---|---|
class |
UDPDiscoveryReceiver.MessageHandler
Separate thread run when a command comes into the UDPDiscoveryReceiver.
|
Constructor and Description |
---|
UDPDiscoveryReceiver(UDPDiscoveryService service,
String multicastAddressString,
int multicastPort)
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.
|
Object |
waitForMessage()
Highly unreliable.
|
public UDPDiscoveryReceiver(UDPDiscoveryService service, String multicastAddressString, int multicastPort) throws IOException
We determine out own host using InetAddress
service
- multicastAddressString
- multicastPort
- IOException
public Object waitForMessage() throws IOException
IOException
public void run()
public void setCnt(int cnt)
cnt
- The cnt to set.public int getCnt()
public void shutdown()
shutdown
in interface IShutdownObserver
Copyright © 2002–2018 The Apache Software Foundation. All rights reserved.