github-forks
/
redisson
mirror of https://github.com/redisson/redisson.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Topic listeners moved to org.redisson.api.listener package

Browse Source
pull/578/head^2
Nikita 9 years ago
parent 8a0b478c49
commit f67d21fe24
23 changed files with 58 additions and 36 deletions
Show Stats Download Patch File Download Diff File

2
redisson/src/main/java/org/redisson/PubSubMessageListener.java
Unescape Escape View File

@ -15,7 +15,7 @@
*/
package org.redisson;
import org.redisson.api.MessageListener;
import org.redisson.api.listener.MessageListener;
import org.redisson.client.RedisPubSubListener;
import org.redisson.client.protocol.pubsub.PubSubType;

4
redisson/src/main/java/org/redisson/PubSubPatternMessageListener.java
Unescape Escape View File

@ -15,8 +15,8 @@
*/
package org.redisson;
import org.redisson.api.MessageListener;
import org.redisson.api.PatternMessageListener;
import org.redisson.api.listener.MessageListener;
import org.redisson.api.listener.PatternMessageListener;
import org.redisson.client.RedisPubSubListener;
import org.redisson.client.protocol.pubsub.PubSubType;

2
redisson/src/main/java/org/redisson/PubSubPatternStatusListener.java
Unescape Escape View File

@ -15,7 +15,7 @@
*/
package org.redisson;
import org.redisson.api.PatternStatusListener;
import org.redisson.api.listener.PatternStatusListener;
import org.redisson.client.RedisPubSubListener;
import org.redisson.client.protocol.pubsub.PubSubType;

2
redisson/src/main/java/org/redisson/PubSubStatusListener.java
Unescape Escape View File

@ -15,7 +15,7 @@
*/
package org.redisson;
import org.redisson.api.StatusListener;
import org.redisson.api.listener.StatusListener;
import org.redisson.client.RedisPubSubListener;
import org.redisson.client.protocol.pubsub.PubSubType;

2
redisson/src/main/java/org/redisson/RedissonExecutorService.java
Unescape Escape View File

@ -37,7 +37,6 @@ import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import java.util.concurrent.atomic.AtomicReference;
import org.redisson.api.MessageListener;
import org.redisson.api.RAtomicLong;
import org.redisson.api.RBucket;
import org.redisson.api.RExecutorService;
@ -46,6 +45,7 @@ import org.redisson.api.RKeys;
import org.redisson.api.RTopic;
import org.redisson.api.RemoteInvocationOptions;
import org.redisson.api.annotation.RInject;
import org.redisson.api.listener.MessageListener;
import org.redisson.client.codec.Codec;
import org.redisson.client.protocol.RedisCommands;
import org.redisson.command.CommandExecutor;

4
redisson/src/main/java/org/redisson/RedissonPatternTopic.java
Unescape Escape View File

@ -18,9 +18,9 @@ package org.redisson;
import java.util.Collections;
import java.util.List;
import org.redisson.api.PatternMessageListener;
import org.redisson.api.PatternStatusListener;
import org.redisson.api.RPatternTopic;
import org.redisson.api.listener.PatternMessageListener;
import org.redisson.api.listener.PatternStatusListener;
import org.redisson.client.RedisPubSubListener;
import org.redisson.client.codec.Codec;
import org.redisson.command.CommandExecutor;

4
redisson/src/main/java/org/redisson/RedissonTopic.java
Unescape Escape View File

@ -18,10 +18,10 @@ package org.redisson;
import java.util.Collections;
import java.util.List;
import org.redisson.api.MessageListener;
import org.redisson.api.RFuture;
import org.redisson.api.RTopic;
import org.redisson.api.StatusListener;
import org.redisson.api.listener.MessageListener;
import org.redisson.api.listener.StatusListener;
import org.redisson.client.RedisPubSubListener;
import org.redisson.client.codec.Codec;
import org.redisson.client.protocol.RedisCommands;

7
redisson/src/main/java/org/redisson/api/RPatternTopic.java
Unescape Escape View File

@ -17,6 +17,9 @@ package org.redisson.api;
import java.util.List;
import org.redisson.api.listener.PatternMessageListener;
import org.redisson.api.listener.PatternStatusListener;
/**
* Distributed topic. Messages are delivered to all message listeners across Redis cluster.
*
@ -40,7 +43,7 @@ public interface RPatternTopic<M> {
*
* @param listener
* @return locally unique listener id
* @see org.redisson.api.MessageListener
* @see org.redisson.api.listener.MessageListener
*/
int addListener(PatternMessageListener<M> listener);
@ -49,7 +52,7 @@ public interface RPatternTopic<M> {
*
* @param listener
* @return
* @see org.redisson.api.StatusListener
* @see org.redisson.api.listener.StatusListener
*/
int addListener(PatternStatusListener listener);

6
redisson/src/main/java/org/redisson/api/RPatternTopicReactive.java
Unescape Escape View File

@ -18,6 +18,8 @@ package org.redisson.api;
import java.util.List;
import org.reactivestreams.Publisher;
import org.redisson.api.listener.PatternMessageListener;
import org.redisson.api.listener.PatternStatusListener;
/**
* Distributed topic. Messages are delivered to all message listeners across Redis cluster.
@ -42,7 +44,7 @@ public interface RPatternTopicReactive<M> {
*
* @param listener
* @return locally unique listener id
* @see org.redisson.api.MessageListener
* @see org.redisson.api.listener.MessageListener
*/
Publisher<Integer> addListener(PatternMessageListener<M> listener);
@ -51,7 +53,7 @@ public interface RPatternTopicReactive<M> {
*
* @param listener
* @return
* @see org.redisson.api.StatusListener
* @see org.redisson.api.listener.StatusListener
*/
Publisher<Integer> addListener(PatternStatusListener listener);

7
redisson/src/main/java/org/redisson/api/RTopic.java
Unescape Escape View File

@ -17,6 +17,9 @@ package org.redisson.api;
import java.util.List;
import org.redisson.api.listener.MessageListener;
import org.redisson.api.listener.StatusListener;
/**
* Distributed topic. Messages are delivered to all message listeners across Redis cluster.
*
@ -48,7 +51,7 @@ public interface RTopic<M> extends RTopicAsync<M> {
*
* @param listener
* @return locally unique listener id
* @see org.redisson.api.MessageListener
* @see org.redisson.api.listener.MessageListener
*/
int addListener(MessageListener<M> listener);
@ -57,7 +60,7 @@ public interface RTopic<M> extends RTopicAsync<M> {
*
* @param listener
* @return
* @see org.redisson.api.StatusListener
* @see org.redisson.api.listener.StatusListener
*/
int addListener(StatusListener listener);

2
redisson/src/main/java/org/redisson/api/RTopicReactive.java
Unescape Escape View File

@ -18,6 +18,8 @@ package org.redisson.api;
import java.util.List;
import org.reactivestreams.Publisher;
import org.redisson.api.listener.MessageListener;
import org.redisson.api.listener.StatusListener;
/**
* Distributed topic. Messages are delivered to all message listeners across Redis cluster.

4
redisson/src/main/java/org/redisson/api/BasePatternStatusListener.java → redisson/src/main/java/org/redisson/api/listener/BasePatternStatusListener.java
Unescape Escape View File

@ -13,7 +13,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.redisson.api;
package org.redisson.api.listener;
import org.redisson.api.RTopic;
/**
* Base status listener for Redis PubSub channel status changes

4
redisson/src/main/java/org/redisson/api/BaseStatusListener.java → redisson/src/main/java/org/redisson/api/listener/BaseStatusListener.java
Unescape Escape View File

@ -13,7 +13,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.redisson.api;
package org.redisson.api.listener;
import org.redisson.api.RTopic;
/**
* Base status listener for Redis PubSub channel status changes

4
redisson/src/main/java/org/redisson/api/MessageListener.java → redisson/src/main/java/org/redisson/api/listener/MessageListener.java
Unescape Escape View File

@ -13,10 +13,12 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.redisson.api;
package org.redisson.api.listener;
import java.util.EventListener;
import org.redisson.api.RTopic;
/**
* Listener for Redis messages published via RTopic Redisson object
*

4
redisson/src/main/java/org/redisson/api/PatternMessageListener.java → redisson/src/main/java/org/redisson/api/listener/PatternMessageListener.java
Unescape Escape View File

@ -13,10 +13,12 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.redisson.api;
package org.redisson.api.listener;
import java.util.EventListener;
import org.redisson.api.RTopic;
/**
* Listener for Redis messages published via RTopic Redisson object
*

4
redisson/src/main/java/org/redisson/api/PatternStatusListener.java → redisson/src/main/java/org/redisson/api/listener/PatternStatusListener.java
Unescape Escape View File

@ -13,10 +13,12 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.redisson.api;
package org.redisson.api.listener;
import java.util.EventListener;
import org.redisson.api.RTopic;
/**
* Listener for Redis PubSub channel status changes
*

4
redisson/src/main/java/org/redisson/api/StatusListener.java → redisson/src/main/java/org/redisson/api/listener/StatusListener.java
Unescape Escape View File

@ -13,10 +13,12 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.redisson.api;
package org.redisson.api.listener;
import java.util.EventListener;
import org.redisson.api.RTopic;
/**
* Listener for Redis PubSub channel status changes
*

2
redisson/src/main/java/org/redisson/client/RedisPubSubListener.java
Unescape Escape View File

@ -15,7 +15,7 @@
*/
package org.redisson.client;
import org.redisson.api.MessageListener;
import org.redisson.api.listener.MessageListener;
import org.redisson.client.protocol.pubsub.PubSubType;
public interface RedisPubSubListener<V> extends MessageListener<V> {

4
redisson/src/main/java/org/redisson/reactive/RedissonPatternTopicReactive.java
Unescape Escape View File

@ -21,9 +21,9 @@ import java.util.List;
import org.reactivestreams.Publisher;
import org.redisson.PubSubPatternMessageListener;
import org.redisson.PubSubPatternStatusListener;
import org.redisson.api.PatternMessageListener;
import org.redisson.api.PatternStatusListener;
import org.redisson.api.RPatternTopicReactive;
import org.redisson.api.listener.PatternMessageListener;
import org.redisson.api.listener.PatternStatusListener;
import org.redisson.client.RedisPubSubListener;
import org.redisson.client.codec.Codec;
import org.redisson.command.CommandReactiveExecutor;

4
redisson/src/main/java/org/redisson/reactive/RedissonTopicReactive.java
Unescape Escape View File

@ -21,9 +21,9 @@ import java.util.List;
import org.reactivestreams.Publisher;
import org.redisson.PubSubMessageListener;
import org.redisson.PubSubStatusListener;
import org.redisson.api.MessageListener;
import org.redisson.api.RTopicReactive;
import org.redisson.api.StatusListener;
import org.redisson.api.listener.MessageListener;
import org.redisson.api.listener.StatusListener;
import org.redisson.client.RedisPubSubListener;
import org.redisson.client.codec.Codec;
import org.redisson.client.protocol.RedisCommands;

10
redisson/src/test/java/org/redisson/RedissonTopicPatternTest.java
Unescape Escape View File

@ -21,13 +21,13 @@ import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Test;
import org.redisson.RedisRunner.RedisProcess;
import org.redisson.api.BasePatternStatusListener;
import org.redisson.api.MessageListener;
import org.redisson.api.PatternMessageListener;
import org.redisson.api.PatternStatusListener;
import org.redisson.api.RPatternTopic;
import org.redisson.api.RTopic;
import org.redisson.api.StatusListener;
import org.redisson.api.listener.BasePatternStatusListener;
import org.redisson.api.listener.MessageListener;
import org.redisson.api.listener.PatternMessageListener;
import org.redisson.api.listener.PatternStatusListener;
import org.redisson.api.listener.StatusListener;
import org.redisson.config.Config;
public class RedissonTopicPatternTest {

6
redisson/src/test/java/org/redisson/RedissonTopicTest.java
Unescape Escape View File

@ -23,12 +23,12 @@ import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Test;
import org.redisson.RedisRunner.RedisProcess;
import org.redisson.api.BaseStatusListener;
import org.redisson.api.MessageListener;
import org.redisson.api.RBlockingQueue;
import org.redisson.api.RSet;
import org.redisson.api.RTopic;
import org.redisson.api.StatusListener;
import org.redisson.api.listener.BaseStatusListener;
import org.redisson.api.listener.MessageListener;
import org.redisson.api.listener.StatusListener;
import org.redisson.client.codec.LongCodec;
import org.redisson.client.codec.StringCodec;
import org.redisson.config.Config;

2
redisson/src/test/java/org/redisson/TimeoutTest.java
Unescape Escape View File

@ -7,9 +7,9 @@ import java.util.List;
import java.util.concurrent.ExecutionException;
import org.junit.Test;
import org.redisson.api.MessageListener;
import org.redisson.api.RMap;
import org.redisson.api.RTopic;
import org.redisson.api.listener.MessageListener;
public class TimeoutTest extends BaseTest {

Write Preview
Loading…
Cancel
Save