...
Code Block |
---|
/// Send elements to bus (work queue) SENDER = SENDER({ transport='RabbitMQ', wrapper='GenericPush', protocol='SimpleByteBuffer', datahandler='Tuple', SINK="SENDER", options=[ ['QUEUE_NAME','nexmark'], ['CONSUMER_TAG','person'], ['HOST','localhost'], ['ByteOrder', 'LittleEndian']Little_Endian'], ['durable',true], ['exclusive',false], ['auto_delete',false], ['rabbit.x-message-ttl',1000] ] }, nexmark:person ) /// Receive elements from bus (work queue) input = ACCESS({ transport='RabbitMQ', source= 'Receiver', wrapper='GenericPush', protocol='SimpleByteBuffer', datahandler='Tuple', options=[ ['QUEUE_NAME','nexmark'], ['CONSUMER_TAG','person'], ['HOST','localhost'], ['ByteOrder', 'LittleEndianLittle_Endian'] ], schema=[ ['TIMESTAMP', 'STARTTIMESTAMP'], ['id', 'INTEGER'], ['name', 'STRING'], ['email', 'STRING'], ['creditcard', 'STRING'], ['city', 'STRING'], ['state', 'STRING'] ] } ) |
...
Code Block |
---|
/// Send elements to bus (publish-subscribe) SENDER = SENDER({ transport='RabbitMQ', wrapper='GenericPush', protocol='SimpleByteBuffer', datahandler='Tuple', SINK="SENDER", options=[ ['EXCHANGE_NAME','nexmark'], ['PUBLISH_STYLE','publishsubscribe'], ['CONSUMER_TAG','person'], ['HOST','localhost'], ['ByteOrder', 'LittleEndianLittle_Endian'] ] }, nexmark:person ) /// Receive elements from bus (publish-subscribe) input = ACCESS({ transport='RabbitMQ', source= 'Receiver', wrapper='GenericPush', protocol='SimpleByteBuffer', datahandler='Tuple', options=[ ['EXCHANGE_NAME','nexmark'], ['PUBLISH_STYLE','publishsubscribe'], ['CONSUMER_TAG','person'], ['HOST','localhost'], ['ByteOrder', 'LittleEndianLittle_Endian'] ], schema=[ ['TIMESTAMP', 'STARTTIMESTAMP'], ['id', 'INTEGER'], ['name', 'STRING'], ['email', 'STRING'], ['creditcard', 'STRING'], ['city', 'STRING'], ['state', 'STRING'] ] } ) |