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

RedisMessageListenerContainer.start介绍

暂无

代码示例

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

private void initMapping(Map<? extends MessageListener, Collection<? extends Topic>> listeners) {
  // stop the listener if currently running
  if (isRunning()) {
    subscriptionTask.cancel();
  }
  patternMapping.clear();
  channelMapping.clear();
  listenerTopics.clear();
  if (!CollectionUtils.isEmpty(listeners)) {
    for (Map.Entry<? extends MessageListener, Collection<? extends Topic>> entry : listeners.entrySet()) {
      addListener(entry.getKey(), entry.getValue());
    }
  }
  // resume activity
  if (initialized) {
    start();
  }
}

代码示例来源：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

@Override
public void start() {
  this.container.start();
}

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

@Override
protected void doStart() {
  super.doStart();
  this.container.start();
}

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

@Override
public void start() {
  container.start();
}

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

@Override
public void start() {
  container.start();
}

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

@Override
public void start() {
  this.container.start();
}

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

@Override
protected void doStart() {
  super.doStart();
  this.container.start();
}

代码示例来源：origin: sentilo/sentilo

private void restartListenerContainer() {
 LOGGER.info("Stopping listener container for process {}", processName);
 try {
  listenerContainer.stop();
 } catch (final Exception re) {
  LOGGER.warn("An error occurred while stopping listener container. If it is not running, we proceed to start it", re.getMessage());
 }
 // Clear count pending events value
 countPendingEvents = 0;
 LOGGER.info("Starting listener container");
 if (!listenerContainer.isRunning()) {
  listenerContainer.start();
 }
}

代码示例来源：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: org.springframework.data/spring-data-redis

private void initMapping(Map<? extends MessageListener, Collection<? extends Topic>> listeners) {
  // stop the listener if currently running
  if (isRunning()) {
    subscriptionTask.cancel();
  }
  patternMapping.clear();
  channelMapping.clear();
  listenerTopics.clear();
  if (!CollectionUtils.isEmpty(listeners)) {
    for (Map.Entry<? extends MessageListener, Collection<? extends Topic>> entry : listeners.entrySet()) {
      addListener(entry.getKey(), entry.getValue());
    }
  }
  // resume activity
  if (initialized) {
    start();
  }
}

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

private void initMapping(Map<? extends MessageListener, Collection<? extends Topic>> listeners) {
  // stop the listener if currently running
  if (isRunning()) {
    subscriptionTask.cancel();
  }
  patternMapping.clear();
  channelMapping.clear();
  listenerTopics.clear();
  if (!CollectionUtils.isEmpty(listeners)) {
    for (Map.Entry<? extends MessageListener, Collection<? extends Topic>> entry : listeners.entrySet()) {
      addListener(entry.getKey(), entry.getValue());
    }
  }
  // resume activity
  if (initialized) {
    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.data/spring-data-redis

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