Package org.redisson.pubsub
Class CountDownLatchPubSub
-
- org.redisson.pubsub.CountDownLatchPubSub
-
public class CountDownLatchPubSub extends
- Author:
- Nikita Koksharov
-
-
Field Summary
Fields Modifier and Type Field Description static
NEW_COUNT_MESSAGE
static
ZERO_COUNT_MESSAGE
-
Constructor Summary
Constructors Constructor Description CountDownLatchPubSub(PublishSubscribeService service)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected RedissonCountDownLatchEntry
createEntry(RPromise<RedissonCountDownLatchEntry> newPromise)
protected void
onMessage(RedissonCountDownLatchEntry value, message)
RFuture<E>
entryName, channelName)
void
unsubscribe(E entry, entryName, channelName)
-
-
-
Constructor Detail
-
CountDownLatchPubSub
public CountDownLatchPubSub(PublishSubscribeService service)
-
-
Method Detail
-
createEntry
protected RedissonCountDownLatchEntry createEntry(RPromise<RedissonCountDownLatchEntry> newPromise)
-
onMessage
protected void onMessage(RedissonCountDownLatchEntry value, message)
-
unsubscribe
public void unsubscribe(E entry, entryName, channelName)
-
subscribe
public entryName, channelName)
-
-