Module io.helidon.messaging.connectors.wls

Package io.helidon.messaging.connectors.wls

Class WeblogicConnector

java.lang.Object

io.helidon.messaging.connectors.jms.JmsConnector

io.helidon.messaging.connectors.wls.WeblogicConnector

All Implemented Interfaces:

Stoppable, ConnectorFactory, IncomingConnectorFactory, OutgoingConnectorFactory

@ApplicationScoped
public class WeblogicConnector
extends JmsConnector

MicroProfile Reactive Messaging Weblogic JMS connector.

Nested Class Summary

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

JmsConnector.JmsConnectorBuilder

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CONNECTOR_NAME	Microprofile messaging Weblogic JMS connector name.

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

ACK_MODE_ATTRIBUTE, AWAIT_ACK_ATTRIBUTE, CLIENT_ID_ATTRIBUTE, 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 org.eclipse.microprofile.reactive.messaging.spi.ConnectorFactory

CHANNEL_NAME_ATTRIBUTE, CONNECTOR_ATTRIBUTE, CONNECTOR_PREFIX, INCOMING_PREFIX, OUTGOING_PREFIX

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	WeblogicConnector(Config config, Instance<jakarta.jms.ConnectionFactory> connectionFactories)
protected	WeblogicConnector(Map<String,jakarta.jms.ConnectionFactory> connectionFactoryMap, ScheduledExecutorService scheduler, String thinJarLocation, ExecutorService executor)

Method Summary

Modifier and Type	Method	Description
protected CompletionStage<?>	consumeAsync(Message<?> m, jakarta.jms.Session session, AtomicReference<MessageMapper> mapper, jakarta.jms.MessageProducer producer, Config config)
protected jakarta.jms.MessageConsumer	createConsumer(Config config, jakarta.jms.Destination destination, SessionMetadata sessionEntry)
protected jakarta.jms.Destination	createDestination(jakarta.jms.Session session, ConnectionContext ctx)
protected Optional<? extends jakarta.jms.ConnectionFactory>	getFactory(ConnectionContext ctx)	Find correct ConnectionFactory for channel.
PublisherBuilder<? extends Message<?>>	getPublisherBuilder(Config mpConfig)
SubscriberBuilder<? extends Message<?>,Void>	getSubscriberBuilder(Config mpConfig)
protected SessionMetadata	prepareSession(Config config, jakarta.jms.ConnectionFactory factory)

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

builder, configBuilder, create, createMessage, createProducer, sendingErrorHandler, stop

Methods inherited from class java.lang.Object

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

Field Details

CONNECTOR_NAME

public static final String CONNECTOR_NAME

Microprofile messaging Weblogic JMS connector name.

See Also:

• Constant Field Values

Constructor Details

WeblogicConnector

@Inject
protected WeblogicConnector(Config config,
 Instance<jakarta.jms.ConnectionFactory> connectionFactories)

WeblogicConnector

protected WeblogicConnector(Map<String,jakarta.jms.ConnectionFactory> connectionFactoryMap,
 ScheduledExecutorService scheduler,
 String thinJarLocation,
 ExecutorService executor)

Method Details

getPublisherBuilder

public PublisherBuilder<? extends Message<?>> getPublisherBuilder(Config mpConfig)

Specified by:

getPublisherBuilder in interface IncomingConnectorFactory

Overrides:

getPublisherBuilder in class JmsConnector

getSubscriberBuilder

public SubscriberBuilder<? extends Message<?>,Void> getSubscriberBuilder(Config mpConfig)

Specified by:

getSubscriberBuilder in interface OutgoingConnectorFactory

Overrides:

getSubscriberBuilder in class JmsConnector

createConsumer

protected jakarta.jms.MessageConsumer createConsumer(Config config,
 jakarta.jms.Destination destination,
 SessionMetadata sessionEntry)
                                              throws jakarta.jms.JMSException

Overrides:

createConsumer in class JmsConnector

Throws:

jakarta.jms.JMSException

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

createDestination

protected jakarta.jms.Destination createDestination(jakarta.jms.Session session,
 ConnectionContext ctx)

Overrides:

createDestination in class JmsConnector

prepareSession

protected SessionMetadata prepareSession(Config config,
 jakarta.jms.ConnectionFactory factory)
                                  throws jakarta.jms.JMSException

Overrides:

prepareSession in class JmsConnector

Throws:

jakarta.jms.JMSException

consumeAsync

protected CompletionStage<?> consumeAsync(Message<?> m,
 jakarta.jms.Session session,
 AtomicReference<MessageMapper> mapper,
 jakarta.jms.MessageProducer producer,
 Config config)

Overrides:

consumeAsync in class JmsConnector