Commit c75dbdf0 by 杨树贤

修改队列吗

parent 5489057a
Showing with 3 additions and 2 deletions
...@@ -2,10 +2,11 @@ package queue ...@@ -2,10 +2,11 @@ package queue
import ( import (
"fmt" "fmt"
"go_supplier_sever/app/service"
"github.com/ichunt2019/cfg/lib" "github.com/ichunt2019/cfg/lib"
"github.com/ichunt2019/go-rabbitmq/utils/rabbitmq" "github.com/ichunt2019/go-rabbitmq/utils/rabbitmq"
"github.com/tidwall/gjson" "github.com/tidwall/gjson"
"go_supplier_sever/app/service"
) )
type RecvPro struct { type RecvPro struct {
...@@ -46,7 +47,7 @@ func (t *RecvPro) FailAction(dataByte []byte) error { ...@@ -46,7 +47,7 @@ func (t *RecvPro) FailAction(dataByte []byte) error {
func Run() { func Run() {
t := &RecvPro{} t := &RecvPro{}
rabbitmq.Recv(rabbitmq.QueueExchange{ rabbitmq.Recv(rabbitmq.QueueExchange{
"supplier_erp", "supplier_erp_RabblitMQ",
"", "",
"", "",
"", "",
......
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