Method run

test/org/apache/catalina/tribes/TesterMulticast.java:109–130

()

        private volatile boolean run = true;

        @Override
        public void run() {
            try (MulticastSocket s = new MulticastSocket(PORT)) {
                s.setOption(StandardSocketOptions.IP_MULTICAST_LOOP, Boolean.valueOf(true));
                s.joinGroup(new InetSocketAddress(INET_ADDRESS, 0), null);
                DatagramPacket p = new DatagramPacket(new byte[4], 4);
                p.setAddress(INET_ADDRESS);
                p.setPort(PORT);
                long counter = 0;
                String msg;
                while (run) {
                    msg = String.format("%04d", Long.valueOf(counter));
                    p.setData(msg.getBytes());
                    System.out.println("Tx: " + msg);
                    s.send(p);
                    counter++;
                    Thread.sleep(500);
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }

        public void stop() {
            run = false;