Merge pull request #10 from kron4eg/custom_channels

New options to define custom errors and blocking channels on *Client.

Author: pavel-d

.travis.yml

@@ -2,7 +2,8 @@ language: go
 
 go:
   - 1.4
-  - tip
+  - 1.5
+  - 1.6
 
 services:
   - rabbitmq

backoff.go

@@ -5,7 +5,7 @@ import (
 	"time"
 )
 
-// See: http://blog.gopheracademy.com/advent-2014/backoff/
+// DefaultBackoff See: http://blog.gopheracademy.com/advent-2014/backoff/
 var DefaultBackoff Backoffer = BackoffPolicy{
 	[]int{0, 10, 100, 200, 500, 1000, 2000, 3000, 5000},
 }

client.go

@@ -72,12 +72,14 @@ func (c *Client) deletePublisher(pub *Publisher) {
 	delete(c.publishers, pub)
 }
 
-// Errors returns AMQP connection level errors
+// Errors returns AMQP connection level errors. Default buffer size is 100.
+// Messages will be dropped in case if receiver can't keep up
 func (c *Client) Errors() <-chan error {
 	return c.errs
 }
 
-// Blocking notifies the server's TCP flow control of the Connection
+// Blocking notifies the server's TCP flow control of the Connection. Default
+// buffer size is 10. Messages will be dropped in case if receiver can't keep up
 func (c *Client) Blocking() <-chan amqp.Blocking {
 	return c.blocking
 }
@@ -231,9 +233,29 @@ func URL(addr string) ClientOpt {
 	}
 }
 
-// Backoff is a functional option, used to define backoff policy
+// Backoff is a functional option, used to define backoff policy, used in
+// `NewClient` constructor
 func Backoff(bo Backoffer) ClientOpt {
 	return func(c *Client) {
 		c.bo = bo
 	}
 }
+
+// ErrorsChan is a functional option, used to initialize error reporting channel
+// in client code, maintaining control over buffer size. Default buffer size is
+// 100. Messages will be dropped in case if receiver can't keep up, used in
+// `NewClient` constructor
+func ErrorsChan(errChan chan error) ClientOpt {
+	return func(c *Client) {
+		c.errs = errChan
+	}
+}
+
+// BlockingChan is a functional option, used to initialize blocking reporting
+// channel in client code, maintaining control over buffering, used in
+// `NewClient` constructor
+func BlockingChan(blockingChan chan amqp.Blocking) ClientOpt {
+	return func(c *Client) {
+		c.blocking = blockingChan
+	}
+}

doc_test.go

@@ -85,6 +85,16 @@ func ExampleURL() {
 	cony.NewClient(cony.URL("amqp://guest:guest@localhost/"))
 }
 
+func ExampleErrorsChan() {
+	errors := make(chan error, 100) // define custom buffer size
+	cony.NewClient(cony.ErrorsChan(errors))
+}
+
+func ExampleBlockingChan() {
+	blockings := make(chan amqp.Blocking, 100) // define custom buffer size
+	cony.NewClient(cony.BlockingChan(blockings))
+}
+
 func ExampleClient_Loop() {
 	client := cony.NewClient(cony.URL("amqp://guest:guest@localhost/"))