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 classAqConnector.AqConnectorBuilderBuilder forAqConnectorImpl.
-
Field Summary
Fields Modifier and Type Field Description static StringCONNECTOR_NAMEOracle AQ connector name.static StringDATASOURCE_ATTRIBUTEConfiguration key for data source identifier.static StringEXECUTOR_THREAD_NAME_PREFIXConfiguration key for thread name prefix used for asynchronous operations like acknowledgement.static StringSCHEDULER_THREAD_NAME_PREFIXConfiguration key for thread name prefix used for polling.static StringURL_ATTRIBUTEConfiguration 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.AqConnectorBuilderbuilder()Provides aJmsConnector.JmsConnectorBuilderfor creating aJmsConnectorinstance.static AqConfigBuilderconfigBuilder()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.JmsConnectorBuilderfor creating aJmsConnectorinstance.- Returns:
- new Builder instance
-
configBuilder
static AqConfigBuilder configBuilder()
Custom config builder for AQ connector.- Returns:
- new AQ specific config builder
-
-