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

ExtendedConsumerProperties.getConcurrency介绍

暂无

代码示例

代码示例来源：origin: spring-cloud-incubator/spring-cloud-alibaba

public synchronized DefaultMQPushConsumer getOrCreateConsumer(String group,
    String topic,
    ExtendedConsumerProperties<RocketMQConsumerProperties> consumerProperties) {
  propertiesMap.put(new AbstractMap.SimpleEntry<>(group, topic),
      consumerProperties);
  Optional.ofNullable(instrumentationManager).ifPresent(manager -> {
    ConsumerGroupInstrumentation instrumentation = manager
        .getConsumerGroupInstrumentation(group);
    instrumentationManager.addHealthInstrumentation(instrumentation);
  });
  if (consumerGroups.containsKey(group)) {
    return consumerGroups.get(group);
  }
  DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(group);
  consumer.setNamesrvAddr(rocketBinderConfigurationProperties.getNamesrvAddr());
  consumerGroups.put(group, consumer);
  started.put(group, false);
  consumer.setConsumeThreadMax(consumerProperties.getConcurrency());
  consumer.setConsumeThreadMin(consumerProperties.getConcurrency());
  if (consumerProperties.getExtension().getBroadcasting()) {
    consumer.setMessageModel(MessageModel.BROADCASTING);
  }
  logger.info("RocketMQ consuming for SCS group {} created", group);
  return consumer;
}

代码示例来源：origin: org.springframework.cloud/spring-cloud-stream-binder-kinesis

@Override
public ConsumerDestination provisionConsumerDestination(String name, String group,
    ExtendedConsumerProperties<KinesisConsumerProperties> properties) throws ProvisioningException {
  if (logger.isInfoEnabled()) {
    logger.info("Using Kinesis stream for inbound: " + name);
  }
  if (properties.getHeaderMode() == null) {
    properties.setHeaderMode(HeaderMode.embeddedHeaders);
  }
  int shardCount = properties.getInstanceCount() * properties.getConcurrency();
  return new KinesisConsumerDestination(name, createOrUpdate(name, shardCount));
}

代码示例来源：origin: org.springframework.cloud/spring-cloud-stream-binder-kinesis-core

@Override
public ConsumerDestination provisionConsumerDestination(String name, String group,
    ExtendedConsumerProperties<KinesisConsumerProperties> properties) throws ProvisioningException {
  if (logger.isInfoEnabled()) {
    logger.info("Using Kinesis stream for inbound: " + name);
  }
  if (properties.getHeaderMode() == null) {
    properties.setHeaderMode(HeaderMode.embeddedHeaders);
  }
  int shardCount = properties.getInstanceCount() * properties.getConcurrency();
  return new KinesisConsumerDestination(name, createOrUpdate(name, shardCount));
}

代码示例来源：origin: spring-cloud/spring-cloud-stream-binder-aws-kinesis

@Override
public ConsumerDestination provisionConsumerDestination(String name, String group,
    ExtendedConsumerProperties<KinesisConsumerProperties> properties)
    throws ProvisioningException {
  if (logger.isInfoEnabled()) {
    logger.info("Using Kinesis stream for inbound: " + name);
  }
  if (properties.getHeaderMode() == null) {
    properties.setHeaderMode(HeaderMode.embeddedHeaders);
  }
  int shardCount = properties.getInstanceCount() * properties.getConcurrency();
  return new KinesisConsumerDestination(name, createOrUpdate(name, shardCount));
}

代码示例来源：origin: org.springframework.cloud/spring-cloud-stream-binder-rocketmq

public synchronized DefaultMQPushConsumer getOrCreateConsumer(String group,
    String topic,
    ExtendedConsumerProperties<RocketMQConsumerProperties> consumerProperties) {
  propertiesMap.put(new AbstractMap.SimpleEntry<>(group, topic),
      consumerProperties);
  Optional.ofNullable(instrumentationManager).ifPresent(manager -> {
    ConsumerGroupInstrumentation instrumentation = manager
        .getConsumerGroupInstrumentation(group);
    instrumentationManager.addHealthInstrumentation(instrumentation);
  });
  if (consumerGroups.containsKey(group)) {
    return consumerGroups.get(group);
  }
  DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(group);
  consumer.setNamesrvAddr(rocketBinderConfigurationProperties.getNamesrvAddr());
  consumerGroups.put(group, consumer);
  started.put(group, false);
  consumer.setConsumeThreadMax(consumerProperties.getConcurrency());
  consumer.setConsumeThreadMin(consumerProperties.getConcurrency());
  if (consumerProperties.getExtension().getBroadcasting()) {
    consumer.setMessageModel(MessageModel.BROADCASTING);
  }
  logger.info("RocketMQ consuming for SCS group {} created", group);
  return consumer;
}

代码示例来源：origin: spring-cloud/spring-cloud-stream-binder-kafka

throw new IllegalArgumentException("Instance count cannot be zero");
int partitionCount = properties.getInstanceCount() * properties.getConcurrency();
ConsumerDestination consumerDestination = new KafkaConsumerDestination(name);
try (AdminClient adminClient = createAdminClient()) {

代码示例来源：origin: org.springframework.cloud/spring-cloud-stream-binder-kafka-core

throw new IllegalArgumentException("Instance count cannot be zero");
int partitionCount = properties.getInstanceCount() * properties.getConcurrency();
ConsumerDestination consumerDestination = new KafkaConsumerDestination(name);
try (AdminClient adminClient = createAdminClient()) {

代码示例来源：origin: spring-cloud/spring-cloud-stream-binder-kafka

extendedConsumerProperties);
int partitionCount = extendedConsumerProperties.getInstanceCount()
    * extendedConsumerProperties.getConcurrency();
int concurrency = usingPatterns ? extendedConsumerProperties.getConcurrency()
    : Math.min(extendedConsumerProperties.getConcurrency(), listenedPartitions.size());
resetOffsets(extendedConsumerProperties, consumerFactory, groupManagement, containerProperties);
@SuppressWarnings("rawtypes")

代码示例来源：origin: org.springframework.cloud/spring-cloud-stream-binder-kafka

extendedConsumerProperties);
int partitionCount = extendedConsumerProperties.getInstanceCount()
    * extendedConsumerProperties.getConcurrency();
int concurrency = usingPatterns ? extendedConsumerProperties.getConcurrency()
    : Math.min(extendedConsumerProperties.getConcurrency(), listenedPartitions.size());
resetOffsets(extendedConsumerProperties, consumerFactory, groupManagement, containerProperties);
@SuppressWarnings("rawtypes")

代码示例来源：origin: org.springframework.cloud/spring-cloud-stream-binder-kinesis

adapter.setConcurrency(properties.getConcurrency());
adapter.setStartTimeout(kinesisConsumerProperties.getStartTimeout());
adapter.setDescribeStreamBackoff(this.configurationProperties.getDescribeStreamBackoff());

代码示例来源：origin: org.springframework.cloud/spring-cloud-stream-binder-kafka11

extendedConsumerProperties);
int partitionCount = extendedConsumerProperties.getInstanceCount()
    * extendedConsumerProperties.getConcurrency();
  containerProperties.setTransactionManager(this.transactionManager);
int concurrency = Math.min(extendedConsumerProperties.getConcurrency(), listenedPartitions.size());
@SuppressWarnings("rawtypes")
final ConcurrentMessageListenerContainer<?, ?> messageListenerContainer =

代码示例来源：origin: org.springframework.cloud/spring-cloud-stream-binder-kafka11-core

@Override
public ConsumerDestination provisionConsumerDestination(final String name, final String group, ExtendedConsumerProperties<KafkaConsumerProperties> properties) {
  KafkaTopicUtils.validateTopicName(name);
  boolean anonymous = !StringUtils.hasText(group);
  Assert.isTrue(!anonymous || !properties.getExtension().isEnableDlq(),
      "DLQ support is not available for anonymous subscriptions");
  if (properties.getInstanceCount() == 0) {
    throw new IllegalArgumentException("Instance count cannot be zero");
  }
  int partitionCount = properties.getInstanceCount() * properties.getConcurrency();
  createTopicsIfAutoCreateEnabledAndAdminUtilsPresent(name, partitionCount, properties.getExtension().isAutoRebalanceEnabled());
  if (this.configurationProperties.isAutoCreateTopics() && adminUtilsOperation != null) {
    final ZkUtils zkUtils = ZkUtils.apply(this.configurationProperties.getZkConnectionString(),
        this.configurationProperties.getZkSessionTimeout(),
        this.configurationProperties.getZkConnectionTimeout(),
        JaasUtils.isZkSecurityEnabled());
    int partitions = adminUtilsOperation.partitionSize(name, zkUtils);
    if (properties.getExtension().isEnableDlq() && !anonymous) {
      String dlqTopic = StringUtils.hasText(properties.getExtension().getDlqName()) ?
          properties.getExtension().getDlqName() : "error." + name + "." + group;
      createTopicAndPartitions(dlqTopic, partitions, properties.getExtension().isAutoRebalanceEnabled());
      return new KafkaConsumerDestination(name, partitions, dlqTopic);
    }
    return new KafkaConsumerDestination(name, partitions);
  }
  return new KafkaConsumerDestination(name);
}

代码示例来源：origin: spring-cloud/spring-cloud-stream-binder-aws-kinesis

adapter.setConcurrency(properties.getConcurrency());
adapter.setStartTimeout(kinesisConsumerProperties.getStartTimeout());
adapter.setDescribeStreamBackoff(

代码示例来源：origin: org.springframework.cloud/spring-cloud-stream-binder-rabbit

listenerContainer.setChannelTransacted(properties.getExtension().isTransacted());
listenerContainer.setDefaultRequeueRejected(properties.getExtension().isRequeueRejected());
int concurrency = properties.getConcurrency();
concurrency = concurrency > 0 ? concurrency : 1;
listenerContainer.setConcurrentConsumers(concurrency);

代码示例来源：origin: spring-cloud/spring-cloud-stream-binder-rabbit

listenerContainer.setChannelTransacted(properties.getExtension().isTransacted());
listenerContainer.setDefaultRequeueRejected(properties.getExtension().isRequeueRejected());
int concurrency = properties.getConcurrency();
concurrency = concurrency > 0 ? concurrency : 1;
listenerContainer.setConcurrentConsumers(concurrency);