Revert "Support for AutoAckOff"

This reverts commit e28a1db.

message.go

@@ -36,8 +36,6 @@ type Message interface {
 	MessageID() uint16
 	Payload() []byte
 	Ack()
-	NoAutoAck() bool
-	AutoAckOff()
 }
 
 type message struct {
@@ -49,7 +47,6 @@ type message struct {
 	payload   []byte
 	once      sync.Once
 	ack       func()
-	noautoack bool
 }
 
 func (m *message) Duplicate() bool {
@@ -80,14 +77,6 @@ func (m *message) Ack() {
 	m.once.Do(m.ack)
 }
 
-func (m *message) NoAutoAck() bool {
-	return m.noautoack
-}
-
-func (m *message) AutoAckOff() {
-	m.noautoack = true
-}
-
 func messageFromPublish(p *packets.PublishPacket, ack func()) Message {
 	return &message{
 		duplicate: p.Dup,
@@ -97,7 +86,6 @@ func messageFromPublish(p *packets.PublishPacket, ack func()) Message {
 		messageID: p.MessageID,
 		payload:   p.Payload,
 		ack:       ack,
-		noautoack: false,
 	}
 }
 

router.go

@@ -186,9 +186,7 @@ func (r *router) matchAndDispatch(messages <-chan *packets.PublishPacket, order
 						wg.Add(1)
 						go func() {
 							hd(client, m)
-							if !m.NoAutoAck() {
-								m.Ack()
-							}
+							m.Ack()
 							wg.Done()
 						}()
 					}
@@ -203,9 +201,7 @@ func (r *router) matchAndDispatch(messages <-chan *packets.PublishPacket, order
 						wg.Add(1)
 						go func() {
 							r.defaultHandler(client, m)
-							if !m.NoAutoAck() {
-								m.Ack()
-							}
+							m.Ack()
 							wg.Done()
 						}()
 					}
@@ -216,9 +212,7 @@ func (r *router) matchAndDispatch(messages <-chan *packets.PublishPacket, order
 			r.RUnlock()
 			for _, handler := range handlers {
 				handler(client, m)
-				if !m.NoAutoAck() {
-					m.Ack()
-				}
+				m.Ack()
 			}
 			// DEBUG.Println(ROU, "matchAndDispatch handled message")
 		}