rabbitmq

func (*Connection) Consume ¶

func (c *Connection) Consume(ch *amqp.Channel, q *amqp.Queue) (<-chan amqp.Delivery, error)

func (*Connection) ConsumeAfterAck ¶

func (c *Connection) ConsumeAfterAck(ch *amqp.Channel, q *amqp.Queue) (<-chan amqp.Delivery, error)

func (*Connection) DeclareQueue ¶

func (c *Connection) DeclareQueue(ch *amqp.Channel, name string) error

func (*Connection) DeclareThrottledQueue ¶

func (c *Connection) DeclareThrottledQueue(ch *amqp.Channel, name string) error

func (*Connection) GetChannel ¶

func (c *Connection) GetChannel(id string) *amqp.Channel

func (*Connection) GetQueue ¶

func (c *Connection) GetQueue(ch *amqp.Channel, queue string) *amqp.Queue

func (*Connection) NewConnection ¶

func (c *Connection) NewConnection(address string) *amqp.Connection

func (*Connection) Publish ¶

func (c *Connection) Publish(ch *amqp.Channel, q *amqp.Queue, bytes []byte) error

Publish

func (*Connection) PublishCancelLendingOrderMessage ¶ added in v1.2.0

func (c *Connection) PublishCancelLendingOrderMessage(o *types.LendingOrder) error

PublishCancelLendingOrderMessage publish cancel message to queue

func (*Connection) PublishCancelOrderMessage ¶

func (c *Connection) PublishCancelOrderMessage(o *types.Order) error

func (*Connection) PublishCancelStopOrderMessage ¶

func (c *Connection) PublishCancelStopOrderMessage(so *types.StopOrder) error

func (*Connection) PublishDepositTransaction ¶

func (c *Connection) PublishDepositTransaction(transaction *types.DepositTransaction) error

func (*Connection) PublishEngineResponse ¶

func (c *Connection) PublishEngineResponse(res *types.EngineResponse) error

PublishEngineResponse publish engine response to queue

func (*Connection) PublishLendingOrder ¶ added in v1.2.0

func (c *Connection) PublishLendingOrder(order *Message) error

PublishLendingOrder publish a lending order

func (*Connection) PublishLendingOrderMessage ¶ added in v1.2.0

func (c *Connection) PublishLendingOrderMessage(o *types.LendingOrder) error

PublishLendingOrderMessage publish message to queue

func (*Connection) PublishLendingOrderResponse ¶ added in v1.2.0

func (c *Connection) PublishLendingOrderResponse(res *types.EngineResponse) error

PublishLendingOrderResponse publish order response to queue

func (*Connection) PublishLendingTradeResponse ¶ added in v1.2.0

func (c *Connection) PublishLendingTradeResponse(res *types.EngineResponse) error

PublishLendingTradeResponse publish trade response to queue

func (*Connection) PublishMessage ¶

func (c *Connection) PublishMessage(res *types.EngineResponse, queue string) error

PublishMessage publish message to rabbitmq

func (*Connection) PublishNewOrderMessage ¶

func (c *Connection) PublishNewOrderMessage(o *types.Order) error

func (*Connection) PublishNewStopOrderMessage ¶

func (c *Connection) PublishNewStopOrderMessage(so *types.StopOrder) error

func (*Connection) PublishOrder ¶

func (c *Connection) PublishOrder(order *Message) error

func (*Connection) PublishOrderResponse ¶

func (c *Connection) PublishOrderResponse(res *types.EngineResponse) error

PublishOrderResponse publish order response to queue

func (*Connection) PublishTradeResponse ¶

func (c *Connection) PublishTradeResponse(res *types.EngineResponse) error

PublishTradeResponse publish trade response to queue

func (*Connection) Purge ¶

func (c *Connection) Purge(ch *amqp.Channel, name string) error

func (*Connection) QueuePoolDepositTransactions ¶

func (c *Connection) QueuePoolDepositTransactions() (<-chan *types.DepositTransaction, error)

QueuePoolDepositTransactions : return a queue as a channel

func (*Connection) SubscribeEngineResponses ¶

func (c *Connection) SubscribeEngineResponses(fn func(*types.EngineResponse) error) error

SubscribeEngineResponses subscribe engine responses

func (*Connection) SubscribeLendingOrderResponses ¶ added in v1.2.0

func (c *Connection) SubscribeLendingOrderResponses(fn func(*types.EngineResponse) error) error

SubscribeLendingOrderResponses subscribe order responses

func (*Connection) SubscribeLendingOrders ¶ added in v1.2.0

func (c *Connection) SubscribeLendingOrders(fn func(*Message) error) error

SubscribeLendingOrders sub a order consumer

func (*Connection) SubscribeLendingTradeResponses ¶ added in v1.2.0

func (c *Connection) SubscribeLendingTradeResponses(fn func(*types.EngineResponse) error) error

SubscribeLendingTradeResponses subscribe trade responses

func (*Connection) SubscribeOrderResponses ¶

func (c *Connection) SubscribeOrderResponses(fn func(*types.EngineResponse) error) error

SubscribeOrderResponses subscribe order responses

func (*Connection) SubscribeOrders ¶

func (c *Connection) SubscribeOrders(fn func(*Message) error) error

func (*Connection) SubscribeQueue ¶

func (c *Connection) SubscribeQueue(fn func(*types.EngineResponse) error, queue string) error

SubscribeQueue subscribe queue

func (*Connection) SubscribeTradeResponses ¶

func (c *Connection) SubscribeTradeResponses(fn func(*types.EngineResponse) error) error

SubscribeTradeResponses subscribe trade responses