gerrit.onap Code Review - ccsdk/sli/adaptors.git/blob

   1 package org.onap.ccsdk.messagerouter.publisher.client.impl;\r
   2 \r
   3 import org.onap.ccsdk.messagerouter.publisher.api.PublisherApi;\r
   4 import org.slf4j.Logger;\r
   5 import org.slf4j.LoggerFactory;\r
   6 \r
   7 public class ClientImpl {\r
   8         private static final Logger logger = LoggerFactory.getLogger(ClientImpl.class);\r
   9         private String topic;\r
  10         private PublisherApi publisher;\r
  11 \r
  12         public void setPublisher(PublisherApi publisherApi) {\r
  13                 this.publisher = publisherApi;\r
  14         }\r
  15 \r
  16         public void setTopic(String topic) {\r
  17                 this.topic = topic;\r
  18         }\r
  19 \r
  20         public ClientImpl() {\r
  21 \r
  22         }\r
  23 \r
  24         public void init() {\r
  25                 for (int i = 0; i < 5; i++) {\r
  26                         String body = "{\"hello\":\"world " + String.valueOf(Math.random()) + "\"}";\r
  27                         logger.error("Loop iteration " + i + " sending body " + body + " to the topic " + topic);\r
  28                         Boolean result = publisher.publish(topic, body);\r
  29                         logger.error("Loop iteration " + i + " returned the boolean value " + result);\r
  30                 }\r
  31         }\r
  32 \r
  33 }