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

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.7 by tdb, Tue Mar 13 02:19:48 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 34 | Line 35 | public class CIWrapper extends Thread {
35		* @param queue a reference to a queue to use
36		*/
37		public CIWrapper(ClientInterface destination, Queue queue){
38	+	// set the Thread name
39	+	setName("rootfilter.CIWrapper");
40	+
41		_destination = destination;
42		_queue = queue;
43	+	_queueID = queue.getQueue();
44		}
45
46		//---PUBLIC METHODS---
#	Line 44 | Line 49 | public class CIWrapper extends Thread {
49		* start the thread and thus gets and sends data
50		*/
51		public void run() {
47	–	int n = _queue.getQueue();
52		String xml = null;
53		while(true) {
54		try {
55	<	xml = (String) _queue.get(n);
55	>	xml = (String) _queue.get(_queueID);
56		}
57		catch (InvalidQueueException e) {
58		_logger.write(toString(), Logger.ERROR, "Queue error: "+e);
#	Line 77 | Line 81 | public class CIWrapper extends Thread {
81		* A reference to a Queue object.
82		*/
83		private Queue _queue;
84	+
85	+	/**
86	+	* Our Queue id.
87	+	*/
88	+	private int _queueID;
89
90		/**
91		* the interface this thread is sending data to

Diff Legend

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