Skip to content

Commit 198e192

Browse files
committed
Add support for PCF integer filters
1 parent 71a2e85 commit 198e192

File tree

1 file changed

+15
-0
lines changed

1 file changed

+15
-0
lines changed

ibmmq/mqiPCF.go

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -251,6 +251,21 @@ func (p *PCFParameter) Bytes() []byte {
251251
offset += 4
252252
}
253253

254+
case C.MQCFT_INTEGER_FILTER:
255+
buf = make([]byte, C.MQCFIF_STRUC_LENGTH)
256+
offset := 0
257+
258+
endian.PutUint32(buf[offset:], uint32(p.Type))
259+
offset += 4
260+
endian.PutUint32(buf[offset:], uint32(len(buf)))
261+
offset += 4
262+
endian.PutUint32(buf[offset:], uint32(p.Filter.Parameter))
263+
offset += 4
264+
endian.PutUint32(buf[offset:], uint32(p.Filter.Operator))
265+
offset += 4
266+
endian.PutUint32(buf[offset:], uint32(p.Filter.FilterValue.(int32)))
267+
offset += 4
268+
254269
case C.MQCFT_STRING:
255270
buf = make([]byte, C.MQCFST_STRUC_LENGTH_FIXED+roundTo4(int32(len(p.String[0]))))
256271
offset := 0

0 commit comments

Comments
 (0)