org.apache.camel.Message.removeHeaders()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(13.4k)|赞(0)|评价(0)|浏览(270)

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

Message.removeHeaders介绍

暂无

代码示例

代码示例来源：origin: org.apache.camel/camel-micrometer

  1. protected boolean clearMetricsHeaders(Message in) {
  2.     return in.removeHeaders(HEADER_PATTERN);
  3.   }
  4. }

代码示例来源：origin: org.apache.camel/camel-metrics

  1. protected boolean clearMetricsHeaders(Message in) {
  2.     return in.removeHeaders(HEADER_PATTERN);
  3.   }
  4. }

代码示例来源：origin: io.syndesis/trade-insight-buy-connector

  1. public TradeInsightBuyComponent(String componentSchema) {
  2.   super("trade-insight-buy", componentSchema, TradeInsightBuyComponent.class.getName());
  3.   // remove all the headers, as we should not propagate any of them
  4.   // and set the content type as json which is what this connector uses
  5.   setBeforeProducer(exchange -> {
  6.     exchange.getIn().removeHeaders("*");
  7.     exchange.getIn().setHeader(CONTENT_TYPE, "application/json");
  8.   });
  9. }

代码示例来源：origin: io.syndesis/trade-insight-sell-connector

  1. public TradeInsightSellComponent(String componentSchema) {
  2.   super("trade-insight-sell", componentSchema, TradeInsightSellComponent.class.getName());
  3.   // remove all the headers, as we should not propagate any of them
  4.   // and set the content type as json which is what this connector uses
  5.   setBeforeProducer(exchange -> {
  6.     exchange.getIn().removeHeaders("*");
  7.     exchange.getIn().setHeader(CONTENT_TYPE, "application/json");
  8.   });
  9. }

代码示例来源：origin: io.syndesis/day-trade-place-connector

  1. public DayTradePlaceComponent(String componentSchema) {
  2.   super("day-trade-place", componentSchema, DayTradePlaceComponent.class.getName());
  3.   // remove all the headers as we should not propagate any of them
  4.   // and set the content type as json which is what this connector uses
  5.   setBeforeProducer(exchange -> {
  6.     exchange.getIn().removeHeaders("*");
  7.     exchange.getIn().setHeader(CONTENT_TYPE, "application/json");
  8.   });
  9. }

代码示例来源：origin: io.syndesis.connector/connector-webhook

  1. private void removeOutput(final Exchange exchange) {
  2.   exchange.getOut().setBody("");
  3.   exchange.getOut().removeHeaders("*");
  4.   if (exchange.getException() == null) {
  5.     // In case of exception, we leave the error code as is
  6.     exchange.getOut().setHeader(Exchange.HTTP_RESPONSE_CODE, 204);
  7.     exchange.getOut().setHeader(Exchange.HTTP_RESPONSE_TEXT, "No Content");
  8.   }
  9. }

代码示例来源：origin: io.syndesis/trade-insight-top-connector

  1. public TradeInsightTopComponent(String componentSchema) {
  2.   super("trade-insight-top", componentSchema, TradeInsightTopComponent.class.getName());
  3.   // remove all the headers, as we should not propagate any of them
  4.   // and set the content type as json which is what this connector uses
  5.   setBeforeProducer(exchange -> {
  6.     exchange.getIn().removeHeaders("*");
  7.     exchange.getIn().setHeader(CONTENT_TYPE, "application/json");
  8.   });
  9. }

代码示例来源：origin: org.fusesource/camel-sap

  1. /**
  2.  * Add endpoint parameters to SAP Camel component message headers.
  3.  * 
  4.  * @param endpoint
  5.  *            - the endpoint whose parameters are added.
  6.  * @param message
  7.  *            - the message added to.
  8.  */
  9. public static void addSapHeadersToMessage(SapSynchronousRfcDestinationEndpoint endpoint, Message message) {
  10.   message.removeHeaders(SapConstants.PROPERTY_PREFIX
  11.       + "*"); /* Remove any previous SAP headers */
  12.   message.setHeader(SapConstants.SAP_SCHEME_NAME_MESSAGE_HEADER, SapConstants.SAP_SYNCHRONOUS_RFC_DESTINATION);
  13.   message.setHeader(SapConstants.SAP_DESTINATION_NAME_MESSAGE_HEADER, endpoint.getDestinationName());
  14.   message.setHeader(SapConstants.SAP_RFC_NAME_MESSAGE_HEADER, endpoint.getRfcName());
  15. }

代码示例来源：origin: org.fusesource/camel-sap

  1. /**
  2.  * Add endpoint parameters to SAP Camel component message headers.
  3.  * 
  4.  * @param endpoint
  5.  *            - the endpoint whose parameters are added.
  6.  * @param message
  7.  *            - the message added to.
  8.  */
  9. public static void addSapHeadersToMessage(SapTransactionalRfcDestinationEndpoint endpoint, Message message) {
  10.   message.removeHeaders(SapConstants.PROPERTY_PREFIX
  11.       + "*"); /* Remove any previous SAP headers */
  12.   message.setHeader(SapConstants.SAP_SCHEME_NAME_MESSAGE_HEADER, SapConstants.SAP_TRANSACTIONAL_RFC_DESTINATION);
  13.   message.setHeader(SapConstants.SAP_DESTINATION_NAME_MESSAGE_HEADER, endpoint.getDestinationName());
  14.   message.setHeader(SapConstants.SAP_RFC_NAME_MESSAGE_HEADER, endpoint.getRfcName());
  15. }

代码示例来源：origin: org.fusesource/camel-sap

  1. /**
  2.  * Add endpoint parameters to SAP Camel component message headers.
  3.  * 
  4.  * @param endpoint
  5.  *            - the endpoint whose parameters are added.
  6.  * @param message
  7.  *            - the message added to.
  8.  */
  9. public static void addSapHeadersToMessage(SapSynchronousRfcServerEndpoint endpoint, Message message) {
  10.   message.removeHeaders(SapConstants.PROPERTY_PREFIX
  11.       + "*"); /* Remove any previous SAP headers */
  12.   message.setHeader(SapConstants.SAP_SCHEME_NAME_MESSAGE_HEADER, SapConstants.SAP_SYNCHRONOUS_RFC_SERVER);
  13.   message.setHeader(SapConstants.SAP_SERVER_NAME_MESSAGE_HEADER, endpoint.getServerName());
  14.   message.setHeader(SapConstants.SAP_RFC_NAME_MESSAGE_HEADER, endpoint.getRfcName());
  15. }

代码示例来源：origin: org.fusesource/camel-sap

  1. /**
  2.  * Add endpoint parameters to SAP Camel component message headers.
  3.  * 
  4.  * @param endpoint
  5.  *            - the endpoint whose parameters are added.
  6.  * @param message
  7.  *            - the message added to.
  8.  */
  9. public static void addSapHeadersToMessage(SapTransactionalRfcServerEndpoint endpoint, Message message) {
  10.   message.removeHeaders(SapConstants.PROPERTY_PREFIX
  11.       + "*"); /* Remove any previous SAP headers */
  12.   message.setHeader(SapConstants.SAP_SCHEME_NAME_MESSAGE_HEADER, SapConstants.SAP_TRANSACTIONAL_RFC_SERVER);
  13.   message.setHeader(SapConstants.SAP_SERVER_NAME_MESSAGE_HEADER, endpoint.getServerName());
  14.   message.setHeader(SapConstants.SAP_RFC_NAME_MESSAGE_HEADER, endpoint.getRfcName());
  15. }

代码示例来源：origin: org.fusesource/camel-sap

  1. /**
  2.  * Add endpoint parameters to SAP Camel component message headers.
  3.  * 
  4.  * @param endpoint
  5.  *            - the endpoint whose parameters are added.
  6.  * @param message
  7.  *            - the message added to.
  8.  */
  9. public static void addSapHeadersToMessage(SapQueuedRfcDestinationEndpoint endpoint, Message message) {
  10.   message.removeHeaders(SapConstants.PROPERTY_PREFIX
  11.       + "*"); /* Remove any previous SAP headers */
  12.   message.setHeader(SapConstants.SAP_SCHEME_NAME_MESSAGE_HEADER, SapConstants.SAP_QUEUED_RFC_DESTINATION);
  13.   message.setHeader(SapConstants.SAP_DESTINATION_NAME_MESSAGE_HEADER, endpoint.getDestinationName());
  14.   message.setHeader(SapConstants.SAP_QUEUE_NAME_MESSAGE_HEADER, endpoint.getQueueName());
  15.   message.setHeader(SapConstants.SAP_RFC_NAME_MESSAGE_HEADER, endpoint.getRfcName());
  16. }

代码示例来源：origin: org.ojbc.bundles.shared/ojb-fedquery-common

  1. exchange.getIn().removeHeaders("*", "federatedQueryRequestGUID", "operationName", "operationNamespace", "tokenID", "webServiceEndpointToCall", Client.REQUEST_CONTEXT, Exchange.DESTINATION_OVERRIDE_URL);

代码示例来源：origin: org.fusesource/camel-sap

  1. /**
  2.  * Add endpoint parameters to SAP Camel component message headers.
  3.  * 
  4.  * @param endpoint
  5.  *            - the endpoint whose parameters are added.
  6.  * @param message
  7.  *            - the message added to.
  8.  */
  9. public static void addSapHeadersToMessage(SapTransactionalIDocListDestinationEndpoint endpoint, Message message) {
  10.   message.removeHeaders(SapConstants.PROPERTY_PREFIX
  11.       + "*"); /* Remove any previous SAP headers */
  12.   message.setHeader(SapConstants.SAP_SCHEME_NAME_MESSAGE_HEADER, SapConstants.SAP_IDOC_LIST_DESTINATION);
  13.   message.setHeader(SapConstants.SAP_DESTINATION_NAME_MESSAGE_HEADER, endpoint.getDestinationName());
  14.   message.setHeader(SapConstants.SAP_IDOC_TYPE_NAME_MESSAGE_HEADER, endpoint.getIdocType());
  15.   message.setHeader(SapConstants.SAP_IDOC_TYPE_EXTENSION_NAME_MESSAGE_HEADER, endpoint.getIdocTypeExtension());
  16.   message.setHeader(SapConstants.SAP_SYSTEM_RELEASE_NAME_MESSAGE_HEADER, endpoint.getSystemRelease());
  17.   message.setHeader(SapConstants.SAP_APPLICATION_RELEASE_NAME_MESSAGE_HEADER, endpoint.getApplicationRelease());
  18. }

代码示例来源：origin: org.fusesource/camel-sap

  1. /**
  2.  * Add endpoint parameters to SAP Camel component message headers.
  3.  * 
  4.  * @param endpoint
  5.  *            - the endpoint whose parameters are added.
  6.  * @param message
  7.  *            - the message added to.
  8.  */
  9. public static void addSapHeadersToMessage(SapQueuedIDocListDestinationEndpoint endpoint, Message message) {
  10.   message.removeHeaders(SapConstants.PROPERTY_PREFIX
  11.       + "*"); /* Remove any previous SAP headers */
  12.   message.setHeader(SapConstants.SAP_SCHEME_NAME_MESSAGE_HEADER, SapConstants.SAP_QUEUED_IDOC_LIST_DESTINATION);
  13.   message.setHeader(SapConstants.SAP_DESTINATION_NAME_MESSAGE_HEADER, endpoint.getDestinationName());
  14.   message.setHeader(SapConstants.SAP_IDOC_TYPE_NAME_MESSAGE_HEADER, endpoint.getIdocType());
  15.   message.setHeader(SapConstants.SAP_IDOC_TYPE_EXTENSION_NAME_MESSAGE_HEADER, endpoint.getIdocTypeExtension());
  16.   message.setHeader(SapConstants.SAP_SYSTEM_RELEASE_NAME_MESSAGE_HEADER, endpoint.getSystemRelease());
  17.   message.setHeader(SapConstants.SAP_APPLICATION_RELEASE_NAME_MESSAGE_HEADER, endpoint.getApplicationRelease());
  18. }

代码示例来源：origin: org.fusesource/camel-sap

  1. /**
  2.  * Add endpoint parameters to SAP Camel component message headers.
  3.  * 
  4.  * @param endpoint
  5.  *            - the endpoint whose parameters are added.
  6.  * @param message
  7.  *            - the message added to.
  8.  */
  9. public static void addSapHeadersToMessage(SapTransactionalIDocDestinationEndpoint endpoint, Message message) {
  10.   message.removeHeaders(SapConstants.PROPERTY_PREFIX
  11.       + "*"); /* Remove any previous SAP headers */
  12.   message.setHeader(SapConstants.SAP_SCHEME_NAME_MESSAGE_HEADER, SapConstants.SAP_IDOC_DESTINATION);
  13.   message.setHeader(SapConstants.SAP_DESTINATION_NAME_MESSAGE_HEADER, endpoint.getDestinationName());
  14.   message.setHeader(SapConstants.SAP_IDOC_TYPE_NAME_MESSAGE_HEADER, endpoint.getIdocType());
  15.   message.setHeader(SapConstants.SAP_IDOC_TYPE_EXTENSION_NAME_MESSAGE_HEADER, endpoint.getIdocTypeExtension());
  16.   message.setHeader(SapConstants.SAP_SYSTEM_RELEASE_NAME_MESSAGE_HEADER, endpoint.getSystemRelease());
  17.   message.setHeader(SapConstants.SAP_APPLICATION_RELEASE_NAME_MESSAGE_HEADER, endpoint.getApplicationRelease());
  18. }

代码示例来源：origin: org.fusesource/camel-sap

  1. /**
  2.  * Add endpoint parameters to SAP Camel component message headers.
  3.  * 
  4.  * @param endpoint
  5.  *            - the endpoint whose parameters are added.
  6.  * @param message
  7.  *            - the message added to.
  8.  */
  9. public static void addSapHeadersToMessage(SapQueuedIDocDestinationEndpoint endpoint, Message message) {
  10.   message.removeHeaders(SapConstants.PROPERTY_PREFIX
  11.       + "*"); /* Remove any previous SAP headers */
  12.   message.setHeader(SapConstants.SAP_SCHEME_NAME_MESSAGE_HEADER, SapConstants.SAP_QUEUED_IDOC_DESTINATION);
  13.   message.setHeader(SapConstants.SAP_DESTINATION_NAME_MESSAGE_HEADER, endpoint.getDestinationName());
  14.   message.setHeader(SapConstants.SAP_IDOC_TYPE_NAME_MESSAGE_HEADER, endpoint.getIdocType());
  15.   message.setHeader(SapConstants.SAP_IDOC_TYPE_EXTENSION_NAME_MESSAGE_HEADER, endpoint.getIdocTypeExtension());
  16.   message.setHeader(SapConstants.SAP_SYSTEM_RELEASE_NAME_MESSAGE_HEADER, endpoint.getSystemRelease());
  17.   message.setHeader(SapConstants.SAP_APPLICATION_RELEASE_NAME_MESSAGE_HEADER, endpoint.getApplicationRelease());
  18. }

代码示例来源：origin: org.fusesource/camel-sap

  1. /**
  2.    * Add endpoint parameters to SAP Camel component message headers.
  3.    * 
  4.    * @param endpoint
  5.    *            - the endpoint whose parameters are added.
  6.    * @param message
  7.    *            - the message added to.
  8.    */
  9.   public static void addSapHeadersToMessage(SapTransactionalIDocListServerEndpoint endpoint, Message message) {
  10.     message.removeHeaders(SapConstants.PROPERTY_PREFIX
  11.         + "*"); /* Remove any previous SAP headers */
  12.     message.setHeader(SapConstants.SAP_SCHEME_NAME_MESSAGE_HEADER, SapConstants.SAP_IDOC_LIST_SERVER);
  13.     message.setHeader(SapConstants.SAP_SERVER_NAME_MESSAGE_HEADER, endpoint.getServerName());
  14.     message.setHeader(SapConstants.SAP_IDOC_TYPE_NAME_MESSAGE_HEADER, endpoint.getIdocType());
  15.     message.setHeader(SapConstants.SAP_IDOC_TYPE_EXTENSION_NAME_MESSAGE_HEADER, endpoint.getIdocTypeExtension());
  16.     message.setHeader(SapConstants.SAP_SYSTEM_RELEASE_NAME_MESSAGE_HEADER, endpoint.getSystemRelease());
  17.     message.setHeader(SapConstants.SAP_APPLICATION_RELEASE_NAME_MESSAGE_HEADER, endpoint.getApplicationRelease());
  18.   }
  19. }

代码示例来源：origin: io.syndesis.connector/connector-api-provider

  1. @Override
  2. public void customize(ComponentProxyComponent component, Map<String, Object> options) {
  3.   final List<Processor> beforeConsumers = new ArrayList<>(2);
  4.   if (outputDataShape != null && outputDataShape.getKind() == DataShapeKinds.JSON_SCHEMA && outputDataShape.getSpecification() != null) {
  5.     try {
  6.       final JsonNode schema = READER.readTree(outputDataShape.getSpecification());
  7.       Set<String> properties = SimpleJsonSchemaInspector.getProperties(schema);
  8.       Set<String> extraneousProperties = new HashSet<>(properties);
  9.       extraneousProperties.removeAll(Arrays.asList("parameters", "body"));
  10.       if (!properties.isEmpty() && extraneousProperties.isEmpty()) {
  11.         beforeConsumers.add(new HttpRequestWrapperProcessor(schema));
  12.       }
  13.     } catch (IOException e) {
  14.       throw new RuntimeCamelException(e);
  15.     }
  16.   }
  17.   // removes all non Syndesis.* headers, this is so the headers that might
  18.   // influence HTTP components in the flow after this connector don't
  19.   // interpret them, for instance the `Host` header is particularly
  20.   // troublesome
  21.   beforeConsumers.add((e) -> e.getIn().removeHeaders("*", "Syndesis.*"));
  22.   component.setBeforeConsumer(Pipeline.newInstance(context, beforeConsumers));
  23. }

代码示例来源：origin: io.syndesis.connector/connector-webhook

  1. @Test
  2. public void shouldDestroyAllOutput() throws Exception {
  3.   final WebhookConnectorCustomizer customizer = new WebhookConnectorCustomizer();
  4.   customizer.customize(component, Collections.emptyMap());
  5.   final Processor afterConsumer = component.getAfterConsumer();
  6.   assertThat(afterConsumer).isNotNull();
  7.   final Exchange exchange = mock(Exchange.class);
  8.   final Message message = mock(Message.class);
  9.   when(exchange.getOut()).thenReturn(message);
  10.   afterConsumer.process(exchange);
  11.   verify(message).setBody("");
  12.   verify(message).removeHeaders("*");
  13.   verify(message).setHeader(Exchange.HTTP_RESPONSE_CODE, 204);
  14.   verify(message).setHeader(Exchange.HTTP_RESPONSE_TEXT, "No Content");
  15. }

内容来源于网络，如有侵权，请联系作者删除！

Message

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com