Examples of org.axonframework.unitofwork.UnitOfWorkListenerAdapter

org.axonframework.unitofwork.UnitOfWorkListenerAdapter
Abstract implementation of the {@link UnitOfWorkListener} that provides empty implementation of all methods declaredin {@link org.axonframework.unitofwork.UnitOfWorkListener}. This implementation does nothing. @author Allard Buijze @since 0.6

        outerUnit.start();
        UnitOfWork middleUnit = DefaultUnitOfWork.startAndGet();
        UnitOfWork innerUnit = DefaultUnitOfWork.startAndGet();


        final Set<UnitOfWork> rolledBack = new HashSet<UnitOfWork>();
        final UnitOfWorkListenerAdapter listener = new UnitOfWorkListenerAdapter() {
            @Override
            public void onRollback(UnitOfWork unitOfWork, Throwable failureCause) {
                rolledBack.add(unitOfWork);
            }
        };

View Full Code Here


        DefaultUnitOfWork.startAndGet();
        StubAggregate loadedAggregate = testSubject.load(aggregate.getIdentifier(), 0L);
        verify(lockManager).obtainLock(aggregate.getIdentifier());


        CurrentUnitOfWork.get().registerListener(new UnitOfWorkListenerAdapter() {
            @Override
            public void onPrepareCommit(UnitOfWork unitOfWork, Set<AggregateRoot> aggregateRoots,
                                        List<EventMessage> events) {
                throw new RuntimeException("Mock Exception");
            }

View Full Code Here


        DefaultUnitOfWork.startAndGet();
        StubAggregate loadedAggregate = testSubject.load(aggregate.getIdentifier(), 0L);
        verify(lockManager).obtainLock(aggregate.getIdentifier());


        CurrentUnitOfWork.get().registerListener(new UnitOfWorkListenerAdapter() {
            @Override
            public void onPrepareCommit(UnitOfWork unitOfWork, Set<AggregateRoot> aggregateRoots,
                                        List<EventMessage> events) {
                throw new RuntimeException("Mock Exception");
            }

View Full Code Here


    private void doReleaseLock(final String sagaId, final Saga sagaInstance) {
        if (sagaInstance == null || !CurrentUnitOfWork.isStarted()) {
            lock.releaseLock(sagaId);
        } else if (CurrentUnitOfWork.isStarted()) {
            CurrentUnitOfWork.get().registerListener(new UnitOfWorkListenerAdapter() {
                @Override
                public void onCleanup(UnitOfWork unitOfWork) {
                    // a reference to the saga is maintained to prevent it from GC until after the UoW commit
                    lock.releaseLock(sagaInstance.getSagaIdentifier());
                }

View Full Code Here


    private void removeEntry(final String sagaIdentifier, final Map<String, ?> sagaMap) {
        if (!CurrentUnitOfWork.isStarted()) {
            sagaMap.remove(sagaIdentifier);
        } else {
            CurrentUnitOfWork.get().registerListener(new UnitOfWorkListenerAdapter() {
                @Override
                public void afterCommit(UnitOfWork unitOfWork) {
                    sagaMap.remove(sagaIdentifier);
                }
            });

View Full Code Here

        contact.removeAddress(command.getAddressType());
    }


    private void cancelClaimedContactName(String contactIdentifier, UnitOfWork unitOfWork) {
        final ContactEntry contactEntry = contactRepository.loadContactDetails(contactIdentifier);
        unitOfWork.registerListener(new UnitOfWorkListenerAdapter() {
            @Override
            public void afterCommit(UnitOfWork uow) {
                logger.debug("About to cancel the name {}", contactEntry.getName());
                contactNameRepository.cancelContactName(contactEntry.getName());
            }

View Full Code Here

            }
        });
    }


    private void registerUnitOfWorkListenerToCancelClaimingName(final String name, UnitOfWork unitOfWork) {
        unitOfWork.registerListener(new UnitOfWorkListenerAdapter() {
            @Override
            public void onRollback(UnitOfWork uow, Throwable failureCause) {
                contactNameRepository.cancelContactName(name);
            }
        });

View Full Code Here


        @Override
        public Object handle(CommandMessage<?> commandMessage, UnitOfWork unitOfWork,
                             InterceptorChain interceptorChain)
                throws Throwable {
            unitOfWork.registerListener(new UnitOfWorkListenerAdapter() {
                @Override
                public void onPrepareCommit(UnitOfWork unitOfWork, Set<AggregateRoot> aggregateRoots,
                                            List<EventMessage> events) {
                    Iterator<AggregateRoot> iterator = aggregateRoots.iterator();
                    if (iterator.hasNext()) {

View Full Code Here

TOP

Related Classes of org.axonframework.unitofwork.UnitOfWorkListenerAdapter

org.axonframework.repository.LockingRepositoryTest

org.axonframework.saga.AbstractSagaManager

org.axonframework.sample.app.command.ContactCommandHandler

org.axonframework.test.GivenWhenThenTestFixture$AggregateRegisteringInterceptor

org.axonframework.unitofwork.nesting.UnitOfWorkNestingTest

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.