Sent from my iPhone

> On 20-Sep-2016, at 11:31 AM, sari.reach [via Camel] 
> <ml-node+s465427n5787741...@n5.nabble.com> wrote:
> 
> 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; 
>                 } 
> 
> 
> 
> 
> 
> If you reply to this email, your message will be added to the discussion 
> below:
> http://camel.465427.n5.nabble.com/Camel-WebSphere-MQ-Integration-tp5787731p5787741.html
> To start a new topic under Camel - Users, email 
> ml-node+s465427n465428...@n5.nabble.com 
> To unsubscribe from Camel - Users, click here.
> NAML




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

Reply via email to