Uses of Interface
org.apache.camel.builder.endpoint.dsl.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder
Packages that use NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder
-
Uses of NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder in org.apache.camel.builder.endpoint.dsl
Subinterfaces of NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder in org.apache.camel.builder.endpoint.dslModifier and TypeInterfaceDescriptionstatic interfaceBuilder for endpoint for the Nats component.Methods in org.apache.camel.builder.endpoint.dsl that return NatsEndpointBuilderFactory.NatsEndpointConsumerBuilderModifier and TypeMethodDescriptionNatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.ackPolicy(io.nats.client.api.AckPolicy ackPolicy) Acknowledgement mode. none = Messages are acknowledged as soon as the server sends them (danger: messages that Camel failed to process is also ack).Acknowledgement mode. none = Messages are acknowledged as soon as the server sends them (danger: messages that Camel failed to process is also ack).NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.ackWait(long ackWait) After a message is delivered to a consumer, the server waits 30 seconds (default) for an acknowledgement.After a message is delivered to a consumer, the server waits 30 seconds (default) for an acknowledgement.NatsEndpointBuilderFactory.AdvancedNatsEndpointConsumerBuilder.basic()NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.connectionTimeout(int connectionTimeout) Timeout for connection attempts.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.connectionTimeout(String connectionTimeout) Timeout for connection attempts.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.credentialsFilePath(String credentialsFilePath) If we use useCredentialsFile to true we'll need to set the credentialsFilePath option.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.durableName(String durableName) Sets the name to assign to the JetStream durable consumer.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.flushConnection(boolean flushConnection) Define if we want to flush connection when stopping or not.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.flushConnection(String flushConnection) Define if we want to flush connection when stopping or not.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.flushTimeout(int flushTimeout) Set the flush timeout (in milliseconds).NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.flushTimeout(String flushTimeout) Set the flush timeout (in milliseconds).NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.jetstreamEnabled(boolean jetstreamEnabled) Sets whether to enable JetStream support for this endpoint.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.jetstreamEnabled(String jetstreamEnabled) Sets whether to enable JetStream support for this endpoint.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.jetstreamName(String jetstreamName) Sets the name of the JetStream stream to use.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.maxDeliver(long maxDeliver) Maximum number of attempts to deliver a message from Nats to a consumer.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.maxDeliver(String maxDeliver) Maximum number of attempts to deliver a message from Nats to a consumer.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.maxMessages(String maxMessages) Stop receiving messages from a topic we are subscribing to after maxMessages.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.maxPingsOut(int maxPingsOut) maximum number of pings have not received a response allowed by the client.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.maxPingsOut(String maxPingsOut) maximum number of pings have not received a response allowed by the client.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.maxReconnectAttempts(int maxReconnectAttempts) Max reconnection attempts.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.maxReconnectAttempts(String maxReconnectAttempts) Max reconnection attempts.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.nackWait(long nackWait) For negative acknowledgements (NAK), redelivery is delayed by 5 seconds (default).For negative acknowledgements (NAK), redelivery is delayed by 5 seconds (default).NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.noEcho(boolean noEcho) Turn off echo.Turn off echo.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.noRandomizeServers(boolean noRandomizeServers) Whether or not randomizing the order of servers for the connection attempts.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.noRandomizeServers(String noRandomizeServers) Whether or not randomizing the order of servers for the connection attempts.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.pedantic(boolean pedantic) Whether or not running in pedantic mode (this affects performance).Whether or not running in pedantic mode (this affects performance).NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.pingInterval(int pingInterval) Ping interval to be aware if connection is still alive (in milliseconds).NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.pingInterval(String pingInterval) Ping interval to be aware if connection is still alive (in milliseconds).NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.poolSize(int poolSize) Consumer thread pool size (default is 10).Consumer thread pool size (default is 10).NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.pullSubscription(boolean pullSubscription) Sets the consumer subscription type for JetStream.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.pullSubscription(String pullSubscription) Sets the consumer subscription type for JetStream.The Queue name if we are using nats for a queue configuration.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.reconnect(boolean reconnect) Whether or not using reconnection feature.Whether or not using reconnection feature.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.reconnectTimeWait(int reconnectTimeWait) Waiting time before attempts reconnection (in milliseconds).NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.reconnectTimeWait(String reconnectTimeWait) Waiting time before attempts reconnection (in milliseconds).NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.replyToDisabled(boolean replyToDisabled) Can be used to turn off sending back reply message in the consumer.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.replyToDisabled(String replyToDisabled) Can be used to turn off sending back reply message in the consumer.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.requestCleanupInterval(int requestCleanupInterval) Interval to clean up cancelled/timed out requests.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.requestCleanupInterval(String requestCleanupInterval) Interval to clean up cancelled/timed out requests.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.secure(boolean secure) Set secure option indicating TLS is required.Set secure option indicating TLS is required.URLs to one or more NAT servers.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.sslContextParameters(String sslContextParameters) To configure security using SSLContextParameters.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.sslContextParameters(org.apache.camel.support.jsse.SSLContextParameters sslContextParameters) To configure security using SSLContextParameters.NatsEndpointBuilderFactory.NatsEndpointConsumerBuilder.verbose(boolean verbose) Whether or not running in verbose mode.Whether or not running in verbose mode.