Package com.wombat.mamda.examples
Class MamdaBookPublisher
- java.lang.Object
-
- com.wombat.mama.MamaDQPublisherManagerCallback
-
- com.wombat.mamda.examples.MamdaBookPublisher
-
- All Implemented Interfaces:
com.wombat.mama.MamaTimerCallback
public class MamdaBookPublisher extends com.wombat.mama.MamaDQPublisherManagerCallback implements com.wombat.mama.MamaTimerCallback
-
-
Constructor Summary
Constructors Constructor Description MamdaBookPublisher()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
createBook(java.lang.String symbol, java.lang.String partId)
void
createMsg()
void
createPublisherManager(java.lang.String pubSource, com.wombat.mama.MamaBridge bridge)
void
createPublisherTransport(com.wombat.mama.MamaBridge bridge)
void
createTimer(java.lang.String symbol, com.wombat.mama.MamaBridge bridge)
MamdaOrderBook
getBook()
com.wombat.mama.MamaMsg
getPublishMsg()
com.wombat.mama.MamaQueueGroup
getQueueGroup()
static void
main(java.lang.String[] args)
void
onCreate(com.wombat.mama.MamaDQPublisherManager publisher)
void
onDestroy(com.wombat.mama.MamaTimer timer)
void
onError(com.wombat.mama.MamaDQPublisherManager publisher, short status, java.lang.String errortxt, com.wombat.mama.MamaMsg msg)
void
onNewRequest(com.wombat.mama.MamaDQPublisherManager publisherManager, java.lang.String symbol, short subType, short msgType, com.wombat.mama.MamaMsg msg)
void
onRefresh(com.wombat.mama.MamaDQPublisherManager publisherManager, com.wombat.mama.MamaDQPublisherManager.MamaPublishTopic mamaPublishTopic, short subType, short msgType, com.wombat.mama.MamaMsg msg)
void
onRequest(com.wombat.mama.MamaDQPublisherManager publisherManager, com.wombat.mama.MamaDQPublisherManager.MamaPublishTopic mamaPublishTopic, short subType, short msgType, com.wombat.mama.MamaMsg msg)
void
onTimer(com.wombat.mama.MamaTimer timer)
void
processOrder()
boolean
publishingSymbol(java.lang.String symbol)
void
publishMessage(com.wombat.mama.MamaMsg request)
void
setProcessEntries(boolean process)
void
setQueueGroup(com.wombat.mama.MamaQueueGroup queues)
-
-
-
Field Detail
-
mPublishMsg
public com.wombat.mama.MamaMsg mPublishMsg
-
bidSide
public char bidSide
-
askSide
public char askSide
-
PLADD
public static final char PLADD
- See Also:
- Constant Field Values
-
PLUPDATE
public static final char PLUPDATE
- See Also:
- Constant Field Values
-
PLDELETE
public static final char PLDELETE
- See Also:
- Constant Field Values
-
PLUNKNOWN
public static final char PLUNKNOWN
- See Also:
- Constant Field Values
-
ENTADD
public static final char ENTADD
- See Also:
- Constant Field Values
-
ENTUPDATE
public static final char ENTUPDATE
- See Also:
- Constant Field Values
-
ENTDELETE
public static final char ENTDELETE
- See Also:
- Constant Field Values
-
-
Method Detail
-
onTimer
public void onTimer(com.wombat.mama.MamaTimer timer)
- Specified by:
onTimer
in interfacecom.wombat.mama.MamaTimerCallback
-
processOrder
public void processOrder()
-
getBook
public MamdaOrderBook getBook()
-
getPublishMsg
public com.wombat.mama.MamaMsg getPublishMsg()
-
publishMessage
public void publishMessage(com.wombat.mama.MamaMsg request)
-
createMsg
public void createMsg()
-
createBook
public void createBook(java.lang.String symbol, java.lang.String partId)
-
createPublisherTransport
public void createPublisherTransport(com.wombat.mama.MamaBridge bridge)
-
createPublisherManager
public void createPublisherManager(java.lang.String pubSource, com.wombat.mama.MamaBridge bridge)
-
createTimer
public void createTimer(java.lang.String symbol, com.wombat.mama.MamaBridge bridge)
-
setProcessEntries
public void setProcessEntries(boolean process)
-
setQueueGroup
public void setQueueGroup(com.wombat.mama.MamaQueueGroup queues)
-
publishingSymbol
public boolean publishingSymbol(java.lang.String symbol)
-
getQueueGroup
public com.wombat.mama.MamaQueueGroup getQueueGroup()
-
onNewRequest
public void onNewRequest(com.wombat.mama.MamaDQPublisherManager publisherManager, java.lang.String symbol, short subType, short msgType, com.wombat.mama.MamaMsg msg)
- Overrides:
onNewRequest
in classcom.wombat.mama.MamaDQPublisherManagerCallback
-
onRequest
public void onRequest(com.wombat.mama.MamaDQPublisherManager publisherManager, com.wombat.mama.MamaDQPublisherManager.MamaPublishTopic mamaPublishTopic, short subType, short msgType, com.wombat.mama.MamaMsg msg)
- Overrides:
onRequest
in classcom.wombat.mama.MamaDQPublisherManagerCallback
-
onRefresh
public void onRefresh(com.wombat.mama.MamaDQPublisherManager publisherManager, com.wombat.mama.MamaDQPublisherManager.MamaPublishTopic mamaPublishTopic, short subType, short msgType, com.wombat.mama.MamaMsg msg)
- Overrides:
onRefresh
in classcom.wombat.mama.MamaDQPublisherManagerCallback
-
onError
public void onError(com.wombat.mama.MamaDQPublisherManager publisher, short status, java.lang.String errortxt, com.wombat.mama.MamaMsg msg)
-
onCreate
public void onCreate(com.wombat.mama.MamaDQPublisherManager publisher)
- Overrides:
onCreate
in classcom.wombat.mama.MamaDQPublisherManagerCallback
-
onDestroy
public void onDestroy(com.wombat.mama.MamaTimer timer)
- Specified by:
onDestroy
in interfacecom.wombat.mama.MamaTimerCallback
-
main
public static void main(java.lang.String[] args)
-
-