Skip to content

Commit c46f651

Browse files
committed
Remove unsused Message.keepMessage
Signed-off-by: Sylvain Rabot <[email protected]>
1 parent 7945e4b commit c46f651

File tree

2 files changed

+0
-5
lines changed

2 files changed

+0
-5
lines changed

in_session.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -275,8 +275,6 @@ func (state inSession) processReject(session *session, msg *Message, rej Message
275275
}
276276

277277
nextState.messageStash[TypedError.ReceivedTarget] = msg
278-
//do not reclaim stashed message
279-
msg.keepMessage = true
280278

281279
return nextState
282280

message.go

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -89,9 +89,6 @@ type Message struct {
8989

9090
//field bytes as they appear in the raw message
9191
fields []TagValue
92-
93-
//flag is true if this message should not be returned to pool after use
94-
keepMessage bool
9592
}
9693

9794
//ToMessage returns the message itself

0 commit comments

Comments
 (0)