diff --git a/amqp-order-handler.go b/amqp-order-handler.go index dd14360..776cfe7 100644 --- a/amqp-order-handler.go +++ b/amqp-order-handler.go @@ -6,7 +6,7 @@ import ( amqp "github.com/rabbitmq/amqp091-go" ) -type RabbitTransportMaster struct { +type AmqpOrderHandler struct { Url string connection *amqp.Connection //channel *amqp.Channel @@ -16,7 +16,7 @@ const ( topic = "order-placed" ) -func (t *RabbitTransportMaster) Connect() error { +func (t *AmqpOrderHandler) Connect() error { conn, err := amqp.DialConfig(t.Url, amqp.Config{ //Vhost: "/", @@ -58,13 +58,13 @@ func (t *RabbitTransportMaster) Connect() error { return nil } -func (t *RabbitTransportMaster) Close() error { +func (t *AmqpOrderHandler) Close() error { log.Println("Closing master channel") return t.connection.Close() //return t.channel.Close() } -func (t *RabbitTransportMaster) OrderCompleted(data []byte) error { +func (t *AmqpOrderHandler) OrderCompleted(data []byte) error { ch, err := t.connection.Channel() if err != nil { return err diff --git a/main.go b/main.go index a9a8779..8487ab8 100644 --- a/main.go +++ b/main.go @@ -144,7 +144,7 @@ func main() { } } }() - orderHandler := &RabbitTransportMaster{ + orderHandler := &AmqpOrderHandler{ Url: amqpUrl, }