
Untitled
By: a guest on
May 6th, 2012 | syntax:
None | size: 0.89 KB | hits: 13 | expires: Never
private boolean setup()
{
if(isInitialized)
return true;
try
{
address = InetAddress.getByName(IP);
socket = new MulticastSocket(port);
socket.setTimeToLive(TTL);
socket.joinGroup(address);
socket.setSoTimeout(1000);
}
catch(Exception e)
{
e.printStackTrace();
return false;
}
isInitialized = true;
return true;
}
public void run()
{
if(!setup())
{
// TODO : LOG ERROR (or something)
return;
}
isRunning = true;
int i = 0;
while(isRunning)
{
try
{
System.out.print("Receiving packet... ");
socket.receive(lastPacket);
System.out.println(++i);
}
catch(SocketTimeoutException e)
{
// We want to keep listening forever
System.out.println("Timeout");
continue;
}
catch(Exception e)
{
// TODO: Log the error
}
}
disconnect();
}