Class AqConnector.AqConnectorBuilder
- java.lang.Object
-
- io.helidon.messaging.connectors.aq.AqConnector.AqConnectorBuilder
-
- All Implemented Interfaces:
Builder<AqConnectorImpl>,Supplier<AqConnectorImpl>
- Enclosing interface:
- AqConnector
public static class AqConnector.AqConnectorBuilder extends Object implements Builder<AqConnectorImpl>
Builder forAqConnectorImpl.
-
-
Constructor Summary
Constructors Constructor Description AqConnectorBuilder()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description AqConnectorImplbuild()Build the instance from this builder.AqConnector.AqConnectorBuilderconfig(Config config)Custom configuration for connector.AqConnector.AqConnectorBuilderdataSource(String name, DataSource dataSource)Add customConnectionFactoryreferencable by supplied name withJmsConnector.NAMED_FACTORY_ATTRIBUTE.AqConnector.AqConnectorBuilderexecutor(ThreadPoolSupplier executorSupplier)Custom executor supplier for asynchronous operations like acknowledgement.AqConnector.AqConnectorBuilderexecutor(ExecutorService executor)Custom executor for asynchronous operations like acknowledgement.AqConnector.AqConnectorBuilderscheduler(ScheduledThreadPoolSupplier schedulerPoolSupplier)Custom executor supplier for loop pulling messages from JMS.AqConnector.AqConnectorBuilderscheduler(ScheduledExecutorService scheduler)Custom executor for loop pulling messages from JMS.
-
-
-
Method Detail
-
dataSource
public AqConnector.AqConnectorBuilder dataSource(String name, DataSource dataSource)
Add customConnectionFactoryreferencable by supplied name withJmsConnector.NAMED_FACTORY_ATTRIBUTE.- Parameters:
name- referencable connection factory namedataSource- custom connection factory- Returns:
- this builder
-
config
public AqConnector.AqConnectorBuilder config(Config config)
Custom configuration for connector.- Parameters:
config- custom config- Returns:
- this builder
-
executor
public AqConnector.AqConnectorBuilder executor(ExecutorService executor)
Custom executor for asynchronous operations like acknowledgement.- Parameters:
executor- custom executor service- Returns:
- this builder
-
scheduler
public AqConnector.AqConnectorBuilder scheduler(ScheduledExecutorService scheduler)
Custom executor for loop pulling messages from JMS.- Parameters:
scheduler- custom scheduled executor service- Returns:
- this builder
-
executor
public AqConnector.AqConnectorBuilder executor(ThreadPoolSupplier executorSupplier)
Custom executor supplier for asynchronous operations like acknowledgement.- Parameters:
executorSupplier- custom executor service- Returns:
- this builder
-
scheduler
public AqConnector.AqConnectorBuilder scheduler(ScheduledThreadPoolSupplier schedulerPoolSupplier)
Custom executor supplier for loop pulling messages from JMS.- Parameters:
schedulerPoolSupplier- custom scheduled executor service- Returns:
- this builder
-
build
public AqConnectorImpl build()
Description copied from interface:BuilderBuild the instance from this builder.- Specified by:
buildin interfaceBuilder<AqConnectorImpl>- Returns:
- instance of the built type
-
-