pcmaniac
/
rabbit_reconnector
mirror of https://github.com/PCManiac/rabbit_reconnector
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

bugfix

Browse Source
main v0.0.2
Валерий Стадченко 4 years ago
parent 1f205e32c8
commit b7dd2a83bc
2 changed files with 6 additions and 6 deletions
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Show Stats Download Patch File Download Diff File
  1. 6
      reconnector.go
  2. 6
      rpc.go

6
reconnector.go
Unescape View File

@ -13,9 +13,9 @@ type Reconnector interface {
RabbitConnect() RabbitConnect()
GetConnection() *amqp.Connection GetConnection() *amqp.Connection
SubscribeTo(exhangeName string, queueName string, routingKey string) (<-chan amqp.Delivery, *amqp.Channel, error) 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) 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) 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) PublishTo(ch *amqp.Channel, exhangeName string, routingKey string, body string) (err error)
} }
type ReconnectorEventHandler interface { type ReconnectorEventHandler interface {

6
rpc.go
Unescape View File

@ -90,7 +90,7 @@ func (s *server) SubscribeTo(exhangeName string, queueName string, routingKey st
return msgs, ch, nil 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( err1 := ch.Publish(
exchangeName, // exchange exchangeName, // exchange
replyTo, // routing key 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( err = ch.ExchangeDeclare(
exhangeName, // name exhangeName, // name
"direct", // type "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( err = ch.ExchangeDeclare(
exhangeName, // name exhangeName, // name
"direct", // type "direct", // type

Write Preview
Loading…
Cancel
Save