diff --git a/ibm-mq/simple_subscriber.go b/ibm-mq/simple_subscriber.go index 2f8b8d0..15dc17d 100644 --- a/ibm-mq/simple_subscriber.go +++ b/ibm-mq/simple_subscriber.go @@ -4,7 +4,6 @@ import ( "context" "fmt" "github.com/ibm-messaging/mq-golang/v5/ibmmq" - "strings" ) type SubscriberConfig struct { @@ -82,7 +81,6 @@ func (c *SimpleSubscriber) Subscribe(ctx context.Context, handle func(context.Co for { msgAvail := true for msgAvail == true && err == nil { - var datalen int mqmd := ibmmq.NewMQMD() // The GET requires control structures, the Message Descriptor (MQMD) // and Get Options (MQGMO). Create those with default values. @@ -95,21 +93,18 @@ func (c *SimpleSubscriber) Subscribe(ctx context.Context, handle func(context.Co gmo.Options |= ibmmq.MQGMO_WAIT gmo.WaitInterval = c.WaitInterval // The WaitInterval is in milliseconds buffer := make([]byte, 0, 1024) - buffer, datalen, err = qObject.GetSlice(mqmd, gmo, buffer) + buffer, _, err = qObject.GetSlice(mqmd, gmo, buffer) if err != nil { msgAvail = false mqReturn := err.(*ibmmq.MQReturn) if mqReturn.MQRC != ibmmq.MQRC_NO_MSG_AVAILABLE { - fmt.Println("NO_MSG_AVAILABLE") handle(ctx, nil, nil, err) } else { err = nil } } else { msgAvail = true - fmt.Printf("Got message of length %d: ", datalen) - fmt.Println(strings.TrimSpace(string(buffer))) handle(ctx, buffer, nil, err) } } diff --git a/ibm-mq/subscriber.go b/ibm-mq/subscriber.go index d320075..c70d042 100644 --- a/ibm-mq/subscriber.go +++ b/ibm-mq/subscriber.go @@ -74,7 +74,6 @@ func (c *Subscriber) Subscribe(ctx context.Context, handle func(context.Context, for { msgAvail := true for msgAvail == true && err == nil { - var datalen int mqmd := ibmmq.NewMQMD() // The GET requires control structures, the Message Descriptor (MQMD) // and Get Options (MQGMO). Create those with default values. @@ -87,21 +86,18 @@ func (c *Subscriber) Subscribe(ctx context.Context, handle func(context.Context, gmo.Options |= ibmmq.MQGMO_WAIT // The WaitInterval is in milliseconds gmo.WaitInterval = c.WaitInterval buffer := make([]byte, 0, 1024) - buffer, datalen, err = qObject.GetSlice(mqmd, gmo, buffer) + buffer, _, err = qObject.GetSlice(mqmd, gmo, buffer) if err != nil { msgAvail = false mqReturn := err.(*ibmmq.MQReturn) if mqReturn.MQRC != ibmmq.MQRC_NO_MSG_AVAILABLE { - fmt.Println("NO_MSG_AVAILABLE") handle(ctx, nil, err) } else { err = nil } } else { msgAvail = true - fmt.Printf("Got message of length %d: ", datalen) - fmt.Println(strings.TrimSpace(string(buffer))) msg := mq.Message{Data: buffer} handle(ctx, &msg, err) }