Inherits from MamaDQPublisherManagerCallback, MamaTimerCallback
Name | |
---|---|
MamdaBookPublisher() | |
void | onTimer(MamaTimer timer) |
void | processOrder() |
MamdaOrderBook | getBook() |
MamaMsg | getPublishMsg() |
void | publishMessage(MamaMsg request) |
void | createMsg() |
void | createBook(final String symbol, final String partId) |
void | createPublisherTransport(MamaBridge bridge) |
void | createPublisherManager(final String pubSource, MamaBridge bridge) |
void | createTimer(final String symbol, MamaBridge bridge) |
void | setProcessEntries(boolean process) |
void | setQueueGroup(MamaQueueGroup queues) |
boolean | publishingSymbol(String symbol) |
MamaQueueGroup | getQueueGroup() |
void | onNewRequest(MamaDQPublisherManager publisherManager, final String symbol, short subType, short msgType, MamaMsg msg) |
void | onRequest(MamaDQPublisherManager publisherManager, MamaDQPublisherManager.MamaPublishTopic mamaPublishTopic, short subType, short msgType, MamaMsg msg) |
void | onRefresh(MamaDQPublisherManager publisherManager, MamaDQPublisherManager.MamaPublishTopic mamaPublishTopic, short subType, short msgType, MamaMsg msg) |
void | onError(MamaDQPublisherManager publisher, final short status, final String errortxt, MamaMsg msg) |
void | onCreate(MamaDQPublisherManager publisher) |
void | onDestroy(MamaTimer timer) |
void | main(final String[] args) |
Name | |
---|---|
MamaMsg | mPublishMsg |
char | bidSide |
char | askSide |
final char | PLADD |
final char | PLUPDATE |
final char | PLDELETE |
final char | PLUNKNOWN |
final char | ENTADD |
final char | ENTUPDATE |
final char | ENTDELETE |
inline MamdaBookPublisher()
inline void onTimer(
MamaTimer timer
)
inline void processOrder()
inline MamdaOrderBook getBook()
inline MamaMsg getPublishMsg()
inline void publishMessage(
MamaMsg request
)
inline void createMsg()
inline void createBook(
final String symbol,
final String partId
)
inline void createPublisherTransport(
MamaBridge bridge
)
inline void createPublisherManager(
final String pubSource,
MamaBridge bridge
)
inline void createTimer(
final String symbol,
MamaBridge bridge
)
inline void setProcessEntries(
boolean process
)
inline void setQueueGroup(
MamaQueueGroup queues
)
inline boolean publishingSymbol(
String symbol
)
inline MamaQueueGroup getQueueGroup()
inline void onNewRequest(
MamaDQPublisherManager publisherManager,
final String symbol,
short subType,
short msgType,
MamaMsg msg
)
inline void onRequest(
MamaDQPublisherManager publisherManager,
MamaDQPublisherManager.MamaPublishTopic mamaPublishTopic,
short subType,
short msgType,
MamaMsg msg
)
inline void onRefresh(
MamaDQPublisherManager publisherManager,
MamaDQPublisherManager.MamaPublishTopic mamaPublishTopic,
short subType,
short msgType,
MamaMsg msg
)
inline void onError(
MamaDQPublisherManager publisher,
final short status,
final String errortxt,
MamaMsg msg
)
inline void onCreate(
MamaDQPublisherManager publisher
)
inline void onDestroy(
MamaTimer timer
)
static inline void main(
final String[] args
)
MamaMsg mPublishMsg = null;
char bidSide = MamdaOrderBookPriceLevel.SIDE_BID;
char askSide = MamdaOrderBookPriceLevel.SIDE_ASK;
static final char PLADD = MamdaOrderBookPriceLevel.ACTION_ADD;
static final char PLUPDATE = MamdaOrderBookPriceLevel.ACTION_UPDATE;
static final char PLDELETE = MamdaOrderBookPriceLevel.ACTION_DELETE;
static final char PLUNKNOWN = MamdaOrderBookPriceLevel.ACTION_UNKNOWN;
static final char ENTADD = MamdaOrderBookEntry.ACTION_ADD;
static final char ENTUPDATE = MamdaOrderBookEntry.ACTION_UPDATE;
static final char ENTDELETE = MamdaOrderBookEntry.ACTION_DELETE;
Updated on 2023-03-31 at 15:30:36 +0100