Fix an error into channel object

_examples/consumer/consumer.go

@@ -12,7 +12,7 @@ import (
 	"syscall"
 	"time"
 
-	amqp "github.com/rabbitmq/amqp091-go"
+	amqp "github.com/killer-djon/rabbitmq-go"
 )
 
 var (

_examples/producer/producer.go

@@ -6,7 +6,7 @@ package main
 import (
 	"context"
 	"flag"
-	amqp "github.com/rabbitmq/amqp091-go"
+	amqp "github.com/killer-djon/rabbitmq-go"
 	"log"
 	"os"
 	"os/signal"

_examples/pubsub/pubsub.go

@@ -17,7 +17,7 @@ import (
 	"os"
 	"time"
 
-	amqp "github.com/rabbitmq/amqp091-go"
+	amqp "github.com/killer-djon/rabbitmq-go"
 )
 
 var url = flag.String("url", "amqp:///", "AMQP url for both the publisher and subscriber")

channel.go

@@ -389,27 +389,27 @@ func (ch *Channel) recvMethod(f frame) {
 		if msg, ok := frame.Method.(messageWithContent); ok {
 			ch.body = make([]byte, 0)
 			ch.message = msg
-			ch.transition((*Channel).recvHeader)
+			ch.transition(ch.recvHeader)
 			return
 		}
 
 		ch.dispatch(frame.Method) // termination state
-		ch.transition((*Channel).recvMethod)
+		ch.transition(ch.recvHeader)
 
 	case *headerFrame:
 		// drop
-		ch.transition((*Channel).recvMethod)
+		ch.transition(ch.recvHeader)
 
 	case *bodyFrame:
 		// drop
-		ch.transition((*Channel).recvMethod)
+		ch.transition(ch.recvHeader)
 
 	default:
 		panic("unexpected frame type")
 	}
 }
 
-func (ch *Channel) recvHeader(f frame) {
+func (ch *Channel) recvHeader(_ *Channel, f frame) {
 	switch frame := f.(type) {
 	case *methodFrame:
 		// interrupt content and handle method
@@ -422,14 +422,14 @@ func (ch *Channel) recvHeader(f frame) {
 		if frame.Size == 0 {
 			ch.message.setContent(ch.header.Properties, ch.body)
 			ch.dispatch(ch.message) // termination state
-			ch.transition((*Channel).recvMethod)
+			ch.transition(ch.recvHeader)
 			return
 		}
-		ch.transition((*Channel).recvContent)
+		ch.transition(ch.recvHeader)
 
 	case *bodyFrame:
 		// drop and reset
-		ch.transition((*Channel).recvMethod)
+		ch.transition(ch.recvHeader)
 
 	default:
 		panic("unexpected frame type")
@@ -446,7 +446,7 @@ func (ch *Channel) recvContent(f frame) {
 
 	case *headerFrame:
 		// drop and reset
-		ch.transition((*Channel).recvMethod)
+		ch.transition(ch.recvHeader)
 
 	case *bodyFrame:
 		if cap(ch.body) == 0 {
@@ -457,11 +457,11 @@ func (ch *Channel) recvContent(f frame) {
 		if uint64(len(ch.body)) >= ch.header.Size {
 			ch.message.setContent(ch.header.Properties, ch.body)
 			ch.dispatch(ch.message) // termination state
-			ch.transition((*Channel).recvMethod)
+			ch.transition(ch.recvHeader)
 			return
 		}
 
-		ch.transition((*Channel).recvContent)
+		ch.transition(ch.recvHeader)
 
 	default:
 		panic("unexpected frame type")

connection.go

@@ -986,7 +986,7 @@ func (c *Connection) openTune(config Config, auth Authentication) error {
 	}
 
 	// Edge case that may race with c.shutdown()
-	// https://github.com/rabbitmq/amqp091-go/issues/170
+	// https://github.com/killer-djon/rabbitmq-go/issues/170
 	c.m.Lock()
 
 	// When the server and client both use default 0, then the max channel is

connection_test.go

@@ -249,7 +249,7 @@ func TestChannelIsClosed(t *testing.T) {
 }
 
 // TestReaderGoRoutineTerminatesWhenMsgIsProcessedDuringClose tests the issue
-// described in https://github.com/rabbitmq/amqp091-go/issues/69.
+// described in https://github.com/killer-djon/rabbitmq-go/issues/69.
 func TestReaderGoRoutineTerminatesWhenMsgIsProcessedDuringClose(t *testing.T) {
 	const routines = 10
 	c := integrationConnection(t, t.Name())
@@ -340,7 +340,7 @@ func TestNewConnectionProperties_HasDefaultProperties(t *testing.T) {
 }
 
 // Connection and channels should be closeable when a memory alarm is active.
-// https://github.com/rabbitmq/amqp091-go/issues/178
+// https://github.com/killer-djon/rabbitmq-go/issues/178
 func TestConnection_Close_WhenMemoryAlarmIsActive(t *testing.T) {
 	err := rabbitmqctl(t, "set_vm_memory_high_watermark", "0.0001")
 	if err != nil {

consumers.go

@@ -76,8 +76,8 @@ func (subs *consumers) buffer(in chan *Delivery, out chan Delivery) {
 
 			case out <- *queue[0]:
 				/*
-				* https://github.com/rabbitmq/amqp091-go/issues/179
-				* https://github.com/rabbitmq/amqp091-go/pull/180
+				* https://github.com/killer-djon/rabbitmq-go/issues/179
+				* https://github.com/killer-djon/rabbitmq-go/pull/180
 				*
 				* Comment from @lars-t-hansen:
 				*

example_client_test.go

@@ -13,7 +13,7 @@ import (
 	"os"
 	"time"
 
-	amqp "github.com/rabbitmq/amqp091-go"
+	amqp "github.com/killer-djon/rabbitmq-go"
 )
 
 // This exports a Client object that wraps this library. It

examples_test.go

@@ -16,7 +16,7 @@ import (
 	"runtime"
 	"time"
 
-	amqp "github.com/rabbitmq/amqp091-go"
+	amqp "github.com/killer-djon/rabbitmq-go"
 )
 
 func ExampleConfig_timeout() {

go.mod

@@ -1,4 +1,5 @@
-module github.com/rabbitmq/amqp091-go
+//module github.com/rabbitmq/amqp091-go
+module github.com/killer-djon/rabbitmq-go
 
 go 1.16
 

integration_test.go

@@ -2025,7 +2025,7 @@ func TestIntegrationGetNextPublishSeqNo(t *testing.T) {
 	}
 }
 
-// https://github.com/rabbitmq/amqp091-go/pull/44
+// https://github.com/killer-djon/rabbitmq-go/pull/44
 func TestShouldNotWaitAfterConnectionClosedIssue44(t *testing.T) {
 	conn := integrationConnection(t, "TestShouldNotWaitAfterConnectionClosedIssue44")
 	ch, err := conn.Channel()
@@ -2120,7 +2120,7 @@ func assertConsumeBody(t *testing.T, messages <-chan Delivery, want []byte) (msg
 	return msg
 }
 
-// https://github.com/rabbitmq/amqp091-go/issues/11
+// https://github.com/killer-djon/rabbitmq-go/issues/11
 func TestShouldNotWaitAfterConnectionClosedNewChannelCreatedIssue11(t *testing.T) {
 	conn := integrationConnection(t, "TestShouldNotWaitAfterConnectionClosedNewChannelCreatedIssue11")
 	ch, err := conn.Channel()

reconnect_test.go

@@ -10,7 +10,7 @@ import (
 	"fmt"
 	"os"
 
-	amqp "github.com/rabbitmq/amqp091-go"
+	amqp "github.com/killer-djon/rabbitmq-go"
 )
 
 // Every connection should declare the topology they expect