1 #include "SocketZyre.hh"
2 #include "MessageZyre.hh"
6 :
Socket(), mpSocket(zyre_new(name.c_str()))
14 SPD_TRACE(
"Creating zyre socket name [{}]", name);
16 for (
auto const &
header : headers) {
17 SPD_DEBUG(
"[{}] header : [{}] [{}]", name,
header.first,
header.second);
39 SPD_TRACE(
"Starting zyre socket name [{}]", zyre_name(
mpSocket));
50 SPD_TRACE(
"Stopping zyre socket name [{}]", zyre_name(
mpSocket));
62 zyre_event_t * pEvent = zyre_event_new(
mpSocket);
72 SPD_WARN(
"SocketZyre::push(Message *) not supported!");
81 if (targetUUID.empty()) {
82 SPD_ERROR(
"Target UUID is empty!");
85 if (payload.empty()) {
86 SPD_ERROR(
"Payload is empty!");
89 return zyre_whispers(
mpSocket, targetUUID.c_str(),
"%s", payload.c_str());
virtual Message * pull()
Pull message.
virtual int disconnect() final
Disconnect function.
virtual int connect() final
Connect function.
std::string header(const char *pKey) const
Returns value for key from header.
std::map< std::string, std::string > mHeaders
List of headers.
zyre_t * mpSocket
Zyre instance.
virtual int push(Message *)
Push message.
Salsa zyre message class.
SocketZyre(std::string name="no_name", std::map< std::string, std::string > headers={})