Merge pull request #8 from djumanoff/feature/unbind_option

feat: unbind option

go.mod

@@ -4,3 +4,5 @@ require (
 	github.com/sirupsen/logrus v1.1.0
 	github.com/streadway/amqp v0.0.0-20180806233856-70e15c650864
 )
+
+go 1.13

server.go

@@ -25,6 +25,8 @@ type (
 	ServerConfig struct {
 		RequestX  string
 		ResponseX string
+		UnbindQsAtStop bool
+		UnbindExAtStop bool
 	}
 
 	server struct {
@@ -36,6 +38,8 @@ type (
 
 		requestX  string
 		responseX string
+		unbindQsAtStop bool
+		unbindExAtStop bool
 
 		qs []*Queue
 		xs []*Exchange
@@ -307,14 +311,18 @@ func (srv *server) Endpoint(endpoint string, handler Handler) error {
 }
 
 func (srv *server) cleanup() error {
-	srv.sess.log.Info("started cleanup server rec channels")
-	if err := srv.cleanupRec(); err != nil {
-		return err
+	if srv.unbindQsAtStop {
+		srv.sess.log.Info("started cleanup server rec channels")
+		if err := srv.cleanupRec(); err != nil {
+			return err
+		}
 	}
 
-	srv.sess.log.Info("started cleanup server sen channels")
-	if err := srv.cleanupSen(); err != nil {
-		return err
+	if srv.unbindExAtStop {
+		srv.sess.log.Info("started cleanup server sen channels")
+		if err := srv.cleanupSen(); err != nil {
+			return err
+		}
 	}
 
 	return nil

session.go

@@ -154,6 +154,8 @@ func (sess *session) createServer(cfg ServerConfig) (*server, error) {
 		close:     make(chan bool),
 		sen:       sen,
 		rec:       rec,
+		unbindExAtStop: cfg.UnbindExAtStop,
+		unbindQsAtStop: cfg.UnbindQsAtStop,
 	}
 
 	senCh := sen.NotifyClose(make(chan *amqp.Error))