From fe022edc69949e73f2d46806489ca95726f47229 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Lars=20Blu=CC=88mke?= <lbl@informatik.uni-kiel.de>
Date: Thu, 12 May 2016 15:11:05 +0200
Subject: [PATCH] AMQP reader test still unfinished
---
.../plugin/reader/amqp/AMQPReaderLogicModule.java | 4 ++++
.../analysis/plugin/reader/amqp/AMQPReaderTest.java | 12 +++++++++++-
2 files changed, 15 insertions(+), 1 deletion(-)
diff --git a/src/main/java/kieker/analysis/plugin/reader/amqp/AMQPReaderLogicModule.java b/src/main/java/kieker/analysis/plugin/reader/amqp/AMQPReaderLogicModule.java
index 7f3d07c7..959b4482 100644
--- a/src/main/java/kieker/analysis/plugin/reader/amqp/AMQPReaderLogicModule.java
+++ b/src/main/java/kieker/analysis/plugin/reader/amqp/AMQPReaderLogicModule.java
@@ -162,16 +162,20 @@ public final class AMQPReaderLogicModule {
final ByteBuffer buffer = ByteBuffer.wrap(body);
final byte recordType = buffer.get();
+ System.out.println("RecordType" + recordType);
// Dispatch to the appropriate handlers
switch (recordType) {
case REGISTRY_RECORD_ID:
+ System.out.println("Registry Record detected");
this.registryRecordHandler.enqueueRegistryRecord(buffer);
break;
case REGULAR_RECORD_ID:
+ System.out.println("Regualar Record detected");
this.regularRecordHandler.enqueueRegularRecord(buffer);
break;
default:
+ System.out.println("Unknown Record detected");
this.log.error(String.format("Unknown record type: %02x", recordType));
break;
}
diff --git a/src/test/java/kieker/analysis/plugin/reader/amqp/AMQPReaderTest.java b/src/test/java/kieker/analysis/plugin/reader/amqp/AMQPReaderTest.java
index 0dc87c7c..c4bfe7d8 100644
--- a/src/test/java/kieker/analysis/plugin/reader/amqp/AMQPReaderTest.java
+++ b/src/test/java/kieker/analysis/plugin/reader/amqp/AMQPReaderTest.java
@@ -6,6 +6,7 @@ import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.ObjectOutputStream;
import java.net.URISyntaxException;
+import java.nio.ByteBuffer;
import java.security.KeyManagementException;
import java.security.NoSuchAlgorithmException;
import java.util.LinkedList;
@@ -22,12 +23,16 @@ import com.rabbitmq.client.ConnectionFactory;
import kieker.common.logging.Log;
import kieker.common.logging.LogFactory;
import kieker.common.record.IMonitoringRecord;
+import kieker.common.record.misc.RegistryRecord;
import kieker.common.record.system.CPUUtilizationRecord;
+import kieker.common.util.registry.ILookup;
+import kieker.common.util.registry.Lookup;
public class AMQPReaderTest {
private AMQPReader amqpReader;
private CPUUtilizationRecord record;
+ private RegistryRecord registryRecord;
// AMQPReader constructor arguments
private final String uri = "amqp://guest:guest@localhost"; // See the amqp uri scheme documentation for detailed information about uri structure
@@ -56,6 +61,7 @@ public class AMQPReaderTest {
public void initializeAMQPReader() {
amqpReader = new AMQPReader(uri, queueName, heartbeat, log);
record = new CPUUtilizationRecord(timestamp, hostname, cpuID, user, system, wait, nice, irq, totalUtilisation, idle);
+ registryRecord = new RegistryRecord(0xFFFFFFFF, "holla");
}
@Test
@@ -67,8 +73,12 @@ public class AMQPReaderTest {
channel = connection.createChannel();
channel.queueDeclare(queueName, false, false, false, null);
+ ILookup<String> stringRegistry = new Lookup<String>();
// Sending the test record as a byte array
- channel.basicPublish("", queueName, null, serialize(record));
+ ByteBuffer buffer = ByteBuffer.allocate(1000);
+ registryRecord.writeBytes(buffer, stringRegistry);
+ System.out.println("RecordType before sending " + buffer.get() + buffer.get() + buffer.get());
+ // channel.basicPublish("", queueName, null, buffer);
System.out.println("Sent record");
channel.close();
--
GitLab