...
| Code Block |
|---|
#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']
]
}
) |
See https://git.swl.informatik.uni-oldenburg.de/projects/ODYDATGEN/repos/telcosim/browse/src/main/java/de/uniol/inf/is/telCoSim/Simulation.java how the data is generated for this input queue.
See RabbitMQ use case for an example how to connect external software with Odysseus via RabbitMQ.