Updated to Redis 7.2.0 with minimal code changes

gresrun · gresrun · commit 5974c62ba55d · 2025-12-27T21:47:03.000-07:00
diff --git a/pom.xml b/pom.xml
@@ -3,7 +3,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>net.greghaines</groupId>
     <artifactId>jesque</artifactId>
-    <version>2.3.1-SNAPSHOT</version>
+    <version>3.0.0-SNAPSHOT</version>
     <packaging>jar</packaging>
     <name>Jesque</name>
     <description>An implementation of Resque in Java</description>
@@ -258,7 +258,7 @@
         <dependency>
             <groupId>redis.clients</groupId>
             <artifactId>jedis</artifactId>
-            <version>3.10.0</version>
+            <version>7.2.0</version>
         </dependency>
         <dependency>
             <groupId>org.apache.commons</groupId>
diff --git a/src/main/java/net/greghaines/jesque/admin/AdminClientImpl.java b/src/main/java/net/greghaines/jesque/admin/AdminClientImpl.java
@@ -120,7 +120,7 @@ public void end() {
         if (this.keepAliveService != null) {
             this.keepAliveService.shutdownNow();
         }
-        this.jedis.quit();
+        this.jedis.close();
     }
 
     private void authenticateAndSelectDB() {
diff --git a/src/main/java/net/greghaines/jesque/admin/AdminImpl.java b/src/main/java/net/greghaines/jesque/admin/AdminImpl.java
@@ -139,7 +139,7 @@ public void run() {
                 }
             } finally {
                 LOG.debug("AdminImpl shutting down");
-                this.jedis.quit();
+                this.jedis.close();
                 this.threadRef.set(null);
             }
         } else {
diff --git a/src/main/java/net/greghaines/jesque/client/ClientImpl.java b/src/main/java/net/greghaines/jesque/client/ClientImpl.java
@@ -146,7 +146,7 @@ public void end() {
         if (this.keepAliveService != null) {
             this.keepAliveService.shutdownNow();
         }
-        this.jedis.quit();
+        this.jedis.close();
     }
 
     /**
diff --git a/src/main/java/net/greghaines/jesque/meta/dao/impl/QueueInfoDAORedisImpl.java b/src/main/java/net/greghaines/jesque/meta/dao/impl/QueueInfoDAORedisImpl.java
@@ -23,7 +23,6 @@
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
-import java.util.Set;
 
 import net.greghaines.jesque.Config;
 import net.greghaines.jesque.Job;
@@ -35,7 +34,7 @@
 import net.greghaines.jesque.utils.PoolUtils;
 import net.greghaines.jesque.utils.PoolUtils.PoolWork;
 import redis.clients.jedis.Jedis;
-import redis.clients.jedis.Tuple;
+import redis.clients.jedis.resps.Tuple;
 import redis.clients.jedis.util.Pool;
 
 /**
@@ -245,7 +244,7 @@ private List<Job> getJobs(final Jedis jedis, final String queueName, final long
         final String key = key(QUEUE, queueName);
         final List<Job> jobs = new ArrayList<>();
         if (JedisUtils.isDelayedQueue(jedis, key)) { // If delayed queue, use ZRANGEWITHSCORES
-            final Set<Tuple> elements = jedis.zrangeWithScores(key, jobOffset, jobOffset + jobCount - 1);
+            final List<Tuple> elements = jedis.zrangeWithScores(key, jobOffset, jobOffset + jobCount - 1);
             for (final Tuple elementWithScore : elements) {
                 final Job job = ObjectMapperFactory.get().readValue(elementWithScore.getElement(), Job.class);
                 job.setRunAt(elementWithScore.getScore());
diff --git a/src/main/java/net/greghaines/jesque/utils/JedisUtils.java b/src/main/java/net/greghaines/jesque/utils/JedisUtils.java
@@ -48,7 +48,7 @@ public static boolean ensureJedisConnection(final Jedis jedis) {
         final boolean jedisOK = testJedisConnection(jedis);
         if (!jedisOK) {
             try {
-                jedis.quit();
+                jedis.close();
             } catch (Exception e) {
             } // Ignore
             try {
diff --git a/src/main/java/net/greghaines/jesque/worker/WorkerImpl.java b/src/main/java/net/greghaines/jesque/worker/WorkerImpl.java
@@ -227,7 +227,7 @@ public void run() {
                 this.jedis.srem(key(WORKERS), this.name);
                 this.jedis.del(key(WORKER, this.name), key(WORKER, this.name, STARTED), key(STAT, FAILED, this.name),
                         key(STAT, PROCESSED, this.name));
-                this.jedis.quit();
+                this.jedis.close();
                 this.threadRef.set(null);
             }
         } else if (RUNNING.equals(this.state.get())) {
diff --git a/src/test/java/net/greghaines/jesque/ClientBeforeWorkerTest.java b/src/test/java/net/greghaines/jesque/ClientBeforeWorkerTest.java
@@ -56,11 +56,8 @@ public void issue18() throws Exception {
         // Enqueue the job before worker is created and started
         final Job job = new Job("TestAction", new Object[] { 1, 2.3, true, "test", Arrays.asList("inner", 4.5) });
         TestUtils.enqueueJobs(testQueue, Arrays.asList(job), config);
-        Jedis jedis = createJedis(config);
-        try { // Assert that we enqueued the job
-            Assert.assertEquals(Long.valueOf(1), jedis.llen(createKey(config.getNamespace(), QUEUE, testQueue)));
-        } finally {
-            jedis.quit();
+        try (Jedis jedis = createJedis(config)) { // Assert that we enqueued the job
+            Assert.assertEquals(1L, jedis.llen(createKey(config.getNamespace(), QUEUE, testQueue)));
         }
 
         // Create and start worker
@@ -75,13 +72,10 @@ public void issue18() throws Exception {
         }
 
         // Assert that the job was run by the worker
-        jedis = createJedis(config);
-        try {
+        try (Jedis jedis = createJedis(config)) {
             Assert.assertEquals("1", jedis.get(createKey(config.getNamespace(), STAT, PROCESSED)));
             Assert.assertNull(jedis.get(createKey(config.getNamespace(), STAT, FAILED)));
-            Assert.assertEquals(Long.valueOf(0), jedis.llen(createKey(config.getNamespace(), QUEUE, testQueue)));
-        } finally {
-            jedis.quit();
+            Assert.assertEquals(0L, jedis.llen(createKey(config.getNamespace(), QUEUE, testQueue)));
         }
     }
 }
diff --git a/src/test/java/net/greghaines/jesque/DelayedQueueTest.java b/src/test/java/net/greghaines/jesque/DelayedQueueTest.java
@@ -52,12 +52,9 @@ public void testCode() throws Exception {
         }
         TestUtils.enqueueJobs(testQueue, jobs, config);
 
-        Jedis jedis = createJedis(config);
-        try { // Assert that we enqueued the job
-            Assert.assertEquals(Long.valueOf(10),
+        try (Jedis jedis = createJedis(config)) { // Assert that we enqueued the job
+            Assert.assertEquals(10L,
                     jedis.zcount(createKey(config.getNamespace(), QUEUE, delayTestQueue), "-inf", "+inf"));
-        } finally {
-            jedis.quit();
         }
 
         // Create and start worker
@@ -79,14 +76,11 @@ public void testCode() throws Exception {
         }
 
         // Assert that the job was run by the worker
-        jedis = createJedis(config);
-        try {
+        try (Jedis jedis = createJedis(config)) {
             Assert.assertEquals(String.valueOf(20), jedis.get(createKey(config.getNamespace(), STAT, PROCESSED)));
             Assert.assertNull(jedis.get(createKey(config.getNamespace(), STAT, FAILED)));
-            Assert.assertEquals(Long.valueOf(0),
+            Assert.assertEquals(0L,
                     jedis.zcount(createKey(config.getNamespace(), QUEUE, delayTestQueue), "-inf", "+inf"));
-        } finally {
-            jedis.quit();
         }
     }
 }
diff --git a/src/test/java/net/greghaines/jesque/DurabilityTest.java b/src/test/java/net/greghaines/jesque/DurabilityTest.java
@@ -53,7 +53,7 @@ public void testNotInterrupted() throws InterruptedException, JsonProcessingExce
 
         final Jedis jedis = TestUtils.createJedis(config);
         Assert.assertEquals("In-flight list should have length one when running the job",
-                jedis.llen(inFlightKey(worker, queue)), (Long)1L);
+                1L, jedis.llen(inFlightKey(worker, queue)));
         Assert.assertEquals("Object on the in-flight list should be the first job",
                 ObjectMapperFactory.get().writeValueAsString(sleepJob), 
                 jedis.lindex(inFlightKey(worker, queue), 0));
@@ -63,7 +63,7 @@ public void testNotInterrupted() throws InterruptedException, JsonProcessingExce
         Assert.assertTrue("The job should not be requeued after succesful processing",
                 jedis.llen(JesqueUtils.createKey(config.getNamespace(), QUEUE, queue)) == 0L);
         Assert.assertEquals("In-flight list should be empty when finishing a job", 
-                jedis.llen(inFlightKey(worker, queue)), (Long)0L);
+                0L, jedis.llen(inFlightKey(worker, queue)));
     }
 
     @Test
@@ -123,7 +123,7 @@ public void testJSONException() throws InterruptedException {
         TestUtils.stopWorker(worker, workerThread, false);
 
         Assert.assertEquals("In-flight list should have length zero if the worker failed during JSON deserialization",
-                jedis.llen(inFlightKey(worker, queue)), (Long) 0L);
+                0L, jedis.llen(inFlightKey(worker, queue)));
     }
 
     private static String inFlightKey(final Worker worker, final String queue) {
diff --git a/src/test/java/net/greghaines/jesque/IntegrationTest.java b/src/test/java/net/greghaines/jesque/IntegrationTest.java
@@ -173,13 +173,10 @@ public void onEvent(final WorkerEvent event, final Worker worker, final String q
             }
         }, JOB_FAILURE);
 
-        final Jedis jedis = createJedis(CONFIG);
-        try {
+        try (Jedis jedis = createJedis(CONFIG)) {
             Assert.assertTrue(didFailWithUnpermittedJob.get());
             Assert.assertEquals("1", jedis.get(createKey(CONFIG.getNamespace(), STAT, FAILED)));
             Assert.assertNull(jedis.get(createKey(CONFIG.getNamespace(), STAT, PROCESSED)));
-        } finally {
-            jedis.quit();
         }
     }
 
@@ -188,12 +185,9 @@ private static void assertSuccess(final WorkerListener listener, final WorkerEve
 
         doWork(Arrays.asList(job), map(entry("TestAction", TestAction.class)), listener, events);
 
-        final Jedis jedis = createJedis(CONFIG);
-        try {
+        try (Jedis jedis = createJedis(CONFIG)) {
             Assert.assertEquals("1", jedis.get(createKey(CONFIG.getNamespace(), STAT, PROCESSED)));
             Assert.assertNull(jedis.get(createKey(CONFIG.getNamespace(), STAT, FAILED)));
-        } finally {
-            jedis.quit();
         }
     }
 
@@ -202,12 +196,9 @@ private static void assertFailure(final WorkerListener listener, final WorkerEve
 
         doWork(Arrays.asList(job), map(entry("FailAction", FailAction.class)), listener, events);
 
-        final Jedis jedis = createJedis(CONFIG);
-        try {
+        try (Jedis jedis = createJedis(CONFIG)) {
             Assert.assertEquals("1", jedis.get(createKey(CONFIG.getNamespace(), STAT, FAILED)));
             Assert.assertNull(jedis.get(createKey(CONFIG.getNamespace(), STAT, PROCESSED)));
-        } finally {
-            jedis.quit();
         }
     }
 
@@ -220,12 +211,9 @@ private static void assertMixed(final WorkerListener listener, final WorkerEvent
         doWork(Arrays.asList(job1, job2, job3, job4),
                 map(entry("FailAction", FailAction.class), entry("TestAction", TestAction.class)), listener, events);
 
-        final Jedis jedis = createJedis(CONFIG);
-        try {
+        try (Jedis jedis = createJedis(CONFIG)) {
             Assert.assertEquals("2", jedis.get(createKey(CONFIG.getNamespace(), STAT, FAILED)));
             Assert.assertEquals("2", jedis.get(createKey(CONFIG.getNamespace(), STAT, PROCESSED)));
-        } finally {
-            jedis.quit();
         }
     }
 
@@ -238,12 +226,9 @@ private static void assertBatchMixed(final WorkerListener listener, final Worker
         doBatchWork(Arrays.asList(job1, job2, job3, job4),
                 map(entry("FailAction", FailAction.class), entry("TestAction", TestAction.class)), listener, events);
 
-        final Jedis jedis = createJedis(CONFIG);
-        try {
+        try (Jedis jedis = createJedis(CONFIG)) {
             Assert.assertEquals("2", jedis.get(createKey(CONFIG.getNamespace(), STAT, FAILED)));
             Assert.assertEquals("2", jedis.get(createKey(CONFIG.getNamespace(), STAT, PROCESSED)));
-        } finally {
-            jedis.quit();
         }
     }
 
diff --git a/src/test/java/net/greghaines/jesque/Issue46.java b/src/test/java/net/greghaines/jesque/Issue46.java
@@ -55,12 +55,9 @@ public void testIssue46() {
         } finally {
             TestUtils.stopWorker(worker, workerThread);
         }
-        final Jedis jedis = createJedis(CONFIG);
-        try {
+        try (Jedis jedis = createJedis(CONFIG)) {
             Assert.assertEquals("1", jedis.get(createKey(CONFIG.getNamespace(), STAT, PROCESSED)));
             Assert.assertNull(jedis.get(createKey(CONFIG.getNamespace(), STAT, FAILED)));
-        } finally {
-            jedis.quit();
         }
     }
 
diff --git a/src/test/java/net/greghaines/jesque/RecurringQueueTest.java b/src/test/java/net/greghaines/jesque/RecurringQueueTest.java
@@ -13,14 +13,13 @@
 import redis.clients.jedis.Jedis;
 
 import java.util.Arrays;
-import java.util.Set;
+import java.util.List;
 
 import static net.greghaines.jesque.TestUtils.createJedis;
 import static net.greghaines.jesque.utils.JesqueUtils.createKey;
 import static net.greghaines.jesque.utils.JesqueUtils.entry;
 import static net.greghaines.jesque.utils.JesqueUtils.map;
 import static net.greghaines.jesque.utils.ResqueConstants.*;
-import static net.greghaines.jesque.utils.ResqueConstants.QUEUE;
 
 /**
  * Created by Karthik (@argvk) on 6/3/15.
@@ -45,17 +44,14 @@ public void testCode() throws Exception {
         Job job = new Job("TestAction", new Object[]{1, 2.3, true, "test", Arrays.asList("inner", 4.5)});
         client.recurringEnqueue(recurringTestQueue, job, System.currentTimeMillis() + recurringFrequency, recurringFrequency);
 
-        Jedis jedis = createJedis(config);
-        try { // Assert that we enqueued the job
-            Assert.assertEquals(Long.valueOf(1),
+        try (Jedis jedis = createJedis(config)) { // Assert that we enqueued the job
+            Assert.assertEquals(1L,
                     jedis.zcount(queueKey, "-inf", "+inf"));
-            Set<String> jobSet = jedis.zrangeByScore(queueKey, "-inf", "+inf", 0, 1);
+            List<String> jobSet = jedis.zrangeByScore(queueKey, "-inf", "+inf", 0, 1);
 
             String jobString = jobSet.iterator().next();
             Assert.assertEquals(String.valueOf(recurringFrequency),
                     jedis.hget(hashKey, jobString));
-        } finally {
-            jedis.quit();
         }
 
         // Create and mark the start worker
@@ -79,20 +75,17 @@ public void testCode() throws Exception {
         Long times = ((endMillis - startMillis)/recurringFrequency);
 
         // Assert that the job was run by the worker
-        jedis = createJedis(config);
-        try {
+        try (Jedis jedis = createJedis(config)) {
             Long processedTimes = Long.valueOf(jedis.get(createKey(config.getNamespace(), STAT, PROCESSED)));
 
             // allowing for off by one error
             Long oneOrZero = Math.abs(times - processedTimes);
 
             Assert.assertTrue(oneOrZero == 0 || oneOrZero == 1);
             Assert.assertNull(jedis.get(createKey(config.getNamespace(), STAT, FAILED)));
-            Assert.assertEquals(Long.valueOf(0),
+            Assert.assertEquals(0L,
                     jedis.zcount(createKey(config.getNamespace(), QUEUE, recurringTestQueue), "-inf", "+inf"));
-            Assert.assertEquals(Long.valueOf(0), jedis.hlen(hashKey));
-        } finally {
-            jedis.quit();
+            Assert.assertEquals(0L, jedis.hlen(hashKey));
         }
     }
 
diff --git a/src/test/java/net/greghaines/jesque/RemoveDelayedQueueTest.java b/src/test/java/net/greghaines/jesque/RemoveDelayedQueueTest.java
@@ -51,12 +51,9 @@ public void testCode() throws Exception {
         final List<Job> jobsToRemove = jobs.subList(0,5);
         TestUtils.removeDelayEnqueueJobs(delayTestQueue, jobsToRemove, config);
 
-        Jedis jedis = createJedis(config);
-        try { // Assert that we removed jobs are not queued
-            Assert.assertEquals(Long.valueOf(5),
+        try (Jedis jedis = createJedis(config)) { // Assert that we removed jobs are not queued
+            Assert.assertEquals(5L,
                     jedis.zcount(createKey(config.getNamespace(), QUEUE, delayTestQueue), "-inf", "+inf"));
-        } finally {
-            jedis.quit();
         }
 
         // Create and start worker
@@ -78,14 +75,11 @@ public void testCode() throws Exception {
         }
 
         // Assert that the job was run by the worker
-        jedis = createJedis(config);
-        try {
+        try (Jedis jedis = createJedis(config)) {
             Assert.assertEquals(String.valueOf(5), jedis.get(createKey(config.getNamespace(), STAT, PROCESSED)));
             Assert.assertNull(jedis.get(createKey(config.getNamespace(), STAT, FAILED)));
-            Assert.assertEquals(Long.valueOf(0),
+            Assert.assertEquals(0L,
                     jedis.zcount(createKey(config.getNamespace(), QUEUE, delayTestQueue), "-inf", "+inf"));
-        } finally {
-            jedis.quit();
         }
     }
 }
diff --git a/src/test/java/net/greghaines/jesque/TestUtils.java b/src/test/java/net/greghaines/jesque/TestUtils.java
@@ -44,12 +44,9 @@ public final class TestUtils {
      *            the location of the Redis server
      */
     public static void resetRedis(final Config config) {
-        final Jedis jedis = createJedis(config);
-        try {
+        try (Jedis jedis = createJedis(config)) {
             log.info("Resetting Redis for next test...");
             jedis.flushDB();
-        } finally {
-            jedis.quit();
         }
     }
 
diff --git a/src/test/java/net/greghaines/jesque/meta/dao/impl/TestKeysDAORedisImpl.java b/src/test/java/net/greghaines/jesque/meta/dao/impl/TestKeysDAORedisImpl.java
@@ -212,7 +212,7 @@ public void testDoWork_HandleZSet() throws Exception {
     @Test
     public void testDoWork_HandleZSet_ArrayValue() throws Exception {
         final String key = "foo:bar";
-        final Set<String> value = new LinkedHashSet<String>(Arrays.asList("foo", "bar", "baz"));
+        final List<String> value = Arrays.asList("foo", "bar", "baz");
         final long size = 8;
         final int offset = 1;
         final int count = value.size();
diff --git a/src/test/java/net/greghaines/jesque/meta/dao/impl/TestQueueInfoDAORedisImpl.java b/src/test/java/net/greghaines/jesque/meta/dao/impl/TestQueueInfoDAORedisImpl.java
@@ -35,7 +35,7 @@
 import com.fasterxml.jackson.core.JsonProcessingException;
 
 import redis.clients.jedis.Jedis;
-import redis.clients.jedis.Tuple;
+import redis.clients.jedis.resps.Tuple;
 import redis.clients.jedis.util.Pool;
 
 public class TestQueueInfoDAORedisImpl {
@@ -217,7 +217,7 @@ public void testGetQueueInfo_ZSet() throws JsonProcessingException {
         final long jobOffset = 1;
         final long jobCount = 2;
         final long size = 4;
-        final Set<Tuple> payloads = new HashSet<>();
+        final List<Tuple> payloads = new ArrayList<>(2);
         payloads.add(new Tuple(ObjectMapperFactory.get().writeValueAsString(new Job("foo")), 1d));
         payloads.add(new Tuple(ObjectMapperFactory.get().writeValueAsString(new Job("bar")), 1d));
         this.mockCtx.checking(new Expectations(){{

Original file line number	Diff line number	Diff line change
`@@ -120,7 +120,7 @@ public void end() {`
`120`	`120`	`if (this.keepAliveService != null) {`
`121`	`121`	`this.keepAliveService.shutdownNow();`
`122`	`122`	`}`
`123`		`- this.jedis.quit();`
	`123`	`+ this.jedis.close();`
`124`	`124`	`}`
`125`	`125`
`126`	`126`	`private void authenticateAndSelectDB() {`
Original file line number	Diff line number	Diff line change
`@@ -139,7 +139,7 @@ public void run() {`
`139`	`139`	`}`
`140`	`140`	`} finally {`
`141`	`141`	`LOG.debug("AdminImpl shutting down");`
`142`		`- this.jedis.quit();`
	`142`	`+ this.jedis.close();`
`143`	`143`	`this.threadRef.set(null);`
`144`	`144`	`}`
`145`	`145`	`} else {`
Original file line number	Diff line number	Diff line change
`@@ -146,7 +146,7 @@ public void end() {`
`146`	`146`	`if (this.keepAliveService != null) {`
`147`	`147`	`this.keepAliveService.shutdownNow();`
`148`	`148`	`}`
`149`		`- this.jedis.quit();`
	`149`	`+ this.jedis.close();`
`150`	`150`	`}`
`151`	`151`
`152`	`152`	`/**`
Original file line number	Diff line number	Diff line change
`@@ -227,7 +227,7 @@ public void run() {`
`227`	`227`	`this.jedis.srem(key(WORKERS), this.name);`
`228`	`228`	`this.jedis.del(key(WORKER, this.name), key(WORKER, this.name, STARTED), key(STAT, FAILED, this.name),`
`229`	`229`	`key(STAT, PROCESSED, this.name));`
`230`		`- this.jedis.quit();`
	`230`	`+ this.jedis.close();`
`231`	`231`	`this.threadRef.set(null);`
`232`	`232`	`}`
`233`	`233`	`} else if (RUNNING.equals(this.state.get())) {`
Original file line number	Diff line number	Diff line change
`@@ -56,11 +56,8 @@ public void issue18() throws Exception {`
`56`	`56`	`// Enqueue the job before worker is created and started`
`57`	`57`	`final Job job = new Job("TestAction", new Object[] { 1, 2.3, true, "test", Arrays.asList("inner", 4.5) });`
`58`	`58`	`TestUtils.enqueueJobs(testQueue, Arrays.asList(job), config);`
`59`		`- Jedis jedis = createJedis(config);`
`60`		`- try { // Assert that we enqueued the job`
`61`		`- Assert.assertEquals(Long.valueOf(1), jedis.llen(createKey(config.getNamespace(), QUEUE, testQueue)));`
`62`		`- } finally {`
`63`		`- jedis.quit();`
	`59`	`+ try (Jedis jedis = createJedis(config)) { // Assert that we enqueued the job`
	`60`	`+ Assert.assertEquals(1L, jedis.llen(createKey(config.getNamespace(), QUEUE, testQueue)));`
`64`	`61`	`}`
`65`	`62`
`66`	`63`	`// Create and start worker`
`@@ -75,13 +72,10 @@ public void issue18() throws Exception {`
`75`	`72`	`}`
`76`	`73`
`77`	`74`	`// Assert that the job was run by the worker`
`78`		`- jedis = createJedis(config);`
`79`		`- try {`
	`75`	`+ try (Jedis jedis = createJedis(config)) {`
`80`	`76`	`Assert.assertEquals("1", jedis.get(createKey(config.getNamespace(), STAT, PROCESSED)));`
`81`	`77`	`Assert.assertNull(jedis.get(createKey(config.getNamespace(), STAT, FAILED)));`
`82`		`- Assert.assertEquals(Long.valueOf(0), jedis.llen(createKey(config.getNamespace(), QUEUE, testQueue)));`
`83`		`- } finally {`
`84`		`- jedis.quit();`
	`78`	`+ Assert.assertEquals(0L, jedis.llen(createKey(config.getNamespace(), QUEUE, testQueue)));`
`85`	`79`	`}`
`86`	`80`	`}`
`87`	`81`	`}`
Original file line number	Diff line number	Diff line change
`@@ -52,12 +52,9 @@ public void testCode() throws Exception {`
`52`	`52`	`}`
`53`	`53`	`TestUtils.enqueueJobs(testQueue, jobs, config);`
`54`	`54`
`55`		`- Jedis jedis = createJedis(config);`
`56`		`- try { // Assert that we enqueued the job`
`57`		`- Assert.assertEquals(Long.valueOf(10),`
	`55`	`+ try (Jedis jedis = createJedis(config)) { // Assert that we enqueued the job`
	`56`	`+ Assert.assertEquals(10L,`
`58`	`57`	`jedis.zcount(createKey(config.getNamespace(), QUEUE, delayTestQueue), "-inf", "+inf"));`
`59`		`- } finally {`
`60`		`- jedis.quit();`
`61`	`58`	`}`
`62`	`59`
`63`	`60`	`// Create and start worker`
`@@ -79,14 +76,11 @@ public void testCode() throws Exception {`
`79`	`76`	`}`
`80`	`77`
`81`	`78`	`// Assert that the job was run by the worker`
`82`		`- jedis = createJedis(config);`
`83`		`- try {`
	`79`	`+ try (Jedis jedis = createJedis(config)) {`
`84`	`80`	`Assert.assertEquals(String.valueOf(20), jedis.get(createKey(config.getNamespace(), STAT, PROCESSED)));`
`85`	`81`	`Assert.assertNull(jedis.get(createKey(config.getNamespace(), STAT, FAILED)));`
`86`		`- Assert.assertEquals(Long.valueOf(0),`
	`82`	`+ Assert.assertEquals(0L,`
`87`	`83`	`jedis.zcount(createKey(config.getNamespace(), QUEUE, delayTestQueue), "-inf", "+inf"));`
`88`		`- } finally {`
`89`		`- jedis.quit();`
`90`	`84`	`}`
`91`	`85`	`}`
`92`	`86`	`}`