36 |
|
//---PUBLIC METHODS--- |
37 |
|
|
38 |
|
public void run() { |
39 |
< |
try { |
40 |
< |
analysePacket((XMLPacket) getQueue().get(getQueueId())); |
41 |
< |
} catch (InvalidQueueException e) { |
42 |
< |
_logger.write(this.toString(), Logger.ERROR, "Unable to get queue."); |
39 |
> |
while(_running) { |
40 |
> |
try { |
41 |
> |
analysePacket((XMLPacket) getQueue().get(getQueueId())); |
42 |
> |
} catch (InvalidQueueException e) { |
43 |
> |
_logger.write(this.toString(), Logger.ERROR, "Unable to get queue."); |
44 |
> |
} |
45 |
|
} |
46 |
|
} |
47 |
|
|
112 |
|
private Logger _logger = ReferenceManager.getInstance().getLogger(); |
113 |
|
|
114 |
|
protected int _qID = -1; |
115 |
+ |
|
116 |
+ |
protected boolean _running = true; |
117 |
|
|
118 |
|
//---STATIC ATTRIBUTES--- |
119 |
|
|