Send message By WebSPhere MQ

[take5]

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

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:

<?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

[Mark Fisher]

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

[GPS]

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...

[take5]

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:

<?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:

		ApplicationContext lCtx = new ClassPathXmlApplicationContext(lParFiles);        

		OutMqMessage lMess = lCtx.getBean(OutMqMessage.class);
		
		lMess.getMessage(getFile("/app/custacupd/gen/CAU_20101028B10102846222_00000.xml"));

Splitter:

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:

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

[take5]

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

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:

   <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

[Mark Fisher]

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

[take5]

Hi Mark,

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

Configuartion:

    <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:

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

[Mark Fisher]

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

[take5]

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