JedisPool pool = new JedisPool(new JedisPoolConfig(), "192.168.28.153");
Jedis jedis = pool.getResource();
String channel = "muc-a";
jedis.subscribe(new JedisPubSub()
{
@Override
publicvoid onUnsubscribe(String channel, int subscribedChannels)
{
System.out.println("onUnsubscribe - " + channel + "|" + subscribedChannels);
}
@Override
publicvoid onSubscribe(String channel, int subscribedChannels)
{
System.out.println("onSubscribe - " + channel + "|" + subscribedChannels);
}
@Override
publicvoid onPUnsubscribe(String pattern, int subscribedChannels)
{
System.out.println("onPUnsubscribe - " + pattern + "|" + subscribedChannels);
}
@Override
publicvoid onPSubscribe(String pattern, int subscribedChannels)
{
System.out.println("onPSubscribe - " + pattern + "|" + subscribedChannels);
}
@Override
publicvoid onPMessage(String pattern, String channel, String message)
{
System.out.println("onPMessage - " + pattern + "|" + channel + "|" + message);
}
@Override
publicvoid onMessage(String channel, String message)
{
System.out.println("onMessage - " + channel + "|" + message);
}
}, channel);
pool.returnResource(jedis);
pool.destroy();
|