From b7dd2a83bc0c66a1b1550a192a4a569c619ef66f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=D0=92=D0=B0=D0=BB=D0=B5=D1=80=D0=B8=D0=B8=CC=86=20=D0=A1?= =?UTF-8?q?=D1=82=D0=B0=D0=B4=D1=87=D0=B5=D0=BD=D0=BA=D0=BE?= Date: Mon, 5 Sep 2022 11:14:15 +0300 Subject: [PATCH] bugfix --- reconnector.go | 6 +++--- rpc.go | 6 +++--- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/reconnector.go b/reconnector.go index 36eb3ee..b7ab7b2 100644 --- a/reconnector.go +++ b/reconnector.go @@ -13,9 +13,9 @@ type Reconnector interface { RabbitConnect() GetConnection() *amqp.Connection SubscribeTo(exhangeName string, queueName string, routingKey string) (<-chan amqp.Delivery, *amqp.Channel, error) - publishResponse(ch *amqp.Channel, exchangeName string, replyTo string, correlationId string, body string, sessionId string, content_type string) (err error) - executeRPC(ch *amqp.Channel, exhangeName string, body []byte, strTimeout string, routingKey string) (response []byte, err error) - publishTo(ch *amqp.Channel, exhangeName string, routingKey string, body string) (err error) + PublishResponse(ch *amqp.Channel, exchangeName string, replyTo string, correlationId string, body string, sessionId string, content_type string) (err error) + ExecuteRPC(ch *amqp.Channel, exhangeName string, body []byte, strTimeout string, routingKey string) (response []byte, err error) + PublishTo(ch *amqp.Channel, exhangeName string, routingKey string, body string) (err error) } type ReconnectorEventHandler interface { diff --git a/rpc.go b/rpc.go index bc657c2..3e8b0e4 100644 --- a/rpc.go +++ b/rpc.go @@ -90,7 +90,7 @@ func (s *server) SubscribeTo(exhangeName string, queueName string, routingKey st return msgs, ch, nil } -func (s *server) publishResponse(ch *amqp.Channel, exchangeName string, replyTo string, correlationId string, body string, sessionId string, content_type string) (err error) { +func (s *server) PublishResponse(ch *amqp.Channel, exchangeName string, replyTo string, correlationId string, body string, sessionId string, content_type string) (err error) { err1 := ch.Publish( exchangeName, // exchange replyTo, // routing key @@ -120,7 +120,7 @@ func (s *server) publishResponse(ch *amqp.Channel, exchangeName string, replyTo } } -func (s *server) executeRPC(ch *amqp.Channel, exhangeName string, body []byte, strTimeout string, routingKey string) (response []byte, err error) { +func (s *server) ExecuteRPC(ch *amqp.Channel, exhangeName string, body []byte, strTimeout string, routingKey string) (response []byte, err error) { err = ch.ExchangeDeclare( exhangeName, // name "direct", // type @@ -262,7 +262,7 @@ func (s *server) executeRPC(ch *amqp.Channel, exhangeName string, body []byte, s } } -func (s *server) publishTo(ch *amqp.Channel, exhangeName string, routingKey string, body string) (err error) { +func (s *server) PublishTo(ch *amqp.Channel, exhangeName string, routingKey string, body string) (err error) { err = ch.ExchangeDeclare( exhangeName, // name "direct", // type