use defaults in consumer

channel.go

@@ -46,7 +46,7 @@ func getNewChannel(url string, conf amqp.Config) (*amqp.Connection, *amqp.Channe
 	if err != nil {
 		return nil, nil, err
 	}
-	return amqpConn, ch, err
+	return amqpConn, ch, nil
 }
 
 // startNotifyCancelOrClosed listens on the channel's cancelled and closed

consume.go

@@ -90,13 +90,10 @@ func (consumer Consumer) StartConsuming(
 	optionFuncs ...func(*ConsumeOptions),
 ) error {
 	defaultOptions := getDefaultConsumeOptions()
-	options := &ConsumeOptions{}
+	options := &defaultOptions
 	for _, optionFunc := range optionFuncs {
 		optionFunc(options)
 	}
-	if options.Concurrency < 1 {
-		options.Concurrency = defaultOptions.Concurrency
-	}
 
 	err := consumer.startGoroutines(
 		handler,

examples/consumer/.gitignore

@@ -0,0 +1 @@
+consumer