aboutsummaryrefslogtreecommitdiffstats
path: root/src/main/java/org/onap/aai/event/EventBusEndPoint.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/org/onap/aai/event/EventBusEndPoint.java')
-rw-r--r--src/main/java/org/onap/aai/event/EventBusEndPoint.java36
1 files changed, 25 insertions, 11 deletions
diff --git a/src/main/java/org/onap/aai/event/EventBusEndPoint.java b/src/main/java/org/onap/aai/event/EventBusEndPoint.java
index 621b30f..5ea6a67 100644
--- a/src/main/java/org/onap/aai/event/EventBusEndPoint.java
+++ b/src/main/java/org/onap/aai/event/EventBusEndPoint.java
@@ -20,34 +20,40 @@
*/
package org.onap.aai.event;
+import org.apache.camel.Category;
import org.apache.camel.Consumer;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
+import org.apache.camel.spi.UriPath;
import org.onap.aai.cl.api.Logger;
import org.onap.aai.cl.eelf.LoggerFactory;
import org.onap.aai.event.api.EventConsumer;
import org.onap.aai.event.api.EventPublisher;
@UriEndpoint(scheme = "event-bus", syntax = "event-bus:name",
-consumerClass = EventBusConsumer.class, title = "event-bus")
+consumerClass = EventBusConsumer.class, title = "event-bus",
+firstVersion = "1.0.0", category = {Category.CORE})
public class EventBusEndPoint extends AbstractEventBusEndpoint {
- @UriParam(label = "eventTopic")
- @Metadata(required = "true")
+
+ @UriPath(description = "client name")
+ private String name;
+ @UriParam(label = "eventTopic", description = "event topic")
+ @Metadata(required = true)
private String eventTopic;
- @UriParam(label = "poolSize")
- @Metadata(required = "true", defaultValue="20")
+ @UriParam(label = "poolSize", description = "pool size")
+ @Metadata(required = true, defaultValue="20")
private int poolSize = 20;
- @UriParam(label = "pollingDelay")
- @Metadata(required = "true", defaultValue="30000")
+ @UriParam(label = "pollingDelay", description = "polling delay")
+ @Metadata(required = true, defaultValue="30000")
private int pollingDelay = 30000;
-
+
EventConsumer consumer; //This would be injected via bean through camel route when passed with #
-
+
EventPublisher publisher; //This would be injected via bean through camel route when passed with #
-
+
private Logger logger = LoggerFactory.getInstance().getLogger(EventBusEndPoint.class);
public EventBusEndPoint(String uri, EventBusComponent component) {
@@ -69,7 +75,7 @@ public class EventBusEndPoint extends AbstractEventBusEndpoint {
return false;
}
- void close() throws Exception {
+ void end() throws Exception {
if(consumer != null)
consumer.close();
if(publisher != null)
@@ -94,6 +100,14 @@ public class EventBusEndPoint extends AbstractEventBusEndpoint {
return eventTopic;
}
+ public String getName() {
+ return name;
+ }
+
+ public void setName(String name) {
+ this.name = name;
+ }
+
public void setEventTopic(String eventTopic) {
this.eventTopic = eventTopic;
}