当前位置: 首页 > 知识库问答 >
问题:

我如何扩展Spring集成的信息?

郑理
2023-03-14

我想扩展spring集成消息。我想在消息流经通道期间添加一些头值。

我阅读了MessageHeader的文档,如下所示。我怎样才能得到第三个案例的样本?

创建消息头的一种方法是使用MessageBuilder:

MessageBuilder。withPayload(“foo”)。setHeader(“键1”,“值1”)。setHeader(“键2”,“值2”);

第二种选择是创建

组织。springframework。消息传递。支持GenericMessage作为对象传递有效负载,作为java传递头。util。Map:Map headers=new HashMap();标题。put(“键1”,“值1”);标题。put(“键2”,“值2”);新的GenericMessage(“foo”,标题);

第三种选择是

使用组织。springframework。消息传递。支持MessageHeaderAccessor或其子类之一,用于创建特定类别的标头。

共有1个答案

燕照
2023-03-14

如果要求仅在消息流经通道期间添加一些标头值,则标头充实器可以达到此目的。

<int:header-enricher input-channel="in" output-channel="out">
     <int:header name="foo" value="123"/>
     <int:header name="bar" ref="someBean"/>
</int:header-enricher>
 类似资料:
  • 我希望能够利用Spring Boot datasource自动配置。但是,它并不支持我使用的所有特性,特别是。 有关等的更多信息,请参见:https://tomcat.apache.org/tomcat-8.0-doc/jdbc-pool.html

  • 我正在致力于将Spring SAML扩展集成到我们的应用程序中,并将SSO与我们客户的一个ADFS2进行集成。0作为IDP,我们已从应用程序生成服务提供商元数据,并将ADFS元数据导入应用程序。当我选择客户端idp并单击start single sign并提供正确的客户端凭据时,我们看到SAML响应如下: Saml回应。 但我也看到以下异常被抛出,因为服务提供商无法验证消息。 异常消息: 如果我遗

  • 我最初应该发布我的问题,说明我们的代码使用了一个嵌入式撒克逊扩展函数——撒克逊:解析($xml),它返回xml的根元素/节点。然而,在Saxon-HE中,该扩展不再可用——所以我试图编写一个集成扩展,将xml字符串解析到文档中并返回根元素。 我使用的是Saxon HE 9.5.1.6——我试图编写一个集成的扩展函数,返回文档的根节点。该函数接收一个xml字符串——创建一个文档,并需要将根节点返回给

  • 问题内容: 我还很陌生,因此无法找到任何文档或示例。我要做的是扩展基本服务,以便可以使用其他服务在基本服务下定义的方法。例如,说我有如下基本服务。 现在,我想定义一个从上述扩展的扩展服务,以便可以使用扩展服务中BasicService下定义的方法。也许像这样: 问题答案: 您应该注入以便能够访问它。旁边是对象文字,因此您实际上不能将其称为函数()。

  • 问题内容: 我必须在Web应用程序中使用3个不同的事务管理器。因此,我根据Spring参考(第10.5.6.3节“自定义快捷方式注释”)编写了自己的注释。 一个注释(用于使用一个特定的transactionmanager)如下所示: 使用自定义的@CustomerTX批注对我的服务层进行批注时,一切工作正常。但是我必须为注释提供更多选项,例如readonly = true,rollbackFor

  • Kubernetes是一个高度开放可扩展的架构,可以通过自定义资源类型CRD来定义自己的类型,还可以自己来扩展API服务,用户的使用方式跟Kubernetes的原生对象无异。