本文整理了Java中redis.clients.jedis.Transaction.publish()
方法的一些代码示例,展示了Transaction.publish()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Transaction.publish()
方法的具体详情如下:
包路径:redis.clients.jedis.Transaction
类名称:Transaction
方法名:publish
暂无
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public Long publish(byte[] channel, byte[] message) {
try {
if (isPipelined()) {
pipeline(newJedisResult(getRequiredPipeline().publish(channel, message)));
return null;
}
if (isQueueing()) {
transaction(newJedisResult(getRequiredTransaction().publish(channel, message)));
return null;
}
return jedis.publish(channel, message);
} catch (Exception ex) {
throw convertJedisAccessException(ex);
}
}
代码示例来源:origin: mindwind/craft-atom
private void publish0(String channel, String message) {
t.publish(channel, message);
}
代码示例来源:origin: com.github.jkutner/tomcat-redis-session
transaction.publish(RedisSessionKeys.getSessionChannel(), message);
代码示例来源:origin: zinin/tomcat-redis-session
transaction.publish(RedisSessionKeys.getSessionChannel(manager.getContainer().getName()), message);
代码示例来源:origin: com.github.jkutner/tomcat-redis-session
String message = new String(Base64Util.encode(bytes));
transaction.publish(RedisSessionKeys.getSessionChannel(), message);
代码示例来源:origin: zinin/tomcat-redis-session
String message = new String(Base64Util.encode(bytes));
transaction.publish(RedisSessionKeys.getSessionChannel(manager.getContainer().getName()), message);
代码示例来源:origin: ai.grakn/redisq
@Override
public void push(T document) {
long timestampMs = System.currentTimeMillis();
String serialized;
String stateSerialized;
try {
serialized = mapper.serialize(new TimedWrap<>(document, timestampMs));
stateSerialized = stateMapper.serialize(new StateInfo(NEW, timestampMs, ""));
} catch (SerializationException e) {
serializationErrors.mark();
throw new RedisqException("Could not serialize element " + document.getIdAsString(), e);
}
LOG.debug("Jedis active: {}, idle: {}", jedisPool.getNumActive(), jedisPool.getNumIdle());
try (Jedis jedis = jedisPool.getResource(); Timer.Context ignored = pushTimer.time();) {
Transaction transaction = jedis.multi();
String id = document.getIdAsString();
String lockId = names.lockKeyFromId(id);
transaction.setex(lockId, lockTime, "locked");
transaction.lpush(queueName, id);
transaction.setex(names.contentKeyFromId(id), ttlStateInfo, serialized);
transaction.setex(names.stateKeyFromId(id), ttlStateInfo, stateSerialized);
transaction.publish(names.stateChannelKeyFromId(id), stateSerialized);
transaction.exec();
LOG.debug("Pushed {} with lockTime {}s lock id: {}", id, lockTime, lockId);
}
}
代码示例来源:origin: apache/servicemix-bundles
@Override
public Long publish(byte[] channel, byte[] message) {
try {
if (isPipelined()) {
pipeline(newJedisResult(getRequiredPipeline().publish(channel, message)));
return null;
}
if (isQueueing()) {
transaction(newJedisResult(getRequiredTransaction().publish(channel, message)));
return null;
}
return jedis.publish(channel, message);
} catch (Exception ex) {
throw convertJedisAccessException(ex);
}
}
代码示例来源:origin: org.springframework.data/spring-data-redis
@Override
public Long publish(byte[] channel, byte[] message) {
try {
if (isPipelined()) {
pipeline(newJedisResult(getRequiredPipeline().publish(channel, message)));
return null;
}
if (isQueueing()) {
transaction(newJedisResult(getRequiredTransaction().publish(channel, message)));
return null;
}
return jedis.publish(channel, message);
} catch (Exception ex) {
throw convertJedisAccessException(ex);
}
}
内容来源于网络,如有侵权,请联系作者删除!