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

AbstractIntegrationMessageBuilder.removeHeader介绍

[英]Remove the value for the given header name.
[中]删除给定标头名称的值。

代码示例

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

@Override
public Message<?> transform(Message<?> message) {
  AbstractIntegrationMessageBuilder<?> builder = this.getMessageBuilderFactory().fromMessage(message);
  if (this.patternMatch) {
    builder.removeHeaders(this.headersToRemove);
  }
  else {
    for (String headerToRemove : this.headersToRemove) {
      builder.removeHeader(headerToRemove);
    }
  }
  return builder.build();
}

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

public AbstractIntegrationMessageBuilder<T> popSequenceDetails() {
  List<List<Object>> incomingSequenceDetails = getSequenceDetails();
  if (incomingSequenceDetails == null) {
    return this;
  }
  else {
    incomingSequenceDetails = new ArrayList<>(incomingSequenceDetails);
  }
  List<Object> sequenceDetails = incomingSequenceDetails.remove(incomingSequenceDetails.size() - 1);
  Assert.state(sequenceDetails.size() == 3, "Wrong sequence details (not created by MessageBuilder?): "
      + sequenceDetails);
  setCorrelationId(sequenceDetails.get(0));
  Integer sequenceNumber = (Integer) sequenceDetails.get(1);
  Integer sequenceSize = (Integer) sequenceDetails.get(2);
  if (sequenceNumber != null) {
    setSequenceNumber(sequenceNumber);
  }
  if (sequenceSize != null) {
    setSequenceSize(sequenceSize);
  }
  if (!incomingSequenceDetails.isEmpty()) {
    setHeader(IntegrationMessageHeaderAccessor.SEQUENCE_DETAILS, incomingSequenceDetails);
  }
  else {
    removeHeader(IntegrationMessageHeaderAccessor.SEQUENCE_DETAILS);
  }
  return this;
}

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

@Override
public Message<?> transform(Message<?> message) {
  AbstractIntegrationMessageBuilder<?> builder = this.getMessageBuilderFactory().fromMessage(message);
  if (this.patternMatch) {
    builder.removeHeaders(this.headersToRemove);
  }
  else {
    for (String headerToRemove : this.headersToRemove) {
      builder.removeHeader(headerToRemove);
    }
  }
  return builder.build();
}

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

@Override
protected Object handleRequestMessage(Message<?> requestMessage) {
  PollableChannel gatherResultChannel = new QueueChannel();
  Object gatherResultChannelName = this.replyChannelRegistry.channelToChannelName(gatherResultChannel);
  Message<?> scatterMessage = getMessageBuilderFactory()
      .fromMessage(requestMessage)
      .setHeader(GATHER_RESULT_CHANNEL, gatherResultChannelName)
      .setReplyChannel(this.gatherChannel)
      .build();
  this.messagingTemplate.send(this.scatterChannel, scatterMessage);
  Message<?> gatherResult = gatherResultChannel.receive(this.gatherTimeout);
  if (gatherResult != null) {
    return getMessageBuilderFactory()
        .fromMessage(gatherResult)
        .removeHeader(GATHER_RESULT_CHANNEL)
        .setHeader(MessageHeaders.REPLY_CHANNEL, requestMessage.getHeaders().getReplyChannel())
        .build();
  }
  return null;
}

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

public AbstractIntegrationMessageBuilder<T> popSequenceDetails() {
  List<List<Object>> incomingSequenceDetails = getSequenceDetails();
  if (incomingSequenceDetails == null) {
    return this;
  }
  else {
    incomingSequenceDetails = new ArrayList<>(incomingSequenceDetails);
  }
  List<Object> sequenceDetails = incomingSequenceDetails.remove(incomingSequenceDetails.size() - 1);
  Assert.state(sequenceDetails.size() == 3, "Wrong sequence details (not created by MessageBuilder?): "
      + sequenceDetails);
  setCorrelationId(sequenceDetails.get(0));
  Integer sequenceNumber = (Integer) sequenceDetails.get(1);
  Integer sequenceSize = (Integer) sequenceDetails.get(2);
  if (sequenceNumber != null) {
    setSequenceNumber(sequenceNumber);
  }
  if (sequenceSize != null) {
    setSequenceSize(sequenceSize);
  }
  if (!incomingSequenceDetails.isEmpty()) {
    setHeader(IntegrationMessageHeaderAccessor.SEQUENCE_DETAILS, incomingSequenceDetails);
  }
  else {
    removeHeader(IntegrationMessageHeaderAccessor.SEQUENCE_DETAILS);
  }
  return this;
}

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

@Override
  public Message<?> preSend(Message<?> message, MessageChannel channel) {
    if (!message.getHeaders().containsKey(BinderHeaders.PARTITION_OVERRIDE)) {
      int partition = this.partitionHandler.determinePartition(message);
      return MessageConverterConfigurer.this.messageBuilderFactory
          .fromMessage(message)
          .setHeader(BinderHeaders.PARTITION_HEADER, partition).build();
    }
    else {
      return MessageConverterConfigurer.this.messageBuilderFactory
          .fromMessage(message)
          .setHeader(BinderHeaders.PARTITION_HEADER,
              message.getHeaders()
                  .get(BinderHeaders.PARTITION_OVERRIDE))
          .removeHeader(BinderHeaders.PARTITION_OVERRIDE).build();
    }
  }
}

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

@Override
protected Object handleRequestMessage(Message<?> requestMessage) {
  PollableChannel gatherResultChannel = new QueueChannel();
  Object gatherResultChannelName = this.replyChannelRegistry.channelToChannelName(gatherResultChannel);
  Message<?> scatterMessage = getMessageBuilderFactory()
      .fromMessage(requestMessage)
      .setHeader(GATHER_RESULT_CHANNEL, gatherResultChannelName)
      .setReplyChannel(this.gatherChannel)
      .build();
  this.messagingTemplate.send(this.scatterChannel, scatterMessage);
  Message<?> gatherResult = gatherResultChannel.receive(this.gatherTimeout);
  if (gatherResult != null) {
    return getMessageBuilderFactory()
        .fromMessage(gatherResult)
        .removeHeader(GATHER_RESULT_CHANNEL)
        .setHeader(MessageHeaders.REPLY_CHANNEL, requestMessage.getHeaders().getReplyChannel())
        .build();
  }
  return null;
}