--- experimental/server/Queue/Consumer.java	2000/12/28 01:02:07	1.1
+++ experimental/server/Queue/Consumer.java	2000/12/28 03:51:03	1.2
@@ -1,17 +1,31 @@
 class Consumer extends Thread {
     
-    public Consumer(Queue queue) {
+    public Consumer(Queue queue, long sleepTime) {
         _queue = queue;
+        _sleepTime = sleepTime;
     }
     
     public void run() {
-        while(true) {
-            try { Thread.sleep(1000); } catch(Exception e) {}
-            String s = (String) _queue.get();
-            System.out.println(s);
+        boolean run;
+        try {
+            _n = _queue.getQueue();
+            System.out.println("Got queue: "+_n);
+            run = true;
         }
+        catch(NoQueueException e) {
+            System.out.println("Failed to get a Queue:");
+            System.out.println(e);
+            run=false;
+        }
+        while(run) {
+            try { Thread.sleep(_sleepTime); } catch(Exception e) {}
+            String s = (String) _queue.get(_n);
+            System.out.println("["+_n+"] "+s);
+        }
     }
     
     private Queue _queue;
+    private int _n;
+    private long _sleepTime;
     
 }
\ No newline at end of file