Go to the source code of this file.
|
MAMAExpDLL mama_status | mamaPublisher_create (mamaPublisher *result, mamaTransport tport, const char *symbol, const char *source, const char *root) |
| Create a mama publisher for the corresponding transport. More...
|
|
MAMAExpDLL mama_status | mamaPublisher_send (mamaPublisher publisher, mamaMsg msg) |
| Send a message from the specified publisher. More...
|
|
MAMAExpDLL mama_status | mamaPublisher_sendWithThrottle (mamaPublisher publisher, mamaMsg msg, mamaThrottledSendCompleteCb sendCompleteCb, void *closure) |
| Send a message with the throttle. More...
|
|
MAMAExpDLL mama_status | mamaPublisher_sendFromInboxWithThrottle (mamaPublisher publisher, mamaInbox inbox, mamaMsg msg, mamaThrottledSendCompleteCb sendCompleteCb, void *closure) |
|
MAMAExpDLL mama_status | mamaPublisher_sendFromInbox (mamaPublisher publisher, mamaInbox inbox, mamaMsg msg) |
|
MAMAExpDLL mama_status | mamaPublisher_sendReplyToInboxHandle (mamaPublisher publisher, mamaMsgReply replyAddress, mamaMsg reply) |
| Send a reply in response to a request to an inbox. More...
|
|
MAMAExpDLL mama_status | mamaPublisher_sendReplyToInbox (mamaPublisher publisher, mamaMsg request, mamaMsg reply) |
| Send a reply in response to a request to an inbox. More...
|
|
MAMAExpDLL mama_status | mamaPublisher_destroy (mamaPublisher publisher) |
| Destroy the publisher. More...
|
|
◆ mamaThrottledSendCompleteCb
Responsible for publishing mama messages.
Prototype for callback invoked when a message sent with either mamaPublisher_sendWithThrottle() or mamaPublisher_sendFromInboxWithThrottle() has been sent from the throttle queue.
Messages sent on the throttle queue are no longer destroyed by the API. It is the responsibility of the application developer to manage the lifecycle of any messages sent on the throttle.
- Parameters
-
publisher | The publisher object used to send the message. |
msg | The mamaMsg which has been sent from the throttle queue. |
status | Whether the message was successfully sent from the throttle. A value of MAMA_STATUS_OK indicates that the send was successful. |
closure | User supplied context data. |
◆ mamaPublisher_create()
Create a mama publisher for the corresponding transport.
If the transport is a marketdata transport, as opposed to a "basic" transport, the topic corresponds to the symbol. For a basic transport, the source and root get ignored.
- Parameters
-
result | A pointer to hold the resulting mamaPublisher. |
tport | The transport. |
symbol | Symbol on which to publish. |
source | The source for market data publishers. (e.g. source.symbol) |
root | The root for market data publishers. Used internally. |
◆ mamaPublisher_send()
Send a message from the specified publisher.
- Parameters
-
publisher | The publisher from which to send a message. |
msg | The mamaMsg to send. |
◆ mamaPublisher_sendWithThrottle()
Send a message with the throttle.
The lifecycle of the message sent is controlled by the user of the API. The callback indicates when the API is no longer using the message and can be destroyed/reused by the application.
- Parameters
-
publisher | The publish from which to send the throttled message. |
msg | The mamaMsg to send. |
sendCompleteCb | Callback invoked once the message has been send on the throttle. |
closure | User supplied data returned in the send complete callback. |
◆ mamaPublisher_sendFromInboxWithThrottle()
◆ mamaPublisher_sendFromInbox()
◆ mamaPublisher_sendReplyToInboxHandle()
Send a reply in response to a request to an inbox.
- Parameters
-
publisher | The mamaPublisher from which to send the response. |
request | The reply address to which you are responding. |
reply | The mamaMsg to be sent as the reply. |
◆ mamaPublisher_sendReplyToInbox()
Send a reply in response to a request to an inbox.
- Parameters
-
publisher | The mamaPublisher from which to send the response. |
request | The mamaMsg to which you are responding. |
reply | The mamaMsg to be sent as the reply. |
◆ mamaPublisher_destroy()
Destroy the publisher.
- Parameters
-
publisher | The mamaPublisher to destroy. |