Package org.wildfly.extension.messaging.activemq.jms

Class ExternalPooledConnectionFactoryService

java.lang.Object

org.wildfly.extension.messaging.activemq.jms.ExternalPooledConnectionFactoryService

All Implemented Interfaces:

Service, Service<ExternalPooledConnectionFactoryService>, Value<ExternalPooledConnectionFactoryService>

public class ExternalPooledConnectionFactoryService
extends Object
implements Service<ExternalPooledConnectionFactoryService>

A service which translates a pooled connection factory into a resource adapter driven connection pool

Author:

Emmanuel Hugonnet (c) 2018 Red Hat, inc.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CONNECTION_PARAMETERS
static final String	CONNECTOR_CLASSNAME
static final String	DISCOVERY_INITIAL_WAIT_TIMEOUT
static final String	DISCOVERY_LOCAL_BIND_ADDRESS
static final String	GROUP_ADDRESS
static final String	GROUP_PORT
static final String	JGROUPS_CHANNEL_LOCATOR_CLASS
static final String	JGROUPS_CHANNEL_NAME
static final String	JGROUPS_CHANNEL_REF_NAME
static final String	REFRESH_TIMEOUT

Fields inherited from interface org.jboss.msc.service.Service

NULL

Constructor Summary

Constructors

Constructor

Description

ExternalPooledConnectionFactoryService(String name, TransportConfiguration[] connectors, DiscoveryGroupConfiguration groupConfiguration, String jgroupsClusterName, String jgroupsChannelName, List<PooledConnectionFactoryConfigProperties> adapterParams, ContextNames.BindInfo bindInfo, List<String> jndiAliases, String txSupport, int minPoolSize, int maxPoolSize, String managedConnectionPoolClassName, Boolean enlistmentTrace, org.jboss.as.controller.capability.CapabilityServiceSupport capabilityServiceSupport, boolean createBinderService)

Method Summary

Modifier and Type	Method	Description
ContextNames.BindInfo	getBindInfo()
BroadcastCommandDispatcherFactory	getCommandDispatcherFactory(String name)
TransportConfiguration[]	getConnectors()
ExternalPooledConnectionFactoryService	getValue()	Get the actual dependency value.
static ExternalPooledConnectionFactoryService	installService(org.jboss.as.controller.OperationContext context, String name, TransportConfiguration[] connectors, DiscoveryGroupConfiguration groupConfiguration, Set<String> connectorsSocketBindings, Set<String> sslContextNames, String jgroupClusterName, String jgroupChannelName, List<PooledConnectionFactoryConfigProperties> adapterParams, ContextNames.BindInfo bindInfo, List<String> jndiAliases, String txSupport, int minPoolSize, int maxPoolSize, String managedConnectionPoolClassName, Boolean enlistmentTrace, ModelNode model)
static ExternalPooledConnectionFactoryService	installService(ServiceTarget serviceTarget, ExternalBrokerConfigurationService configuration, String name, TransportConfiguration[] connectors, DiscoveryGroupConfiguration groupConfiguration, Set<String> connectorsSocketBindings, Set<String> sslContextNames, String jgroupClusterName, String jgroupChannelName, List<PooledConnectionFactoryConfigProperties> adapterParams, ContextNames.BindInfo bindInfo, List<String> jndiAliases, String txSupport, int minPoolSize, int maxPoolSize, String managedConnectionPoolClassName, Boolean enlistmentTrace, org.jboss.as.controller.capability.CapabilityServiceSupport capabilityServiceSupport)
void	start(StartContext context)	Start the service.
void	stop(StopContext context)	Stop the service.

Methods inherited from class java.lang.Object

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

Field Details

CONNECTOR_CLASSNAME

public static final String CONNECTOR_CLASSNAME

See Also:

• Constant Field Values

CONNECTION_PARAMETERS

public static final String CONNECTION_PARAMETERS

See Also:

• Constant Field Values

GROUP_ADDRESS

public static final String GROUP_ADDRESS

See Also:

• Constant Field Values

DISCOVERY_INITIAL_WAIT_TIMEOUT

public static final String DISCOVERY_INITIAL_WAIT_TIMEOUT

See Also:

• Constant Field Values

GROUP_PORT

public static final String GROUP_PORT

See Also:

• Constant Field Values

REFRESH_TIMEOUT

public static final String REFRESH_TIMEOUT

See Also:

• Constant Field Values

DISCOVERY_LOCAL_BIND_ADDRESS

public static final String DISCOVERY_LOCAL_BIND_ADDRESS

See Also:

• Constant Field Values

JGROUPS_CHANNEL_LOCATOR_CLASS

public static final String JGROUPS_CHANNEL_LOCATOR_CLASS

See Also:

• Constant Field Values

JGROUPS_CHANNEL_NAME

public static final String JGROUPS_CHANNEL_NAME

See Also:

• Constant Field Values

JGROUPS_CHANNEL_REF_NAME

public static final String JGROUPS_CHANNEL_REF_NAME

See Also:

• Constant Field Values

Constructor Details

ExternalPooledConnectionFactoryService

public ExternalPooledConnectionFactoryService(String name,
 TransportConfiguration[] connectors,
 DiscoveryGroupConfiguration groupConfiguration,
 String jgroupsClusterName,
 String jgroupsChannelName,
 List<PooledConnectionFactoryConfigProperties> adapterParams,
 ContextNames.BindInfo bindInfo,
 List<String> jndiAliases,
 String txSupport,
 int minPoolSize,
 int maxPoolSize,
 String managedConnectionPoolClassName,
 Boolean enlistmentTrace,
 org.jboss.as.controller.capability.CapabilityServiceSupport capabilityServiceSupport,
 boolean createBinderService)

Method Details

getConnectors

public TransportConfiguration[] getConnectors()

getBindInfo

public ContextNames.BindInfo getBindInfo()

installService

public static ExternalPooledConnectionFactoryService installService(ServiceTarget serviceTarget,
 ExternalBrokerConfigurationService configuration,
 String name,
 TransportConfiguration[] connectors,
 DiscoveryGroupConfiguration groupConfiguration,
 Set<String> connectorsSocketBindings,
 Set<String> sslContextNames,
 String jgroupClusterName,
 String jgroupChannelName,
 List<PooledConnectionFactoryConfigProperties> adapterParams,
 ContextNames.BindInfo bindInfo,
 List<String> jndiAliases,
 String txSupport,
 int minPoolSize,
 int maxPoolSize,
 String managedConnectionPoolClassName,
 Boolean enlistmentTrace,
 org.jboss.as.controller.capability.CapabilityServiceSupport capabilityServiceSupport)
                                                             throws org.jboss.as.controller.OperationFailedException

Throws:

org.jboss.as.controller.OperationFailedException

installService

public static ExternalPooledConnectionFactoryService installService(org.jboss.as.controller.OperationContext context,
 String name,
 TransportConfiguration[] connectors,
 DiscoveryGroupConfiguration groupConfiguration,
 Set<String> connectorsSocketBindings,
 Set<String> sslContextNames,
 String jgroupClusterName,
 String jgroupChannelName,
 List<PooledConnectionFactoryConfigProperties> adapterParams,
 ContextNames.BindInfo bindInfo,
 List<String> jndiAliases,
 String txSupport,
 int minPoolSize,
 int maxPoolSize,
 String managedConnectionPoolClassName,
 Boolean enlistmentTrace,
 ModelNode model)
                                                             throws org.jboss.as.controller.OperationFailedException

Throws:

org.jboss.as.controller.OperationFailedException

getValue

public ExternalPooledConnectionFactoryService getValue()
                                                throws IllegalStateException,
IllegalArgumentException

Description copied from interface: Value

Get the actual dependency value.

Specified by:

getValue in interface Value<ExternalPooledConnectionFactoryService>

Returns:

the actual dependency value

Throws:

IllegalStateException - if the value is time-sensitive and the current state does not allow retrieval.

IllegalArgumentException - when the value cannot be read due to misconfiguration

start

public void start(StartContext context)
           throws StartException

Description copied from interface: Service

Start the service. Do not return until the service has been fully started, unless an asynchronous service start is performed. All injections will be complete before this method is called.

If the service start involves any activities that may block, the asynchronous mechanism provided by the context should be used. See the class javadoc for details.

Specified by:

start in interface Service

Parameters:

context - the context which can be used to trigger an asynchronous service start

Throws:

StartException - if the service could not be started for some reason

stop

public void stop(StopContext context)

Description copied from interface: Service

Stop the service. Do not return until the service has been fully stopped, unless an asynchronous service stop is performed. All injections will remain intact until the service is fully stopped. This method should not throw an exception.

If the service start involves any activities that may block, the asynchronous mechanism provided by the context should be used. See the class javadoc for details.

Specified by:

stop in interface Service

Parameters:

context - the context which can be used to trigger an asynchronous service stop

getCommandDispatcherFactory

public BroadcastCommandDispatcherFactory getCommandDispatcherFactory(String name)