...
Code Block |
---|
/// Send/Receive via publish/subscribe sender = SENDER({ id='sender', transport='ZeroMQ', wrapper='GenericPush', protocol='SVM', datahandler='Tuple', SINK="SENDER", options=[ ['HOST','192.168.1.101'], ['READPORT','5554'], ['WRITEPORT','5555'], ['DELAYOFMSG','1'], ['THREADS','1'], ['ByteOrder', 'LittleEndian'] ] },nexmark:Person } ) /// Send/Receive via pull sender = SENDER({ id='sender', transport='ZeroMQ', wrapper='GenericPull', protocol='SVM', datahandler='Tuple', SINK="SENDER", options=[ ['HOST','192.168.1.101'], ['READPORT','5554'], ['WRITEPORT','5555'], ['DELAYOFMSG','1'], ['THREADS','1'], ['ByteOrder', 'LittleEndian'] ] },nexmark:Person } ) |