7 |
/* */ import com.ibm.mq.MQQueueManager; |
/* */ import com.ibm.mq.MQQueueManager; |
8 |
/* */ import java.io.IOException; |
/* */ import java.io.IOException; |
9 |
/* */ import java.io.OutputStreamWriter; |
/* */ import java.io.OutputStreamWriter; |
10 |
|
|
11 |
import java.util.Hashtable; |
import java.util.Hashtable; |
12 |
/* */ |
|
13 |
/* */ public class MQ |
|
14 |
|
/* */ public class MQ implements AutoCloseable |
15 |
/* */ { |
/* */ { |
16 |
/* */ MQQueueManager _qMgr; |
/* */ MQQueueManager _qMgr; |
17 |
/* */ MQQueue _mQQueue; |
/* */ MQQueue _mQQueue; |
70 |
/* 87 */ mQMessage.write(message); |
/* 87 */ mQMessage.write(message); |
71 |
/* 88 */ this._mQQueue.put(mQMessage); |
/* 88 */ this._mQQueue.put(mQMessage); |
72 |
/* */ } |
/* */ } |
73 |
/* */ |
/* */ |
74 |
|
@Override |
75 |
/* */ public void close() throws MQException { |
/* */ public void close() throws MQException { |
76 |
/* 92 */ if (this._mQQueue != null) |
/* 92 */ if (this._mQQueue != null) |
77 |
/* 93 */ this._mQQueue.close(); |
/* 93 */ this._mQQueue.close(); |
83 |
/* Location: C:\Users\thn\workspace\mq-utils.jar |
/* Location: C:\Users\thn\workspace\mq-utils.jar |
84 |
* Qualified Name: com.traiana.utils.mq.MQ |
* Qualified Name: com.traiana.utils.mq.MQ |
85 |
* JD-Core Version: 0.6.2 |
* JD-Core Version: 0.6.2 |
|
*/ |
|
86 |
|
*/ |