Make generic router core implementations

[aai/router-core.git] / src / main / java / org / onap / aai / event / EventBusComponent.java

diff --git a/src/test/java/org/onap/aai/event/TestProcessor.java b/src/main/java/org/onap/aai/event/EventBusComponent.java
similarity index 59%
rename from src/test/java/org/onap/aai/event/TestProcessor.java
rename to src/main/java/org/onap/aai/event/EventBusComponent.java
index e0f2d27..766382b 100644 (file)
--- a/src/test/java/org/onap/aai/event/TestProcessor.java
+++ b/src/main/java/org/onap/aai/event/EventBusComponent.java
@@ -2,8 +2,8 @@
  * ============LICENSE_START=======================================================
  * org.onap.aai
  * ================================================================================
- * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved.
- * Copyright © 2017-2018 Amdocs
+ * Copyright © 2018 AT&T Intellectual Property. All rights reserved.
+ * Copyright © 2018 Amdocs
  * ================================================================================
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -18,18 +18,26 @@
  * limitations under the License.
  * ============LICENSE_END=========================================================
  */
-
 package org.onap.aai.event;
 
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-
-public class TestProcessor implements Processor {
-
-    @Override
-    public void process(Exchange exchange) throws Exception {
-        // TODO Auto-generated method stub
+import java.util.Map;
 
-    }
+import org.apache.camel.CamelContext;
+import org.apache.camel.Endpoint;
+import org.apache.camel.impl.DefaultComponent;
 
+public class EventBusComponent extends DefaultComponent {
+       public EventBusComponent() {
+               super();
+       }
+       public EventBusComponent(CamelContext context) {
+               super(context);
+       }
+       
+       @Override
+       protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception {
+               Endpoint endpoint = new EventBusEndPoint(uri, this);
+               setProperties(endpoint, parameters);
+               return endpoint;
+       }
 }