7 |
{ |
{ |
8 |
public class MQHelper |
public class MQHelper |
9 |
{ |
{ |
10 |
|
public static MQQueue openQueueHelper(string queueName, MQQueueManager mqMgr, int openOptions) |
11 |
|
{ |
12 |
|
try |
13 |
|
{ |
14 |
|
return mqMgr.AccessQueue(queueName, openOptions); |
15 |
|
} catch (MQException e) { |
16 |
|
throw new Exception("Error opening queue " + queueName + ": " + e.Message, e); |
17 |
|
} |
18 |
|
} |
19 |
|
|
20 |
public static void closeQueueSafe(MQQueue queue) |
public static void closeQueueSafe(MQQueue queue) |
21 |
{ |
{ |
22 |
if (queue != null && queue.IsOpen) |
if (queue != null && queue.IsOpen) |