59 |
|
while(_running) { |
60 |
|
|
61 |
|
String xml = (String) _dataQueue.get(_myQueue); |
62 |
+ |
// if we want to debug the packets |
63 |
+ |
if(Configuration.getInstance().getProperty("packetDump").equals("1")) { |
64 |
+ |
System.out.println("[PACKET DUMP]\n" + xml); |
65 |
+ |
} |
66 |
+ |
|
67 |
|
Conient.setQueueStatus(_dataQueue.queueSize(_myQueue), _dataQueue.elementCount()); |
68 |
|
if (xml == null) { |
69 |
|
// shouldn't really happen...but not sure |
82 |
|
// Use XMLPacketMaker to make an XMLPacket object. |
83 |
|
XMLPacketMaker xmlPacketMaker = new XMLPacketMaker(xml); |
84 |
|
XMLPacket packet = xmlPacketMaker.createXMLPacket(); |
80 |
– |
|
81 |
– |
// if we want to debug the packets |
82 |
– |
if(Configuration.getInstance().getProperty("packetDump").equals("1")) { |
83 |
– |
System.out.println("[PACKET DUMP]\n" + packet.printAll()); |
84 |
– |
} |
85 |
|
|
86 |
|
String packetType = packet.getParam("packet.attributes.type"); |
87 |
|
if (packetType.equals("heartbeat") || packetType.equals("data")) { |