驼峰JMS CXF终结点不创建新的临时回复队列

Question

我有两个使用JMS作为传输的CXFendpoint；一个用作消费者，另一个用作生产者。这是一个非常精简的设置。

<camelcxf:cxfEndpoint xmlns:i="http://inbound.com/inbound"
                      id="myInboundEndpoint"
                      endpointName="i:InboundService"
                      serviceName="i:InboundService"
                      address="camel://direct:my-inbound-route"
                      serviceClass="com.InboundService"
                      bus="cxf"
                      wsdlURL="classpath:META-INF/wsdl/inbound.wsdl">
    <camelcxf:properties>
        <entry key="dataFormat" value="POJO"/>
    </camelcxf:properties>
</camelcxf:cxfEndpoint>

<camelcxf:cxfEndpoint xmlns:o="http://outbound.com/outbound"
                      id="myOutboundEndpoint"
                      endpointName="o:OutboundService"
                      serviceName="o:OutboundService"
                      address=""jms://"" 
                      serviceClass="com.OutboundService"
                      bus="cxf"
                      wsdlURL="classpath:META-INF/wsdl/outbound.wsdl">
    <camelcxf:properties>
        <entry key="dataFormat" value="POJO"/>
    </camelcxf:properties>
    <camelcxf:features>
        <bean class="org.apache.cxf.transport.jms.JMSConfigFeature">
            <property name="jmsConfig" ref="jmsConfig" />
        </bean>
    </camelcxf:features>
</camelcxf:cxfEndpoint>

<bean id="jmsConfig" class="org.apache.cxf.transport.jms.JMSConfiguration">
    <property name="connectionFactory" ref="pooledConnectionFactory" />
    <property name="targetDestination" value="some-queue" />
</bean>

<camelContext>
    <route id="inQueue">
        <from uri="activemq:inbound-queue" />
        <to uri="direct:my-inbound-route" />
    </route>
    <route id="inVm">
        <from uri="direct:in-vm" />
        <to uri="direct:my-inbound-route" />
    </route>
    <route id="serviceProxy">
        <from uri="cxf:bean:myInboundEndpoint?synchronous=true" />
        <setHeader headerName="operationName"><constant>myOtherOperation</constant></setHeader>
        <to uri="cxf:bean:outboundEndpoint?synchronous=true" />
    </route>        
</camelContext>

但是当调用第二个路由时会发生什么，CXF组件或camel会尝试重用来自原始入站消息（包括回复队列）的所有JMS配置，而不是仅为此交换创建另一个临时回复队列。这似乎是从in消息中获取的标头。

如果您只使用纯JMS并将CXF从等式中去掉，那么camel会正确地为路由的内部创建一个新队列，尽管我需要继续使用CXF，因为我必须使用一些遗留拦截器。

我尝试了使用jms://JMSConfig样式和camel://style。

我目前正在使用jaxws： Client方法，只是使用bean： myBean进行引用？method=myMethod，它可以工作，但不允许我从原始入站方法传播SOAP标头，因此切换到使用cxf： endpoint。

我试图找到一个使用CXF在JMS上使用SOAP的示例，但似乎没有具体的示例。

所以问题是。。。。我是否需要为我的生产者进行任何其他配置，或者是否有其他方法可以使用CXF通过JMS执行SOAP，并传播/设置原始消息/骆驼交换中的一些头？

Answer 1

我认为您可能需要从inMessage中筛选replyTo的标题。

如果您想使用SOAP over JMS，您可以在地址上指定所有与JMS相关的设置，而无需破解JMSConfiguration。这是您可以作为示例的文档。