diff options
Diffstat (limited to 'message-router/publisher/sample.client/src')
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();
- }
-
-}
|