This repository has been archived by the owner on Jan 30, 2020. It is now read-only.
/
put_xmit_q.rb
72 lines (69 loc) · 2.5 KB
/
put_xmit_q.rb
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
#
# Sample : put() : Put a message to a queue with a Transmission header
#
require 'wmq'
WMQ::QueueManager.connect(q_mgr_name: 'REID') do |qmgr|
qmgr.open_queue(q_name: 'TEST.QUEUE', mode: :output) do |queue|
message = WMQ::Message.new
message.data = "Test message from 'LOCALQMS1'"
message.descriptor = {
original_length: -1,
priority: 0,
put_time: '18510170',
msg_id: "AMQ LOCALQMS1 E\233\001\237 \000\003\005",
expiry: -1,
persistence: 0,
reply_to_q: 'MQMON',
correl_id: "AMQ LOCALQMS1 E\233\001\237 \000\003\004",
feedback: 0,
offset: 0,
report: 0,
msg_flags: 0,
reply_to_q_mgr: 'LOCALQMS1',
appl_identity_data: '',
put_appl_name: 'LOCALQMS1',
user_identifier: 'mqm',
msg_seq_number: 1,
appl_origin_data: '',
accounting_token: "\026\001\005\025\000\000\000\271U\305\002\261\022\362\321\021D\3206\357\003\000\000\000\000\000\000\000\000\000\000\v",
backout_count: 0,
coded_char_set_id: 437,
put_appl_type: 7,
msg_type: 8,
group_id: '',
put_date: '20070109',
format: 'MQSTR',
encoding: 546
}
message.headers =
[
{
priority: 0,
remote_q_mgr_name: 'OTHER.QMGR',
put_time: '18510170',
msg_id: "AMQ LOCALQMS1 E\233\001\237 \000\003\004",
expiry: -1,
persistence: 0,
remote_q_name: 'OTHER.Q',
header_type: :xmit_q_header,
reply_to_q: 'MQMON',
correl_id: '',
feedback: 0,
report: 0,
reply_to_q_mgr: 'LOCALQMS1',
appl_identity_data: '',
put_appl_name: "uments\\MQ\\MQMon\\mqmonntp.exe",
user_identifier: 'mqm',
appl_origin_data: '',
accounting_token: "\026\001\005\025\000\000\000\271U\305\002\261\022\362\321\021D\3206\357\003\000\000\000\000\000\000\000\000\000\000\v",
backout_count: 0,
coded_char_set_id: 437,
put_appl_type: 11,
msg_type: 8,
put_date: '20070109',
encoding: 546
}
]
queue.put(message: message)
end
end