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

RedisMessageListenerContainer.addMessageListener介绍

[英]Adds a message listener to the (potentially running) container. If the container is running, the listener starts receiving (matching) messages as soon as possible.
[中]将消息侦听器添加到（可能正在运行的）容器中。如果容器正在运行，侦听器将尽快开始接收（匹配）消息。

代码示例

Official Spring framework guide

代码示例来源：origin: spring-guides/gs-messaging-redis

@Bean
RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
    MessageListenerAdapter listenerAdapter) {
  RedisMessageListenerContainer container = new RedisMessageListenerContainer();
  container.setConnectionFactory(connectionFactory);
  container.addMessageListener(listenerAdapter, new PatternTopic("chat"));
  return container;
}

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

/**
 * Register instance within the container.
 *
 * @param container never {@literal null}.
 */
protected void doRegister(RedisMessageListenerContainer container) {
  listenerContainer.addMessageListener(this, TOPIC_ALL_KEYEVENTS);
}

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

@Override
protected void doRegister(RedisMessageListenerContainer listenerContainer) {
  listenerContainer.addMessageListener(this, KEYEVENT_EXPIRED_TOPIC);
}

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

/**
 * Adds a message listener to the (potentially running) container. If the container is running, the listener starts
 * receiving (matching) messages as soon as possible.
 *
 * @param listener message listener
 * @param topic message topic
 */
public void addMessageListener(MessageListener listener, Topic topic) {
  addMessageListener(listener, Collections.singleton(topic));
}

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

@Bean
public RedisMessageListenerContainer redisMessageListenerContainer() {
  RedisMessageListenerContainer container = new RedisMessageListenerContainer();
  container.setConnectionFactory(this.redisConnectionFactory);
  if (this.redisTaskExecutor != null) {
    container.setTaskExecutor(this.redisTaskExecutor);
  }
  if (this.redisSubscriptionExecutor != null) {
    container.setSubscriptionExecutor(this.redisSubscriptionExecutor);
  }
  container.addMessageListener(sessionRepository(), Arrays.asList(
      new ChannelTopic(sessionRepository().getSessionDeletedChannel()),
      new ChannelTopic(sessionRepository().getSessionExpiredChannel())));
  container.addMessageListener(sessionRepository(),
      Collections.singletonList(new PatternTopic(
          sessionRepository().getSessionCreatedChannelPrefix() + "*")));
  return container;
}

代码示例来源：origin: Nepxion/Discovery

@Bean
public RedisMessageListenerContainer redisMessageListenerContainer(MessageListenerAdapter partialMessageListenerAdapter, MessageListenerAdapter globalMessageListenerAdapter) {
  String group = pluginAdapter.getGroup();
  String serviceId = pluginAdapter.getServiceId();
  RedisMessageListenerContainer redisMessageListenerContainer = new RedisMessageListenerContainer();
  redisMessageListenerContainer.setConnectionFactory(redisConnectionFactory);
  redisMessageListenerContainer.addMessageListener(partialMessageListenerAdapter, new PatternTopic(group + "-" + serviceId));
  redisMessageListenerContainer.addMessageListener(globalMessageListenerAdapter, new PatternTopic(group + "-" + group));
  return redisMessageListenerContainer;
}

代码示例来源：origin: mrdear/JavaWEB

/**
 * 注入消息容器
 * @param jedisConnectionFactory jedis连接池
 * @param listenerAdapter 监听适配器
 * @return bean
 */
@Bean
public RedisMessageListenerContainer container(RedisConnectionFactory jedisConnectionFactory,
  MessageListenerAdapter listenerAdapter){
 RedisMessageListenerContainer container = new RedisMessageListenerContainer();
 container.setConnectionFactory(jedisConnectionFactory);
 //绑定监听者与信道的管理
 container.addMessageListener(listenerAdapter,new PatternTopic("java"));
 return container;
}

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

this.container.addMessageListener(adapter, topicList);
this.container.afterPropertiesSet();

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

/**
 * Register instance within the container.
 *
 * @param container never {@literal null}.
 */
protected void doRegister(RedisMessageListenerContainer container) {
  listenerContainer.addMessageListener(this, TOPIC_ALL_KEYEVENTS);
}

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

/**
 * Adds a message listener to the (potentially running) container. If the container is running, the listener starts
 * receiving (matching) messages as soon as possible.
 *
 * @param listener message listener
 * @param topic message topic
 */
public void addMessageListener(MessageListener listener, Topic topic) {
  addMessageListener(listener, Collections.singleton(topic));
}

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

/**
 * 添加消息监听
 *
 * @param name 缓存名称
 */
protected void addMessageListener(String name) {
  container.addMessageListener(messageListener, new ChannelTopic(name));
}

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

private void doRegisterMockSubscription() {
 LOGGER.debug("Not found stored subscriptions in Redis. Registering a mock subscription to channel {}", DUMMY_TOPIC);
 final MessageListenerImpl listener = new MockMessageListenerImpl(DUMMY_TOPIC);
 listenerContainer.addMessageListener(listener, ChannelUtils.buildTopic(DUMMY_TOPIC));
}

代码示例来源：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: com.lodsve/lodsve-redis

public RedisTimerMessageListenerContainer(LodsveRedisConnectionFactory connectionFactory, RedisTimerListener listener) {
    super.setConnectionFactory(connectionFactory);
    super.addMessageListener(listener, new PatternTopic("__keyevent@*:expired"));
  }
}

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

adapter.setSerializer(this.serializer);
adapter.afterPropertiesSet();
this.container.addMessageListener(adapter, new ChannelTopic(this.topicName));
this.container.afterPropertiesSet();
this.dispatcher.setBeanFactory(this.getBeanFactory());

代码示例来源：origin: lcw2004/one

@Bean
public RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) {
  RedisMessageListenerContainer container = new RedisMessageListenerContainer();
  container.setConnectionFactory(connectionFactory);
  container.addMessageListener(listenerAdapter, new ChannelTopic("OneEvent"));
  return container;
}

代码示例来源：origin: tobiasflohre/movie-database

@Bean
public RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
    MessageListenerAdapter listenerAdapter) {
  RedisMessageListenerContainer container = new RedisMessageListenerContainer();
  container.setConnectionFactory(connectionFactory);
  container.addMessageListener(listenerAdapter, new PatternTopic("movieChannel"));
  return container;
}

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

private void activateSubscription(final String listenerName, final Topic topic, final NotificationParams notificationParams) {
 MessageListenerImpl listener = listeners.get(listenerName);
 if (listener == null) {
  listener = addNewListener(listenerName);
 }
 LOGGER.info("Subscribing listener {} to channel {}", listener.getName(), topic.getTopic());
 listenerContainer.addMessageListener(listener, topic);
 listener.addSubscription(topic, notificationParams);
}

代码示例来源：origin: Apereo-Learning-Analytics-Initiative/OpenLRS

@Bean
RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
    MessageListenerAdapter listenerAdapter) {
  
  RedisMessageListenerContainer container = new RedisMessageListenerContainer();
  container.setConnectionFactory(connectionFactory);
  container.addMessageListener(listenerAdapter, new ChannelTopic(channelName()));
  return container;
}

代码示例来源：origin: alibaba/tac

@Override
public void subscribe() {
  container.addMessageListener(messageListenerAdapter,
    new ChannelTopic(tacRedisConfigProperties.getPublishEventChannel()));
  this.loadAllMsCode();
}