本文整理了Java中redis.clients.jedis.Jedis.subscribe()
方法的一些代码示例,展示了Jedis.subscribe()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Jedis.subscribe()
方法的具体详情如下:
包路径:redis.clients.jedis.Jedis
类名称:Jedis
方法名:subscribe
暂无
代码示例来源:origin: sohutv/cachecloud
@Override
public Integer execute(Jedis connection) {
connection.subscribe(jedisPubSub, patterns);
return 0;
}
}.runWithAnyNode();
代码示例来源:origin: sohutv/cachecloud
@Override
public Integer execute(Jedis connection) {
connection.subscribe(jedisPubSub, channels);
return 0;
}
}.runWithAnyNode();
代码示例来源:origin: sohutv/cachecloud
@Override
public Integer execute(Jedis connection) {
connection.subscribe(jedisPubSub, patterns);
return 0;
}
}.runWithAnyNode();
代码示例来源:origin: sohutv/cachecloud
@Override
public Integer execute(Jedis connection) {
connection.subscribe(jedisPubSub, channels);
return 0;
}
}.runWithAnyNode();
代码示例来源:origin: sohutv/cachecloud
j.subscribe(new JedisPubSub() {
@Override
public void onMessage(String channel, String message) {
代码示例来源:origin: sohutv/cachecloud
/**
* 订阅单一频道(阻塞操作)
*
* @param jedisPubSub
* @param channel
*/
public void subscribe(final JedisPubSub jedisPubSub, final String channel, final int timeout) {
SubPubClusterCommand subPubClusterCommand = new SubPubClusterCommand(this, connectionHandler, maxRedirections);
Jedis jedis = subPubClusterCommand.getNewJedis(channel, timeout);
try {
jedis.subscribe(jedisPubSub, channel);
} finally {
if (jedis != null) {
jedis.close();
}
}
}
代码示例来源:origin: ltsopensource/light-task-scheduler
jedis.subscribe(new NotifySub(jedisPool), listenNodePath); // 阻塞
break;
} finally {
代码示例来源:origin: ltsopensource/light-task-scheduler
jedis.subscribe(new NotifySub(jedisPool), listenNodePath); // 阻塞
break;
} finally {
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public void subscribe(MessageListener listener, byte[]... channels) {
if (isSubscribed()) {
throw new RedisSubscribedConnectionException(
"Connection already subscribed; use the connection Subscription to cancel or add new channels");
}
if (isQueueing()) {
throw new UnsupportedOperationException();
}
if (isPipelined()) {
throw new UnsupportedOperationException();
}
try {
BinaryJedisPubSub jedisPubSub = new JedisMessageListener(listener);
subscription = new JedisSubscription(listener, jedisPubSub, channels, null);
jedis.subscribe(jedisPubSub, channels);
} catch (Exception ex) {
throw convertJedisAccessException(ex);
}
}
代码示例来源:origin: gresrun/jesque
/**
* {@inheritDoc}
*/
@Override
public Void doWork(final Jedis jedis) {
jedis.subscribe(jedisPubSub, createFullChannels());
return null;
}
});
代码示例来源:origin: io.leopard/leopard-redis
@Override
public Object execute(Jedis jedis) {
jedis.subscribe(jedisPubSub, channels);
return null;
}
});
代码示例来源:origin: apache/servicemix-bundles
@Override
public Integer execute(Jedis connection) {
connection.subscribe(jedisPubSub, channels);
return 0;
}
}.runWithAnyNode();
代码示例来源:origin: lindzh/hasting
@Override
public void run() {
logger.info("subscribe:"+channel);
jedis.subscribe(this, channel);
}
}
代码示例来源:origin: stackoverflow.com
new Thread(new Runnable() {
@Override
public void run() {
Jedis subscriberJedis = new Jedis("localhost");
try {
subscriberJedis.subscribe(new JedisPubSub() …..,"CC");
} catch (Exception e) {
e.printStackTrace();
}
}
}).start();
代码示例来源:origin: ysrc/Liudao
@Override
public Object doInRedis(RedisConnection connection) throws DataAccessException {
((Jedis) connection.getNativeConnection()).subscribe(jedisPubSub, channels);
return null;
}
});
代码示例来源:origin: org.nuxeo.runtime/nuxeo-runtime-redis
/**
* Run a subscriber, do not return.
*/
default void subscribe(JedisPubSub subscriber, String channel) throws JedisException {
execute(jedis -> {
jedis.subscribe(subscriber, channel);
return null;
});
}
代码示例来源:origin: io.enoa/nosql-redis
default void subscribe(JedisPubSub jedisPubSub, String... channels) {
this.run((jedis, serializer) -> {
jedis.subscribe(jedisPubSub, channels);
return this;
});
}
代码示例来源:origin: com.github.biezhi/unique-support-redis
@Override
Object execute() {
Jedis _jedis = jedis.getShard(channel);
// 注意subscribe是一个阻塞操作,因为当前线程要轮询Redis的响应然后调用subscribe
_jedis.subscribe(jedisPubSub, channel);
return null;
}
}.getResult();
代码示例来源:origin: vakinge/jeesuite-libs
@Override
public void run() {
subClient = getRedisClient();
subClient.subscribe(new LockStateListener(), new String[]{channelName});
}
}, channelName);
代码示例来源:origin: CoinbaseWallet/toshi-headless-client
@Override
public void run() {
Jedis subscriberJedis = new Jedis(config.getRedis().getUri());
try {
subscriberJedis.subscribe(subscriber, wallet.getOwnerAddress(), wallet.getOwnerAddress() + "_rpc_request");
System.out.println("Subscription ended.");
} catch (Exception e) {
logger.log(Level.SEVERE, "Subscribing failed.", e);
}
}
}).start();
内容来源于网络,如有侵权,请联系作者删除!