Skip to content

Commit 960cf5f

Browse files
committed
Add support for msg/hdr compression on MQCD (#137)
1 parent 35f3bf1 commit 960cf5f

File tree

1 file changed

+13
-2
lines changed

1 file changed

+13
-2
lines changed

ibmmq/mqiMQCD.go

Lines changed: 13 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -56,6 +56,8 @@ type MQCD struct {
5656
ConnectionAffinity int32
5757
DefReconnect int32
5858
CertificateLabel string
59+
HdrCompList [2]int32
60+
MsgCompList [16]int32
5961
}
6062

6163
/*
@@ -84,6 +86,15 @@ func NewMQCD() *MQCD {
8486
cd.DefReconnect = int32(C.MQRCN_NO)
8587
cd.CertificateLabel = ""
8688

89+
cd.HdrCompList[0] = int32(C.MQCOMPRESS_NONE)
90+
for i := 1; i < 2; i++ {
91+
cd.HdrCompList[i] = int32(C.MQCOMPRESS_NOT_AVAILABLE)
92+
}
93+
cd.MsgCompList[0] = int32(C.MQCOMPRESS_NONE)
94+
for i := 1; i < 16; i++ {
95+
cd.MsgCompList[i] = int32(C.MQCOMPRESS_NOT_AVAILABLE)
96+
}
97+
8798
return cd
8899
}
89100

@@ -173,10 +184,10 @@ func copyCDtoC(mqcd *C.MQCD, gocd *MQCD) {
173184
setMQIString((*C.char)(&mqcd.LocalAddress[0]), "", C.MQ_LOCAL_ADDRESS_LENGTH)
174185
mqcd.BatchHeartbeat = 0
175186
for i := 0; i < 2; i++ {
176-
mqcd.HdrCompList[i] = C.MQCOMPRESS_NOT_AVAILABLE
187+
mqcd.HdrCompList[i] = C.MQLONG(gocd.HdrCompList[i])
177188
}
178189
for i := 0; i < 16; i++ {
179-
mqcd.MsgCompList[i] = C.MQCOMPRESS_NOT_AVAILABLE
190+
mqcd.MsgCompList[i] = C.MQLONG(gocd.MsgCompList[i])
180191
}
181192
mqcd.CLWLChannelRank = 0
182193
mqcd.CLWLChannelPriority = 0

0 commit comments

Comments
 (0)