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

RedisMessageListenerContainer.setTaskExecutor介绍

[英]Sets the task executor used for running the message listeners when messages are received. If no task executor is set, an instance of SimpleAsyncTaskExecutor will be used by default. The task executor can be adjusted depending on the work done by the listeners and the number of messages coming in.
[中]设置接收消息时用于运行消息侦听器的任务执行器。如果未设置任务执行器，默认情况下将使用SimpleAsynctAskeExecutor的实例。任务执行器可以根据侦听器完成的工作和传入的消息数进行调整。

代码示例

代码示例来源：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: spring-projects/spring-integration

/**
 * Specify an {@link Executor} used for running the message listeners when messages are received.
 * @param taskExecutor the Executor to use for listener container.
 * @since 4.3.13
 * @see RedisMessageListenerContainer#setTaskExecutor(Executor)
 */
public void setTaskExecutor(Executor taskExecutor) {
  this.container.setTaskExecutor(taskExecutor);
}

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

/**
 * Specify an {@link Executor} used for running the message listeners when messages are received.
 * @param taskExecutor the Executor to use for listener container.
 * @since 4.3.13
 * @see RedisMessageListenerContainer#setTaskExecutor(Executor)
 */
public void setTaskExecutor(Executor taskExecutor) {
  this.container.setTaskExecutor(taskExecutor);
}

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

this.taskExecutor = new ErrorHandlingTaskExecutor(this.taskExecutor, errorHandler);
this.container.setTaskExecutor(this.taskExecutor);
MessageListenerAdapter adapter = new MessageListenerAdapter(new MessageListenerDelegate());
adapter.setSerializer(this.serializer);

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

@Bean
public RedisMessageListenerContainer redisMessageListenerContainer(JedisConnectionFactory jedisConnectionFactory) {
  RedisMessageListenerContainer container = new RedisMessageListenerContainer();
  container.setConnectionFactory(jedisConnectionFactory);
  // set thread pool
  container.setTaskExecutor(ThreadPoolUtils.createThreadPool(10, "tac-redis-subscribe-pool"));
  return container;
}

代码示例来源：origin: com.alibaba/tac-engine

@Bean
public RedisMessageListenerContainer redisMessageListenerContainer(JedisConnectionFactory jedisConnectionFactory) {
  RedisMessageListenerContainer container = new RedisMessageListenerContainer();
  container.setConnectionFactory(jedisConnectionFactory);
  // set thread pool
  container.setTaskExecutor(ThreadPoolUtils.createThreadPool(10, "tac-redis-subscribe-pool"));
  return container;
}

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

this.taskExecutor = new ErrorHandlingTaskExecutor(this.taskExecutor, errorHandler);
this.container.setTaskExecutor(this.taskExecutor);
MessageListenerAdapter adapter = new MessageListenerAdapter(new MessageListenerDelegate());
adapter.setSerializer(this.serializer);