...
Code Block | ||
---|---|---|
| ||
#PARSER PQL #QNAME Query0Query1 #RUNQUERY timer = TIMER({ period = 500, timefromstart = true, source = 'timerSource1' } ) out = SENDER({ transport='RabbitMQ', wrapper='GenericPush', protocol='csv', datahandler='Tuple', sink="SENDER", options=[ ['QUEUE_NAME','Ody_Monitor'], ['CONSUMER_TAG','example'], ['HOST','localhost'] ] }, timer ) |
...