From 92496e96aba9c74692db970d9fdcfd214752c622 Mon Sep 17 00:00:00 2001 From: Nikita Date: Mon, 16 Apr 2018 15:19:12 +0300 Subject: [PATCH] refactoring --- .../org/redisson/reactive/RedissonSemaphoreReactive.java | 8 -------- 1 file changed, 8 deletions(-) diff --git a/redisson/src/main/java/org/redisson/reactive/RedissonSemaphoreReactive.java b/redisson/src/main/java/org/redisson/reactive/RedissonSemaphoreReactive.java index 40a01d51b..cf88a2489 100644 --- a/redisson/src/main/java/org/redisson/reactive/RedissonSemaphoreReactive.java +++ b/redisson/src/main/java/org/redisson/reactive/RedissonSemaphoreReactive.java @@ -15,17 +15,13 @@ */ package org.redisson.reactive; -import java.util.UUID; import java.util.concurrent.TimeUnit; import org.reactivestreams.Publisher; -import org.redisson.RedissonLock; import org.redisson.RedissonSemaphore; import org.redisson.api.RFuture; -import org.redisson.api.RLockAsync; import org.redisson.api.RSemaphoreAsync; import org.redisson.api.RSemaphoreReactive; -import org.redisson.command.CommandAsyncExecutor; import org.redisson.command.CommandReactiveExecutor; import org.redisson.pubsub.SemaphorePubSub; @@ -45,10 +41,6 @@ public class RedissonSemaphoreReactive extends RedissonExpirableReactive impleme instance = new RedissonSemaphore(commandExecutor, name, semaphorePubSub); } - protected RLockAsync createLock(CommandAsyncExecutor connectionManager, String name) { - return new RedissonLock(commandExecutor, name); - } - @Override public Publisher tryAcquire() { return reactive(new Supplier>() {