本文整理了Java中org.springframework.data.redis.connection.RedisConnection.lPush
方法的一些代码示例,展示了RedisConnection.lPush
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RedisConnection.lPush
方法的具体详情如下:
包路径:org.springframework.data.redis.connection.RedisConnection
类名称:RedisConnection
方法名:lPush
暂无
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public Long lPush(byte[] key, byte[]... values) {
return convertAndReturn(delegate.lPush(key, values), identityConverter);
}
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public Long leftPush(K key, V value) {
byte[] rawKey = rawKey(key);
byte[] rawValue = rawValue(value);
return execute(connection -> connection.lPush(rawKey, rawValue), true);
}
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public Long leftPushAll(K key, V... values) {
byte[] rawKey = rawKey(key);
byte[][] rawValues = rawValues(values);
return execute(connection -> connection.lPush(rawKey, rawValues), true);
}
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public Long leftPushAll(K key, Collection<V> values) {
byte[] rawKey = rawKey(key);
byte[][] rawValues = rawValues(values);
return execute(connection -> connection.lPush(rawKey, rawValues), true);
}
代码示例来源:origin: 1991wangliang/tx-lcn
@Override
public Long lPush(byte[] key, byte[]... values) {
return redisConnection.lPush(key, values);
}
代码示例来源:origin: gudaoxuri/dew
@Override
protected boolean doRequest(String address, String message) {
redisTemplate.execute((RedisCallback<Void>) connection -> {
connection.lPush(address.getBytes(), message.getBytes());
return null;
});
return true;
}
代码示例来源:origin: org.springframework.data/spring-data-redis
@Override
public Long lPush(byte[] key, byte[]... values) {
return convertAndReturn(delegate.lPush(key, values), identityConverter);
}
代码示例来源:origin: aillamsun/devX
@Override
public boolean request(String address, String message) {
logger.trace("[MQ] request {}:{}", address, message);
redisTemplate.execute((RedisCallback<Void>) connection -> {
connection.lPush(address.getBytes(), message.getBytes());
return null;
});
return true;
}
代码示例来源:origin: apache/servicemix-bundles
@Override
public Long lPush(byte[] key, byte[]... values) {
return convertAndReturn(delegate.lPush(key, values), identityConverter);
}
代码示例来源:origin: com.ecfront.dew/cluster-spi-redis
@Override
public void request(String address, String message) {
logger.trace("[MQ] request {}:{}", address, message);
RedisConnection connection = null;
try {
connection = redisTemplate.getConnectionFactory().getConnection();
connection.lPush(address.getBytes(), message.getBytes());
} finally {
if (connection != null && !connection.isClosed()) {
connection.close();
}
}
}
代码示例来源:origin: apache/servicemix-bundles
@Override
public Long leftPush(K key, V value) {
byte[] rawKey = rawKey(key);
byte[] rawValue = rawValue(value);
return execute(connection -> connection.lPush(rawKey, rawValue), true);
}
代码示例来源:origin: apache/servicemix-bundles
@Override
public Long leftPushAll(K key, V... values) {
byte[] rawKey = rawKey(key);
byte[][] rawValues = rawValues(values);
return execute(connection -> connection.lPush(rawKey, rawValues), true);
}
代码示例来源:origin: org.springframework.data/spring-data-redis
@Override
public Long leftPushAll(K key, V... values) {
byte[] rawKey = rawKey(key);
byte[][] rawValues = rawValues(values);
return execute(connection -> connection.lPush(rawKey, rawValues), true);
}
代码示例来源:origin: org.springframework.data/spring-data-redis
@Override
public Long leftPushAll(K key, Collection<V> values) {
byte[] rawKey = rawKey(key);
byte[][] rawValues = rawValues(values);
return execute(connection -> connection.lPush(rawKey, rawValues), true);
}
代码示例来源:origin: qq53182347/liugh-parent
@Override
public Long doInRedis(RedisConnection connection) throws DataAccessException {
RedisSerializer<String> serializer = redisTemplate.getStringSerializer();
long count = connection.lPush(serializer.serialize(key), serializer.serialize(value));
return count;
}
});
代码示例来源:origin: org.springframework.data/spring-data-redis
@Override
public Long leftPush(K key, V value) {
byte[] rawKey = rawKey(key);
byte[] rawValue = rawValue(value);
return execute(connection -> connection.lPush(rawKey, rawValue), true);
}
代码示例来源:origin: apache/servicemix-bundles
@Override
public Long leftPushAll(K key, Collection<V> values) {
byte[] rawKey = rawKey(key);
byte[][] rawValues = rawValues(values);
return execute(connection -> connection.lPush(rawKey, rawValues), true);
}
代码示例来源:origin: xiaour/SpringBootDemo
@Override
public Long doInRedis(RedisConnection connection) throws DataAccessException {
RedisSerializer<String> serializer = redisTemplate.getStringSerializer();
long count = connection.lPush(serializer.serialize(key), serializer.serialize(value));
return count;
}
});
内容来源于网络,如有侵权,请联系作者删除!