Camel ProducerTemplate은 모든 메시지에 동일한 JMSCorrelationID를 사용하고 생성 된 각 메시지에 대해 고유 ID를 얻는 방법은 무엇입니까?

Question

는 내가 메시지를 생성하는 내 서비스 중 하나에이 빈을 주입하고

<camel:template id="msgProducerTemplate" />

낙타

를 사용하여 생산자 템플릿을 정의했다. 이것은 CorrelationID를 생성 생산하고 모든 메시지에 대한

msgProducerTemplate.sendBodyAndHeaders(endpointUri, message, headerMap);

내가이 실제 메시지가 동일한 경우에도 각 메시지에 대한 새로운 ID를 생성 할 수있는 방법, 동일합니다. 주제 :

내 endpointUri는 inboundTopic입니다

<bean id="inboundTopic" class="org.apache.camel.component.jms.JmsComponent"> 
    <property name="connectionFactory" ref="jmsTopicConnectionFactory" /> 
    <property name="destinationResolver" ref="topicDestinationResolver" /> 
    <property name="transacted" value="true" /> 
    <property name="transactionManager" ref="topicTxManager" /> 
    <property name="cacheLevelName" value="CACHE_CONSUMER" /> 
</bean> 

<bean id="topicConnectionFactory" class="com.ibm.mq.jms.MQTopicConnectionFactory"> 
    <property name="hostName" value="${queuehost}" /> 
    <property name="port" value="${queueport}" /> 
    <property name="queueManager" value="${queuemanager}" /> 
    <property name="channel" value="${channel}" /> 
    <property name="transportType" value="${transportType}" /> 
</bean> 

<bean id="jmsTopicConnectionFactory" class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter"> 
    <property name="targetConnectionFactory" ref="topicConnectionFactory" /> 
    <property name="username"> 
     <value>${userid}</value> 
    </property> 
</bean> 

<bean id="topicDestinationResolver" class="com.abc.jms.JMSTopicDestinationResolver" /> 

Answer 1

그냥 JMSCorrelationID 헤더를 추가

내 jmscomponent는 다음과 같이 정의된다 $ {topic.name} ....

예 :

headerMap.put("JMSCorrelationID", UUID.randomUUID().toString());