Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
titleSimpleQuery_1.qry
#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
      )

...