Documentation ¶
Index ¶
- type Receiver
- func (r Receiver) FromAdmin(msg *quickfix.Message, sessionID quickfix.SessionID) quickfix.MessageRejectError
- func (r *Receiver) FromApp(msg *quickfix.Message, sessionID quickfix.SessionID) (reject quickfix.MessageRejectError)
- func (r Receiver) OnCreate(sessionID quickfix.SessionID)
- func (r Receiver) OnLogon(sessionID quickfix.SessionID)
- func (r Receiver) OnLogout(sessionID quickfix.SessionID)
- func (r *Receiver) OnNewOrderSingle(msg newordersingle.NewOrderSingle, sessionID quickfix.SessionID) (err quickfix.MessageRejectError)
- func (r *Receiver) OnOrderCancelRequest(msg ordercancelrequest.OrderCancelRequest, sessionID quickfix.SessionID) quickfix.MessageRejectError
- func (r Receiver) ToAdmin(msg *quickfix.Message, sessionID quickfix.SessionID)
- func (r Receiver) ToApp(msg *quickfix.Message, sessionID quickfix.SessionID) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Receiver ¶
type Receiver struct { *quickfix.MessageRouter *nsq.Producer }
Receiver implements the quickfix.Application interface.
func (Receiver) FromAdmin ¶
func (r Receiver) FromAdmin(msg *quickfix.Message, sessionID quickfix.SessionID) quickfix.MessageRejectError
FromAdmin implemented as part of Application interface
func (*Receiver) FromApp ¶
func (r *Receiver) FromApp(msg *quickfix.Message, sessionID quickfix.SessionID) (reject quickfix.MessageRejectError)
FromApp implemented as part of Application interface, uses Router on incoming application messages.
func (*Receiver) OnNewOrderSingle ¶
func (r *Receiver) OnNewOrderSingle(msg newordersingle.NewOrderSingle, sessionID quickfix.SessionID) (err quickfix.MessageRejectError)
OnNewOrderSingle handles the NewOrderSingle.
func (*Receiver) OnOrderCancelRequest ¶
func (r *Receiver) OnOrderCancelRequest(msg ordercancelrequest.OrderCancelRequest, sessionID quickfix.SessionID) quickfix.MessageRejectError
Click to show internal directories.
Click to hide internal directories.