Announcement Announcement Module
Collapse
No announcement yet.
Send message By WebSPhere MQ Page Title Module
Move Remove Collapse
X
Conversation Detail Module
Collapse
  • Filter
  • Time
  • Show
Clear All
new posts

  • Send message By WebSPhere MQ

    Hi,

    I have to write a mainline program what get messages from 3 different WebSphere queue, process the messages and send back the answers to the message owners.
    It works correcly, when I write the singleton java classes, but I want to use spring integration.
    The inside message processing is OK, I use the message-driven-channel-adapter.
    I try to do the output way to do, but I can't set the WebSpehere spcific properties. I have to fill the RFH2 header, and some other properties.

    Here is the part of sender original procedure
    Code:
    lConn = (MQQueueConnection)QueFact.createQueueConnection() ;
    
    lSess = (MQQueueSession)lConn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
    MyQueue = (MQQueue)lSess.createQueue(fParams.getMqOutputQueue());
    
    MyQueue.setTargetClient(JMSC.MQJMS_CLIENT_JMS_COMPLIANT);
    
    lSender = (MQQueueSender)lSess.createSender(MyQueue);
    
    BytesMessage lTextMess = lSess.createBytesMessage();
    lTextMess.setIntProperty("JMS_IBM_Feedback", 0);
    lTextMess.setIntProperty("JMS_IBM_Encoding", MQC.MQENC_NATIVE);
    lTextMess.setIntProperty("JMS_IBM_Character_Set", 819);
    lTextMess.setStringProperty("JMS_IBM_Format", "MQRFH2");
    
    lTextMess.setIntProperty("JMS_IBM_MsgType", MQC.MQMT_DATAGRAM);
    lTextMess.setJMSPriority(5);
    
    lTextMess.setJMSDeliveryMode(MQC.MQPER_PERSISTENT);
    
    //mqrfh2 <usr>    
    lTextMess.setStringProperty("SOURCE", fParams.getMqSource());
    
    //CUBEBLSZ
    lTextMess.setStringProperty("DESTINATION", fParams.getMqDest());  
    
    //mqrfh2 <mcd>  
    lTextMess.setJMSType("mcd://jms_text//" + PMessageName);
    
    lTextMess.writeBytes(PText.getBytes("UTF8"));
    
    lSender.send(lTextMess);
    I woud like to change it to spring sending methode. I try to use JMSTemplate, but I dont't know how can I fill the properties.

    Spring configuration file:

    Code:
    <?xml version="1.0" encoding="UTF-8" standalone="no"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
    	xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx"
    	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:si="http://www.springframework.org/schema/integration"
    	xmlns:file="http://www.springframework.org/schema/integration/file"
    	xmlns:util="http://www.springframework.org/schema/util" xmlns:jms="http://www.springframework.org/schema/integration/jms"
    	xmlns:integration="http://www.springframework.org/schema/integration"
    	xmlns:stream="http://www.springframework.org/schema/integration/stream"
    	xsi:schemaLocation="http://www.springframework.org/schema/beans 
    	http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
    	http://www.springframework.org/schema/aop 
    	http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
    	http://www.springframework.org/schema/context 
    	http://www.springframework.org/schema/context/spring-context-3.0.xsd
    	http://www.springframework.org/schema/jee 
    	http://www.springframework.org/schema/jee/spring-jee-3.0.xsd
    	http://www.springframework.org/schema/tx 
    	http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
    	http://www.springframework.org/schema/integration
        http://www.springframework.org/schema/integration/spring-integration-2.0.xsd
        http://www.springframework.org/schema/integration/file
        http://www.springframework.org/schema/integration/file/spring-integration-file-2.0.xsd
        http://www.springframework.org/schema/integration/jms
        http://www.springframework.org/schema/integration/jms/spring-integration-jms-2.0.xsd
        http://www.springframework.org/schema/util
        http://www.springframework.org/schema/util/spring-util-3.0.xsd
        http://www.springframework.org/schema/integration/stream
        http://www.springframework.org/schema/integration/stream/spring-integration-stream-2.0.xsd">
    
    	<!-- Property-file betöltése  -->
    	<bean id="placeholderConfig"
    		class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
    		<property name="location" value="classpath:config.properties" />
    	</bean>
    
    	<!-- Log4J beállítás  -->
    	<bean
    		class="org.springframework.beans.factory.config.MethodInvokingFactoryBean">
    		<property name="targetClass" value="org.springframework.util.Log4jConfigurer" />
    		<property name="targetMethod" value="initLogging" />
    		<property name="arguments">
    			<list>
    				<value>classpath:log4j.xml</value>
    			</list>
    		</property>
    	</bean>
    
    	<!-- Collect annotated bean 
    	<context:component-scan base-package="com.com" />
    	-->
    	<context:component-scan base-package="com.MQReader" />
    
    	<bean id="connectionFactoryFCC" class="com.ibm.mq.jms.MQQueueConnectionFactory">
    		<property name="hostName" value="${MQ_FCC_HOST}" />
    		<property name="port" value="${MQ_FCC_PORT}" />
    		<property name="queueManager" value="${MQ_FCC_QUEUE_MANAGGER}" />
    		<property name="CCSID" value="${MQ_FCC_CCSID}" />
    		<property name="channel" value="${MQ_FCC_CHANNEL}" />
    		<property name="transportType">
    			<util:constant static-field="com.ibm.mq.jms.JMSC.MQJMS_TP_CLIENT_MQ_TCPIP" />
    		</property>
    	</bean>
    
    
    	<!-- JMS Queue Template !!! WRONG !!! --> 
    	<bean id="jmsQueueTemplateFCC" class="org.springframework.jms.core.JmsTemplate">
    		<property name="connectionFactory">
    			<ref bean="connectionFactoryFCC" />
    		</property>
    		<property name="JMS_IBM_Feedback">
    			<value>0</value>
    		</property>
    		<property name="JMS_IBM_Encoding">
    			<util:constant static-field="com.ibm.mq.MQC.MQENC_NATIVE" />
    		</property>
    		<property name="JMS_IBM_Character_Set">
    			<value>819</value>
    		</property>
    		<property name="JMS_IBM_Format">
    			<value>MQRFH2</value>
    		</property>
    		<property name="JMS_IBM_MsgType">
    			<util:constant static-field="com.ibm.mq.MQC.MQMT_DATAGRAM" />
    		</property>
    		<property name="JMSDeliveryMode">
    			<util:constant static-field="com.ibm.mq.MQC.MQPER_PERSISTENT" />
    		</property>
    		<property name="SOURCE">
    			<value>${MQ_FCC_SOURCE}</value>
    		</property>
    		<property name="DESTINATION">
    			<value>${MQ_FCC_DEST}</value>
    		</property>
    		<property name="JMSType">
    			<value>${GF_MSG_NAME}</value>
    		</property>
    	</bean>
    	
    
    
    	<!-- Output messages  -->
    	
    	<si:gateway id="outputMqMessage" service-interface="com.MQReader.OutputMqMessage" />
    
    	<si:channel id="outMessSplit" />
    	<si:channel id="outMessRouter" />
    	<si:channel id="outMessChFccQ" ><si:queue capacity="100"/></si:channel>
    	
    	<si:channel id="outMessChFcc" />
    	
    	<si:channel id="outMessSendFcc" />
    
    	<si:bridge input-channel="outMessChFccQ" output-channel="outMessChFcc">
    	</si:bridge>
    
    	<jms:outbound-channel-adapter id="sendMessageFcc" 
    								  destination-name="${MQ_FCC_OUTPUT_QUEUE}"
    								  jms-template="jmsQueueTemplateFCC"
    								  channel="outMessSendFcc" />
    
    
    </beans>
    Do you have any idea, how can I do it?

    Thx!
    Feri

  • #2
    I think you might want to have a look at the Spring Integration <header-enricher> component. That can precede your outbound JMS adapter. Alternatively, you can customize the HeaderMapper of an outbound JMS adapter (and reference it via the 'header-mapper' attribute).

    HTH,
    Mark

    Comment


    • #3
      In addition, do make sure that targetClient is set as "0" (MQDestination.setTargetClient(0))

      We faced similar issue, where in any headers set before sending the message via JMS Adapter were getting lost and RFH2 was not getting populated at all. This wasted a lot of time actually, as you will see in logs that the JMS message contains all the header values, but at receiving end, those are not present.

      We are using weblogic<-->websphere communication, and have configured things via MQ bindings, and this targetClient change was made in the ".bindings" file to make things work.

      Thought, might be helpful for you...

      Comment


      • #4
        Send message By WebSPhere MQ

        Hi Mark,

        Thanks your answer, but it doesn't work. I think my problem is not the message header. As I can check, the MQ manager don'T get my message.
        I tkae the codes:

        Code:
        <?xml version="1.0" encoding="UTF-8" standalone="no"?>
        <beans xmlns="http://www.springframework.org/schema/beans"
        	xmlns:context="http://www.springframework.org/schema/context" 
        	xmlns:tx="http://www.springframework.org/schema/tx"
        	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
        	xmlns:si="http://www.springframework.org/schema/integration"
        	xmlns:file="http://www.springframework.org/schema/integration/file"
        	xmlns:util="http://www.springframework.org/schema/util" 
        	xmlns:jms="http://www.springframework.org/schema/integration/jms"
        	xmlns:integration="http://www.springframework.org/schema/integration"
        	xmlns:stream="http://www.springframework.org/schema/integration/stream"
        	xmlns:ws="http://www.springframework.org/schema/integration/ws"
        	xsi:schemaLocation="http://www.springframework.org/schema/beans 
        	http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
        	http://www.springframework.org/schema/aop 
        	http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
        	http://www.springframework.org/schema/context 
        	http://www.springframework.org/schema/context/spring-context-3.0.xsd
        	http://www.springframework.org/schema/jee 
        	http://www.springframework.org/schema/jee/spring-jee-3.0.xsd
        	http://www.springframework.org/schema/tx 
        	http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
        	http://www.springframework.org/schema/integration
            http://www.springframework.org/schema/integration/spring-integration-2.0.xsd
            http://www.springframework.org/schema/integration/file
            http://www.springframework.org/schema/integration/file/spring-integration-file-2.0.xsd
            http://www.springframework.org/schema/integration/jms
            http://www.springframework.org/schema/integration/jms/spring-integration-jms-2.0.xsd
            http://www.springframework.org/schema/util
            http://www.springframework.org/schema/util/spring-util-3.0.xsd
            http://www.springframework.org/schema/integration/stream
            http://www.springframework.org/schema/integration/stream/spring-integration-stream-2.0.xsd
            http://www.springframework.org/schema/integration/ws 
            http://www.springframework.org/schema/integration/ws/spring-integration-ws-2.0.xsd">
        
        	<!-- Property-file betöltése  -->
        	<bean id="placeholderConfig"
        		class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        		<property name="location" value="classpath:config.properties" />
        	</bean>
        
        	<!-- Log4J beállítás  -->
        	<bean
        		class="org.springframework.beans.factory.config.MethodInvokingFactoryBean">
        		<property name="targetClass" value="org.springframework.util.Log4jConfigurer" />
        		<property name="targetMethod" value="initLogging" />
        		<property name="arguments">
        			<list>
        				<value>classpath:log4j.xml</value>
        			</list>
        		</property>
        	</bean>
        
        	<context:component-scan base-package="com.MQReader" />
        
        
        	<bean id="connectionFactoryFCC" class="com.ibm.mq.jms.MQQueueConnectionFactory">
        		<property name="hostName" value="${MQ_FCC_HOST}" />
        		<property name="port" value="${MQ_FCC_PORT}" />
        		<property name="queueManager" value="${MQ_FCC_QUEUE_MANAGGER}" />
        		<property name="CCSID" value="${MQ_FCC_CCSID}" />
        		<property name="channel" value="${MQ_FCC_CHANNEL}" />
        		<property name="transportType">
        			<util:constant static-field="com.ibm.mq.jms.JMSC.MQJMS_TP_CLIENT_MQ_TCPIP" />
        		</property>
        	</bean>
        
        
        	<si:annotation-config />
        
        	<si:gateway id="outMqMessage" service-interface="com.MQReader.OutMqMessage" />
        
        	<si:channel id="outMessSplit" />
        	<si:channel id="outMessRouter" />
            
        	<si:channel id="outMessChFccQ" ><si:queue capacity="100"/></si:channel>
        	
        	<si:channel id="outMessChFcc" />
        	
        	<si:channel id="outMessSendFcc" />
        
        	<si:channel id="outMessSendFccWS" />
        
        	<si:bridge input-channel="outMessChFccQ" output-channel="outMessChFcc">
        	</si:bridge>
        
        	<integration:chain input-channel="outMessChFcc" output-channel="outMessSendFccWS">
        		<integration:header-enricher>
        			<integration:header name="JMS_IBM_Feedback" value="0"/>
        			<integration:header name="JMS_IBM_Feedback" value="0"/> 
        			<!--
        			<property name="JMS_IBM_Encoding">
        				<util:constant static-field="com.ibm.mq.MQC.MQENC_NATIVE" />
        			</property>
        			-->
        			<integration:header name="JMS_IBM_Encoding" value="273" />
        			<integration:header name="JMS_IBM_Character_Set" value="819" />
        			<integration:header name="JMS_IBM_Format" value="MQRFH2" />
        			<!--
        			<property name="JMS_IBM_MsgType">
        				<util:constant static-field="com.ibm.mq.MQC.MQMT_DATAGRAM" />
        			</property>
        			-->
        			<integration:header name="JMS_IBM_MsgType" value="8" />
        			<!--
        			<property name="JMSDeliveryMode">
        				<util:constant static-field="com.ibm.mq.MQC.MQPER_PERSISTENT" />
        			</property>
        			-->
        			<integration:header name="JMSDeliveryMode" value="1" />
        			
        			<integration:header name="SOURCE" value="${MQ_FCC_SOURCE}" />
        			<integration:header name="DESTINATION" value="${MQ_FCC_DEST}" />
        			<integration:header name="JMSType" value="${GF_MSG_NAME}" />
        		</integration:header-enricher>
        	</integration:chain>
        
        	<jms:outbound-channel-adapter id="sendMessageFcc" 
        	                              connection-factory="connectionFactoryFCC"
        								  destination-name="${MQ_FCC_OUTPUT_QUEUE}"
        								  channel="outMessSendFccWS" />
        								  
        </beans>
        The start of sending:

        Code:
        		ApplicationContext lCtx = new ClassPathXmlApplicationContext(lParFiles);        
        
        		OutMqMessage lMess = lCtx.getBean(OutMqMessage.class);
        		
        		lMess.getMessage(getFile("/app/custacupd/gen/CAU_20101028B10102846222_00000.xml"));
        Splitter:

        Code:
        import java.util.ArrayList;
        import java.util.List;
        
        import org.springframework.integration.annotation.MessageEndpoint;
        import org.springframework.integration.annotation.Splitter;
        
        @MessageEndpoint
        public class OutMqSplitter
        {
        	
        	@Splitter(inputChannel = "outMessSplit", outputChannel = "outMessRouter")
        	public List<String> convert(String pMessage)
        	{
        		List<String> lRetV = new ArrayList<String>();
        		
        		lRetV.add(pMessage);
        		
        		return lRetV;
        	}
        }
        The router:
        Code:
        import org.springframework.integration.annotation.MessageEndpoint;
        import org.springframework.integration.annotation.Router;
        
        @MessageEndpoint
        public class OutMqRouter
        {
        
        	@Router(inputChannel="outMessRouter")
        	public String resolveMqMessChannel(String pMessage)
        	{
        		return "outMessChFccQ";
        	}
        }
        The router get the message, but I don't know what happen after that.

        I think I do somthing wrong, but I don't know what.
        Do you have any idea?

        Thx!
        Feri
        Last edited by take5; Nov 26th, 2010, 04:31 AM.

        Comment


        • #5
          Send message By WebSPhere MQ

          I try to change the setup.
          One of my idea was the usage of JmsTemplate.
          I made a class what is inherited from JmsTemplate:

          Code:
          public class SimpleMessageProducer
          {
          
              @Autowired
              MqJmsTemplate jmsTemplate;
          
              protected int numberOfMessages = 100;
          
              public void sendMessages(final String PMessage) throws JMSException
              {
                  {
          
                      jmsTemplate.send(new MessageCreator()
                      {
                          @Override
                          public Message createMessage(Session session) throws JMSException
                          {
                              System.out.println("CREATE MESSAGE");
                              
                              BytesMessage lByteMessage = session.createBytesMessage();
                              
                              lByteMessage.setIntProperty("JMS_IBM_Feedback", 0);
                              lByteMessage.setIntProperty("JMS_IBM_Encoding", MQC.MQENC_NATIVE);
                              lByteMessage.setIntProperty("JMS_IBM_Character_Set", 819);
                              lByteMessage.setStringProperty("JMS_IBM_Format", "MQRFH2");
          
                              lByteMessage.setIntProperty("JMS_IBM_MsgType", MQC.MQMT_DATAGRAM);
                              lByteMessage.setJMSPriority(5);
          
                              lByteMessage.setJMSDeliveryMode(MQC.MQPER_PERSISTENT);                 // PESISTENCE
                              
          //                    lByteMessage.setStringProperty("SOURCE", fParams.getMqSource());
                              lByteMessage.setStringProperty("SOURCE", jmsTemplate.getSource());
                              
          //                    lByteMessage.setStringProperty("DESTINATION", fParams.getMqDest());  
                              lByteMessage.setStringProperty("DESTINATION", jmsTemplate.getDestination());  
                              
          //                    lByteMessage.setJMSType("mcd://jms_text//" + PMessageName);
                              lByteMessage.setJMSType("mcd://jms_text//" + jmsTemplate.getJmsType());
                              
                              try
                              {
                                  lByteMessage.writeBytes(PMessage.getBytes("UTF8"));
                              }
                              catch (Exception e)
                              {
                                  
                              }
                              
                              return lByteMessage;
                          }
                      });
                  }
              }
          }
          and change the setup:

          Code:
             <bean id="producerTemplate" 
                    class="com.MQReader.MqJmsTemplate" >
                 <property name="connectionFactory">
                      <ref bean="connectionFactoryFCC"/>
                 </property>
                 <property name="Source" value="${MQ_FCC_SOURCE}" />
                 <property name="Destination" value="${MQ_FCC_DEST}" />
                 <property name="JmsType" value="${GF_MSG_NAME}" />
              </bean>
          
              <jms:outbound-channel-adapter id="sendMessageFcc" 
                              jms-template="producerTemplate"
                              destination-name="${MQ_FCC_OUTPUT_QUEUE}"
                              channel="outMessChFccQ" />
          As you see I changed the channel.
          Then the message sented, but it was absolutelly wrong. (Missing RFH2 header.)

          I dont't understand,
          why not run my own class message-creator part,
          why not work the brigde. If I take the bidge output-channel to outboud-channel-adapter channel, it doesn't work.

          Can help me anybody, what is the problem?

          Thank you!
          Feri

          Comment


          • #6
            I don't quite understand what you are trying to do with the JmsTemplate extension there. How would it know how to use your custom MessageCreator logic? From the example that you are showing, you are only implementing that MessageCreator in some other class: SimpleMessageProducer.

            Also, I would recommend having a look at DefaultJmsHeaderMapper. That is responsible for mapping from MessageHeaders to the JMS properties. Maybe that will give you some ideas.

            HTH,
            Mark

            Comment


            • #7
              Send message By WebSPhere MQ

              Hi Mark,

              Thank you your answer, that was what show me the path what I need.
              The solution is next:

              Configuartion:
              Code:
                  <bean id="connectionFactoryFCC" class="com.ibm.mq.jms.MQQueueConnectionFactory">
                      <property name="hostName" value="${MQ_FCC_HOST}" />
                      <property name="port" value="${MQ_FCC_PORT}" />
                      <property name="queueManager" value="${MQ_FCC_QUEUE_MANAGGER}" />
                      <property name="CCSID" value="${MQ_FCC_CCSID}" />
                      <property name="channel" value="${MQ_FCC_CHANNEL}" />
                      <property name="transportType">
                          <util:constant static-field="com.ibm.mq.jms.JMSC.MQJMS_TP_CLIENT_MQ_TCPIP" />
                      </property>
                  </bean>
              
                  <si:gateway id="outMqMessage" service-interface="com.MQReader.OutMqMessage" />
              
                  <si:channel id="outMessSplit" />
                  <si:channel id="outMessRouter" />
              	
                  <si:channel id="outMessSendFcc" />
              
                  <bean id="mqMsgConv" class="com.MQReader.MqMsgConv" >
                      <property name="Source" value="${MQ_FCC_SOURCE}" />
                      <property name="Destination" value="${MQ_FCC_DEST}" />
                      <property name="JmsType" value="${GF_MSG_NAME}" />
                  </bean>
              	
                  <bean id="outputDestination" class="com.ibm.mq.jms.MQQueue">
                      <constructor-arg value="${MQ_FCC_OUTPUT_QUEUE}"/>
                      <property name="TargetClient">
                          <util:constant static-field="com.ibm.mq.jms.JMSC.MQJMS_CLIENT_JMS_COMPLIANT" />
                      </property>
                  </bean>
              
                  <jms:outbound-channel-adapter id="sendMessageFcc" 
                                                connection-factory="connectionFactoryFCC"
                                                destination="outputDestination"
                                                channel="outMessSendFcc"
                                                message-converter="mqMsgConv"
                                                />
              In definition of output queue is very important the TargetClient settings, because this told that this message has RFH2 header.

              The needed values set in my class:
              Code:
              public class MqMsgConv implements MessageConverter
              {
              
                  String Source;
                  String Destination;
                  String JmsType;
                  
                  public String getSource()
                  {
                      return Source;
                  }
                  public void setSource(String source)
                  {
                      Source = source;
                  }
                  public String getDestination()
                  {
                      return Destination;
                  }
                  public void setDestination(String destination)
                  {
                      Destination = destination;
                  }
                  public String getJmsType()
                  {
                      return JmsType;
                  }
                  public void setJmsType(String jmsType)
                  {
                      JmsType = jmsType;
                  }
                  
                  @Override
                  public Object fromMessage(Message arg0) throws JMSException, MessageConversionException
                  {
                      // TODO Auto-generated method stub
                      System.out.println("MessageConverter fromMessage (arg0): " + arg0);
                      return (arg0);
                  }
              
                  @Override
                  public Message toMessage(Object arg0, Session arg1) throws JMSException, MessageConversionException
                  {
                      System.out.println("toMessage (arg0): " + arg0);
                      return getBMess((String)arg0, arg1);
                  }
              
                  private BytesMessage getBMess(String pMess, Session pSess)
                  {
                      BytesMessage lBytesMess = null;
                      
                      try
                      {
                          
                          lBytesMess = pSess.createBytesMessage();
              
                          lBytesMess.setIntProperty("JMS_IBM_Feedback", 0);
                          lBytesMess.setIntProperty("JMS_IBM_Encoding", MQC.MQENC_NATIVE);
                          lBytesMess.setIntProperty("JMS_IBM_Character_Set", 819);
                          lBytesMess.setStringProperty("JMS_IBM_Format", "MQRFH2");
              
                          lBytesMess.setIntProperty("JMS_IBM_MsgType", MQC.MQMT_DATAGRAM);
                          lBytesMess.setJMSPriority(5);
              
                          // PESISTENCE
                          lBytesMess.setJMSDeliveryMode(MQC.MQPER_PERSISTENT);                 
                          
                          //mqrfh2 <usr>    
                          lBytesMess.setStringProperty("SOURCE", getSource());
              
                          //CUBEBLSZ
                          lBytesMess.setStringProperty("DESTINATION", getDestination());  
              
                          //mqrfh2 <mcd> 
                          lBytesMess.setJMSType("mcd://jms_text//" + getJmsType());
                          
                          lBytesMess.writeBytes(pMess.getBytes("UTF8"));
                      }
                      catch (Exception e)
                      {
                          
                      }
                      return lBytesMess;
                  }
              If I use this solution, then the message sending worr correctly.

              Thank you your help!
              Feri
              Last edited by take5; Dec 1st, 2010, 06:55 AM.

              Comment


              • #8
                I'm glad you were able to get it working. However, it still seems to me that you could accomplish what you're doing there with just the HeaderMapper strategy instead of a full MessageConverter. Did you try that, and if so, did you encounter a limitation with that approach?

                Thanks,
                Mark

                Comment


                • #9
                  Hi Mark,

                  That is the true I looking for users guide or sample about header mapper strategy, but it was not successfull. (That is tre real possibility, it is my mistake! )
                  But, when I checked the outbound-channel-adapter possible properties, and then I saw the message-converter prop. I check the net aboit it, and I found some solution, and I understand the logic of integration.
                  As you see, I did it without spring, but when I try to use spring then I see I need this solution.

                  Thank you!
                  Feri

                  Comment

                  Working...
                  X