Package org.apache.geronimo.transaction.manager

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

77
78
79
80
81
82
83
84
85
86
87
    }


    public ConnectionManagerFactory.ReturnableXAResource getRecoveryXAResource(ManagedConnectionFactory managedConnectionFactory) throws ResourceException {
        ManagedConnectionInfo mci = new ManagedConnectionInfo(managedConnectionFactory, null);
        NamedXAResource namedXAResource = (NamedXAResource) mci.getXAResource();
        if (namedXAResource == null) {
            //obviously, we can't do recovery.
            return null;
        }
        ConnectionInfo recoveryConnectionInfo = new ConnectionInfo(mci);
View Full Code Here
120
121
122
123
124
125
126
127
128
129
130
            if (isRecoverable(rm)) {
                try {
                    ActiveMQConnectionFactory connFactory = (ActiveMQConnectionFactory) rm.getConnectionFactory();
                    ActiveMQConnection activeConn = (ActiveMQConnection)connFactory.createConnection();
                    ActiveMQSession session = (ActiveMQSession)activeConn.createSession(true, Session.SESSION_TRANSACTED);
                    NamedXAResource namedXaResource = new WrapperNamedXAResource(session.getTransactionContext(), rm.getResourceName());

                    RecoverableTransactionManager rtxManager = (RecoverableTransactionManager) rm.getTransactionManager();
                    rtxManager.recoverResourceManager(namedXaResource);
                    return true;
                } catch (JMSException e) {
View Full Code Here
78
79
80
81
82
83
84
85
86
87
88
    }


    public ConnectionManagerContainer.ReturnableXAResource getRecoveryXAResource(ManagedConnectionFactory managedConnectionFactory) throws ResourceException {
        ManagedConnectionInfo mci = new ManagedConnectionInfo(managedConnectionFactory, null);
        NamedXAResource namedXAResource = (NamedXAResource) mci.getXAResource();
        if (namedXAResource == null) {
            //obviously, we can't do recovery.
            return null;
        }
        ConnectionInfo recoveryConnectionInfo = new ConnectionInfo(mci);
View Full Code Here
48
49
50
51
52
53
54
55
56
57
58
        if (isRecoverable(rm)) {
            try {
                ActiveMQConnectionFactory connFactory = (ActiveMQConnectionFactory) rm.getConnectionFactory();
                ActiveMQConnection activeConn = (ActiveMQConnection)connFactory.createConnection();
                ActiveMQSession session = (ActiveMQSession)activeConn.createSession(true, Session.SESSION_TRANSACTED);
                NamedXAResource namedXaResource = new WrapperNamedXAResource(session.getTransactionContext(), rm.getResourceName());

                RecoverableTransactionManager rtxManager = (RecoverableTransactionManager) rm.getTransactionManager();
                rtxManager.recoverResourceManager(namedXaResource);
                return true;
            } catch (JMSException e) {
View Full Code Here
128
129
130
131
132
133
134
135
136
137
138
    private void recoverResourceManager(ResourceManager resourceManager) {
        TransactionContext oldTransactionContext = TransactionContext.getContext();
        try {
            TransactionContext.setContext(new UnspecifiedTransactionContext());
            NamedXAResource namedXAResource = null;
            try {
                namedXAResource = resourceManager.getRecoveryXAResources();
            } catch (SystemException e) {
                recoveryLog.error(e);
                recoveryErrors.add(e);
View Full Code Here
96
97
98
99
100
101
102
103
       
        ConnectionInfo recoveryConnectionInfo = new ConnectionInfo(mci);
        getRecoveryStack().getConnection(recoveryConnectionInfo);

        // For pooled resources, we may now have a new MCI (not the one constructed above). Make sure we use the correct MCI
        NamedXAResource namedXAResource = (NamedXAResource) recoveryConnectionInfo.getManagedConnectionInfo().getXAResource();
        return new ConnectionManagerContainer.ReturnableXAResource(namedXAResource, getRecoveryStack(), recoveryConnectionInfo);
    }
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
    }


    public ConnectionManagerContainer.ReturnableXAResource getRecoveryXAResource(ManagedConnectionFactory managedConnectionFactory) throws ResourceException {
        ManagedConnectionInfo mci = new ManagedConnectionInfo(managedConnectionFactory, null);
        NamedXAResource namedXAResource = (NamedXAResource) mci.getXAResource();
        if (namedXAResource == null) {
            //obviously, we can't do recovery.
            return null;
        }
        ConnectionInfo recoveryConnectionInfo = new ConnectionInfo(mci);
View Full Code Here
TOP

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

  • org.apache.activemq.pool.ActiveMQResourceManager$Recovery
  • org.apache.geronimo.connector.outbound.AbstractConnectionManager
  • org.apache.geronimo.transaction.TransactionManagerProxy
  • org.apache.servicemix.activemq.Recovery
    • 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.