...
| 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', '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=[
['PUBLISH_STYLE','workqueue'],
['QUEUE_NAME','nexmark'],
['CONSUMER_TAG','person'],
['HOST','localhost'],
['ByteOrder', 'Little_Endian'],
['durable',true],
['exclusive',false],
['auto_delete',false],
['rabbit.x-message-ttl',1000]
],
schema=[
['TIMESTAMP', 'STARTTIMESTAMP'],
['id', 'INTEGER'],
['name', 'STRING'],
['email', 'STRING'],
['creditcard', 'STRING'],
['city', 'STRING'],
['state', 'STRING']
]
}
)
|
...