X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fonap%2Faai%2Fevent%2FEventBusComponent.java;fp=src%2Ftest%2Fjava%2Forg%2Fonap%2Faai%2Fevent%2FTestProcessor.java;h=766382b02c2575532934effc1d48f668d06411db;hb=82f4f1ccada97fa394f88cf208ce526ff5ebf751;hp=e0f2d274f8bf9207fca5e07857cee2d9b8b085f0;hpb=9f43c23e7fbb4531fd045d081ddb59b5a547833c;p=aai%2Frouter-core.git

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
--- 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;
+	}
 }