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.