We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6a62512 commit 05f1138Copy full SHA for 05f1138
pkg/storage/rabbitmq/rabbitmq.go
@@ -1,8 +1,7 @@
1
package rabbitmq
2
3
import (
4
- "bytes"
5
- "encoding/gob"
+ "fmt"
6
7
"github.com/streadway/amqp"
8
@@ -93,21 +92,14 @@ func (c storage) Name() string {
93
92
// @param value that will be pushed
94
// @return an error if the push failed
95
func (c storage) Push(value interface{}) error {
96
- var buf bytes.Buffer
97
-
98
- enc := gob.NewEncoder(&buf)
99
- if err := enc.Encode(value); err != nil {
100
- return err
101
- }
102
103
if err := c.channel.Publish(
104
c.config.Exchange,
105
c.routingKey.Name,
106
c.config.Mandatory,
107
c.config.Immediate,
108
amqp.Publishing{
109
ContentType: c.config.ContentType(),
110
- Body: []byte(buf.Bytes()),
+ Body: []byte(fmt.Sprintf("%v", value)),
111
}); err != nil {
112
return err
113
}
0 commit comments