diff --git a/fairmq/FairMQChannel.h b/fairmq/FairMQChannel.h index 95c1de67..386ce186 100644 --- a/fairmq/FairMQChannel.h +++ b/fairmq/FairMQChannel.h @@ -26,9 +26,7 @@ #include "FairMQPoller.h" #include "FairMQTransports.h" #include "FairMQLogger.h" - -class FairMQPoller; -class FairMQTransportFactory; +#include "FairMQParts.h" class FairMQChannel { @@ -222,6 +220,36 @@ class FairMQChannel /// In case of errors, returns -1. int64_t ReceiveAsync(std::vector>& msgVec) const; + int64_t Send(FairMQParts& parts) const + { + return Send(parts.fParts); + } + + int64_t Receive(FairMQParts& parts) const + { + return Receive(parts.fParts); + } + + int64_t Send(FairMQParts& parts, int sndTimeoutInMs) const + { + return Send(parts.fParts, sndTimeoutInMs); + } + + int64_t Receive(FairMQParts& parts, int rcvTimeoutInMs) const + { + return Receive(parts.fParts, rcvTimeoutInMs); + } + + int64_t SendAsync(FairMQParts& parts) const + { + return SendAsync(parts.fParts); + } + + int64_t ReceiveAsync(FairMQParts& parts) const + { + return ReceiveAsync(parts.fParts); + } + // TODO: this might go to some base utility library static void Tokenize(std::vector& output, const std::string& input, const std::string delimiters = ",");