Examples of registerNamedXAResourceFactory()

Examples of org.apache.geronimo.transaction.manager.GeronimoTransactionManager.registerNamedXAResourceFactory()

68
69
70
71
72
73
74
75
76
77
78
                null);
        txLog.doStart();
        GeronimoTransactionManager tm = new GeronimoTransactionManager(600, xidFactory, txLog);
        XAResource xar1 = new TestXAResource("res1");
        XAResource xar2 = new TestXAResource("res2");
        tm.registerNamedXAResourceFactory(new TestXAResourceFactory("res1"));
        tm.registerNamedXAResourceFactory(new TestXAResourceFactory("res2"));
        for (int i = minThreads; i <= maxThreads; i *= 10) {
            for (int j = minTxPerThread; j <= maxTxPerThread; j *= 10) {
                long ms = testThroughput(tm, xar1, xar2, i, j);
                System.err.println("TPS (" + i + " threads, " + j + " tx) = " + ((i * j) / (ms / 1000.0)));
View Full Code Here

Examples of org.apache.geronimo.transaction.manager.GeronimoTransactionManager.registerNamedXAResourceFactory()

69
70
71
72
73
74
75
76
77
78
79
        txLog.doStart();
        GeronimoTransactionManager tm = new GeronimoTransactionManager(600, xidFactory, txLog);
        XAResource xar1 = new TestXAResource("res1");
        XAResource xar2 = new TestXAResource("res2");
        tm.registerNamedXAResourceFactory(new TestXAResourceFactory("res1"));
        tm.registerNamedXAResourceFactory(new TestXAResourceFactory("res2"));
        for (int i = minThreads; i <= maxThreads; i *= 10) {
            for (int j = minTxPerThread; j <= maxTxPerThread; j *= 10) {
                long ms = testThroughput(tm, xar1, xar2, i, j);
                System.err.println("TPS (" + i + " threads, " + j + " tx) = " + ((i * j) / (ms / 1000.0)));
            }
View Full Code Here

Examples of org.apache.geronimo.transaction.manager.RecoverableTransactionManager.registerNamedXAResourceFactory()

103
104
105
106
107
108
109
110
111
112
113
        public static boolean recover(final GenericResourceManager rm) throws IOException {
            if (isRecoverable(rm)) {
                final XAConnectionFactory connFactory = (XAConnectionFactory) rm.getConnectionFactory();

                RecoverableTransactionManager rtxManager = (RecoverableTransactionManager) rm.getTransactionManager();
                rtxManager.registerNamedXAResourceFactory(new NamedXAResourceFactory() {

                    public String getName() {
                        return rm.getResourceName();
                    }
View Full Code Here

Examples of org.apache.geronimo.transaction.manager.RecoverableTransactionManager.registerNamedXAResourceFactory()

126
127
128
129
130
131
132
133
134
135
136
                    ActiveMQConnection activeConn = (ActiveMQConnection)connFactory.createConnection();
                    final ActiveMQSession session = (ActiveMQSession)activeConn.createSession(true, Session.SESSION_TRANSACTED);
                    NamedXAResource namedXaResource = new WrapperNamedXAResource(session.getTransactionContext(), rm.getResourceName());

                    RecoverableTransactionManager rtxManager = (RecoverableTransactionManager) rm.getTransactionManager();
                    rtxManager.registerNamedXAResourceFactory(new NamedXAResourceFactory() {

                        @Override
                        public String getName() {
                            return rm.getResourceName();
                        }
View Full Code Here

Examples of org.apache.geronimo.transaction.manager.RecoverableTransactionManager.registerNamedXAResourceFactory()

100
101
102
103
104
105
106
107
108
109
110
        public static boolean recover(final GenericResourceManager rm) throws IOException {
            if (isRecoverable(rm)) {
                final XADataSource dataSource = (XADataSource) rm.getDataSource();

                RecoverableTransactionManager rtxManager = (RecoverableTransactionManager) rm.getTransactionManager();
                rtxManager.registerNamedXAResourceFactory(new NamedXAResourceFactory() {

                    public String getName() {
                        return rm.getResourceName();
                    }
View Full Code Here

Examples of org.apache.geronimo.transaction.manager.RecoverableTransactionManager.registerNamedXAResourceFactory()

139
140
141
142
143
144
145
146
147
148
149
        public static boolean recover(final GenericResourceManager rm) throws IOException {
            if (isRecoverable(rm)) {
                final XAConnectionFactory connFactory = (XAConnectionFactory) rm.getConnectionFactory();

                RecoverableTransactionManager rtxManager = (RecoverableTransactionManager) rm.getTransactionManager();
                rtxManager.registerNamedXAResourceFactory(new NamedXAResourceFactory() {

                    @Override
                    public String getName() {
                        return rm.getResourceName();
                    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.