From deece43ea420d25429f553805c61944f1ec8596f Mon Sep 17 00:00:00 2001 From: Nikita Date: Mon, 9 Nov 2015 12:07:11 +0300 Subject: [PATCH] RBlocking excess interface methods removed --- .../java/org/redisson/core/RBlockingQueue.java | 15 ++------------- .../org/redisson/core/RBlockingQueueAsync.java | 2 -- 2 files changed, 2 insertions(+), 15 deletions(-) diff --git a/src/main/java/org/redisson/core/RBlockingQueue.java b/src/main/java/org/redisson/core/RBlockingQueue.java index 630674785..e2f58bd9a 100644 --- a/src/main/java/org/redisson/core/RBlockingQueue.java +++ b/src/main/java/org/redisson/core/RBlockingQueue.java @@ -15,9 +15,8 @@ */ package org.redisson.core; -import java.util.concurrent.*; - -import io.netty.util.concurrent.Future; +import java.util.concurrent.BlockingQueue; +import java.util.concurrent.TimeUnit; /** * {@link BlockingQueue} backed by Redis @@ -27,16 +26,6 @@ import io.netty.util.concurrent.Future; */ public interface RBlockingQueue extends BlockingQueue, RQueue, RBlockingQueueAsync { - Future pollLastAndOfferFirstToAsync(String queueName, long timeout, TimeUnit unit); - - Future pollAsync(long timeout, TimeUnit unit); - - Future takeAsync(); - - Future putAsync(V e); - - Future offerAsync(V e); - V pollLastAndOfferFirstTo(String queueName, long timeout, TimeUnit unit) throws InterruptedException; V pollLastAndOfferFirstTo(RBlockingQueue queue, long timeout, TimeUnit unit) throws InterruptedException; diff --git a/src/main/java/org/redisson/core/RBlockingQueueAsync.java b/src/main/java/org/redisson/core/RBlockingQueueAsync.java index 62175ccec..c8f3041c2 100644 --- a/src/main/java/org/redisson/core/RBlockingQueueAsync.java +++ b/src/main/java/org/redisson/core/RBlockingQueueAsync.java @@ -40,6 +40,4 @@ public interface RBlockingQueueAsync extends RQueueAsync, RExpirableAsync Future putAsync(V e); - Future offerAsync(V e); - }