From 439e8f635e91ab53258dd2320fcf0ec225b9eaec Mon Sep 17 00:00:00 2001
From: Christian Meier <meier.kristian@gmail.com>
Date: Mon, 2 Nov 2015 19:56:42 +0100
Subject: [PATCH] declare private methods as such

helps to understand what methods could be used by other threads
---
 .../github/lookout/verspaetung/KafkaPoller.groovy  | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/src/main/groovy/com/github/lookout/verspaetung/KafkaPoller.groovy b/src/main/groovy/com/github/lookout/verspaetung/KafkaPoller.groovy
index c3ee6c8..260dc3c 100644
--- a/src/main/groovy/com/github/lookout/verspaetung/KafkaPoller.groovy
+++ b/src/main/groovy/com/github/lookout/verspaetung/KafkaPoller.groovy
@@ -81,14 +81,14 @@ class KafkaPoller extends Thread {
         }
     }
 
-    void slower(Delay delay) {
+    private void slower(Delay delay) {
         if (delay.slower()) {
             LOGGER.error('using ' + delay)
         }
     }
 
     @SuppressWarnings(['CatchException'])
-    void dumpMetadata() {
+    private void dumpMetadata() {
         LOGGER.debug('dumping meta-data')
 
         Object metadata = fetchMetadataForCurrentTopics()
@@ -113,7 +113,7 @@ class KafkaPoller extends Thread {
      * The 'metadata' is the expected return from
      * kafka.client.ClientUtils.fetchTopicMetadata
      */
-    void withTopicsAndPartitions(Object metadata, Closure closure) {
+    private void withTopicsAndPartitions(Object metadata, Closure closure) {
         withScalaCollection(metadata.topicsMetadata).each { kafka.api.TopicMetadata f ->
             withScalaCollection(f.partitionsMetadata).each { p ->
                 TopicPartition tp = new TopicPartition(f.topic, p.partitionId)
@@ -125,7 +125,7 @@ class KafkaPoller extends Thread {
     /**
      * Fetch the leader metadata and update our data structures
      */
-    void captureLatestOffsetFor(TopicPartition tp, Object partitionMetadata) {
+    private void captureLatestOffsetFor(TopicPartition tp, Object partitionMetadata) {
         Integer leaderId = partitionMetadata.leader.get()?.id
         Integer partitionId = partitionMetadata.partitionId
 
@@ -134,7 +134,7 @@ class KafkaPoller extends Thread {
         this.topicOffsetMap[tp] = offset
     }
 
-    Long latestFromLeader(Integer leaderId, String topic, Integer partition) {
+    private Long latestFromLeader(Integer leaderId, String topic, Integer partition) {
         SimpleConsumer consumer = this.brokerConsumerMap[leaderId]
 
         /* If we don't have a proper SimpleConsumer instance (e.g. null) then
@@ -149,14 +149,14 @@ class KafkaPoller extends Thread {
         return consumer.earliestOrLatestOffset(topicAndPart, -1, 0)
     }
 
-    Iterable withScalaCollection(scala.collection.Iterable iter) {
+    private Iterable withScalaCollection(scala.collection.Iterable iter) {
         return JavaConversions.asJavaIterable(iter)
     }
 
     /**
      * Blocking reconnect to the Kafka brokers
      */
-    void reconnect() {
+    private void reconnect() {
         disconnectConsumers()
         LOGGER.info('Creating SimpleConsumer connections for brokers')
         synchronized(this.brokers) {