summaryrefslogtreecommitdiffstats
path: root/message-router/publisher/sample.client/src
diff options
context:
space:
mode:
Diffstat (limited to 'message-router/publisher/sample.client/src')
-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
3 files changed, 0 insertions, 103 deletions
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();
- }
-
-}