LDIO AMQP Out
Ldio:AmqpOut
The LDIO AMQP Out sends messages to an AMQP 1.0 queue. The content-type configured in the rdf-writer.content-type is added as a header to the message with key “contentType”.
Config
Property | Description | Required | Default | Supported values | Example |
---|---|---|---|---|---|
remote-url | URI to AMQP queue | Yes | N/A | In line with amqp[s]://hostname:port[?option=value[&option2=value...]] or amqpws[s]://hostname:port[/path][?option=value[&option2=value...]] | amqp://server:61616 |
queue | Name of the queue | Yes | N/A | String | quickstart-events |
username | Username used in authentication | Yes | N/A | String | client |
password | Password used in the authentication | Yes | N/A | String | secret |
RDF Writer Properties
Property | Description | Required | Default | Supported values | Example |
---|---|---|---|---|---|
rdf-writer.content-type | Target content type. | No | text/turtle | Any type supported by Apache Jena | application/ld+json |
rdf-writer.frame | Additional JSON-LD Frame to format the outputted JSON-LD Object. | No | N/A | Any valid JSON Object that describes a JSON-LD Frame | See https://www.w3.org/TR/json-ld11-framing/#sample-library-frame |
Example RDF Writer config
Format as N-Quads:
config:
rdf-writer:
content-type: application/n-quads
Format as JSON-LD with given frame:
config:
rdf-writer:
content-type: application/ld+json
frame: |
{
"@context": {"@vocab": "http://example.org/"},
"@type": "Library",
"contains": {
"@type": "Book",
"contains": {
"@type": "Chapter"
}
}
}
Example
outputs:
- name: Ldio:AmqpOut
config:
remote-url: amqp://localhost:61616
username: artemis
password: artemis
queue: example
rdf-writer:
content-type: application/n-quads