Page History

/// 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
		}
	)