aboutsummaryrefslogtreecommitdiffstats
path: root/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/SingleThreadedBusTopicSource.java
diff options
context:
space:
mode:
authorPamela Dragosh <pdragosh@research.att.com>2018-08-10 14:45:45 -0400
committerPamela Dragosh <pdragosh@research.att.com>2018-08-13 10:17:19 -0400
commit269e543ba89dbf553fc66227f7123a302f56b5b4 (patch)
treeb5ac0196770bc6669246953800dc832c6a1b3056 /policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/SingleThreadedBusTopicSource.java
parent637993a21e4826c36ac3dab256acf1510b824d82 (diff)
Remove simple checkstyle
Mostly concentrated on the period at the end of summary. But I did clear a few others for longer than 120 characters and placement of methods next to each other. Possibly a few others. I did not clear everything, but will submit a few more reviews to get the others. Issue-ID: POLICY-881 Change-Id: I692a5349d686d52fee4040757cdc2ed8b5cc221b Signed-off-by: Pamela Dragosh <pdragosh@research.att.com>
Diffstat (limited to 'policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/SingleThreadedBusTopicSource.java')
-rw-r--r--policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/SingleThreadedBusTopicSource.java18
1 files changed, 9 insertions, 9 deletions
diff --git a/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/SingleThreadedBusTopicSource.java b/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/SingleThreadedBusTopicSource.java
index 400cbfe2..e4b335c3 100644
--- a/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/SingleThreadedBusTopicSource.java
+++ b/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/SingleThreadedBusTopicSource.java
@@ -34,7 +34,7 @@ import org.slf4j.LoggerFactory;
/**
* This topic source implementation specializes in reading messages over a bus topic source and
- * notifying its listeners
+ * notifying its listeners.
*/
public abstract class SingleThreadedBusTopicSource extends BusTopicBase
implements Runnable, BusTopicSource, FilterableTopicSource {
@@ -47,32 +47,32 @@ public abstract class SingleThreadedBusTopicSource extends BusTopicBase
private static final Logger netLogger = LoggerFactory.getLogger(NETWORK_LOGGER);
/**
- * Bus consumer group
+ * Bus consumer group.
*/
protected final String consumerGroup;
/**
- * Bus consumer instance
+ * Bus consumer instance.
*/
protected final String consumerInstance;
/**
- * Bus fetch timeout
+ * Bus fetch timeout.
*/
protected final int fetchTimeout;
/**
- * Bus fetch limit
+ * Bus fetch limit.
*/
protected final int fetchLimit;
/**
- * Message Bus Consumer
+ * Message Bus Consumer.
*/
protected BusConsumer consumer;
/**
- * Independent thread reading message over my topic
+ * Independent thread reading message over my topic.
*/
protected Thread busPollerThread;
@@ -113,7 +113,7 @@ public abstract class SingleThreadedBusTopicSource extends BusTopicBase
}
/**
- * Initialize the Bus client
+ * Initialize the Bus client.
*/
public abstract void init() throws MalformedURLException;
@@ -204,7 +204,7 @@ public abstract class SingleThreadedBusTopicSource extends BusTopicBase
}
/**
- * Run thread method for the Bus Reader
+ * Run thread method for the Bus Reader.
*/
@Override
public void run() {