summaryrefslogtreecommitdiffstats
path: root/message-router/publisher/sample.client
diff options
context:
space:
mode:
authorJessica Wagantall <jwagantall@linuxfoundation.org>2020-12-01 11:26:31 -0800
committerJessica Wagantall <jwagantall@linuxfoundation.org>2020-12-01 11:27:11 -0800
commit11510b43c277b8e1dd7e58d79785544810118c8e (patch)
treeb88a497c999d24b5f357ea9b26bc93e0990fd5e7 /message-router/publisher/sample.client
parent5d2eab72fc4442f14108b41800cec88126913823 (diff)
Migrate sli-adaptor files
Migrate sli-adaptor repo files into a new "adaptors" directory. Signed-off-by: Jessica Wagantall <jwagantall@linuxfoundation.org>
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/sli/adaptors/messagerouter/publisher/client/impl/ClientImpl.java58
-rwxr-xr-xmessage-router/publisher/sample.client/src/main/resources/OSGI-INF/blueprint/blueprint.xml16
-rw-r--r--message-router/publisher/sample.client/src/test/java/org/onap/ccsdk/sli/adaptors/messagerouter/publisher/client/impl/ClientImplTest.java29
4 files changed, 0 insertions, 142 deletions
diff --git a/message-router/publisher/sample.client/pom.xml b/message-router/publisher/sample.client/pom.xml
deleted file mode 100755
index 694af1f4a..000000000
--- a/message-router/publisher/sample.client/pom.xml
+++ /dev/null
@@ -1,39 +0,0 @@
-<?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.sli.adaptors.messagerouter</groupId>
- <artifactId>publisher.aggregate</artifactId>
- <version>1.1.1-SNAPSHOT</version>
- </parent>
-
- <artifactId>sample.client</artifactId>
- <packaging>bundle</packaging>
-
- <dependencies>
- <dependency>
- <groupId>${project.groupId}</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>${project.groupId}.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/sli/adaptors/messagerouter/publisher/client/impl/ClientImpl.java b/message-router/publisher/sample.client/src/main/java/org/onap/ccsdk/sli/adaptors/messagerouter/publisher/client/impl/ClientImpl.java
deleted file mode 100755
index d1610305a..000000000
--- a/message-router/publisher/sample.client/src/main/java/org/onap/ccsdk/sli/adaptors/messagerouter/publisher/client/impl/ClientImpl.java
+++ /dev/null
@@ -1,58 +0,0 @@
-/**
- * ============LICENSE_START====================================================
- * org.onap.aaf
- * ===========================================================================
- * Copyright (c) 2019 AT&T Intellectual Property. All rights reserved.
- *
- * Modifications Copyright (C) 2019 IBM.
- * ===========================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END====================================================
- *
- */
-
-package org.onap.ccsdk.sli.adaptors.messagerouter.publisher.client.impl;
-
-import org.onap.ccsdk.sli.adaptors.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 ClientImpl() {
-
- }
-
- public void setPublisher(PublisherApi publisherApi) {
- this.publisher = publisherApi;
- }
-
- public void setTopic(String topic) {
- this.topic = topic;
- }
-
-
-
- public void init() {
- for (int i = 0; i < 5; i++) {
- String body = "{\"hello\":\"world " + 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
deleted file mode 100755
index c2e981da2..000000000
--- a/message-router/publisher/sample.client/src/main/resources/OSGI-INF/blueprint/blueprint.xml
+++ /dev/null
@@ -1,16 +0,0 @@
-<?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.sli.adaptors.messagerouter.publisher.client.impl.ClientImpl"
- init-method="init">
- <property name="publisher" ref="publisher" />
- <cm:managed-properties
- persistent-id="org.onap.ccsdk.sli.adaptors.messagerouter.publisher.client"
- update-strategy="container-managed" />
- </bean>
-
- <reference id="publisher" interface="org.onap.ccsdk.sli.adaptors.messagerouter.publisher.api.PublisherApi" />
-
-</blueprint> \ No newline at end of file
diff --git a/message-router/publisher/sample.client/src/test/java/org/onap/ccsdk/sli/adaptors/messagerouter/publisher/client/impl/ClientImplTest.java b/message-router/publisher/sample.client/src/test/java/org/onap/ccsdk/sli/adaptors/messagerouter/publisher/client/impl/ClientImplTest.java
deleted file mode 100644
index 82a1566c3..000000000
--- a/message-router/publisher/sample.client/src/test/java/org/onap/ccsdk/sli/adaptors/messagerouter/publisher/client/impl/ClientImplTest.java
+++ /dev/null
@@ -1,29 +0,0 @@
-package org.onap.ccsdk.sli.adaptors.messagerouter.publisher.client.impl;
-
-import static org.junit.Assert.assertEquals;
-
-import org.junit.Test;
-import org.onap.ccsdk.sli.adaptors.messagerouter.publisher.api.PublisherApi;
-
-public class ClientImplTest {
-
- @Test
- public void testSetTopic() {
- ClientImpl impl = new ClientImpl();
- String myTopic = "stock updates";
- impl.setTopic(myTopic);
-
- PublisherApi publisherImpl = new PublisherApi() {
-
- @Override
- public Boolean publish(String topic, String body) {
- assertEquals(myTopic,topic);
- return true;
- }
-
- };
- impl.setPublisher(publisherImpl);
- impl.init();
- }
-
-}