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