refactor: Removed memcached exception class

redis · May 21, 2024 · cbfc94b · cbfc94b
1 parent cc0b7b4
commit cbfc94b
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 24 deletions.
diff --git a/...ng-batch-memcached/src/main/java/com/redis/spring/batch/memcached/MemcachedException.java b/...ng-batch-memcached/src/main/java/com/redis/spring/batch/memcached/MemcachedException.java
diff --git a/...g-batch-memcached/src/main/java/com/redis/spring/batch/memcached/MemcachedItemWriter.java b/...g-batch-memcached/src/main/java/com/redis/spring/batch/memcached/MemcachedItemWriter.java
@@ -8,7 +8,6 @@
 
 import org.springframework.batch.item.Chunk;
 import org.springframework.batch.item.ExecutionContext;
-import org.springframework.batch.item.ItemStreamException;
 import org.springframework.batch.item.ItemStreamWriter;
 
 import net.spy.memcached.MemcachedClient;
@@ -31,14 +30,14 @@ public MemcachedItemWriter(Supplier<MemcachedClient> clientSupplier) {
 	}
 
 	@Override
-	public synchronized void open(ExecutionContext executionContext) throws ItemStreamException {
+	public synchronized void open(ExecutionContext executionContext) {
 		if (client == null) {
 			client = clientSupplier.get();
 		}
 	}
 
 	@Override
-	public synchronized void close() throws ItemStreamException {
+	public synchronized void close() {
 		if (client != null) {
 			client.shutdown();
 			client = null;
@@ -52,7 +51,7 @@ public void write(Chunk<? extends MemcachedEntry> chunk) throws Exception {
 		for (int index = 0; index < results.size(); index++) {
 			Boolean result = results.get(index);
 			if (!Boolean.TRUE.equals(result)) {
-				throw new MemcachedException("Could not write key " + chunk.getItems().get(index).getKey());
+				throw new Exception("Could not write key " + chunk.getItems().get(index).getKey());
 			}
 		}
 	}

diff --git a/...emcached/src/main/java/com/redis/spring/batch/memcached/reader/LruMetadumpItemReader.java b/...emcached/src/main/java/com/redis/spring/batch/memcached/reader/LruMetadumpItemReader.java
@@ -8,7 +8,6 @@
 import org.apache.commons.logging.LogFactory;
 
 import com.redis.spring.batch.item.AbstractQueuePollableItemReader;
-import com.redis.spring.batch.memcached.MemcachedException;
 import com.redis.spring.batch.memcached.reader.LruCrawlerMetadumpOperation.Callback;
 
 import net.spy.memcached.MemcachedClient;
@@ -40,7 +39,7 @@ private void safePut(LruMetadumpEntry entry) {
 			queue.put(entry);
 		} catch (InterruptedException e) {
 			Thread.currentThread().interrupt();
-			throw new MemcachedException("Interrupted while trying to add entry to queue", e);
+			throw new RuntimeException("Interrupted while trying to add entry to queue", e);
 		}
 	}