本文整理了Java中org.springframework.data.redis.connection.RedisConnection.setConfig
方法的一些代码示例,展示了RedisConnection.setConfig
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RedisConnection.setConfig
方法的具体详情如下:
包路径:org.springframework.data.redis.connection.RedisConnection
类名称:RedisConnection
方法名:setConfig
暂无
代码示例来源:origin: spring-projects/spring-data-redis
@Override
public void setConfig(String param, String value) {
delegate.setConfig(param, value);
}
代码示例来源:origin: spring-projects/spring-session
@Override
public void configure(RedisConnection connection) {
String notifyOptions = getNotifyOptions(connection);
String customizedNotifyOptions = notifyOptions;
if (!customizedNotifyOptions.contains("E")) {
customizedNotifyOptions += "E";
}
boolean A = customizedNotifyOptions.contains("A");
if (!(A || customizedNotifyOptions.contains("g"))) {
customizedNotifyOptions += "g";
}
if (!(A || customizedNotifyOptions.contains("x"))) {
customizedNotifyOptions += "x";
}
if (!notifyOptions.equals(customizedNotifyOptions)) {
connection.setConfig(CONFIG_NOTIFY_KEYSPACE_EVENTS, customizedNotifyOptions);
}
}
代码示例来源:origin: spring-projects/spring-session
private void assertOptionsContains(String... expectedValues) {
verify(this.connection).setConfig(eq(CONFIG_NOTIFY_KEYSPACE_EVENTS),
this.options.capture());
for (String expectedValue : expectedValues) {
assertThat(this.options.getValue()).contains(expectedValue);
}
assertThat(this.options.getValue().length()).isEqualTo(expectedValues.length);
}
代码示例来源:origin: spring-projects/spring-data-redis
/**
* Initialize the message listener by writing requried redis config for {@literal notify-keyspace-events} and
* registering the listener within the container.
*/
public void init() {
if (StringUtils.hasText(keyspaceNotificationsConfigParameter)) {
RedisConnection connection = listenerContainer.getConnectionFactory().getConnection();
try {
Properties config = connection.getConfig("notify-keyspace-events");
if (!StringUtils.hasText(config.getProperty("notify-keyspace-events"))) {
connection.setConfig("notify-keyspace-events", keyspaceNotificationsConfigParameter);
}
} finally {
connection.close();
}
}
doRegister(listenerContainer);
}
代码示例来源:origin: spring-projects/spring-session
@Test
public void afterPropertiesSetAEK() throws Exception {
setConfigNotification("AEK");
this.initializer.afterPropertiesSet();
verify(this.connection, never()).setConfig(anyString(), anyString());
}
代码示例来源:origin: spring-projects/spring-session
@Test
public void afterPropertiesSetAE() throws Exception {
setConfigNotification("AE");
this.initializer.afterPropertiesSet();
verify(this.connection, never()).setConfig(anyString(), anyString());
}
代码示例来源:origin: org.springframework.data/spring-data-redis
@Override
public void setConfig(String param, String value) {
delegate.setConfig(param, value);
}
代码示例来源:origin: 1991wangliang/tx-lcn
@Override
public void setConfig(String param, String value) {
redisConnection.setConfig(param, value);
}
代码示例来源:origin: apache/servicemix-bundles
@Override
public void setConfig(String param, String value) {
delegate.setConfig(param, value);
}
代码示例来源:origin: org.springframework.data/spring-data-redis
/**
* Initialize the message listener by writing requried redis config for {@literal notify-keyspace-events} and
* registering the listener within the container.
*/
public void init() {
if (StringUtils.hasText(keyspaceNotificationsConfigParameter)) {
RedisConnection connection = listenerContainer.getConnectionFactory().getConnection();
try {
Properties config = connection.getConfig("notify-keyspace-events");
if (!StringUtils.hasText(config.getProperty("notify-keyspace-events"))) {
connection.setConfig("notify-keyspace-events", keyspaceNotificationsConfigParameter);
}
} finally {
connection.close();
}
}
doRegister(listenerContainer);
}
代码示例来源:origin: apache/servicemix-bundles
/**
* Initialize the message listener by writing requried redis config for {@literal notify-keyspace-events} and
* registering the listener within the container.
*/
public void init() {
if (StringUtils.hasText(keyspaceNotificationsConfigParameter)) {
RedisConnection connection = listenerContainer.getConnectionFactory().getConnection();
try {
Properties config = connection.getConfig("notify-keyspace-events");
if (!StringUtils.hasText(config.getProperty("notify-keyspace-events"))) {
connection.setConfig("notify-keyspace-events", keyspaceNotificationsConfigParameter);
}
} finally {
connection.close();
}
}
doRegister(listenerContainer);
}
内容来源于网络,如有侵权,请联系作者删除!