diff options
| author |   Smokowski, Kevin (ks6305) <kevin.smokowski@att.com> | 2019-03-13 21:02:14 +0000 |
|---|---|---|
| committer |   Dan Timoney <dtimoney@att.com> | 2019-03-18 18:30:18 +0000 |
| commit | 8506f0b261083e945488e869803bcd5ab8b7ea84 (patch) | |
| tree | fa0937b2fdf31b2d334affd1eb2838d2bddf2842 /message-router/publisher/sample.client/src | |
| parent | 20e9eda25ee9aebbcd5fda7497a0baccb64348af (diff) | |
add message router publisher
initial api and implementation of message router publisher
Change-Id: Ic69d013bae8ab8c842e6ecd2eef41e10649d1009
Issue-ID: CCSDK-1163
Signed-off-by: Smokowski, Kevin (ks6305) <kevin.smokowski@att.com>
Diffstat (limited to 'message-router/publisher/sample.client/src')
2 files changed, 49 insertions, 0 deletions
diff --git a/message-router/publisher/sample.client/src/main/java/org/onap/ccsdk/messagerouter/publisher/client/impl/ClientImpl.java b/message-router/publisher/sample.client/src/main/java/org/onap/ccsdk/messagerouter/publisher/client/impl/ClientImpl.java new file mode 100755 index 000000000..dbf49fe94 --- /dev/null +++ b/message-router/publisher/sample.client/src/main/java/org/onap/ccsdk/messagerouter/publisher/client/impl/ClientImpl.java @@ -0,0 +1,33 @@ +package org.onap.ccsdk.messagerouter.publisher.client.impl;
+
+import org.onap.ccsdk.messagerouter.publisher.api.PublisherApi;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class ClientImpl {
+ private static final Logger logger = LoggerFactory.getLogger(ClientImpl.class);
+ private String topic;
+ private PublisherApi publisher;
+
+ public void setPublisher(PublisherApi publisherApi) {
+ this.publisher = publisherApi;
+ }
+
+ public void setTopic(String topic) {
+ this.topic = topic;
+ }
+
+ public ClientImpl() {
+
+ }
+
+ public void init() {
+ for (int i = 0; i < 5; i++) {
+ String body = "{\"hello\":\"world " + String.valueOf(Math.random()) + "\"}";
+ logger.error("Loop iteration " + i + " sending body " + body + " to the topic " + topic);
+ Boolean result = publisher.publish(topic, body);
+ logger.error("Loop iteration " + i + " returned the boolean value " + result);
+ }
+ }
+
+}
\ No newline at end of file diff --git a/message-router/publisher/sample.client/src/main/resources/OSGI-INF/blueprint/blueprint.xml b/message-router/publisher/sample.client/src/main/resources/OSGI-INF/blueprint/blueprint.xml new file mode 100755 index 000000000..c44a68adc --- /dev/null +++ b/message-router/publisher/sample.client/src/main/resources/OSGI-INF/blueprint/blueprint.xml @@ -0,0 +1,16 @@ +<?xml version="1.0" encoding="UTF-8"?> +<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0" + xmlns:cm="http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.2.0"> + + <bean id="client" + class="org.onap.ccsdk.messagerouter.publisher.client.impl.ClientImpl" + init-method="init"> + <property name="publisher" ref="publisher" /> + <cm:managed-properties + persistent-id="org.onap.ccsdk.messagerouter.publisher.client" + update-strategy="container-managed" /> + </bean> + + <reference id="publisher" interface="org.onap.ccsdk.messagerouter.publisher.api.PublisherApi" /> + +</blueprint>
\ No newline at end of file |