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 AqConnectorImpl
build()
Build the instance from this builder.AqConnector.AqConnectorBuilder
config(Config config)
Custom configuration for connector.AqConnector.AqConnectorBuilder
dataSource(String name, DataSource dataSource)
Add customConnectionFactory
referencable by supplied name withJmsConnector.NAMED_FACTORY_ATTRIBUTE
.AqConnector.AqConnectorBuilder
executor(ThreadPoolSupplier executorSupplier)
Custom executor supplier for asynchronous operations like acknowledgement.AqConnector.AqConnectorBuilder
executor(ExecutorService executor)
Custom executor for asynchronous operations like acknowledgement.AqConnector.AqConnectorBuilder
scheduler(ScheduledThreadPoolSupplier schedulerPoolSupplier)
Custom executor supplier for loop pulling messages from JMS.AqConnector.AqConnectorBuilder
scheduler(ScheduledExecutorService scheduler)
Custom executor for loop pulling messages from JMS.
-
-
-
Method Detail
-
dataSource
public AqConnector.AqConnectorBuilder dataSource(String name, DataSource dataSource)
Add customConnectionFactory
referencable 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:Builder
Build the instance from this builder.- Specified by:
build
in interfaceBuilder<AqConnectorImpl>
- Returns:
- instance of the built type
-
-