From eae03a07b27c0cc53f309effb71633ba36a73139 Mon Sep 17 00:00:00 2001
From: Jose Robles <jose.robles@1ksfl-mbp-jose.robles>
Date: Thu, 19 Jul 2018 16:05:00 -0400
Subject: [PATCH] wip

---
 channel.go  |  6 ++++++
 producer.go | 16 +++++-----------
 2 files changed, 11 insertions(+), 11 deletions(-)

diff --git a/channel.go b/channel.go
index 72164be..39b9af1 100644
--- a/channel.go
+++ b/channel.go
@@ -28,3 +28,9 @@ func createChannel(conn *amqp.Connection) (*amqp.Channel, error) {
 		return channel, nil
 	}
 }
+
+func CloseChannel(channel *amqp.Channel) {
+
+	channel.Close()
+
+}
diff --git a/producer.go b/producer.go
index 4e024c8..af61097 100644
--- a/producer.go
+++ b/producer.go
@@ -1,8 +1,9 @@
 package conejo
 
 import (
-	"errors"
+	//"errors"
 	"github.com/streadway/amqp"
+	"log"
 )
 
 func Publish(conn *amqp.Connection, queue Queue, exchange Exchange, body string) error {
@@ -12,7 +13,7 @@ func Publish(conn *amqp.Connection, queue Queue, exchange Exchange, body string)
 		return err
 	}
 	channel.Confirm(false)
-	ack, nack := channel.NotifyConfirm(make(chan uint64, 1), make(chan uint64, 1))
+	//ack, nack := channel.NotifyConfirm(make(chan uint64, 1), make(chan uint64, 1))
 
 	err = declareExchange(exchange, channel)
 	if err != nil {
@@ -51,18 +52,11 @@ func Publish(conn *amqp.Connection, queue Queue, exchange Exchange, body string)
 				); err != nil {
 					return err
 				} else {
-
-					select {
-					case <-ack:
-						return nil
-					case <-nack:
-						err = errors.New("Message not acknowledged")
-						return err
-					}
+					log.Println("CONEJO: Channel closed")
+					channel.Close()
 				}
 			}
 		}
 	}
-	defer channel.Close()
 	return nil
 }