#3 Added abstract processor component

IncQueryLabs · Aug 10, 2016 · 0b2f38c · 0b2f38c
1 parent be99d0f
commit 0b2f38c
Show file tree

Hide file tree

Showing 2 changed files with 43 additions and 0 deletions.
diff --git a/...ommunication/src/main/java/com/incquerylabs/iot/processor/AbstractProcessorComponent.java b/...ommunication/src/main/java/com/incquerylabs/iot/processor/AbstractProcessorComponent.java
@@ -0,0 +1,36 @@
+package com.incquerylabs.iot.processor;
+
+import com.incquerylabs.iot.communication.IAddress;
+import com.incquerylabs.iot.communication.ISubscriberCallback;
+import com.incquerylabs.iot.communication.PublisherPool;
+import com.incquerylabs.iot.communication.SubscriberPool;
+import com.incquerylabs.iot.communication.exception.PoolNotInitializedException;
+
+public class AbstractProcessorComponent implements ISubscriberCallback {
+
+	IAddress sourceAddress;
+	IAddress targetAddress;
+
+	IDataProcessor processor;
+
+	public AbstractProcessorComponent(IAddress sourceAddress, IAddress targetAddress, IDataProcessor processor) throws PoolNotInitializedException {
+
+		this.sourceAddress = sourceAddress;
+		this.targetAddress = targetAddress;
+
+		processor = this.processor;
+
+		SubscriberPool.getInstance().registerCallback(sourceAddress, this);
+	}
+
+	@Override
+	public void messageArrived(IAddress address, byte[] data) {
+		try {
+			PublisherPool.getInstance().next(targetAddress).publish(processor.process(data), 0);
+		} catch (PoolNotInitializedException e) {
+			// TODO Logging ...
+			e.printStackTrace();
+		}
+	}
+
+}
diff --git a/...rylabs.iot.communication/src/main/java/com/incquerylabs/iot/processor/IDataProcessor.java b/...rylabs.iot.communication/src/main/java/com/incquerylabs/iot/processor/IDataProcessor.java
@@ -0,0 +1,7 @@
+package com.incquerylabs.iot.processor;
+
+public interface IDataProcessor {
+
+	public byte[] process(byte[] data);
+
+}