[uima-async-scaleout] 32/34: UIMA-5501 refactored to use pluggagble endpoints

[cw...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

cwiklik pushed a commit to branch uima-as-3
in repository https://gitbox.apache.org/repos/asf/uima-async-scaleout.git

commit b48b8d63ad24314c4d3bcf327f55a91954fbbf85
Author: cwiklik <cwiklik>
AuthorDate: Thu Nov 29 17:35:21 2018 +0000

    UIMA-5501 refactored to use pluggagble endpoints
---
 .../mockup/TestClientMessageProcessor.java         | 25 ++++++++++++++++++++++
 1 file changed, 25 insertions(+)

diff --git a/uimaj-as-connectors/src/main/java/org/apache/uima/as/connectors/mockup/TestClientMessageProcessor.java b/uimaj-as-connectors/src/main/java/org/apache/uima/as/connectors/mockup/TestClientMessageProcessor.java
new file mode 100644
index 0000000..8aa3d55
--- /dev/null
+++ b/uimaj-as-connectors/src/main/java/org/apache/uima/as/connectors/mockup/TestClientMessageProcessor.java
@@ -0,0 +1,25 @@
+package org.apache.uima.as.connectors.mockup;
+
+import org.apache.uima.aae.message.MessageContext;
+import org.apache.uima.aae.message.MessageProcessor;
+import org.apache.uima.as.client.DirectMessageContext;
+
+public class TestClientMessageProcessor implements MessageProcessor {
+
+	public TestClientMessageProcessor() {
+		
+	}
+	@Override
+	public void process(MessageContext message) throws Exception {
+		if ( message instanceof DirectMessageContext ) {
+			process((DirectMessageContext)message);
+		}
+	}
+	
+	private void process(DirectMessageContext message) {
+		System.out.println("Client Message Processor Received Message From:"+
+		        message.getMessage().getOrigin());
+
+	}
+
+}