Page History

#PARSER PQL
#REQUIRED de.uniol.inf.is.odysseus.wrapper.rabbitmq.feature
#RUNQUERY
input = ACCESS({
            transport='RabbitMQ',
            source= 'Receiver',
            wrapper='GenericPush',
            protocol='SimpleCSV',
            datahandler='Tuple',
            options=[
              ['EXCHANGE_NAME','TelCoSim'],
              ['QUEUE_NAME','DataUsage'],
              ['CONSUMER_TAG','Odysseus'],
              ['HOST','localhost'],
              ['ByteOrder', 'Little_Endian'],
              ['csv.delimiter',';']
            ],
            schema=[
              ['TIMESTAMP', 'STARTTIMESTAMP'],
              ['id', 'String'],
              ['volume', 'Long']
            ]                                                                 
          }                                 
        )