EII Message Bus C Reference
|
#include <protocol.h>
Public Attributes | |
void * | proto_ctx |
config_t * | config |
void(* | destroy )(void *ctx) |
msgbus_ret_t(* | publisher_new )(void *ctx, const char *topic, void **pub_ctx) |
msgbus_ret_t(* | publisher_publish )(void *ctx, void *pub_ctx, msg_envelope_t *msg) |
void(* | publisher_destroy )(void *ctx, void *pub_ctx) |
msgbus_ret_t(* | subscriber_new )(void *ctx, const char *topic, void **subscriber) |
void(* | recv_ctx_destroy )(void *ctx, void *recv_ctx) |
msgbus_ret_t(* | request )(void *ctx, void *service_ctx, msg_envelope_t *message) |
msgbus_ret_t(* | response )(void *ctx, void *service_ctx, msg_envelope_t *message) |
msgbus_ret_t(* | service_get )(void *ctx, const char *service_name, void **service_ctx) |
msgbus_ret_t(* | service_new )(void *ctx, const char *service_name, void **service_ctx) |
msgbus_ret_t(* | recv_wait )(void *ctx, void *recv_ctx, msg_envelope_t **message) |
msgbus_ret_t(* | recv_timedwait )(void *ctx, void *recv_ctx, int timeout, msg_envelope_t **message) |
msgbus_ret_t(* | recv_nowait )(void *ctx, void *recv_ctx, msg_envelope_t **message) |
Underlying protocol interface for messaging through the message bus.