Module io.helidon.messaging.connectors.aq

Package io.helidon.messaging.connectors.aq

Class AqConnectorImpl

java.lang.Object

io.helidon.messaging.connectors.jms.JmsConnector

io.helidon.messaging.connectors.aq.AqConnectorImpl

All Implemented Interfaces:

AqConnector, Stoppable, ConnectorFactory, IncomingConnectorFactory, OutgoingConnectorFactory

@ApplicationScoped
public class AqConnectorImpl
extends JmsConnector
implements AqConnector

MicroProfile Reactive Messaging Oracle AQ connector.

Nested Class Summary

Nested classes/interfaces inherited from class io.helidon.messaging.connectors.jms.JmsConnector

JmsConnector.JmsConnectorBuilder

Nested classes/interfaces inherited from interface io.helidon.messaging.connectors.aq.AqConnector

AqConnector.AqConnectorBuilder

Field Summary

Fields inherited from class io.helidon.messaging.connectors.jms.JmsConnector

ACK_MODE_ATTRIBUTE, AWAIT_ACK_ATTRIBUTE, CLIENT_ID_ATTRIBUTE, CONNECTOR_NAME, DESTINATION_ATTRIBUTE, DURABLE_ATTRIBUTE, MESSAGE_SELECTOR_ATTRIBUTE, NAMED_FACTORY_ATTRIBUTE, NON_LOCAL_ATTRIBUTE, PASSWORD_ATTRIBUTE, PERIOD_EXECUTIONS_ATTRIBUTE, POLL_TIMEOUT_ATTRIBUTE, SESSION_GROUP_ID_ATTRIBUTE, SUBSCRIBER_NAME_ATTRIBUTE, TRANSACTED_ATTRIBUTE, TYPE_ATTRIBUTE, USERNAME_ATTRIBUTE

Fields inherited from interface io.helidon.messaging.connectors.aq.AqConnector

CONNECTOR_NAME, DATASOURCE_ATTRIBUTE, EXECUTOR_THREAD_NAME_PREFIX, SCHEDULER_THREAD_NAME_PREFIX, URL_ATTRIBUTE

Fields inherited from interface org.eclipse.microprofile.reactive.messaging.spi.ConnectorFactory

CHANNEL_NAME_ATTRIBUTE, CONNECTOR_ATTRIBUTE, CONNECTOR_PREFIX, INCOMING_PREFIX, OUTGOING_PREFIX

Method Summary

Modifier and Type	Method	Description
protected JmsMessage<?>	createMessage(NackHandler nackHandler, jakarta.jms.Message message, Executor executor, SessionMetadata sessionMetadata)	Create reactive messaging message from JMS message.
protected Optional<? extends jakarta.jms.ConnectionFactory>	getFactory(ConnectionContext ctx)	Find correct ConnectionFactory for channel.
protected BiConsumer<Message<?>,jakarta.jms.JMSException>	sendingErrorHandler(Config config)	Customizable handler for errors during sending.
void	stop()	Invoked during Messaging.stop().

Methods inherited from class io.helidon.messaging.connectors.jms.JmsConnector

builder, configBuilder, consumeAsync, create, createConsumer, createDestination, createProducer, getPublisherBuilder, getSubscriberBuilder, prepareSession

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

getFactory

protected Optional<? extends jakarta.jms.ConnectionFactory> getFactory(ConnectionContext ctx)

Description copied from class: JmsConnector

Find correct ConnectionFactory for channel.

Overrides:

getFactory in class JmsConnector

Parameters:

ctx - Channel's context

Returns:

appropriate connection factory

createMessage

protected JmsMessage<?> createMessage(NackHandler nackHandler,
 jakarta.jms.Message message,
 Executor executor,
 SessionMetadata sessionMetadata)

Description copied from class: JmsConnector

Create reactive messaging message from JMS message.

Overrides:

createMessage in class JmsConnector

Parameters:

nackHandler - Not acknowledged handler

message - JMS message

executor - executor used for async execution of ack

sessionMetadata - JMS session metadata

Returns:

reactive messaging message extended with custom JMS features

sendingErrorHandler

protected BiConsumer<Message<?>,jakarta.jms.JMSException> sendingErrorHandler(Config config)

Description copied from class: JmsConnector

Customizable handler for errors during sending.

Overrides:

sendingErrorHandler in class JmsConnector

Parameters:

config - channel's config

Returns:

consumer of errors

stop

public void stop()

Description copied from interface: Stoppable

Invoked during Messaging.stop().

Specified by:

stop in interface Stoppable

Overrides:

stop in class JmsConnector