Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add support for true multipart in pub/sub messages #64

Open
wants to merge 1 commit into
base: main
Choose a base branch
from
Open

Add support for true multipart in pub/sub messages #64

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 7 additions & 0 deletions xop-stub-generator/interface.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -89,6 +89,9 @@ THREADSAFE variable zeromq_pub_bind(string localPoint);
/// Message filtering happens on the publisher side, around ZMQ_SNDHWM messages (by default 1000) will be kept.
THREADSAFE variable zeromq_pub_send(string filter, string msg);

/// @brief Multipart variant of zeromq_pub_send
THREADSAFE variable zeromq_pub_send_multi(WAVE/WAVE payload);

/// @brief Connect to a ZMQ_PUB socket as ZMQ_SUB
///
/// @param remotePoint Protocol and address of the server, usually something like `tcp://127.0.0.1:5670`
Expand All @@ -114,6 +117,10 @@ THREADSAFE variable zeromq_sub_remove_filter(string filter);
THREADSAFE string zeromq_sub_recv(string *filter);
/// @}

/// @brief Receive subscribed messages (multipart)
THREADSAFE variable zeromq_sub_recv_multi(WAVE/WAVE payload);
/// @}

/// @name Message handler
///
/// The XOP implements a threaded message handler. This message handler can be
Expand Down