removed bury without reason

src/main/java/rtalk/RTalk.java

@@ -3,6 +3,8 @@
 import static java.util.UUID.randomUUID;
 import static java.util.stream.Collectors.toMap;
 
+import java.io.PrintWriter;
+import java.io.StringWriter;
 import java.util.Map;
 import java.util.Optional;
 import java.util.Set;
@@ -566,11 +568,18 @@ public synchronized Response bury(String id, long pri, String reason) {
         }
         return new Response(NOT_FOUND, id, tube);
     }
-
-    public Response bury(String id, long pri) {
-        return bury(id, pri, null);
+
+    public synchronized Response bury(String id, long pri, Throwable e) {
+        if (e != null) {
+            StringWriter stringWriter = new StringWriter();
+            e.printStackTrace(new PrintWriter(stringWriter));
+            String reason = stringWriter.toString();
+            return bury(id, pri, reason);
+        }
+        return bury(id, pri, "");
     }
 
+
     /**
      * The "touch" command allows a worker to request more time to work on a
      * job. This is useful for jobs that potentially take a long time, but you
@@ -862,7 +871,7 @@ protected Jedis getRedis() {
             }
             try {
                 long retryMsec = (1 << attempt) * 100L;
-                System.err.println("retry getRedis in " + retryMsec + " because " + lastError);
+                System.err.println("retry RTalk.getRedis in " + retryMsec + " because " + lastError);
                 Thread.sleep(retryMsec);
             } catch (InterruptedException e) {
                 e.printStackTrace();

src/test/java/rtalk/RTalkTest.java

@@ -160,7 +160,7 @@ public void testPutBuryKickJob() throws Exception {
         RTalk rt = new RTalk(jedisPool);
         Response put = rt.put(0, 0, 0, "a");
         assertEquals(INSERTED, put.status);
-        assertEquals(BURIED, rt.bury(put.id, 0).status);
+        assertEquals(BURIED, rt.bury(put.id, 0, "reason").status);
         assertEquals(0, rt.statsTube().currentjobsready);
         assertEquals(1, rt.statsTube().currentjobsburied);
         assertEquals(KICKED, rt.kickJob(put.id).status);