diff --git a/in_session.go b/in_session.go index 663e115a5..50666a703 100644 --- a/in_session.go +++ b/in_session.go @@ -290,8 +290,6 @@ func (state inSession) processReject(session *session, msg *Message, rej Message } nextState.messageStash[TypedError.ReceivedTarget] = msg - // Do not reclaim stashed message. - msg.keepMessage = true return nextState diff --git a/message.go b/message.go index 63dca9043..36aef1dda 100644 --- a/message.go +++ b/message.go @@ -104,9 +104,6 @@ type Message struct { // Field bytes as they appear in the raw message. fields []TagValue - - // Flag is true if this message should not be returned to pool after use. - keepMessage bool } // ToMessage returns the message itself.