src/org/lwes/listener/EventCountingHandler.java

   1 package org.lwes.listener;
   2 /**
   3  * @author fmaritato
   4  */
   5
   6 import org.lwes.Event;
   7
   8 import java.net.InetAddress;
   9
  10 public class EventCountingHandler implements EventHandler {
  11
  12     protected int count = 0;
  13
  14     public void destroy() {
  15         System.out.println("Count: " + count);
  16     }
  17
  18     public void handleEvent(Event event) {
  19         count++;
  20         System.out.println("Count: "+count);
  21     }
  22
  23     public static void main(String[] args) throws Exception {
  24         EventCountingHandler eventHandler = new EventCountingHandler();
  25         DatagramEventListener listener = new DatagramEventListener();
  26         listener.setAddress(InetAddress.getByName("224.1.1.11"));
  27         listener.setPort(6969);
  28         listener.addHandler(eventHandler);
  29         listener.setTimeToLive(1);
  30         listener.initialize();
  31
  32         Runtime.getRuntime().addShutdownHook(new ShutdownThread(eventHandler));
  33
  34         while (true) {
  35             Thread.sleep(1000);
  36         }
  37     }
  38
  39     static class ShutdownThread extends Thread {
  40
  41         EventHandler eventHandler;
  42
  43         ShutdownThread(EventHandler eh) {
  44             eventHandler = eh;
  45         }
  46
  47         public void run() {
  48             eventHandler.destroy();
  49         }
  50     }
  51 }