fix typos

CONTRIBUTING.md

@@ -1,4 +1,4 @@
-## Prequisites
+## Prerequisites
 
 1. Go: [https://golang.org/dl/](https://golang.org/dl/)
 1. Golint `go get -u -v github.com/golang/lint/golint`

_examples/pubsub/pubsub.go

@@ -25,7 +25,7 @@ var url = flag.String("url", "amqp:///", "AMQP url for both the publisher and su
 const exchange = "pubsub"
 
 // message is the application type for a message.  This can contain identity,
-// or a reference to the recevier chan for further demuxing.
+// or a reference to the receiver chan for further demuxing.
 type message []byte
 
 // session composes an amqp.Connection with an amqp.Channel
@@ -168,7 +168,7 @@ func subscribe(sessions chan chan session, messages chan<- message) {
 			return
 		}
 
-		routingKey := "application specific routing key for fancy toplogies"
+		routingKey := "application specific routing key for fancy topologies"
 		if err := sub.QueueBind(queue, routingKey, exchange, false, nil); err != nil {
 			log.Printf("cannot consume without a binding to exchange: %q, %v", exchange, err)
 			return

connection_test.go

@@ -159,7 +159,7 @@ func TestConcurrentClose(t *testing.T) {
 	wg.Wait()
 }
 
-// TestPlaintextDialTLS esnures amqp:// connections succeed when using DialTLS.
+// TestPlaintextDialTLS ensures amqp:// connections succeed when using DialTLS.
 func TestPlaintextDialTLS(t *testing.T) {
 	uri, err := ParseURI(integrationURLFromEnv())
 	if err != nil {

delivery.go

@@ -12,7 +12,7 @@ import (
 var errDeliveryNotInitialized = errors.New("delivery not initialized")
 
 // Acknowledger notifies the server of successful or failed consumption of
-// delivieries via identifier found in the Delivery.DeliveryTag field.
+// deliveries via identifier found in the Delivery.DeliveryTag field.
 //
 // Applications can provide mock implementations in tests of Delivery handlers.
 type Acknowledger interface {

doc.go

@@ -3,7 +3,7 @@
 // license that can be found in the LICENSE file.
 
 /*
-package amqp091 is an AMQP 0.9.1 client with RabbitMQ extensions
+Package amqp091 is an AMQP 0.9.1 client with RabbitMQ extensions
 
 Understand the AMQP 0.9.1 messaging model by reviewing these links first. Much
 of the terminology in this library directly relates to AMQP concepts.
@@ -58,7 +58,7 @@ of band from an RPC call like basic.ack or basic.flow.
 
 Any asynchronous events, including Deliveries and Publishings must always have
 a receiver until the corresponding chans are closed.  Without asynchronous
-receivers, the sychronous methods will block.
+receivers, the synchronous methods will block.
 
 Use Case
 

example_client_test.go

@@ -232,7 +232,7 @@ func (session *Session) Push(data []byte) error {
 // UnsafePush will push to the queue without checking for
 // confirmation. It returns an error if it fails to connect.
 // No guarantees are provided for whether the server will
-// recieve the message.
+// receive the message.
 func (session *Session) UnsafePush(data []byte) error {
 	if !session.isReady {
 		return errNotConnected

examples_test.go

@@ -13,7 +13,7 @@ import (
 )
 
 func ExampleConfig_timeout() {
-	// Provide your own anonymous Dial function that delgates to net.DialTimout
+	// Provide your own anonymous Dial function that delegates to net.DialTimout
 	// for custom timeouts
 
 	conn, err := amqp.DialConfig("amqp:///", amqp.Config{

read.go

@@ -13,7 +13,7 @@ import (
 )
 
 /*
-Reads a frame from an input stream and returns an interface that can be cast into
+ReadFrame reads a frame from an input stream and returns an interface that can be cast into
 one of the following:
 
    methodFrame

types.go

@@ -28,7 +28,7 @@ var (
 	ErrChannelMax = &Error{Code: ChannelError, Reason: "channel id space exhausted"}
 
 	// ErrSASL is returned from Dial when the authentication mechanism could not
-	// be negoated.
+	// be negotiated.
 	ErrSASL = &Error{Code: AccessRefused, Reason: "SASL could not negotiate a shared mechanism"}
 
 	// ErrCredentials is returned when the authenticated client is not authorized