public JDBCConnectionProviderImpl()

in tx-control-providers/jdbc/tx-control-provider-jdbc-xa/src/main/java/org/apache/aries/tx/control/jdbc/xa/impl/JDBCConnectionProviderImpl.java [53:75]

22 lines of code
3 McCabe index (conditional complexity)


	public JDBCConnectionProviderImpl(DataSource dataSource, boolean xaEnabled,
			boolean localEnabled, String recoveryIdentifier, BundleContext ctx,
			Map<String, Object> providerProperties) {
		super(dataSource);
		this.xaEnabled = xaEnabled;
		this.localEnabled = localEnabled;
		this.recoveryIdentifier = recoveryIdentifier;
		
		if(recoveryIdentifier != null) {
			if(!toBoolean(providerProperties, XA_ENLISTMENT_ENABLED, true)) {
				LOG.warn("A JDBCResourceProvider has been configured with a recovery identifier {} but it has also been configured not to use XA transactions. No recovery will be available.", recoveryIdentifier);
				reg = null;
			} else {
				reg = ctx.registerService(RecoverableXAResource.class, 
						new RecoverableXAResourceImpl(recoveryIdentifier, this, 
								(String) providerProperties.get("recovery.user"),
								(String) providerProperties.get(".recovery.password)")), 
						null);
			}
		} else {
			reg = null;
		}
	}