39 |
|
* @throws IOException if something goes badly wrong |
40 |
|
*/ |
41 |
|
public TCPReaderInit(Socket socket, Queue queue) throws IOException { |
42 |
+ |
// set the Thread name |
43 |
+ |
setName("filter.TCPReaderInit"); |
44 |
+ |
|
45 |
|
_socket = socket; |
46 |
|
_queue = queue; |
47 |
|
// setup the reader & writer |
119 |
|
_queue.add(xml); |
120 |
|
|
121 |
|
} catch (Exception e) { |
122 |
< |
_logger.write(toString(), Logger.ERROR, "ERROR: " + e.getMessage()); |
122 |
> |
_logger.write(toString(), Logger.ERROR, "ERROR: " + e); |
123 |
|
} |
124 |
|
|
125 |
|
// Disconnect streams & socket |