Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

NameTypeDescription
natsMessageTimestamplongThe timestamp of a consumed message
natsSubscribeSidInteger

The subscription Id of a consumer

 

Producer example:

 

Code Block
languagejava
from("direct:send").to("nats://localhost:4222?topic=test");

 

Consumer example:

...

 

Code Block
languagejava
from("nats://localhost:4222?topic=test&maxMessages=5&queueName=test").to("mock:result");