package org.kairosdb.util;

import java.util.concurrent.Callable;

public abstract class RetryCallable implements Callable<Integer>
{
	private int m_retries = -1;

	@Override
	public final Integer call() throws Exception
	{
		m_retries ++;

		if (m_retries > 0)
			System.out.println("Retrying batch");

		retryCall();

		return m_retries;
	}

	public abstract void retryCall() throws Exception;
}

@@ -60,16 +60,74 @@
 lable;%0A%0A
+import org.slf4j.Logger;%0Aimport org.slf4j.LoggerFactory;%0A%0A
 public a
@@ -185,16 +185,99 @@
 eger%3E%0A%7B%0A
+%09public static final Logger logger = LoggerFactory.getLogger(RetryCallable.class);%0A
 %09private
@@ -403,26 +403,19 @@
 %0A%09%09%09
-System.out.println
+logger.info
 (%22Re

change system.out to logger