modify: add deadletter example

Author: Yesphet

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>com.meitu</groupId>
     <artifactId>java-lmstfy-client</artifactId>
-    <version>1.0-SNAPSHOT</version>
+    <version>1.0.0</version>
     <dependencies>
         <dependency>
             <groupId>com.squareup.okhttp3</groupId>
@@ -64,5 +64,4 @@
         </plugins>
     </build>
 
-
 </project>

src/main/java/com/meitu/platform/lmstfy/client/LmstfyClient.java

@@ -107,7 +107,6 @@ public String publish(String queue, byte[] data, int ttlSecond, short tries, int
             default:
                 throw new LmstfyUnexpectedException(response.getCode());
         }
-
     }
 
     /**
@@ -273,7 +272,7 @@ public int respawnDeadLetter(String queue, int limit, int ttlSecond) throws Lmst
                 .addQueryParameter(QUERY_LIMIT, String.valueOf(limit))
                 .addQueryParameter(QUERY_TTL, String.valueOf(ttlSecond))
                 .build();
-        LmstfyResponse response = doRequest("PUT", url, null);
+        LmstfyResponse response = doRequest("PUT", url, RequestBody.create(MediaType.parse("text/binary"), new byte[]{}));
         switch (response.getCode()) {
             case HTTP_OK:
                 RespawnResponse respawnResponse = response.unmarshalBody(RespawnResponse.class);

src/main/java/com/meitu/platform/lmstfy/example.java

@@ -3,6 +3,7 @@
 import com.meitu.platform.lmstfy.client.LmstfyClient;
 import com.meitu.platform.lmstfy.exception.LmstfyException;
 import com.meitu.platform.lmstfy.exception.LmstfyNotJobException;
+import com.meitu.platform.lmstfy.response.DeadLetterResponse;
 
 /**
  * Description:
@@ -26,6 +27,8 @@ public static void main(String[] args) {
         queueSize();
         peekQueue();
         peekJob();
+        peekDeadLetter();
+        respawnDeadLetter();
     }
 
     private static void publish() {
@@ -82,7 +85,6 @@ private static void peekQueue() {
             } else {
                 System.out.println(job.getData());
             }
-
         } catch (LmstfyException e) {
             System.out.println("Request Lmstfy error, " + e.getMessage());
         }
@@ -102,5 +104,23 @@ private static void peekJob() {
         }
     }
 
+    private static void peekDeadLetter() {
+        try {
+            DeadLetterResponse deadLetterResponse = client.peekDeadLetter(queue);
+            System.out.println(deadLetterResponse.getDeadLetterSize());
+        } catch (LmstfyException e) {
+            System.out.println("Request Lmstfy error, " + e.getMessage());
+        }
+    }
+
+    private static void respawnDeadLetter() {
+        try {
+            int count = client.respawnDeadLetter(queue, 1, 60);
+            System.out.println("Respawn deadletter count: " + count);
+        } catch (LmstfyException e) {
+            System.out.println("Request Lmstfy error, " + e.getMessage());
+        }
+    }
+
 
 }