diff --git a/connection.go b/connection.go index 04de993..3d3f778 100644 --- a/connection.go +++ b/connection.go @@ -809,6 +809,8 @@ func (c *Connection) openTune(config Config, auth Authentication) error { config.Properties["capabilities"] = Table{ "connection.blocked": true, "consumer_cancel_notify": true, + "basic.nack": true, + "publisher_confirms": true, } ok := &connectionStartOk{