rabbitmq

package
v0.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 5, 2021 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

View Source
const CHANNEL_ORDER_ASKPAY_KEY = "channel_order_askpay"

串货订单请求支付route key

View Source
const CHANNEL_ORDER_ASKPAY_QUEUE = "channel_order_askpay_queue"

订单请求支付队列,串货服务用

View Source
const CHANNEL_ORDER_ASK_FOR_REFUND_QUEUE string = "channel_order_ask_for_refund_queue"

订单申请退款队列,串货服务用

View Source
const CHANNEL_ORDER_AUTO_CANCEL_QUEUE string = "channel_order_auto_cancel_queue"

未支付订单过期自动取消队列,串货服务用

View Source
const CHANNEL_ORDER_AUTO_RECEIVE_QUEUE string = "channel_order_auto_receive_queue"

订单自动收货队列,串货服务用

View Source
const CHANNEL_ORDER_CANCELED_QUEUE = "channel_order_canceled_queue"

订单取消队列,串货服务用

View Source
const CHANNEL_ORDER_CREATED_QUEUE = "channel_order_created_queue"

已创建订单队列,串货服务用

View Source
const CHANNEL_ORDER_DELIVERED_QUEUE = "channel_order_delivered_queue"

订单发货队列,串货服务用

View Source
const CHANNEL_ORDER_EXCHANGE string = "ex_channel_order"

--串货-- 串货订单路由

View Source
const CHANNEL_ORDER_FINISHED_QUEUE = "channel_order_finished_queue"

订单退款队列,串货服务用

View Source
const CHANNEL_ORDER_PAYED_QUEUE = "channel_order_payed_queue"

订单已支付队列,串货服务用

View Source
const CHANNEL_ORDER_RECEIVED_QUEUE = "channel_order_received_queue"

订单取消队列,串货服务用

View Source
const CHANNEL_ORDER_REFUNDED_QUEUE = "channel_order_refunded_queue"

订单退款队列,串货服务用

View Source
const CHANNEL_ORDER_STATUS_CHANGE_QUEUE = "channel_order_update_status"

订单状态更新,串货服务用

View Source
const ORDER_ADD_KEY = "add"

订单等待创建key,订单服务用

View Source
const ORDER_ADD_QUEUE = "order_add_queue"

订单等待创建队列,订单服务用

View Source
const ORDER_ASKPAY_KEY = "order_askpay"

订单请求支付route key

View Source
const ORDER_ASKPAY_QUEUE = "order_askpay_queue"

订单请求支付队列,串货服务用

View Source
const ORDER_ASK_FOR_REFUND_KEY string = "order_ask_for_refund"

订单申请退款消息key

View Source
const ORDER_ASK_FOR_REFUND_QUEUE string = "order_ask_for_refund_queue"

订单申请退款消息队列

View Source
const ORDER_AUTO_CANCEL_KEY string = "order_auto_cancel"

未支付订单过期自动取消key

View Source
const ORDER_AUTO_CANCEL_QUEUE string = "order_auto_cancel_queue"

未支付订单过期自动取消队列

View Source
const ORDER_AUTO_RECEIVE_KEY string = "order_auto_received"

订单发货后到期自动收货key

View Source
const ORDER_AUTO_RECEIVE_QUEUE string = "order_auto_receive_queue"

订单发货后到期自动收货队列

View Source
const ORDER_CANCELED_KEY string = "canceled"

订单取消route key

View Source
const ORDER_CANCELED_QUEUE = "order_canceled_queue"

订单取消队列,订单服务用

View Source
const ORDER_CREATED_KEY string = "created"

已创建订单route key

View Source
const ORDER_CREATED_QUEUE = "order_created_queue"

订单已创建队列,订单服务用

View Source
const ORDER_DELAY_EXCHANGE string = "ex_order_delay"

订单延迟队列路由

View Source
const ORDER_DELIVERED_KEY string = "delivered"

订单发货route key

View Source
const ORDER_DELIVERED_QUEUE = "order_delivered_queue"

订单发货队列,订单服务用

View Source
const ORDER_EXCHANGE string = "ex_order"

--订单-- 订单路由

View Source
const ORDER_FINISHED_KEY string = "finished"

订单完成route key

View Source
const ORDER_FINISHED_QUEUE = "order_finished_queue"

订单退款队列,订单服务用

View Source
const ORDER_PAYED_KEY string = "payed"

已支付订单route key

View Source
const ORDER_PAYED_QUEUE = "order_payed_queue"

订单已支付队列,订单服务用

View Source
const ORDER_RECEIVED_KEY string = "received"

订单收货route key

View Source
const ORDER_RECEIVED_QUEUE = "order_received_queue"

订单取消队列,订单服务用

View Source
const ORDER_REFUNDED_KEY string = "refunded"

订单退款route key

View Source
const ORDER_REFUNDED_QUEUE = "order_refunded_queue"

订单退款队列,订单服务用

View Source
const ORDER_STATUS_CHANGE_KEY string = "status_change"

订单状态更新route key

View Source
const ORDER_STATUS_UPDATE_QUEUE = "order_status_update_queue"

订单状态更新队列,订单服务用

View Source
const SEND_API_MSG_KEY = "api_send_msg"

发送接口请求路由route key

View Source
const SEND_MSG_EXCHANGE string = "ex_send_msg"

--通知-- 发送接口请求路由

View Source
const SEND_MSG_QUEUE = "send_msg_queue"

发送接口请求队列,定时服务用

Variables

Functions

func Channel

func Channel() error

func CloseChannel

func CloseChannel() error

func CloseConn

func CloseConn() error

func Connect

func Connect(host, port, username, pwd, vhost string) error

func Send

func Send(extype string, exchange string, route string, body []byte, extend ...bool) error

*

  • 发送消息
  • @param exchange 交换机名
  • @param extype 消息类型
  • @param route 路由key
  • @param body 内容

func SendDelay

func SendDelay(extype string, exchange string, route string, body []byte, delay int64, extend ...bool) error

*

  • 发送消息
  • @param exchange 交换机名
  • @param extype 消息类型
  • @param route 路由key
  • @param body 内容
  • @param delay 延迟多少毫秒

func SendNotice

func SendNotice(site_id, dbname, msg_id string) error

*

  • 发送一条api通知消息
  • @param exchange 交换机名
  • @param extype 消息类型
  • @param route 路由key
  • @param body 内容

func SendOrderPayed

func SendOrderPayed(site_id, dbname, order_id, order_sn, price string) error

*

  • 发布订单已支付消息
  • @param exchange 交换机名
  • @param extype 消息类型
  • @param route 路由key
  • @param body 内容

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL