Skip to content
Snippets Groups Projects
Commit 6e150030 authored by Lars Erik Blümke's avatar Lars Erik Blümke
Browse files

small fix

parent d33aa58d
No related branches found
No related tags found
No related merge requests found
......@@ -84,7 +84,7 @@ public class AMQPReaderTest {
}
try {
Thread.sleep(300000);
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
......@@ -163,7 +163,6 @@ final class AMQPWriterThread extends Thread {
}
protected void consume(final IMonitoringRecord monitoringRecord) throws Exception {
System.out.println("holla");
int classId;
if (monitoringRecord instanceof RegistryRecord) {
final ByteBuffer localBuffer = ByteBuffer.allocate(monitoringRecord.getSize() + 1);
......@@ -189,10 +188,6 @@ final class AMQPWriterThread extends Thread {
System.arraycopy(localBuffer.array(), localBuffer.arrayOffset(), data, 0, dataSize);
this.channel.basicPublish(this.exchangeName, this.queueName, null, data);
System.out.println("WRITER THREAD registry record");
System.out.println(stringRegistry.get(classId));
System.out.println("nix");
}
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment