Package org.apache.geronimo.transaction.manager

Examples of org.apache.geronimo.transaction.manager.WrapperNamedXAResource

112
113
114
115
116
117
118
        return geronimoTransactionManager;
    }

    public static class GeronimoXAResourceWrapper implements XAResourceWrapper {
        public XAResource wrap(final XAResource xaResource, final String name) {
            return new WrapperNamedXAResource(xaResource, name);
        }
View Full Code Here
121
122
123
124
125
126
127
128
129
130
        try {
            XAResource[] xaResources = resourceAdapterWrapper.getXAResources(new ActivationSpec[]{activationSpec});
            if (xaResources == null || xaResources.length == 0) {
                return null;
            }
            return new WrapperNamedXAResource(xaResources[0], containerId);
        } catch (ResourceException e) {
            throw (SystemException) new SystemException("Could not get XAResource for recovery for mdb: " + containerId).initCause(e);
        }
    }
View Full Code Here
38
39
40
41
42
43
44
    }

    public void getConnection(ConnectionInfo connectionInfo) throws ResourceException {
        next.getConnection(connectionInfo);
        ManagedConnectionInfo mci = connectionInfo.getManagedConnectionInfo();
        mci.setXAResource(new WrapperNamedXAResource(mci.getManagedConnection().getXAResource(), name));
    }
View Full Code Here
52
53
54
55
56
57
58
59
60
61
        try {
            XAResource[] xaResources = resourceAdapter.getXAResources(new ActivationSpec[]{activationSpec});
            if (xaResources == null || xaResources.length == 0 || xaResources[0] == null) {
                return null;
            }
            return new WrapperNamedXAResource(xaResources[0], name);
        } catch (ResourceException e) {
            throw (SystemException) new SystemException("Could not get XAResource for recovery for mdb: " + name).initCause(e);
        }
    }
View Full Code Here
38
39
40
41
42
43
44
    }

    public void getConnection(ConnectionInfo connectionInfo) throws ResourceException {
        next.getConnection(connectionInfo);
        ManagedConnectionInfo mci = connectionInfo.getManagedConnectionInfo();
        mci.setXAResource(new WrapperNamedXAResource(mci.getManagedConnection().getXAResource(), name));
    }
View Full Code Here
157
158
159
160
161
162
163
164
165
166
        try {
            XAResource[] xaResources = resourceAdapterWrapper.getXAResources(new ActivationSpec[]{activationSpec});
            if (xaResources == null || xaResources.length == 0) {
                return null;
            }
            return new WrapperNamedXAResource(xaResources[0], containerId);
        } catch (ResourceException e) {
            throw (SystemException) new SystemException("Could not get XAResource for recovery for mdb: " + containerId).initCause(e);
        }
    }
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
        return instanceFactory;
    }

    public MessageEndpoint createEndpoint(XAResource xaResource) throws UnavailableException {
        if (txRecovery && xaResource != null) {
            xaResource = new WrapperNamedXAResource(xaResource, container.getContainerID().toString());
        }
        EndpointHandler endpointHandler = new EndpointHandler(container, deploymentInfo, instanceFactory, xaResource);
        MessageEndpoint messageEndpoint = (MessageEndpoint) Proxy.newProxyInstance(classLoader, interfaces, endpointHandler);
        return messageEndpoint;
    }
View Full Code Here
111
112
113
114
115
116
117
118
        public void commit() throws HeuristicMixedException, HeuristicRollbackException, RollbackException, SecurityException, SystemException {
            transaction.commit();
        }

        public boolean delistResource(XAResource xaResource, int i) throws IllegalStateException, SystemException {
            XAResource wrapper = new WrapperNamedXAResource(xaResource, name);
            return transaction.delistResource(wrapper, i);
        }
View Full Code Here
116
117
118
119
120
121
122
123
            XAResource wrapper = new WrapperNamedXAResource(xaResource, name);
            return transaction.delistResource(wrapper, i);
        }

        public boolean enlistResource(XAResource xaResource) throws IllegalStateException, RollbackException, SystemException {
            XAResource wrapper = new WrapperNamedXAResource(xaResource, name);
            return transaction.enlistResource(wrapper);
        }
View Full Code Here
34
35
36
37
38
39
40
41
42
    }

    protected XAResource createXaResource(PooledSession session) throws JMSException {
        XAResource xares = new LocalAndXATransaction(session.getInternalSession().getTransactionContext());
        if (name != null) {
            xares = new WrapperNamedXAResource(xares, name);
        }
        return xares;
    }
View Full Code Here
TOP

Related Classes of org.apache.geronimo.transaction.manager.WrapperNamedXAResource

  • org.apache.activemq.jms.pool.JcaConnectionPool
  • org.apache.activemq.pool.ActiveMQResourceManager$Recovery
  • org.apache.activemq.pool.JcaConnectionPool
  • org.apache.aries.transaction.jms.internal.RecoverableConnectionPool
  • org.apache.geronimo.connector.ActivationSpecNamedXAResourceFactory
  • org.apache.geronimo.connector.ActivationSpecWrapper
  • org.apache.geronimo.connector.outbound.XAResourceInsertionInterceptor
  • org.apache.openejb.core.mdb.EndpointFactory
  • org.apache.openejb.resource.GeronimoTransactionManagerFactory$GeronimoXAResourceWrapper
  • org.apache.openejb.resource.jdbc.ManagedDataSourceWithRecovery$TransactionWrapper
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.