summaryrefslogtreecommitdiffstats
path: root/message-router/publisher/sample.client
diff options
context:
space:
mode:
Diffstat (limited to 'message-router/publisher/sample.client')
-rwxr-xr-xmessage-router/publisher/sample.client/pom.xml39
-rwxr-xr-xmessage-router/publisher/sample.client/src/main/java/org/onap/ccsdk/messagerouter/publisher/client/impl/ClientImpl.java33
-rwxr-xr-xmessage-router/publisher/sample.client/src/main/resources/OSGI-INF/blueprint/blueprint.xml16
3 files changed, 88 insertions, 0 deletions
diff --git a/message-router/publisher/sample.client/pom.xml b/message-router/publisher/sample.client/pom.xml
new file mode 100755
index 000000000..a264bff13
--- /dev/null
+++ b/message-router/publisher/sample.client/pom.xml
@@ -0,0 +1,39 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+ <modelVersion>4.0.0</modelVersion>
+
+ <parent>
+ <groupId>org.onap.ccsdk.messagerouter</groupId>
+ <artifactId>publisher.aggregate</artifactId>
+ <version>0.4.1-SNAPSHOT</version>
+ </parent>
+
+ <artifactId>sample.client</artifactId>
+ <packaging>bundle</packaging>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.onap.ccsdk.messagerouter</groupId>
+ <artifactId>publisher.api</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-api</artifactId>
+ </dependency>
+ </dependencies>
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.felix</groupId>
+ <artifactId>maven-bundle-plugin</artifactId>
+ <configuration>
+ <instructions>
+ <Private-Package>org.onap.ccsdk.messagerouter.publisher.client.impl</Private-Package>
+ </instructions>
+ </configuration>
+ </plugin>
+ </plugins>
+ </build>
+</project>
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