Interface AqConnector
-
- All Superinterfaces:
ConnectorFactory
- All Known Implementing Classes:
AqConnectorImpl
public interface AqConnector extends ConnectorFactory
Reactive Messaging Oracle AQ connector.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
AqConnector.AqConnectorBuilder
Builder forAqConnectorImpl
.
-
Field Summary
Fields Modifier and Type Field Description static String
CONNECTOR_NAME
Oracle AQ connector name.static String
DATASOURCE_ATTRIBUTE
Configuration key for data source identifier.static String
EXECUTOR_THREAD_NAME_PREFIX
Configuration key for thread name prefix used for asynchronous operations like acknowledgement.static String
SCHEDULER_THREAD_NAME_PREFIX
Configuration key for thread name prefix used for polling.static String
URL_ATTRIBUTE
Configuration key for Oracle db connection string.-
Fields inherited from interface org.eclipse.microprofile.reactive.messaging.spi.ConnectorFactory
CHANNEL_NAME_ATTRIBUTE, CONNECTOR_ATTRIBUTE, CONNECTOR_PREFIX, INCOMING_PREFIX, OUTGOING_PREFIX
-
-
Method Summary
Static Methods Modifier and Type Method Description static AqConnector.AqConnectorBuilder
builder()
Provides aJmsConnector.JmsConnectorBuilder
for creating aJmsConnector
instance.static AqConfigBuilder
configBuilder()
Custom config builder for AQ connector.
-
-
-
Field Detail
-
CONNECTOR_NAME
static final String CONNECTOR_NAME
Oracle AQ connector name.- See Also:
- Constant Field Values
-
DATASOURCE_ATTRIBUTE
static final String DATASOURCE_ATTRIBUTE
Configuration key for data source identifier.- See Also:
- Constant Field Values
-
URL_ATTRIBUTE
static final String URL_ATTRIBUTE
Configuration key for Oracle db connection string.- See Also:
- Constant Field Values
-
EXECUTOR_THREAD_NAME_PREFIX
static final String EXECUTOR_THREAD_NAME_PREFIX
Configuration key for thread name prefix used for asynchronous operations like acknowledgement.- See Also:
- Constant Field Values
-
SCHEDULER_THREAD_NAME_PREFIX
static final String SCHEDULER_THREAD_NAME_PREFIX
Configuration key for thread name prefix used for polling.- See Also:
- Constant Field Values
-
-
Method Detail
-
builder
static AqConnector.AqConnectorBuilder builder()
Provides aJmsConnector.JmsConnectorBuilder
for creating aJmsConnector
instance.- Returns:
- new Builder instance
-
configBuilder
static AqConfigBuilder configBuilder()
Custom config builder for AQ connector.- Returns:
- new AQ specific config builder
-
-