ViewVC Help
View File | Revision Log | Show Annotations | Revision Graph | Root Listing
root/i-scream/projects/cms/source/server/uk/org/iscream/cms/server/rootfilter/CIWrapper.java
(Generate patch)

Comparing projects/cms/source/server/uk/org/iscream/cms/server/rootfilter/CIWrapper.java (file contents):
Revision 1.3 by tdb, Fri Jan 12 00:45:48 2001 UTC vs.
Revision 1.6 by tdb, Fri Jan 19 01:16:03 2001 UTC

# Line 3 | Line 3 | package uk.ac.ukc.iscream.rootfilter;
3  
4   //---IMPORTS---
5   import uk.ac.ukc.iscream.core.*;
6 + import uk.ac.ukc.iscream.componentmanager.*;
7   import uk.ac.ukc.iscream.clientinterface.*;
8   import uk.ac.ukc.iscream.util.*;
9  
# Line 36 | Line 37 | public class CIWrapper extends Thread {
37      public CIWrapper(ClientInterface destination, Queue queue){
38          _destination = destination;
39          _queue = queue;
40 +        _queueID = queue.getQueue();
41      }
42  
43   //---PUBLIC METHODS---
# Line 44 | Line 46 | public class CIWrapper extends Thread {
46       * start the thread and thus gets and sends data
47       */
48      public void run() {
47 –        int n = _queue.getQueue();
49          String xml = null;
50          while(true) {
51              try {
52 <                xml = (String) _queue.get(n);
52 >                xml = (String) _queue.get(_queueID);
53              }
54              catch (InvalidQueueException e) {
55                  _logger.write(toString(), Logger.ERROR, "Queue error: "+e);
# Line 77 | Line 78 | public class CIWrapper extends Thread {
78       * A reference to a Queue object.
79       */
80      private Queue _queue;
81 +    
82 +    /**
83 +     * Our Queue id.
84 +     */
85 +    private int _queueID;
86      
87      /**
88       * the interface this thread is sending data to

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines