move test helpers to _test.go file

Author: kron4eg

cony.go

@@ -46,44 +46,3 @@ type mqChannel interface {
 	Publish(string, string, bool, bool, amqp.Publishing) error
 	Qos(int, int, bool) error
 }
-
-type mqDeleterTest struct {
-	_deletePublisher func(*Publisher)
-	_deleteConsumer  func(*Consumer)
-}
-
-func (m *mqDeleterTest) deletePublisher(p *Publisher) {
-	m._deletePublisher(p)
-}
-
-func (m *mqDeleterTest) deleteConsumer(c *Consumer) {
-	m._deleteConsumer(c)
-}
-
-type mqChannelTest struct {
-	_Close       func() error
-	_Consume     func(string, string, bool, bool, bool, bool, amqp.Table) (<-chan amqp.Delivery, error)
-	_NotifyClose func(chan *amqp.Error) chan *amqp.Error
-	_Publish     func(string, string, bool, bool, amqp.Publishing) error
-	_Qos         func(int, int, bool) error
-}
-
-func (m *mqChannelTest) Close() error {
-	return m._Close()
-}
-
-func (m *mqChannelTest) Consume(name string, tag string, autoAck bool, exclusive bool, noLocal bool, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error) {
-	return m._Consume(name, tag, autoAck, exclusive, noLocal, noWait, args)
-}
-
-func (m *mqChannelTest) NotifyClose(c chan *amqp.Error) chan *amqp.Error {
-	return m._NotifyClose(c)
-}
-
-func (m *mqChannelTest) Publish(exchange string, key string, mandatory bool, immediate bool, msg amqp.Publishing) error {
-	return m._Publish(exchange, key, mandatory, immediate, msg)
-}
-
-func (m *mqChannelTest) Qos(prefetchCount int, prefetchSize int, global bool) error {
-	return m._Qos(prefetchCount, prefetchSize, global)
-}

cony_test.go

@@ -0,0 +1,44 @@
+package cony
+
+import "github.com/streadway/amqp"
+
+type mqDeleterTest struct {
+	_deletePublisher func(*Publisher)
+	_deleteConsumer  func(*Consumer)
+}
+
+func (m *mqDeleterTest) deletePublisher(p *Publisher) {
+	m._deletePublisher(p)
+}
+
+func (m *mqDeleterTest) deleteConsumer(c *Consumer) {
+	m._deleteConsumer(c)
+}
+
+type mqChannelTest struct {
+	_Close       func() error
+	_Consume     func(string, string, bool, bool, bool, bool, amqp.Table) (<-chan amqp.Delivery, error)
+	_NotifyClose func(chan *amqp.Error) chan *amqp.Error
+	_Publish     func(string, string, bool, bool, amqp.Publishing) error
+	_Qos         func(int, int, bool) error
+}
+
+func (m *mqChannelTest) Close() error {
+	return m._Close()
+}
+
+func (m *mqChannelTest) Consume(name string, tag string, autoAck bool, exclusive bool, noLocal bool, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error) {
+	return m._Consume(name, tag, autoAck, exclusive, noLocal, noWait, args)
+}
+
+func (m *mqChannelTest) NotifyClose(c chan *amqp.Error) chan *amqp.Error {
+	return m._NotifyClose(c)
+}
+
+func (m *mqChannelTest) Publish(exchange string, key string, mandatory bool, immediate bool, msg amqp.Publishing) error {
+	return m._Publish(exchange, key, mandatory, immediate, msg)
+}
+
+func (m *mqChannelTest) Qos(prefetchCount int, prefetchSize int, global bool) error {
+	return m._Qos(prefetchCount, prefetchSize, global)
+}