DaoMqPump2/DaoCommon/MQHelper.cs

using System;

using IBM.WMQ;
using System.Collections;

namespace DaoCommon
{
    public class MQHelper
    {
        public static void closeQueueSafe(MQQueue queue)
        {
            if (queue != null && queue.IsOpen)
            {
                try
                {
                    queue.Close();
                }
                catch (Exception e)
                {
                    Console.WriteLine("Error cleaning up queue " + e.Message);
                }
            }

        }

        public static void closeQueueManagerSafe(MQQueueManager mqMgr)
        {
            if (mqMgr != null && mqMgr.IsOpen)
            {
                try
                {
                    mqMgr.Close();
                }
                catch (Exception e)
                {
                    Console.WriteLine("Error cleaning up qmgr " + e.Message);
                }
            }
        }

        public static Hashtable getConnectionProperties(string mqHost, string mqChannel)
        {
            Hashtable connProperties = new Hashtable();
            connProperties.Add(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES_CLIENT);
            connProperties.Add(MQC.HOST_NAME_PROPERTY, mqHost);
            connProperties.Add(MQC.CHANNEL_PROPERTY, mqChannel);
            return connProperties;
        }
    }
}
1	torben	2172	using System;
2
3			using IBM.WMQ;
4			using System.Collections;
5
6			namespace DaoCommon
7			{
8			public class MQHelper
9			{
10			public static void closeQueueSafe(MQQueue queue)
11			{
12			if (queue != null && queue.IsOpen)
13			{
14			try
15			{
16			queue.Close();
17			}
18			catch (Exception e)
19			{
20			Console.WriteLine("Error cleaning up queue " + e.Message);
21			}
22			}
23
24			}
25
26			public static void closeQueueManagerSafe(MQQueueManager mqMgr)
27			{
28			if (mqMgr != null && mqMgr.IsOpen)
29			{
30			try
31			{
32			mqMgr.Close();
33			}
34			catch (Exception e)
35			{
36			Console.WriteLine("Error cleaning up qmgr " + e.Message);
37			}
38			}
39			}
40
41			public static Hashtable getConnectionProperties(string mqHost, string mqChannel)
42			{
43			Hashtable connProperties = new Hashtable();
44			connProperties.Add(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES_CLIENT);
45			connProperties.Add(MQC.HOST_NAME_PROPERTY, mqHost);
46			connProperties.Add(MQC.CHANNEL_PROPERTY, mqChannel);
47			return connProperties;
48			}
49			}
50			}