Uses of Interface
org.apache.camel.builder.component.dsl.NatsComponentBuilderFactory.NatsComponentBuilder
Packages that use NatsComponentBuilderFactory.NatsComponentBuilder
-
Uses of NatsComponentBuilderFactory.NatsComponentBuilder in org.apache.camel.builder.component
Methods in org.apache.camel.builder.component that return NatsComponentBuilderFactory.NatsComponentBuilderModifier and TypeMethodDescriptionComponentsBuilderFactory.nats()Nats (camel-nats) Send and receive messages from NATS messaging system. -
Uses of NatsComponentBuilderFactory.NatsComponentBuilder in org.apache.camel.builder.component.dsl
Classes in org.apache.camel.builder.component.dsl that implement NatsComponentBuilderFactory.NatsComponentBuilderModifier and TypeClassDescriptionstatic classMethods in org.apache.camel.builder.component.dsl that return NatsComponentBuilderFactory.NatsComponentBuilderModifier and TypeMethodDescriptionNatsComponentBuilderFactory.NatsComponentBuilder.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).NatsComponentBuilderFactory.NatsComponentBuilder.ackWait(long ackWait) After a message is delivered to a consumer, the server waits 30 seconds (default) for an acknowledgement.NatsComponentBuilderFactory.NatsComponentBuilder.autowiredEnabled(boolean autowiredEnabled) Whether autowiring is enabled.NatsComponentBuilderFactory.NatsComponentBuilder.bridgeErrorHandler(boolean bridgeErrorHandler) Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions (if possible) occurred while the Camel consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler.NatsComponentBuilderFactory.NatsComponentBuilder.configuration(org.apache.camel.component.nats.NatsConfiguration configuration) To use a shared configuration.NatsComponentBuilderFactory.NatsComponentBuilder.connection(io.nats.client.Connection connection) Reference an already instantiated connection to Nats server.NatsComponentBuilderFactory.NatsComponentBuilder.connectionTimeout(int connectionTimeout) Timeout for connection attempts.NatsComponentBuilderFactory.NatsComponentBuilder.consumerConfiguration(io.nats.client.api.ConsumerConfiguration consumerConfiguration) Sets a custom ConsumerConfiguration object for the JetStream consumer.NatsComponentBuilderFactory.NatsComponentBuilder.credentialsFilePath(String credentialsFilePath) If we use useCredentialsFile to true we'll need to set the credentialsFilePath option.NatsComponentBuilderFactory.NatsComponentBuilder.durableName(String durableName) Sets the name to assign to the JetStream durable consumer.NatsComponentBuilderFactory.NatsComponentBuilder.flushConnection(boolean flushConnection) Define if we want to flush connection when stopping or not.NatsComponentBuilderFactory.NatsComponentBuilder.flushTimeout(int flushTimeout) Set the flush timeout (in milliseconds).NatsComponentBuilderFactory.NatsComponentBuilder.headerFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy headerFilterStrategy) To use a custom header filter strategy.NatsComponentBuilderFactory.NatsComponentBuilder.jetstreamAsync(boolean jetstreamAsync) Sets whether to operate JetStream requests asynchronously.NatsComponentBuilderFactory.NatsComponentBuilder.jetstreamEnabled(boolean jetstreamEnabled) Sets whether to enable JetStream support for this endpoint.NatsComponentBuilderFactory.NatsComponentBuilder.jetstreamName(String jetstreamName) Sets the name of the JetStream stream to use.NatsComponentBuilderFactory.NatsComponentBuilder.lazyStartProducer(boolean lazyStartProducer) Whether the producer should be started lazy (on the first message).NatsComponentBuilderFactory.NatsComponentBuilder.manualAck(boolean manualAck) Whether to allow doing manual acknowledgment via NatsManualAck.NatsComponentBuilderFactory.NatsComponentBuilder.maxDeliver(long maxDeliver) Maximum number of attempts to deliver a message from Nats to a consumer.NatsComponentBuilderFactory.NatsComponentBuilder.maxMessages(String maxMessages) Stop receiving messages from a topic we are subscribing to after maxMessages.NatsComponentBuilderFactory.NatsComponentBuilder.maxPingsOut(int maxPingsOut) maximum number of pings have not received a response allowed by the client.NatsComponentBuilderFactory.NatsComponentBuilder.maxReconnectAttempts(int maxReconnectAttempts) Max reconnection attempts.NatsComponentBuilderFactory.NatsComponentBuilder.nackWait(long nackWait) For negative acknowledgements (NAK), redelivery is delayed by 5 seconds (default).NatsComponentBuilderFactory.nats()Nats (camel-nats) Send and receive messages from NATS messaging system.NatsComponentBuilderFactory.NatsComponentBuilder.noEcho(boolean noEcho) Turn off echo.NatsComponentBuilderFactory.NatsComponentBuilder.noRandomizeServers(boolean noRandomizeServers) Whether or not randomizing the order of servers for the connection attempts.NatsComponentBuilderFactory.NatsComponentBuilder.pedantic(boolean pedantic) Whether or not running in pedantic mode (this affects performance).NatsComponentBuilderFactory.NatsComponentBuilder.pingInterval(int pingInterval) Ping interval to be aware if connection is still alive (in milliseconds).NatsComponentBuilderFactory.NatsComponentBuilder.poolSize(int poolSize) Consumer thread pool size (default is 10).NatsComponentBuilderFactory.NatsComponentBuilder.pullBatchSize(int pullBatchSize) Maximum number of messages to fetch per pull request when using a JetStream Pull Subscription.NatsComponentBuilderFactory.NatsComponentBuilder.pullFetchTimeout(long pullFetchTimeout) Maximum time (in milliseconds) to wait for a batch of messages to be available on the server during a single fetch when using a JetStream Pull Subscription.NatsComponentBuilderFactory.NatsComponentBuilder.pullSubscription(boolean pullSubscription) Sets the consumer subscription type for JetStream.The Queue name if we are using nats for a queue configuration.NatsComponentBuilderFactory.NatsComponentBuilder.reconnect(boolean reconnect) Whether or not using reconnection feature.NatsComponentBuilderFactory.NatsComponentBuilder.reconnectTimeWait(int reconnectTimeWait) Waiting time before attempts reconnection (in milliseconds).NatsComponentBuilderFactory.NatsComponentBuilder.replySubject(String replySubject) the subject to which subscribers should send response.NatsComponentBuilderFactory.NatsComponentBuilder.replyToDisabled(boolean replyToDisabled) Can be used to turn off sending back reply message in the consumer.NatsComponentBuilderFactory.NatsComponentBuilder.requestCleanupInterval(int requestCleanupInterval) Interval to clean up cancelled/timed out requests.NatsComponentBuilderFactory.NatsComponentBuilder.requestTimeout(long requestTimeout) Request timeout in milliseconds.NatsComponentBuilderFactory.NatsComponentBuilder.secure(boolean secure) Set secure option indicating TLS is required.URLs to one or more NAT servers.NatsComponentBuilderFactory.NatsComponentBuilder.sslContextParameters(org.apache.camel.support.jsse.SSLContextParameters sslContextParameters) To configure security using SSLContextParameters.NatsComponentBuilderFactory.NatsComponentBuilder.traceConnection(boolean traceConnection) Whether or not connection trace messages should be printed to standard out for fine grained debugging of connection issues.NatsComponentBuilderFactory.NatsComponentBuilder.useGlobalSslContextParameters(boolean useGlobalSslContextParameters) Enable usage of global SSL context parameters.NatsComponentBuilderFactory.NatsComponentBuilder.verbose(boolean verbose) Whether or not running in verbose mode.