Detailed Description

Allow to send/receive ROOT/KV objects between ZeroMQ sockets.

Examples of use

Sending an object

// ZMQ socket
zmq::socket_t socket;
 
// pointer to object
TObject* obj;
 
KVZMQMessage message;
message.WriteObject(obj);
socket.send(message.GetMessage());

Receiving an object

// ZMQ socket
zmq::socket_t socket;
 
// ZMQ message
zmq::message_t zmq_message;
 
if(socket.recv(&zmq_message))
{
   KVZMQMessage message(zmq_message);
   TObject* object = message.GetObject();
}

Definition at line 46 of file KVZMQMessage.h.

#include <KVZMQMessage.h>

Inheritance diagram for KVZMQMessage:

[legend]

Public Member Functions
	KVZMQMessage ()

	KVZMQMessage (zmq::message_t &g)

virtual	~KVZMQMessage ()

zmq::message_t &	GetMessage ()

TObject *	GetObject ()

template<class T >
T *	GetObject ()

virtual void	WriteObject (const TObject *obj, Bool_t cacheReuse=kTRUE)

Public Member Functions inherited from TMessage
	TMessage (UInt_t what=kMESS_ANY, Int_t bufsiz=TBuffer::kInitialSize)

virtual	~TMessage ()

char *	CompBuffer () const

Int_t	CompLength () const

Int_t	Compress ()

void	EnableSchemaEvolution (Bool_t enable=kTRUE)

void	ForceWriteInfo (TVirtualStreamerInfo *info, Bool_t force) override

void	Forward ()

TClass *	GetClass () const

Int_t	GetCompressionAlgorithm () const

Int_t	GetCompressionLevel () const

Int_t	GetCompressionSettings () const

TList *	GetStreamerInfos () const

TClass *	IsA () const override

void	Reset () override

void	Reset (UInt_t what)

void	SetCompressionAlgorithm (Int_t algorithm=ROOT::RCompressionSetting::EAlgorithm::kUseGlobal)

void	SetCompressionLevel (Int_t level=ROOT::RCompressionSetting::ELevel::kUseMin)

void	SetCompressionSettings (Int_t settings=ROOT::RCompressionSetting::EDefaults::kUseCompiledDefault)

void	SetWhat (UInt_t what)

void	Streamer (TBuffer &) override

void	StreamerNVirtual (TBuffer &ClassDef_StreamerNVirtual_b)

void	TagStreamerInfo (TVirtualStreamerInfo *info) override

Int_t	Uncompress ()

Bool_t	UsesSchemaEvolution () const

UInt_t	What () const

UShort_t	WriteProcessID (TProcessID *pid) override

Public Member Functions inherited from TBufferFile
	TBufferFile (TBuffer::EMode mode)

	TBufferFile (TBuffer::EMode mode, Int_t bufsiz)

	TBufferFile (TBuffer::EMode mode, Int_t bufsiz, void *buf, Bool_t adopt=kTRUE, ReAllocCharFun_t reallocfunc=nullptr)

	~TBufferFile () override

Int_t	ApplySequence (const TStreamerInfoActions::TActionSequence &sequence, void *object) override

Int_t	ApplySequence (const TStreamerInfoActions::TActionSequence &sequence, void start_collection, void end_collection) override

Int_t	ApplySequenceVecPtr (const TStreamerInfoActions::TActionSequence &sequence, void start_collection, void end_collection) override

Int_t	CheckByteCount (UInt_t startpos, UInt_t bcnt, const char *classname) override

Int_t	CheckByteCount (UInt_t startpos, UInt_t bcnt, const TClass *clss) override

Bool_t	CheckObject (const TObject *obj) override

Bool_t	CheckObject (const void obj, const TClass ptrClass) override

void	ClassBegin (const TClass *, Version_t=-1) override

void	ClassEnd (const TClass *) override

void	ClassMember (const char , const char =nullptr, Int_t=-1, Int_t=-1) override

void	DecrementLevel (TVirtualStreamerInfo *) override

TVirtualStreamerInfo *	GetInfo () override

void	IncrementLevel (TVirtualStreamerInfo *info) override

Int_t	ReadArray (Bool_t *&b) override

Int_t	ReadArray (Char_t *&c) override

Int_t	ReadArray (Double_t *&d) override

Int_t	ReadArray (Float_t *&f) override

Int_t	ReadArray (Int_t *&i) override

Int_t	ReadArray (Long64_t *&l) override

Int_t	ReadArray (Long_t *&l) override

Int_t	ReadArray (Short_t *&h) override

Int_t	ReadArray (UChar_t *&c) override

Int_t	ReadArray (UInt_t *&i) override

Int_t	ReadArray (ULong64_t *&l) override

Int_t	ReadArray (ULong_t *&l) override

Int_t	ReadArray (UShort_t *&h) override

Int_t	ReadArrayDouble32 (Double_t &d, TStreamerElement ele=nullptr) override

Int_t	ReadArrayFloat16 (Float_t &f, TStreamerElement ele=nullptr) override

void	ReadBool (Bool_t &b) override

Int_t	ReadBuf (void *buf, Int_t max) override

void	ReadChar (Char_t &c) override

void	ReadCharP (Char_t *c) override

void	ReadCharStar (char *&s) override

TClass *	ReadClass (const TClass cl=nullptr, UInt_t objTag=nullptr) override

Int_t	ReadClassBuffer (const TClass cl, void pointer, const TClass *onfile_class) override

Int_t	ReadClassBuffer (const TClass cl, void pointer, Int_t version, UInt_t start, UInt_t count, const TClass *onfile_class) override

Int_t	ReadClassEmulated (const TClass cl, void object, const TClass *onfile_class) override

void	ReadDouble (Double_t &d) override

void	ReadDouble32 (Double_t d, TStreamerElement ele=nullptr) override

void	ReadFastArray (Bool_t *b, Int_t n) override

void	ReadFastArray (Char_t *c, Int_t n) override

void	ReadFastArray (Double_t *d, Int_t n) override

void	ReadFastArray (Float_t *f, Int_t n) override

void	ReadFastArray (Int_t *i, Int_t n) override

void	ReadFastArray (Long64_t *l, Int_t n) override

void	ReadFastArray (Long_t *l, Int_t n) override

void	ReadFastArray (Short_t *h, Int_t n) override

void	ReadFastArray (UChar_t *c, Int_t n) override

void	ReadFastArray (UInt_t *i, Int_t n) override

void	ReadFastArray (ULong64_t *l, Int_t n) override

void	ReadFastArray (ULong_t *l, Int_t n) override

void	ReadFastArray (UShort_t *h, Int_t n) override

void	ReadFastArray (void *startp, const TClass cl, Int_t n=1, Bool_t isPreAlloc=kFALSE, TMemberStreamer s=nullptr, const TClass onFileClass=nullptr) override

void	ReadFastArray (void start, const TClass cl, Int_t n=1, TMemberStreamer s=nullptr, const TClass onFileClass=nullptr) override

void	ReadFastArrayDouble32 (Double_t d, Int_t n, TStreamerElement ele=nullptr) override

void	ReadFastArrayFloat16 (Float_t f, Int_t n, TStreamerElement ele=nullptr) override

void	ReadFastArrayString (Char_t *c, Int_t n) override

void	ReadFastArrayWithFactor (Double_t *ptr, Int_t n, Double_t factor, Double_t minvalue) override

void	ReadFastArrayWithFactor (Float_t *ptr, Int_t n, Double_t factor, Double_t minvalue) override

void	ReadFastArrayWithNbits (Double_t *ptr, Int_t n, Int_t nbits) override

void	ReadFastArrayWithNbits (Float_t *ptr, Int_t n, Int_t nbits) override

void	ReadFloat (Float_t &f) override

void	ReadFloat16 (Float_t f, TStreamerElement ele=nullptr) override

void	ReadInt (Int_t &i) override

void	ReadLong (Long_t &l) override

void	ReadLong64 (Long64_t &l) override

TObject *	ReadObject (const TClass *cl) override

void *	ReadObjectAny (const TClass *cast) override

void	ReadShort (Short_t &s) override

Int_t	ReadStaticArray (Bool_t *b) override

Int_t	ReadStaticArray (Char_t *c) override

Int_t	ReadStaticArray (Double_t *d) override

Int_t	ReadStaticArray (Float_t *f) override

Int_t	ReadStaticArray (Int_t *i) override

Int_t	ReadStaticArray (Long64_t *l) override

Int_t	ReadStaticArray (Long_t *l) override

Int_t	ReadStaticArray (Short_t *h) override

Int_t	ReadStaticArray (UChar_t *c) override

Int_t	ReadStaticArray (UInt_t *i) override

Int_t	ReadStaticArray (ULong64_t *l) override

Int_t	ReadStaticArray (ULong_t *l) override

Int_t	ReadStaticArray (UShort_t *h) override

Int_t	ReadStaticArrayDouble32 (Double_t d, TStreamerElement ele=nullptr) override

Int_t	ReadStaticArrayFloat16 (Float_t f, TStreamerElement ele=nullptr) override

virtual void	ReadStdString (std::string &s)

void	ReadStdString (std::string *s) override

virtual void	ReadStdString (std::string *s)=0

char *	ReadString (char *s, Int_t max) override

void	ReadTString (TString &s) override

void	ReadUChar (UChar_t &c) override

void	ReadUInt (UInt_t &i) override

void	ReadULong (ULong_t &l) override

void	ReadULong64 (ULong64_t &l) override

void	ReadUShort (UShort_t &s) override

Version_t	ReadVersion (UInt_t start=nullptr, UInt_t bcnt=nullptr, const TClass *cl=nullptr) override

Version_t	ReadVersionForMemberWise (const TClass *cl=nullptr) override

Version_t	ReadVersionNoCheckSum (UInt_t start=nullptr, UInt_t bcnt=nullptr) override

void	ReadWithFactor (Double_t *ptr, Double_t factor, Double_t minvalue) override

void	ReadWithFactor (Float_t *ptr, Double_t factor, Double_t minvalue) override

void	ReadWithNbits (Double_t *ptr, Int_t nbits) override

void	ReadWithNbits (Float_t *ptr, Int_t nbits) override

void	SetByteCount (UInt_t cntpos, Bool_t packInVersion=kFALSE) override

void	SetStreamerElementNumber (TStreamerElement *, Int_t) override

void	SkipObjectAny () override

void	SkipVersion (const TClass *cl=nullptr) override

void	StreamerNVirtual (TBuffer &ClassDef_StreamerNVirtual_b)

void	StreamObject (TObject *obj) override

void	StreamObject (void obj, const char className, const TClass *onFileClass=nullptr) override

void	StreamObject (void obj, const std::type_info &typeinfo, const TClass onFileClass=nullptr) override

void	StreamObject (void obj, const TClass cl, const TClass *onFileClass=nullptr) override

void	WriteArray (const Bool_t *b, Int_t n) override

void	WriteArray (const Char_t *c, Int_t n) override

void	WriteArray (const Double_t *d, Int_t n) override

void	WriteArray (const Float_t *f, Int_t n) override

void	WriteArray (const Int_t *i, Int_t n) override

void	WriteArray (const Long64_t *l, Int_t n) override

void	WriteArray (const Long_t *l, Int_t n) override

void	WriteArray (const Short_t *h, Int_t n) override

void	WriteArray (const UChar_t *c, Int_t n) override

void	WriteArray (const UInt_t *i, Int_t n) override

void	WriteArray (const ULong64_t *l, Int_t n) override

void	WriteArray (const ULong_t *l, Int_t n) override

void	WriteArray (const UShort_t *h, Int_t n) override

void	WriteArrayDouble32 (const Double_t d, Int_t n, TStreamerElement ele=nullptr) override

void	WriteArrayFloat16 (const Float_t f, Int_t n, TStreamerElement ele=nullptr) override

void	WriteBool (Bool_t b) override

void	WriteBuf (const void *buf, Int_t max) override

void	WriteChar (Char_t c) override

void	WriteCharP (const Char_t *c) override

void	WriteCharStar (char *s) override

void	WriteClass (const TClass *cl) override

Int_t	WriteClassBuffer (const TClass cl, void pointer) override

void	WriteDouble (Double_t d) override

void	WriteDouble32 (Double_t d, TStreamerElement ele=nullptr) override

void	WriteFastArray (const Bool_t *b, Long64_t n) override

void	WriteFastArray (const Char_t *c, Long64_t n) override

void	WriteFastArray (const Double_t *d, Long64_t n) override

void	WriteFastArray (const Float_t *f, Long64_t n) override

void	WriteFastArray (const Int_t *i, Long64_t n) override

void	WriteFastArray (const Long64_t *l, Long64_t n) override

void	WriteFastArray (const Long_t *l, Long64_t n) override

void	WriteFastArray (const Short_t *h, Long64_t n) override

void	WriteFastArray (const UChar_t *c, Long64_t n) override

void	WriteFastArray (const UInt_t *i, Long64_t n) override

void	WriteFastArray (const ULong64_t *l, Long64_t n) override

void	WriteFastArray (const ULong_t *l, Long64_t n) override

void	WriteFastArray (const UShort_t *h, Long64_t n) override

Int_t	WriteFastArray (void *startp, const TClass cl, Long64_t n=1, Bool_t isPreAlloc=kFALSE, TMemberStreamer *s=nullptr) override

void	WriteFastArray (void start, const TClass cl, Long64_t n=1, TMemberStreamer *s=nullptr) override

void	WriteFastArrayDouble32 (const Double_t d, Long64_t n, TStreamerElement ele=nullptr) override

void	WriteFastArrayFloat16 (const Float_t f, Long64_t n, TStreamerElement ele=nullptr) override

void	WriteFastArrayString (const Char_t *c, Long64_t n) override

void	WriteFloat (Float_t f) override

void	WriteFloat16 (Float_t f, TStreamerElement ele=nullptr) override

void	WriteInt (Int_t i) override

void	WriteLong (Long_t l) override

void	WriteLong64 (Long64_t l) override

void	WriteShort (Short_t s) override

void	WriteStdString (const std::string *s) override

virtual void	WriteStdString (const std::string *s)=0

virtual void	WriteStdString (std::string &s)

void	WriteString (const char *s) override

void	WriteTString (const TString &s) override

void	WriteUChar (UChar_t c) override

void	WriteUInt (UInt_t i) override

void	WriteULong (ULong_t l) override

void	WriteULong64 (ULong64_t l) override

void	WriteUShort (UShort_t s) override

UInt_t	WriteVersion (const TClass *cl, Bool_t useBcnt=kFALSE) override

UInt_t	WriteVersionMemberWise (const TClass *cl, Bool_t useBcnt=kFALSE) override

Public Member Functions inherited from TBufferIO
	~TBufferIO () override

Bool_t	CheckObject (const TObject *obj) override

Bool_t	CheckObject (const void obj, const TClass ptrClass) override

void	ForceWriteInfoClones (TClonesArray *a) override

Int_t	GetBufferDisplacement () const override

TProcessID *	GetLastProcessID (TRefTable *reftable) const override

Int_t	GetMapCount () const override

void	GetMappedObject (UInt_t tag, void &ptr, TClass &ClassPtr) const override

UShort_t	GetPidOffset () const override

UInt_t	GetTRefExecId () override

Int_t	GetVersionOwner () const override

void	InitMap () override

void	MapObject (const TObject *obj, UInt_t offset=1) override

void	MapObject (const void obj, const TClass cl, UInt_t offset=1) override

Int_t	ReadClones (TClonesArray *a, Int_t nobjects, Version_t objvers) override

TProcessID *	ReadProcessID (UShort_t pidf) override

void	ResetMap () override

void	SetBufferDisplacement () override

void	SetBufferDisplacement (Int_t skipped) override

void	SetPidOffset (UShort_t offset) override

void	SetReadParam (Int_t mapsize) override

void	SetWriteParam (Int_t mapsize) override

void	StreamerNVirtual (TBuffer &ClassDef_StreamerNVirtual_b)

Int_t	WriteClones (TClonesArray *a, Int_t nobjects) override

Int_t	WriteObject (const T *objptr, Bool_t cacheReuse=kTRUE)

Int_t	WriteObjectAny (const void obj, const TClass ptrClass, Bool_t cacheReuse=kTRUE) override

Public Member Functions inherited from TBuffer
	TBuffer (EMode mode)

	TBuffer (EMode mode, Int_t bufsiz)

	TBuffer (EMode mode, Int_t bufsiz, void *buf, Bool_t adopt=kTRUE, ReAllocCharFun_t reallocfunc=nullptr)

virtual	~TBuffer ()

void	AutoExpand (Int_t size_needed)

char *	Buffer () const

Int_t	BufferSize () const

Bool_t	ByteSwapBuffer (Long64_t n, EDataType type)

void	DetachBuffer ()

void	Expand (Int_t newsize, Bool_t copy=kTRUE)

Int_t	GetBufferVersion () const

char *	GetCurrent () const

TObject *	GetParent () const

ReAllocCharFun_t	GetReAllocFunc () const

Bool_t	IsReading () const

Bool_t	IsWriting () const

Int_t	Length () const

virtual TVirtualArray *	PeekDataCache () const

virtual TVirtualArray *	PopDataCache ()

virtual void	PushDataCache (TVirtualArray *)

void	SetBuffer (void *buf, UInt_t bufsiz=0, Bool_t adopt=kTRUE, ReAllocCharFun_t reallocfunc=nullptr)

void	SetBufferOffset (Int_t offset=0)

void	SetParent (TObject *parent)

void	SetReadMode ()

void	SetReAllocFunc (ReAllocCharFun_t reallocfunc=nullptr)

void	SetWriteMode ()

void	StreamerNVirtual (TBuffer &ClassDef_StreamerNVirtual_b)

Int_t	WriteObject (const T *objptr, Bool_t cacheReuse=kTRUE)

Public Member Functions inherited from TObject
	TObject ()

	TObject (const TObject &object)

virtual	~TObject ()

void	AbstractMethod (const char *method) const

virtual void	AppendPad (Option_t *option="")

virtual void	Browse (TBrowser *b)

ULong_t	CheckedHash ()

virtual const char *	ClassName () const

virtual void	Clear (Option_t *="")

virtual TObject *	Clone (const char *newname="") const

virtual Int_t	Compare (const TObject *obj) const

virtual void	Copy (TObject &object) const

virtual void	Delete (Option_t *option="")

virtual Int_t	DistancetoPrimitive (Int_t px, Int_t py)

virtual void	Draw (Option_t *option="")

virtual void	DrawClass () const

virtual TObject *	DrawClone (Option_t *option="") const

virtual void	Dump () const

virtual void	Error (const char method, const char msgfmt,...) const

virtual void	Execute (const char method, const char params, Int_t *error=nullptr)

virtual void	Execute (TMethod method, TObjArray params, Int_t *error=nullptr)

virtual void	ExecuteEvent (Int_t event, Int_t px, Int_t py)

virtual void	Fatal (const char method, const char msgfmt,...) const

virtual TObject *	FindObject (const char *name) const

virtual TObject *	FindObject (const TObject *obj) const

virtual Option_t *	GetDrawOption () const

virtual const char *	GetIconName () const

virtual const char *	GetName () const

virtual char *	GetObjectInfo (Int_t px, Int_t py) const

virtual Option_t *	GetOption () const

virtual const char *	GetTitle () const

virtual UInt_t	GetUniqueID () const

virtual Bool_t	HandleTimer (TTimer *timer)

virtual ULong_t	Hash () const

Bool_t	HasInconsistentHash () const

virtual void	Info (const char method, const char msgfmt,...) const

virtual Bool_t	InheritsFrom (const char *classname) const

virtual Bool_t	InheritsFrom (const TClass *cl) const

virtual void	Inspect () const

void	InvertBit (UInt_t f)

Bool_t	IsDestructed () const

virtual Bool_t	IsEqual (const TObject *obj) const

virtual Bool_t	IsFolder () const

R__ALWAYS_INLINE Bool_t	IsOnHeap () const

virtual Bool_t	IsSortable () const

R__ALWAYS_INLINE Bool_t	IsZombie () const

virtual void	ls (Option_t *option="") const

void	MayNotUse (const char *method) const

virtual Bool_t	Notify ()

void	Obsolete (const char method, const char asOfVers, const char *removedFromVers) const

void	operator delete (void *ptr)

void	operator delete (void ptr, void vp)

void	operator delete[] (void *ptr)

void	operator delete[] (void ptr, void vp)

void *	operator new (size_t sz)

void *	operator new (size_t sz, void *vp)

void *	operator new[] (size_t sz)

void *	operator new[] (size_t sz, void *vp)

TObject &	operator= (const TObject &rhs)

virtual void	Paint (Option_t *option="")

virtual void	Pop ()

virtual void	Print (Option_t *option="") const

virtual void	RecursiveRemove (TObject *obj)

void	ResetBit (UInt_t f)

virtual void	SaveAs (const char filename="", Option_t option="") const

virtual void	SavePrimitive (std::ostream &out, Option_t *option="")

void	SetBit (UInt_t f)

void	SetBit (UInt_t f, Bool_t set)

virtual void	SetDrawOption (Option_t *option="")

virtual void	SetUniqueID (UInt_t uid)

void	StreamerNVirtual (TBuffer &ClassDef_StreamerNVirtual_b)

virtual void	SysError (const char method, const char msgfmt,...) const

R__ALWAYS_INLINE Bool_t	TestBit (UInt_t f) const

Int_t	TestBits (UInt_t f) const

virtual void	UseCurrentStyle ()

virtual void	Warning (const char method, const char msgfmt,...) const

Private Attributes
zmq::message_t	fMessage

std::unique_ptr< TObject >	fObject

Bool_t	fReadNewObject

Additional Inherited Members
Public Types inherited from TBufferIO
enum	EStatusBits

Public Types inherited from TBuffer
enum	EMode

enum	EStatusBits

Public Types inherited from TObject
enum	EDeprecatedStatusBits

enum	EStatusBits

Static Public Member Functions inherited from TMessage
static TClass *	Class ()

static const char *	Class_Name ()

static constexpr Version_t	Class_Version ()

static const char *	DeclFileName ()

static void	EnableSchemaEvolutionForAll (Bool_t enable=kTRUE)

static Bool_t	UsesSchemaEvolutionForAll ()

Static Public Member Functions inherited from TBufferFile
static TClass *	Class ()

static const char *	Class_Name ()

static constexpr Version_t	Class_Version ()

static const char *	DeclFileName ()

Static Public Member Functions inherited from TBufferIO
static TClass *	Class ()

static const char *	Class_Name ()

static constexpr Version_t	Class_Version ()

static const char *	DeclFileName ()

static Int_t	GetGlobalReadParam ()

static Int_t	GetGlobalWriteParam ()

static void	SetGlobalReadParam (Int_t mapsize)

static void	SetGlobalWriteParam (Int_t mapsize)

Static Public Member Functions inherited from TBuffer
static TClass *	Class ()

static const char *	Class_Name ()

static constexpr Version_t	Class_Version ()

static const char *	DeclFileName ()

static TClass *	GetClass (const char *className)

static TClass *	GetClass (const std::type_info &typeinfo)

Static Public Member Functions inherited from TObject
static TClass *	Class ()

static const char *	Class_Name ()

static constexpr Version_t	Class_Version ()

static const char *	DeclFileName ()

static Longptr_t	GetDtorOnly ()

static Bool_t	GetObjectStat ()

static void	SetDtorOnly (void *obj)

static void	SetObjectStat (Bool_t stat)

Public Attributes inherited from TBufferFile
	kStreamedMemberWise

Public Attributes inherited from TBufferIO
	kMapSize

	kNotDecompressed

	kTextBasedStreaming

	kUser1

	kUser2

	kUser3

Public Attributes inherited from TBuffer
	kCannotHandleMemberWiseStreaming

	kInitialSize

	kIsOwner

	kMinimalSize

	kRead

	kWrite

Public Attributes inherited from TObject
	kBitMask

	kCanDelete

	kCannotPick

	kHasUUID

	kInconsistent

	kInvalidObject

	kIsOnHeap

	kIsReferenced

	kMustCleanup

	kNoContextMenu

	kNotDeleted

	kObjInCanvas

	kOverwrite

	kSingleKey

	kWriteDelete

	kZombie

Protected Types inherited from TBufferFile
typedef std::vector< TStreamerInfo * >	InfoList_t

Protected Types inherited from TBuffer
typedef std::vector< TVirtualArray * >	CacheList_t

Protected Member Functions inherited from TMessage
	TMessage (void *buf, Int_t bufsize)

void	SetLength () const

Protected Member Functions inherited from TBufferFile
	TBufferFile ()

	TBufferFile (const TBufferFile &)=delete

Int_t	CheckByteCount (UInt_t startpos, UInt_t bcnt, const TClass clss, const char classname)

void	CheckCount (UInt_t offset) override

UInt_t	CheckObject (UInt_t offset, const TClass *cl, Bool_t readClass=kFALSE)

void	operator= (const TBufferFile &)=delete

void	WriteObjectClass (const void actualObjStart, const TClass actualClass, Bool_t cacheReuse) override

Protected Member Functions inherited from TBufferIO
	TBufferIO ()

	TBufferIO (TBuffer::EMode mode)

	TBufferIO (TBuffer::EMode mode, Int_t bufsiz)

	TBufferIO (TBuffer::EMode mode, Int_t bufsiz, void *buf, Bool_t adopt=kTRUE, ReAllocCharFun_t reallocfunc=nullptr)

Long64_t	GetObjectTag (const void *obj)

Protected Member Functions inherited from TBuffer
	TBuffer ()

	TBuffer (const TBuffer &)=delete

void	operator= (const TBuffer &)=delete

Int_t	Read (const char *name) override

Int_t	Write (const char *name, Int_t opt, Int_t bufs) const override

Int_t	Write (const char *name, Int_t opt, Int_t bufs) override

Protected Member Functions inherited from TObject
virtual void	DoError (int level, const char location, const char fmt, va_list va) const

void	MakeZombie ()

Static Protected Member Functions inherited from TBufferIO
static R__ALWAYS_INLINE ULong_t	Void_Hash (const void *ptr)

Protected Attributes inherited from TBufferFile
TStreamerInfo *	fInfo

InfoList_t	fInfoStack

Protected Attributes inherited from TBufferIO
TExMap *	fClassMap

Int_t	fDisplacement

TExMap *	fMap

Int_t	fMapCount

Int_t	fMapSize

UShort_t	fPidOffset

	kNullTag

Protected Attributes inherited from TBuffer
char *	fBufCur

char *	fBuffer

char *	fBufMax

Int_t	fBufSize

CacheList_t	fCacheStack

Bool_t	fMode

TObject *	fParent

ReAllocCharFun_t	fReAllocFunc

Int_t	fVersion

Protected Attributes inherited from TObject
	kOnlyPrepStep

Static Protected Attributes inherited from TBufferIO
static Int_t	fgMapSize

Constructor & Destructor Documentation

◆ KVZMQMessage() [1/2]

KVZMQMessage::KVZMQMessage ( )

inline

Definition at line 52 of file KVZMQMessage.h.

◆ KVZMQMessage() [2/2]

KVZMQMessage::KVZMQMessage ( zmq::message_t & g )

inline

stop the underlying TBuffer from deleting the buffer which in our case belongs to the zmq::message_t object

Definition at line 57 of file KVZMQMessage.h.

◆ ~KVZMQMessage()

virtual KVZMQMessage::~KVZMQMessage ( )

inlinevirtual

Definition at line 65 of file KVZMQMessage.h.

Member Function Documentation

◆ GetMessage()

zmq::message_t& KVZMQMessage::GetMessage ( )

inline

Definition at line 77 of file KVZMQMessage.h.

◆ GetObject() [1/2]

TObject* KVZMQMessage::GetObject ( )

inline

Definition at line 82 of file KVZMQMessage.h.

◆ GetObject() [2/2]

template<class T >

T* KVZMQMessage::GetObject ( )

inline

Definition at line 91 of file KVZMQMessage.h.

◆ WriteObject()

virtual void KVZMQMessage::WriteObject	(	const TObject *	obj,
		Bool_t	cacheReuse = `kTRUE`
	)

inlinevirtual

Reimplemented from TBufferIO.

Definition at line 71 of file KVZMQMessage.h.

Member Data Documentation

◆ fMessage

zmq::message_t KVZMQMessage::fMessage

private

Definition at line 49 of file KVZMQMessage.h.

◆ fObject

std::unique_ptr<TObject> KVZMQMessage::fObject

private

Definition at line 47 of file KVZMQMessage.h.

◆ fReadNewObject

Bool_t KVZMQMessage::fReadNewObject

private

Definition at line 48 of file KVZMQMessage.h.

Detailed Description

Examples of use

Sending an object

Receiving an object

Public Member Functions

Private Attributes

Additional Inherited Members

Constructor & Destructor Documentation

◆ KVZMQMessage() [1/2]

◆ KVZMQMessage() [2/2]

◆ ~KVZMQMessage()

Member Function Documentation

◆ GetMessage()

◆ GetObject() [1/2]

◆ GetObject() [2/2]

◆ WriteObject()

Member Data Documentation

◆ fMessage

◆ fObject

◆ fReadNewObject