added main() for SwissTiming UDP receiver

This commit is contained in:
Axel Uhl committed 2011-08-29 18:05:39 +02:00
1 parent 2532061164
commit 61367173d8
2 files changed
+18 -5

No files matched your search

@@ -1,5 +0,0 @@
package com.sap.sailing.domain.swisstimingadapter;
public interface SwissTimingListener {
void received(SwissTimingMessage message);
}
@@ -1,5 +1,6 @@
package com.sap.sailing.domain.swisstimingadapter.impl;
import java.io.IOException;
import java.net.SocketException;
import com.sap.sailing.domain.swisstimingadapter.SwissTimingMessage;
@@ -20,5 +21,22 @@ public class SwissTimingUDPReceiverImpl extends UDPReceiver<SwissTimingMessage,
protected UDPMessageParser<SwissTimingMessage> getParser() {
return parser;
}
/**
* Launches a listener and dumps messages received to the console
* @param args 0: port to listen on
*
* @throws IOException
*/
public static void main(String[] args) throws IOException {
SwissTimingUDPReceiverImpl receiver = new SwissTimingUDPReceiverImpl(Integer.valueOf(args[0]));
receiver.addListener(new SwissTimingMessageListener() {
@Override
public void received(SwissTimingMessage message) {
System.out.println(message);
}
}, /* validMessagesOnly */ false);
receiver.run();
}
}