--- experimental/server/XMLReader/UDPReader.java	2000/11/17 11:23:19	1.1
+++ experimental/server/XMLReader/UDPReader.java	2000/11/17 12:16:39	1.2
@@ -10,19 +10,38 @@ public class UDPReader {
 
     public static void main(String[] args) throws IOException {
 
-        DatagramSocket socket = new DatagramSocket(4589);
+        // default UDP listening port.
+        int port = 4589;
+        final int packetSizeLimit = 8192;
 
-        try {
-            byte[] buf = new byte[1024];
-                // receive request
-            DatagramPacket packet = new DatagramPacket(buf, buf.length);
-            socket.receive(packet);
-            String dataIn = new String(packet.getData());
-            System.out.println("Received: " + dataIn);
+        // Allow the user to choose their own port number.
+        if (args.length == 1){
+            try {
+                port = new Integer(args[0]).intValue();
+            }
+            catch (Exception e){
+                // If something went wrong, use the default again.
+                port = 4589;
+            }
         }
-        catch (IOException e) {
-            System.out.println("An exception occured!");
-            e.printStackTrace();
+
+        DatagramSocket socket = new DatagramSocket(port);
+        System.out.println("UDPReader ready and listening for UDP packets on port "+port);
+
+        boolean running = true;
+        while (running){
+            try {
+                byte[] buf = new byte[packetSizeLimit];
+                // receive request
+                DatagramPacket packet = new DatagramPacket(buf, buf.length);
+                socket.receive(packet);
+                UDPReaderThread thread = new UDPReaderThread(packet);
+                thread.run();
+            }
+            catch (IOException e) {
+                System.out.println("An exception occured in the UDPReader!");
+                e.printStackTrace();
+            }
         }
         socket.close();
     }