本文整理了Java中org.springframework.data.redis.listener.RedisMessageListenerContainer.afterPropertiesSet方法的一些代码示例，展示了RedisMessageListenerContainer.afterPropertiesSet的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。RedisMessageListenerContainer.afterPropertiesSet方法的具体详情如下：
包路径：org.springframework.data.redis.listener.RedisMessageListenerContainer
类名称：RedisMessageListenerContainer
方法名：afterPropertiesSet

RedisMessageListenerContainer.afterPropertiesSet介绍

暂无

代码示例

代码示例来源：origin: spring-projects/spring-data-redis

private void initMessageListenerContainer() {
  this.messageListenerContainer = new RedisMessageListenerContainer();
  this.messageListenerContainer.setConnectionFactory(((RedisTemplate<?, ?>) redisOps).getConnectionFactory());
  this.messageListenerContainer.afterPropertiesSet();
  this.messageListenerContainer.start();
}

代码示例来源：origin: spring-projects/spring-integration

this.container.afterPropertiesSet();

代码示例来源：origin: spring-projects/spring-integration

@Test
@RedisAvailable
public void testRedisPublishingMessageHandler() throws Exception {
  int numToTest = 10;
  String topic = "si.test.channel";
  final CountDownLatch latch = new CountDownLatch(numToTest * 2);
  RedisConnectionFactory connectionFactory = this.getConnectionFactoryForTest();
  MessageListenerAdapter listener = new MessageListenerAdapter();
  listener.setDelegate(new Listener(latch));
  listener.setSerializer(new StringRedisSerializer());
  listener.afterPropertiesSet();
  RedisMessageListenerContainer container = new RedisMessageListenerContainer();
  container.setConnectionFactory(connectionFactory);
  container.afterPropertiesSet();
  container.addMessageListener(listener, Collections.<Topic>singletonList(new ChannelTopic(topic)));
  container.start();
  this.awaitContainerSubscribed(container);
  final RedisPublishingMessageHandler handler = new RedisPublishingMessageHandler(connectionFactory);
  handler.setTopicExpression(new LiteralExpression(topic));
  for (int i = 0; i < numToTest; i++) {
    handler.handleMessage(MessageBuilder.withPayload("test-" + i).build());
  }
  for (int i = 0; i < numToTest; i++) {
    handler.handleMessage(MessageBuilder.withPayload(("test-" + i).getBytes()).build());
  }
  assertTrue(latch.await(10, TimeUnit.SECONDS));
  container.stop();
}

代码示例来源：origin: spring-projects/spring-integration

adapter.afterPropertiesSet();
this.container.addMessageListener(adapter, new ChannelTopic(this.topicName));
this.container.afterPropertiesSet();
this.dispatcher.setBeanFactory(this.getBeanFactory());
this.initialized = true;

代码示例来源：origin: org.springframework.data/spring-data-redis

private void initMessageListenerContainer() {
  this.messageListenerContainer = new RedisMessageListenerContainer();
  this.messageListenerContainer.setConnectionFactory(((RedisTemplate<?, ?>) redisOps).getConnectionFactory());
  this.messageListenerContainer.afterPropertiesSet();
  this.messageListenerContainer.start();
}

代码示例来源：origin: apache/servicemix-bundles

private void initMessageListenerContainer() {
  this.messageListenerContainer = new RedisMessageListenerContainer();
  this.messageListenerContainer.setConnectionFactory(((RedisTemplate<?, ?>) redisOps).getConnectionFactory());
  this.messageListenerContainer.afterPropertiesSet();
  this.messageListenerContainer.start();
}

代码示例来源：origin: org.springframework.integration/spring-integration-redis

this.container.afterPropertiesSet();

代码示例来源：origin: com.github.xiaolyuh/layering-cache-core

@Override
public void afterPropertiesSet() throws Exception {
  messageListener.setCacheManager(this);
  container.setConnectionFactory(getRedisTemplate().getConnectionFactory());
  container.afterPropertiesSet();
  messageListener.afterPropertiesSet();
  BeanFactory.getBean(StatsService.class).setCacheManager(this);
  if (getStats()) {
    // 采集缓存命中率数据
    BeanFactory.getBean(StatsService.class).syncCacheStats();
  }
}

代码示例来源：origin: xiaolyuh/layering-cache

@Override
public void afterPropertiesSet() throws Exception {
  messageListener.setCacheManager(this);
  container.setConnectionFactory(getRedisTemplate().getConnectionFactory());
  container.afterPropertiesSet();
  messageListener.afterPropertiesSet();
  BeanFactory.getBean(StatsService.class).setCacheManager(this);
  if (getStats()) {
    // 采集缓存命中率数据
    BeanFactory.getBean(StatsService.class).syncCacheStats();
  }
}

代码示例来源：origin: org.springframework.integration/spring-integration-redis

adapter.afterPropertiesSet();
this.container.addMessageListener(adapter, new ChannelTopic(this.topicName));
this.container.afterPropertiesSet();
this.dispatcher.setBeanFactory(this.getBeanFactory());
this.initialized = true;