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

AbstractIntegrationMessageBuilder.setHeader介绍

[英]Set the value for the given header name. If the provided value is null, the header will be removed.
[中]设置给定标头名称的值。如果提供的值为null，则标题将被删除。

代码示例

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

public AbstractIntegrationMessageBuilder<T> setSequenceNumber(Integer sequenceNumber) {
  return setHeader(IntegrationMessageHeaderAccessor.SEQUENCE_NUMBER, sequenceNumber);
}

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

public AbstractIntegrationMessageBuilder<T> setExpirationDate(Long expirationDate) {
  return setHeader(IntegrationMessageHeaderAccessor.EXPIRATION_DATE, expirationDate);
}

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

public AbstractIntegrationMessageBuilder<T> setCorrelationId(Object correlationId) {
  return setHeader(IntegrationMessageHeaderAccessor.CORRELATION_ID, correlationId);
}

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

public AbstractIntegrationMessageBuilder<T> setReplyChannel(MessageChannel replyChannel) {
  return setHeader(MessageHeaders.REPLY_CHANNEL, replyChannel);
}

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

public AbstractIntegrationMessageBuilder<T> setErrorChannelName(String errorChannelName) {
  return setHeader(MessageHeaders.ERROR_CHANNEL, errorChannelName);
}

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

public AbstractIntegrationMessageBuilder<T> setSequenceSize(Integer sequenceSize) {
  return setHeader(IntegrationMessageHeaderAccessor.SEQUENCE_SIZE, sequenceSize);
}

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

public AbstractIntegrationMessageBuilder<T> setErrorChannel(MessageChannel errorChannel) {
  return setHeader(MessageHeaders.ERROR_CHANNEL, errorChannel);
}

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

public AbstractIntegrationMessageBuilder<T> setPriority(Integer priority) {
  return setHeader(IntegrationMessageHeaderAccessor.PRIORITY, priority);
}

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

public AbstractIntegrationMessageBuilder<T> setReplyChannelName(String replyChannelName) {
  return setHeader(MessageHeaders.REPLY_CHANNEL, replyChannelName);
}

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

public AbstractIntegrationMessageBuilder<T> setExpirationDate(Date expirationDate) {
  if (expirationDate != null) {
    return setHeader(IntegrationMessageHeaderAccessor.EXPIRATION_DATE, expirationDate.getTime());
  }
  else {
    return setHeader(IntegrationMessageHeaderAccessor.EXPIRATION_DATE, null);
  }
}

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

private Message<?> createServiceUnavailableResponse() {
  if (logger.isDebugEnabled()) {
    logger.debug("Endpoint is stopped; returning status " + HttpStatus.SERVICE_UNAVAILABLE);
  }
  return this.getMessageBuilderFactory().withPayload("Endpoint is stopped")
      .setHeader(org.springframework.integration.http.HttpHeaders.STATUS_CODE, HttpStatus.SERVICE_UNAVAILABLE)
      .build();
}

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

protected void send(String line) {
  Message<?> message = this.getMessageBuilderFactory().withPayload(line)
      .setHeader(FileHeaders.FILENAME, this.file.getName())
      .setHeader(FileHeaders.ORIGINAL_FILE, this.file)
      .build();
  super.sendMessage(message);
  updateLastProduce();
}

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

private Object doMv(Message<?> requestMessage) {
  String remoteFilePath = this.fileNameProcessor.processMessage(requestMessage);
  String remoteFilename = getRemoteFilename(remoteFilePath);
  String remoteDir = getRemoteDirectory(remoteFilePath, remoteFilename);
  String remoteFileNewPath = this.renameProcessor.processMessage(requestMessage);
  Assert.hasLength(remoteFileNewPath, "New filename cannot be empty");
  Boolean result =
      this.remoteFileTemplate.execute(session ->
          mv(requestMessage, session, remoteFilePath, remoteFileNewPath));
  return getMessageBuilderFactory()
      .withPayload(result)
      .setHeader(FileHeaders.REMOTE_DIRECTORY, remoteDir)
      .setHeader(FileHeaders.REMOTE_FILE, remoteFilename)
      .setHeader(FileHeaders.RENAME_TO, remoteFileNewPath);
}

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

private AbstractIntegrationMessageBuilder<?> addRoutingSlipHeader(Object reply, List<?> routingSlip,
    AtomicInteger routingSlipIndex) {
  //TODO Migrate to the SF MessageBuilder
  AbstractIntegrationMessageBuilder<?> builder = null;
  if (reply instanceof Message) {
    builder = this.getMessageBuilderFactory().fromMessage((Message<?>) reply);
  }
  else if (reply instanceof AbstractIntegrationMessageBuilder) {
    builder = (AbstractIntegrationMessageBuilder<?>) reply;
  }
  else {
    builder = this.getMessageBuilderFactory().withPayload(reply);
  }
  builder.setHeader(IntegrationMessageHeaderAccessor.ROUTING_SLIP,
      Collections.singletonMap(routingSlip, routingSlipIndex.get()));
  return builder;
}

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

private Object doRm(Message<?> requestMessage) {
  final String remoteFilePath = this.fileNameProcessor.processMessage(requestMessage);
  String remoteFilename = getRemoteFilename(remoteFilePath);
  String remoteDir = getRemoteDirectory(remoteFilePath, remoteFilename);
  boolean payload = this.remoteFileTemplate.execute(session -> rm(requestMessage, session, remoteFilePath));
  return getMessageBuilderFactory()
      .withPayload(payload)
      .setHeader(FileHeaders.REMOTE_DIRECTORY, remoteDir)
      .setHeader(FileHeaders.REMOTE_FILE, remoteFilename);
}

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

private Object doMget(final Message<?> requestMessage) {
  final String remoteFilePath = this.fileNameProcessor.processMessage(requestMessage);
  final String remoteFilename = getRemoteFilename(remoteFilePath);
  final String remoteDir = getRemoteDirectory(remoteFilePath, remoteFilename);
  List<File> payload = this.remoteFileTemplate.execute(session ->
      mGet(requestMessage, session, remoteDir, remoteFilename));
  return getMessageBuilderFactory()
      .withPayload(payload)
      .setHeader(FileHeaders.REMOTE_DIRECTORY, remoteDir)
      .setHeader(FileHeaders.REMOTE_FILE, remoteFilename);
}

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

protected void fromSoapHeaders(MessageContext messageContext, AbstractIntegrationMessageBuilder<?> builder) {
  WebServiceMessage request = messageContext.getRequest();
  String[] propertyNames = messageContext.getPropertyNames();
  if (propertyNames != null) {
    for (String propertyName : propertyNames) {
      builder.setHeader(propertyName, messageContext.getProperty(propertyName));
    }
  }
  if (request instanceof SoapMessage) {
    SoapMessage soapMessage = (SoapMessage) request;
    Map<String, ?> headers = this.headerMapper.toHeadersFromRequest(soapMessage);
    if (!CollectionUtils.isEmpty(headers)) {
      builder.copyHeaders(headers);
    }
  }
}

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

private AbstractIntegrationMessageBuilder<Object> markerToReturn(FileMarker fileMarker) {
  Object payload;
  if (FileSplitter.this.markersJson) {
    try {
      payload = OBJECT_MAPPER.toJson(fileMarker);
    }
    catch (Exception e) {
      throw new MessageHandlingException(this.message, "Failed to convert marker to JSON", e);
    }
  }
  else {
    payload = fileMarker;
  }
  return getMessageBuilderFactory().withPayload(payload)
      .setHeader(FileHeaders.MARKER, fileMarker.mark.name());
}

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

private Object doNlst(Message<?> requestMessage) {
  String dir = this.fileNameProcessor != null
      ? this.fileNameProcessor.processMessage(requestMessage)
      : null;
  if (dir != null && !dir.endsWith(this.remoteFileTemplate.getRemoteFileSeparator())) {
    dir += this.remoteFileTemplate.getRemoteFileSeparator();
  }
  final String fullDir = dir;
  List<?> payload = this.remoteFileTemplate.execute(session -> nlst(requestMessage, session, fullDir));
  return getMessageBuilderFactory()
      .withPayload(payload)
      .setHeader(FileHeaders.REMOTE_DIRECTORY, dir);
}

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

private Object doLs(Message<?> requestMessage) {
  String dir = this.fileNameProcessor != null
      ? this.fileNameProcessor.processMessage(requestMessage)
      : null;
  if (dir != null && !dir.endsWith(this.remoteFileTemplate.getRemoteFileSeparator())) {
    dir += this.remoteFileTemplate.getRemoteFileSeparator();
  }
  final String fullDir = dir;
  List<?> payload = this.remoteFileTemplate.execute(session -> ls(requestMessage, session, fullDir));
  return getMessageBuilderFactory()
      .withPayload(payload)
      .setHeader(FileHeaders.REMOTE_DIRECTORY, dir);
}