Examples of org.jboss.internal.soa.esb.couriers.tx.InVMXAResource

Package org.jboss.internal.soa.esb.couriers.tx

Examples of org.jboss.internal.soa.esb.couriers.tx.InVMXAResource

org.jboss.internal.soa.esb.couriers.tx.InVMXAResource
This XAResource instance controls the InVM queue manipulation under the control of the transaction manager. Since InVM is inherently volatile, a crash failure will take the entire queue with it, along with the client and server, we have much less to worry about here in terms of recovery. Therefore we need to ensure that the transaction manager does not save this instance to the log, since it won't make sense upon recovery: the entire queue will have been destroyed. This does mean that we could have non-atomic outcomes in the event of a crash where durable participants (e.g., database) were involved in the same transaction. But there is nothing we can do about that, without affecting the performance benefits of InVM. We will call this out explicitly in the documentation and the user needs to be aware of the possible consequences. Could be a Synchronization if we could guarantee that afterCompletion will be called (where we would do the compensation). But since that's only a 'best effort' we need to make this an XAResource.

             * is the transaction controller thread!
             */
            final TransactionStrategy txStrategy = TransactionStrategy.getTransactionStrategy(true) ;
            try
            {
                txStrategy.enlistResource(new InVMXAResource(inVMEpr, addedObject, InVMXAResource.Operation.INSERT));
            }
            catch (final TransactionStrategyException tse)
            {
                throw new InVMException("Unexpected error enlisting transaction resource", tse) ;
            }

View Full Code Here

                    LOGGER.debug("Pickup enlisting transactional resource for service " + serviceId) ;
                }
                final TransactionStrategy txStrategy = TransactionStrategy.getTransactionStrategy(true) ;
                try
                {
                    txStrategy.enlistResource(new InVMXAResource(inVMEpr, msgObject, InVMXAResource.Operation.REMOVE)) ;
                }
                catch (final TransactionStrategyException tse)
                {
                    throw new InVMException("Unexpected error enlisting transaction resource", tse) ;
                }

View Full Code Here

             * is the transaction controller thread!
             */
            final TransactionStrategy txStrategy = TransactionStrategy.getTransactionStrategy(true) ;
            try
            {
                txStrategy.enlistResource(new InVMXAResource(inVMEpr, addedObject, InVMXAResource.Operation.INSERT));
            }
            catch (final TransactionStrategyException tse)
            {
                throw new InVMException("Unexpected error enlisting transaction resource", tse) ;
            }

View Full Code Here

                        LOGGER.debug("Pickup enlisting transactional resource for service " + serviceId) ;
                    }
                    final TransactionStrategy txStrategy = TransactionStrategy.getTransactionStrategy(true) ;
                    try
                    {
                        txStrategy.enlistResource(new InVMXAResource(inVMEpr, msgObject, InVMXAResource.Operation.REMOVE)) ;
                    }
                    catch (final TransactionStrategyException tse)
                    {
                        throw new InVMException("Unexpected error enlisting transaction resource", tse) ;
                    }

View Full Code Here

TOP

Related Classes of org.jboss.internal.soa.esb.couriers.tx.InVMXAResource

org.jboss.internal.soa.esb.couriers.transport.InVMTemporaryTransport

org.jboss.internal.soa.esb.couriers.transport.InVMTransport

org.jboss.soa.esb.client.ServiceInvoker

org.jboss.soa.esb.message.Message

javax.transaction.xa.XAException

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.