ViewVC Help

View File | Revision Log | Show Annotations | Revision Graph | Root Listing

root/i-scream/projects/cms/source/server/uk/org/iscream/cms/server/clientinterface/TCPDataHandler.java

Comparing projects/cms/source/server/uk/org/iscream/cms/server/clientinterface/TCPDataHandler.java (file contents):
Revision 1.3 by tdb, Tue Jan 23 00:01:39 2001 UTC vs.
Revision 1.4 by tdb, Tue Jan 23 16:56:31 2001 UTC

#	Line 32 | Line 32 | class TCPDataHandler extends Thread {
32
33		//---CONSTRUCTORS---
34
35	<	public TCPDataHandler(Socket socket, Queue queue) throws IOException {
35	>	public TCPDataHandler(Socket socket) throws IOException {
36		_socket = socket;
37	<	_queue = queue;
38	<	_queueID = queue.getQueue();
37	>	_queue = new Queue();
38		_socketIn = new BufferedReader(new InputStreamReader(_socket.getInputStream()));
39		_socketOut = new PrintWriter(_socket.getOutputStream());
40		_logger.write(toString(), Logger.SYSINIT, "created");
#	Line 45 | Line 44 | class TCPDataHandler extends Thread {
44
45		public void run() {
46		run = true;
47	+	int qID = _queue.getQueue();
48		while(run) {
49		try {
50	<	String xml = (String) _queue.get(_queueID);
50	>	String xml = (String) _queue.get(qID);
51		_socketOut.println(xml);
52		_socketOut.flush();
53		}
#	Line 65 | Line 65 | class TCPDataHandler extends Thread {
65		catch(IOException e) {
66		_logger.write(toString(), Logger.ERROR, "Exception whilst shutting down: "+e);
67		}
68	<	_queue.removeQueue(_queueID);
68	>	_queue.removeQueue(qID);
69		}
70
71		public void shutdown() {
#	Line 92 | Line 92 | class TCPDataHandler extends Thread {
92
93		//---ACCESSOR/MUTATOR METHODS---
94
95	+	public Queue getQueue() {
96	+	return _queue;
97	+	}
98	+
99		//---ATTRIBUTES---
100
101		/**
#	Line 124 | Line 128 | class TCPDataHandler extends Thread {
128		private Socket _socket;
129
130		private Queue _queue;
127	–	private int _queueID;
131		private boolean run;
132
133		//---STATIC ATTRIBUTES---

Diff Legend

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