Skip to content

Commit

Permalink
Revert "Channel exposes confirms in order to get sequential number of…
Browse files Browse the repository at this point in the history
… the published messages"

This reverts commit 94db825.

See #336 (comment).
  • Loading branch information
michaelklishin committed Feb 25, 2019
1 parent 1821d50 commit 30f8ed6
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 13 deletions.
5 changes: 0 additions & 5 deletions channel.go
Original file line number Diff line number Diff line change
Expand Up @@ -1588,8 +1588,3 @@ func (ch *Channel) Reject(tag uint64, requeue bool) error {
Requeue: requeue,
})
}

// Confirms returns control structure over confirm mode
func (ch *Channel) Confirms() *confirms {
return ch.confirms
}
8 changes: 0 additions & 8 deletions confirms.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,14 +20,6 @@ func newConfirms() *confirms {
}
}

// Published returns sequential number of published messages
func (c *confirms) Published() uint64 {
c.m.Lock()
defer c.m.Unlock()

return c.published
}

func (c *confirms) Listen(l chan Confirmation) {
c.m.Lock()
defer c.m.Unlock()
Expand Down

0 comments on commit 30f8ed6

Please sign in to comment.