Skip to content

wang / go_upload_sync

Go to a project
Commit 906c78a1 by mushishixian
Options

fix

parent 20d76816
Inline Side-by-side
Showing with 10 additions and 10 deletions
app/queue/supplier.go
......@@ -12,17 +12,17 @@ type RecvPro struct {
}
func init() {
queueExchange := rabbitmq.QueueExchange{
"supplier_erp",
"",
"",
"",
"amqp://guest:guest@192.168.2.232:5672/",
}
str := `{"supplierNumber":"C0000102","PTID":"L0000002","supplierID":"LxYAAAG0CQA3xn38","supplierName":"TestName"}`
//queueExchange := rabbitmq.QueueExchange{
// "supplier_erp",
// "",
// "",
// "",
// "amqp://guest:guest@192.168.2.232:5672/",
//}
//
//str := `{"supplierNumber":"C0000102","PTID":"L0000002","supplierID":"LxYAAAG0CQA3xn38","supplierName":"TestName"}`
//str := `{"supplierNumber":"C0000102","PTID":"12324","supplierID":"LxYAAAG0CQA3xn38"}`
rabbitmq.Send(queueExchange, str)
//rabbitmq.Send(queueExchange, str)
}
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