Skip to content

杨树贤 / bom_server

Go to a project
Commit a5ce534a by mushishixian
Options

fix

parent 4e9a3c1a
Inline Side-by-side
Showing with 11 additions and 11 deletions
cmd/queue/bom.go
...@@ -14,17 +14,17 @@ type RecvPro struct { ...@@ -14,17 +14,17 @@ type RecvPro struct {
} }
func init() { func init() {
queueExchange := rabbitmq.QueueExchange{ //queueExchange := rabbitmq.QueueExchange{
"bom_match", // "bom_match",
"bom_match", // "bom_match",
"bom", // "bom",
"direct", // "direct",
"amqp://huntadmin:jy2y2900@192.168.1.237:5672/", // "amqp://huntadmin:jy2y2900@192.168.1.237:5672/",
} //}
//
//str := `{"bom_id":666,"delivery_type":1,"sort":1}` ////str := `{"bom_id":666,"delivery_type":1,"sort":1}`
str := `{"bom_id":684,"delivery_type":1,"sort":1}` //str := `{"bom_id":684,"delivery_type":1,"sort":1}`
rabbitmq.Send(queueExchange, str) //rabbitmq.Send(queueExchange, str)
} }
func (t *RecvPro) Consumer(dataByte []byte) (err error) { func (t *RecvPro) Consumer(dataByte []byte) (err error) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment