protected MQQueueManager mqQueueManager; public override void Open() { Hashtable properties = new Hashtable(); properties.Add(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES_MANAGED); properties.Add(MQC.HOST_NAME_PROPERTY, mq_hostName); properties.Add(MQC.CHANNEL_PROPERTY, mq_channel); properties.Add(MQC.PORT_PROPERTY, mq_port); properties.Add(MQC.USER_ID_PROPERTY, mq_userName); properties.Add(MQC.PASSWORD_PROPERTY, mq_password); properties.Add(MQC.USE_MQCSP_AUTHENTICATION_PROPERTY, true); try { mqQueueManager = new MQQueueManager(mq_queueManagerName, properties); Console.WriteLine("Connected to MQ"); } catch (MQException e) { log.Fatal("MQ Queue Manager creation Error", e); throw e; } }
var
This content, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)