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

ServiceActivator介绍

暂无

代码示例

代码示例来源：origin: dyc87112/SpringCloud-Learning

/**
 * 消息消费失败的降级处理逻辑
 *
 * @param message
 */
@ServiceActivator(inputChannel = "test-topic.stream-exception-handler.errors")
public void error(Message<?> message) {
  log.info("Message consumer failed, call fallback!");
}

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

@ServiceActivator
  public String upperCase(String input) {
    return "JMS response: " + input.toUpperCase();
  }
}

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

@ServiceActivator(inputChannel = "messages")
public void log(Message<?> message) {
  log.info("Received: " + message);
  this.restTemplate.getForObject("http://localhost:" + this.port + "/foo",
      String.class);
}

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

@ServiceActivator
public void log(int i) {
  logger.info("odd:  " + i + " at " + new SimpleDateFormat("yyyy-MM-dd hh:mm:ss").format(new Date()));
}

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

@ServiceActivator
public void log(int i) {
  logger.info("even: " + i + " at " + new SimpleDateFormat("yyyy-MM-dd hh:mm:ss").format(new Date()));
}

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

@ServiceActivator(inputChannel="tickers", outputChannel="quotes")
public Quote lookupQuote(String ticker) {
  BigDecimal price = new BigDecimal(new Random().nextDouble() * 100);//NOSONAR
  return new Quote(ticker, price.setScale(2, RoundingMode.HALF_EVEN));
}

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

@ServiceActivator(inputChannel = "smokein", outputChannel = "smokeout")
public String process(String message) {
  count++;
  String result = message + ": " + count;
  return result;
}

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

@ServiceActivator
  public String cat(String value) {
    for (int i=1; i<factor; i++) {
      value += value;
    }
    return value;
  }
}

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

@ServiceActivator
  public void service(String input) {
    count++;
    return;
  }
}

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

@ServiceActivator(inputChannel = "xform")
public String log(Message<?> message) throws InterruptedException {
  log.info("Received: " + message);
  this.background.background();
  return message.getPayload().toString().toUpperCase();
}

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

@ServiceActivator
  public String transform(String input) {
    if (input.equals("filter")) {
      return null;
    }
    return input + ": " + (count++);
  }
}

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

@ServiceActivator(inputChannel = "toEcho")
public String upCase(String in) {
  return in.toUpperCase();
}

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

@ServiceActivator(inputChannel="coldDrinkBarista", outputChannel="preparedDrinks")
public Drink prepareColdDrink(OrderItem orderItem) {
  try {
    Thread.sleep(this.coldDrinkDelay);
    logger.info(Thread.currentThread().getName()
        + " prepared cold drink #" + coldDrinkCounter.incrementAndGet() + " for order #"
        + orderItem.getOrderNumber() + ": " + orderItem);
    return new Drink(orderItem.getOrderNumber(), orderItem.getDrinkType(), orderItem.isIced(),
        orderItem.getShots());
  } catch (InterruptedException e) {
    Thread.currentThread().interrupt();
    return null;
  }
}

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

@ServiceActivator(inputChannel="hotDrinkBarista", outputChannel="preparedDrinks")
public Drink prepareHotDrink(OrderItem orderItem) {
  try {
    Thread.sleep(this.hotDrinkDelay);
    logger.info(Thread.currentThread().getName()
        + " prepared hot drink #" + hotDrinkCounter.incrementAndGet() + " for order #"
        + orderItem.getOrderNumber() + ": " + orderItem);
    return new Drink(orderItem.getOrderNumber(), orderItem.getDrinkType(), orderItem.isIced(),
        orderItem.getShots());
  } catch (InterruptedException e) {
    Thread.currentThread().interrupt();
    return null;
  }
}

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

@ServiceActivator(inputChannel = "requests", outputChannel = "replies")
public String process(String message) {
  String result = message + ": " + (count++);
  logger.debug("Handling: " + message);
  if (count <= expected.size()) {
    processed.add(message);
  }
  if ("fail".equals(message)) {
    throw new RuntimeException("Planned failure");
  }
  return result;
}

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

@ServiceActivator(inputChannel = "requests", outputChannel = "replies")
public String process(String message) {
  String result = message + ": " + count;
  logger.debug("Handling: " + message);
  if (count < expected.size()) {
    processed.add(message);
    count++;
  }
  if ("fail".equals(message)) {
    throw new RuntimeException("Planned failure");
  }
  return result;
}

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

@Bean
@ServiceActivator(inputChannel="mathServiceChannel")
public MathService mathService() {
  return new MathService();
}

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

@Bean
@ServiceActivator(inputChannel = "mathServiceChannel")
public MathService mathService() {
  return new MathService();
}

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

@ServiceActivator
public JobExecution launch(JobLaunchRequest request) throws JobExecutionException {
  Job job = request.getJob();
  JobParameters jobParameters = request.getJobParameters();
  return jobLauncher.run(job, jobParameters);
}

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

@ServiceActivator
public String cat(String value, @Header(value="stepExecution.jobExecution.jobParameters.getLong('factor')", required=false) Integer input) {
  long factor = input==null ? 1 : input;
  for (int i=1; i<factor; i++) {
    value += value;
  }
  return value;
}