oracle.integration.platform.blocks.event

Class BusinessEventConnectionFactorySupport

java.lang.Object

oracle.integration.platform.blocks.event.BusinessEventConnectionFactorySupport

public class BusinessEventConnectionFactorySupport
extends Object

Support class for lookup of BusinessEventConnection factory based on JNDI names known to either EDN-DB (AQ-based) or EDN-JMS (JMS queue-based) implementation.

Field Summary

Fields

Modifier and Type	Field and Description
static String	AQJMS_LOCAL_TX_DATASOURCE
static String	AQJMS_XA_DATASOURCE
static String	JDNI_USER_TRANSACTION
static String	JNDI_DATASOURCE_NAME
static String	JNDI_LOCAL_TX_DATASOURCE_NAME
static String	JNDI_LOCALTX_DURABLE_JCA_FACTORY_NAME
static String	JNDI_LOCALTX_JCA_FACTORY_NAME
static String	JNDI_LOGICAL_DATASOURCE_NAME
static String	JNDI_LOGICAL_LOCAL_TX_DATASOURCE_NAME
static String	JNDI_OLD_DATASOURCE_NAME
static String	JNDI_OLD_LOCAL_TX_DATASOURCE_NAME
static String	JNDI_QUEUE_CONNECTION_FACTORY_NAME
static String	JNDI_QUEUE_NAME
static String	JNDI_TOPIC_NAME
static String	JNDI_XA_DURABLE_JCA_FACTORY_NAME
static String	JNDI_XA_JCA_FACTORY_NAME
static String	JNDI_XA_QUEUE_CONNECTION_FACTORY_NAME
static String	USER_TRANSACTION

Constructor Summary

Constructors

Constructor and Description
BusinessEventConnectionFactorySupport()

Method Summary

Methods

Modifier and Type	Method and Description
static BusinessEventConnectionFactory	findRelevantBusinessEventConnectionFactory(boolean forceRetry) Find Event Connection Factory object relevant to the underlying EDN implementation (either AQ-based, or JMS-based).
static void	reset() Reset to the initial state where no lookup has been performed.
static void	setDatasourceProperties(Properties dsProps) Specify datasource properties for AQ JMS.
static void	setJndiProperties(Properties jndiProps) Specify JNDI properties.

Methods inherited from class java.lang.Object

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

Field Detail

JDNI_USER_TRANSACTION

public static String JDNI_USER_TRANSACTION

JNDI_OLD_DATASOURCE_NAME

public static String JNDI_OLD_DATASOURCE_NAME

JNDI_OLD_LOCAL_TX_DATASOURCE_NAME

public static String JNDI_OLD_LOCAL_TX_DATASOURCE_NAME

JNDI_DATASOURCE_NAME

public static String JNDI_DATASOURCE_NAME

JNDI_LOCAL_TX_DATASOURCE_NAME

public static String JNDI_LOCAL_TX_DATASOURCE_NAME

JNDI_LOGICAL_DATASOURCE_NAME

public static String JNDI_LOGICAL_DATASOURCE_NAME

JNDI_LOGICAL_LOCAL_TX_DATASOURCE_NAME

public static String JNDI_LOGICAL_LOCAL_TX_DATASOURCE_NAME

JNDI_QUEUE_CONNECTION_FACTORY_NAME

public static String JNDI_QUEUE_CONNECTION_FACTORY_NAME

JNDI_XA_QUEUE_CONNECTION_FACTORY_NAME

public static String JNDI_XA_QUEUE_CONNECTION_FACTORY_NAME

JNDI_QUEUE_NAME

public static String JNDI_QUEUE_NAME

JNDI_XA_JCA_FACTORY_NAME

public static String JNDI_XA_JCA_FACTORY_NAME

JNDI_XA_DURABLE_JCA_FACTORY_NAME

public static String JNDI_XA_DURABLE_JCA_FACTORY_NAME

JNDI_LOCALTX_JCA_FACTORY_NAME

public static String JNDI_LOCALTX_JCA_FACTORY_NAME

JNDI_LOCALTX_DURABLE_JCA_FACTORY_NAME

public static String JNDI_LOCALTX_DURABLE_JCA_FACTORY_NAME

JNDI_TOPIC_NAME

public static String JNDI_TOPIC_NAME

AQJMS_XA_DATASOURCE

public static String AQJMS_XA_DATASOURCE

AQJMS_LOCAL_TX_DATASOURCE

public static String AQJMS_LOCAL_TX_DATASOURCE

USER_TRANSACTION

public static String USER_TRANSACTION

Constructor Detail

BusinessEventConnectionFactorySupport

public BusinessEventConnectionFactorySupport()

Method Detail

setJndiProperties

public static void setJndiProperties(Properties jndiProps)

Specify JNDI properties. This is typically used by an EDN client that runs in a J2SE environment and wants to use SOA API to pub/sub events.

Parameters:

jndiProps -

setDatasourceProperties

public static void setDatasourceProperties(Properties dsProps)

Specify datasource properties for AQ JMS. Allowed keys are "AQjmsXADatasource", "AQjmsLocalTxDatasource", and "UserTranasction". Values are JNDI names for the corresponding key property. This is typically used for an EDN client that wants to pub/sub to AQ based EDN.

Parameters:

dsProps -

findRelevantBusinessEventConnectionFactory

public static BusinessEventConnectionFactory findRelevantBusinessEventConnectionFactory(boolean forceRetry)
                                                                                 throws oracle.fabric.common.FabricException

Find Event Connection Factory object relevant to the underlying EDN implementation (either AQ-based, or JMS-based). It does the lookup based on the following order:

(1) if in debug mode (system property "edn.debug.event-connection" is true), then returns DebugBusinessEventConnectionFactory object.

(2) if co-located with SOA (SoaInfraRegistry.get("EventConnectionFactory" is not null) , returns a local connection factory.

(3) performs EDN-DB JNDI lookup in following order to return SAQRemoteBusinessEventConnectionFactory object.

• Logical datasources: "java:comp/env/jdbc/EDNLogicalDataSource", "java:comp/env/jdbc/EDNLogicalLocalTxDataSource"
• Datasources: "jdbc/EDNDataSource", "jdbc/EDNLocalTxDataSource"
• Legacy datasources: "jdbc/EDNSource", "jdbc/EDNLocalTxSource"

  (4) performs EDN-JMS resource JNDI lookup of Queue and QueueConnectionFactory to return JmsRemoteBusinessEventConnectionFactory object.

Parameters:

forceRetry - whether or not to enforce lookup retry. If this flag is set to false, then a previously lookup of factory instance is returned. Otherwise, lookup will be performed regardless of previous lookup.

Returns:

a connection factory instance.

Throws:

oracle.fabric.common.FabricException

reset

public static void reset()

Reset to the initial state where no lookup has been performed.