Examples of org.axonframework.domain.DomainEventStream.peek()

Class org.axonframework.domain.DomainEventStream

Examples of org.axonframework.domain.DomainEventStream.peek()

org.axonframework.domain.DomainEventStream.peek()
Returns the next events in the stream, if available, without moving the pointer forward. Hence, a call to {@link #next()} will return the same event as a call to peek(). Use hasNext() to obtain aguarantee about the availability of any next event.
If the pointer has reached the end of the stream, the behavior of this method is undefined. It could either return null, or throw an exception, depending on the actual implementation. Use {@link #hasNext()}to confirm the existence of elements after the current pointer. @return the next event in the stream.

        entityManager.persist(entry);
        entityManager.flush();
        entityManager.clear();


        DomainEventStream stream = testSubject.readEvents("test", aggregateIdentifier);
        assertEquals(0L, stream.peek().getSequenceNumber());
    }


    @Test
    @Transactional
    public void testEntireStreamIsReadOnUnserializableSnapshot_WithError() {

View Full Code Here

        entityManager.persist(entry);
        entityManager.flush();
        entityManager.clear();


        DomainEventStream stream = testSubject.readEvents("test", aggregateIdentifier);
        assertEquals(0L, stream.peek().getSequenceNumber());
    }


    @Test
    @Transactional
    public void testLoad_LargeAmountOfEventsWithSnapshot() {

View Full Code Here

        @Override
        public void run() {
            DomainEventStream eventStream = eventStore.readEvents(typeIdentifier, aggregateIdentifier);
            try {
                // a snapshot should only be stored if the snapshot replaces at least more than one event
                long firstEventSequenceNumber = eventStream.peek().getSequenceNumber();
                DomainEventMessage snapshotEvent = createSnapshot(typeIdentifier, aggregateIdentifier, eventStream);
                if (snapshotEvent != null && snapshotEvent.getSequenceNumber() > firstEventSequenceNumber) {
                    eventStore.appendSnapshotEvent(typeIdentifier, snapshotEvent);
                }
            } finally {

View Full Code Here

        entityManager.persist(entry);
        entityManager.flush();
        entityManager.clear();


        DomainEventStream stream = testSubject.readEvents("test", aggregateIdentifier);
        assertEquals(0L, stream.peek().getSequenceNumber());
    }


    @Test
    @Transactional
    public void testEntireStreamIsReadOnUnserializableSnapshot_WithError() {

View Full Code Here

        entityManager.persist(entry);
        entityManager.flush();
        entityManager.clear();


        DomainEventStream stream = testSubject.readEvents("test", aggregateIdentifier);
        assertEquals(0L, stream.peek().getSequenceNumber());
    }


    @Test
    @Transactional
    public void testLoad_LargeAmountOfEventsWithSnapshot() {

View Full Code Here

                DomainEventStream events = null;
                try {
                    events = decorator.decorateForRead(typeIdentifier, aggregateIdentifier,
                                                       eventStore.readEvents(typeIdentifier, aggregateIdentifier));
                    if (events.hasNext()) {
                        aggregateRoot = aggregateFactory.createAggregate(aggregateIdentifier, events.peek());
                        aggregateRoot.initializeState(events);
                    }
                } catch (EventStreamNotFoundException e) {
                    throw new AggregateNotFoundException(
                            aggregateIdentifier,

View Full Code Here

TOP

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.