Package org.eblocker.server.common.pubsub

Class JedisPubSubService

java.lang.Object

org.eblocker.server.common.pubsub.JedisPubSubService

All Implemented Interfaces:

PubSubService

public class JedisPubSubService
extends Object
implements PubSubService

Constructor Summary

Constructors

Constructor	Description
JedisPubSubService(redis.clients.jedis.JedisPool pool, int retryDelay)

Method Summary

Modifier and Type	Method	Description
void	publish(String channel, String message)	Publish a message in a channel
void	subscribeAndLoop(String channel, Subscriber subscriber)	Subscribe to a channel.
void	unsubscribe(Subscriber subscriber)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JedisPubSubService

@Inject
public JedisPubSubService(redis.clients.jedis.JedisPool pool,
 int retryDelay)

Method Details

publish

public void publish(String channel,
 String message)

Description copied from interface: PubSubService

Publish a message in a channel

Specified by:

publish in interface PubSubService

subscribeAndLoop

public void subscribeAndLoop(String channel,
 Subscriber subscriber)

Description copied from interface: PubSubService

Subscribe to a channel. This method never returns, so it should be run in a background thread.

Specified by:

subscribeAndLoop in interface PubSubService

unsubscribe

public void unsubscribe(Subscriber subscriber)

Specified by:

unsubscribe in interface PubSubService