Skip to content

Commit

Permalink
Returning org.jboss.jca.core.connectionmanager.ConnectionManager in…
Browse files Browse the repository at this point in the history
…stead of subinterface
  • Loading branch information
gastaldi committed Sep 2, 2023
1 parent 16bd0b0 commit 0e73bc2
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
import org.jboss.jca.common.api.metadata.common.FlushStrategy;
import org.jboss.jca.core.api.connectionmanager.ccm.CachedConnectionManager;
import org.jboss.jca.core.api.connectionmanager.pool.PoolConfiguration;
import org.jboss.jca.core.connectionmanager.TxConnectionManager;
import org.jboss.jca.core.connectionmanager.ConnectionManager;
import org.jboss.jca.core.connectionmanager.pool.api.Pool;
import org.jboss.jca.core.connectionmanager.pool.api.PoolFactory;
import org.jboss.jca.core.connectionmanager.pool.api.PoolStrategy;
Expand All @@ -28,7 +28,7 @@ public ConnectionManagerFactory(TransactionIntegration transactionIntegration, C
this.ccm = ccm;
}

public TxConnectionManager createConnectionManager(String id, ManagedConnectionFactory mcf) {
public ConnectionManager createConnectionManager(String id, ManagedConnectionFactory mcf) {
Pool pool = new PoolFactory()
.create(PoolStrategy.POOL_BY_CRI,
mcf,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@
import jakarta.resource.spi.ManagedConnectionFactory;
import jakarta.resource.spi.ResourceAdapter;

import org.jboss.jca.core.connectionmanager.TxConnectionManager;
import org.jboss.jca.core.connectionmanager.ConnectionManager;

import io.quarkiverse.ironjacamar.ResourceAdapterFactory;
import io.quarkiverse.ironjacamar.runtime.endpoint.DefaultMessageEndpointFactory;
Expand All @@ -23,12 +23,12 @@ public class IronJacamarContainer implements Closeable {

private final ResourceAdapter resourceAdapter;
private final ManagedConnectionFactory managedConnectionFactory;
private final TxConnectionManager connectionManager;
private final ConnectionManager connectionManager;

public IronJacamarContainer(ResourceAdapterFactory resourceAdapterFactory,
ResourceAdapter resourceAdapter,
ManagedConnectionFactory managedConnectionFactory,
TxConnectionManager connectionManager) {
ConnectionManager connectionManager) {
this.resourceAdapterFactory = resourceAdapterFactory;
this.resourceAdapter = resourceAdapter;
this.managedConnectionFactory = managedConnectionFactory;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
import jakarta.resource.spi.ManagedConnectionFactory;
import jakarta.resource.spi.ResourceAdapter;

import org.jboss.jca.core.connectionmanager.TxConnectionManager;
import org.jboss.jca.core.connectionmanager.ConnectionManager;

import io.quarkiverse.ironjacamar.ResourceAdapterFactory;
import io.quarkiverse.ironjacamar.ResourceAdapterKind;
Expand Down Expand Up @@ -43,7 +43,7 @@ public IronJacamarContainer createContainer(String id, String kind) {
} catch (ResourceException re) {
throw new DeploymentException("Cannot deploy resource adapter", re);
}
TxConnectionManager connectionManager = connectionManagerFactory.createConnectionManager(id, managedConnectionFactory);
ConnectionManager connectionManager = connectionManagerFactory.createConnectionManager(id, managedConnectionFactory);
return new IronJacamarContainer(resourceAdapterFactory, resourceAdapter, managedConnectionFactory,
connectionManager);
}
Expand Down

0 comments on commit 0e73bc2

Please sign in to comment.