THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
Nats Component
Available since Camel 2.17.0
Nats is a fast and reliable messaging platform.
Maven users will need to add the following dependency to their pom.xml for this component.
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-nats</artifactId>
<!-- use the same version as your Camel core version -->
<version>x.y.z</version>
</dependency>
URI format
nats:servers[?options]
Where servers represents the list of nats servers.
Options
Name | Default Value | Description |
|---|---|---|
| null | Defines the servers the component should connect to. |
| topic | null | The topic to connect to |
| reconnect | true | Whether or not using reconnection feature |
| pedantic | false | Whether or not running in pedantic mode (this affects performance) |
| verbose | false | Whether or not running in verbose mode |
| ssl | false | Wherer or not using ssl |
| reconnectTimeWait | 2000 | Waiting time before attempts reconnection (in milliseconds) |
| maxReconnectAttempts | 3 | To set the maximum time an action could take to complete. |
| pingInterval | 4000 | Ping interval to be aware if connection is still alive (in milliseconds) |
| noRandomizeServers | false | Whether or not randomizing the order of servers for the connection attempts |
| queueName | null | The Queue name if we are using nats for a queue configuration |
| maxMessages | null | Stop receiving messages from a topic we are subscribing to after maxMessages (consumer) |
| poolSize | 10 | The Queue name if we are using nats for a queue configuration (consumer) |
Headers
| Name | Type | Description |
|---|---|---|
| natsMessageTimestamp | long | The timestamp of a consumed message |
| natsSubscribeSid | Integer | The subscription Id of a consumer |
Producer example:
from("direct:send").to("nats://localhost:4222?topic=test");
Consumer example:
from("nats://localhost:4222?topic=test&maxMessages=5&queueName=test").to("mock:result");