Author: cwiklik
Date: Thu Nov 29 17:35:21 2018
New Revision: 1847742
URL: http://svn.apache.org/viewvc?rev=1847742&view=rev
Log:
UIMA-5501 refactored to use pluggagble endpoints
Added:
uima/uima-as/branches/uima-as-3/uimaj-as-connectors/src/main/java/org/apache/uima/as/connectors/mockup/TestClientMessageProcessor.java
Added:
uima/uima-as/branches/uima-as-3/uimaj-as-connectors/src/main/java/org/apache/uima/as/connectors/mockup/TestClientMessageProcessor.java
URL:
http://svn.apache.org/viewvc/uima/uima-as/branches/uima-as-3/uimaj-as-connectors/src/main/java/org/apache/uima/as/connectors/mockup/TestClientMessageProcessor.java?rev=1847742&view=auto
==============================================================================
---
uima/uima-as/branches/uima-as-3/uimaj-as-connectors/src/main/java/org/apache/uima/as/connectors/mockup/TestClientMessageProcessor.java
(added)
+++
uima/uima-as/branches/uima-as-3/uimaj-as-connectors/src/main/java/org/apache/uima/as/connectors/mockup/TestClientMessageProcessor.java
Thu Nov 29 17:35:21 2018
@@ -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());
+
+ }
+
+}
