...
In addition, arbitrary options can bedefined. They need to start with the prefix "rabbit." which will be removed in the actual argument. Example: ['rabbit.x-message-ttl',1000] will be the argument 'x-message-ttl' with the long value '1000'.
Example
| 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 RabbitMQ use case for an example how to connect external software with Odysseus via RabbitMQ.