camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "sari.reach" <sari.re...@gmail.com>
Subject Re: Camel- WebSphere MQ Integration
Date Tue, 20 Sep 2016 06:01:13 GMT
Hi souciane,

I am posting message to websphere queue with all the headers set to camel
message but this message is not published to MQ. However, when I try to
publish it with a standalone applciation, the message is published. Please
find sample code below.

message.setHeader("provider-uri", providerUri);
message.setHeader(JmsConstants.JMS_IBM_MQMD_APPLIDENTITYDATA,
                                                               
appIdententyData());
message.setHeader(JmsConstants.JMS_IBM_MQMD_MSGID, createMsgId());
message.setHeader(JmsConstants.JMS_IBM_MQMD_PERSISTENCE,
                                                               
MQC.MQPER_NOT_PERSISTENT);
MQMessage mqMessage = new MQMessage();
mqMessage.write(byte[])
message.setBody(mqMessage);

if (camelContext.getComponent(connName) == null) {     
              camelContext.addComponent(connName, JmsComponent                           
                                                   
.jmsComponent(createWMQConnection(wmqHost, mqPort,                                       
                                                                       
queueMngr, channel)));
 
                                }


                private UserCredentialsConnectionFactoryAdapter
createWMQConnection(
                                                String host, int port,
String queueMngr, String channel)
                                                throws JMSException {
 
                                MQEnvironment.CCSID = 943;
                                MQEnvironment.channel = channel;
                                MQEnvironment.hostname = host;
                                MQEnvironment.port = port;
 
                                MQPutMessageOptions pmo = new
MQPutMessageOptions();
 
                                pmo.options = MQC.MQPMO_FAIL_IF_QUIESCING
                                                                +
MQC.MQPMO_SET_IDENTITY_CONTEXT;
 
                                JmsFactoryFactory ff = JmsFactoryFactory
                                                               
.getInstance("com.ibm.msg.client.wmq");
                                JmsConnectionFactory cf =
ff.createConnectionFactory();
                                // Set the properties
                                cf.setStringProperty("XMSC_WMQ_HOST_NAME",
host);
                                cf.setIntProperty("XMSC_WMQ_PORT", port);
                                cf.setStringProperty("XMSC_WMQ_CHANNEL",
channel);
                                cf.setBooleanProperty("Use MQCSP
authentication", true);
                               
cf.setIntProperty("XMSC_WMQ_CONNECTION_MODE", 1);
                               
cf.setStringProperty("XMSC_WMQ_QUEUE_MANAGER", queueMngr);
 
                                ucf = new
UserCredentialsConnectionFactoryAdapter();
                                ucf.setTargetConnectionFactory(cf);
                                ucf.setUsername("JTB0001");
                                ucf.setPassword("1BOI6F4Ztgkd4X6EDNaQ9");
                                return ucf;
                }







--
View this message in context: http://camel.465427.n5.nabble.com/Camel-WebSphere-MQ-Integration-tp5787731p5787741.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Mime
View raw message