import org.axonframework.eventstore.EventStore; //导入依赖的package包/类
@Bean
public com.github.msemys.esjc.EventStore eventStoreClient() {
   final ThreadPoolExecutor executor = new ThreadPoolExecutor(2, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, new SynchronousQueue<>(), new DefaultThreadFactory("es"));
   final EventStoreBuilder eventStoreBuilder = EventStoreBuilder.newBuilder()
         .reconnectionDelay(Duration.ofSeconds(5))
         .heartbeatInterval(Duration.ofSeconds(15000))
         .heartbeatTimeout(Duration.ofSeconds(2000))
         .requireMaster(true)
         .operationTimeout(Duration.ofSeconds(2000))
         .operationTimeoutCheckInterval(Duration.ofSeconds(15000))
         .maxOperationQueueSize(10000)
         .maxConcurrentOperations(5000)
         .maxOperationRetries(Integer.MAX_VALUE)
         .maxReconnections(Integer.MAX_VALUE)
         .failOnNoServerResponse(false)
         .userCredentials("admin", "changeit")
         .singleNodeAddress("127.0.0.1", 3335)
         .executor(executor);

   return eventStoreBuilder.build();
}
 

import org.axonframework.eventstore.EventStore; //导入依赖的package包/类
private Injector createInjector() {
    return Guice.createInjector(new AbstractModule() {
        @Override
        protected void configure() {
            // Event store
            CommandBus commandBus = new SimpleCommandBus();
            CommandGateway commandGateway = new DefaultCommandGateway(commandBus);

            EventStore eventStore = new FileSystemEventStore(new SimpleEventFileResolver(eventStoreFolder));

            EventBus eventBus = new SimpleEventBus();

            EventSourcingRepository repository = new EventSourcingRepository(Rating.class, eventStore);
            repository.setEventBus(eventBus);

            // Event store handlers
            AggregateAnnotationCommandHandler.subscribe(Rating.class, repository, commandBus);
            AnnotationEventListenerAdapter.subscribe(new RatingEventHandler(), eventBus);

            // Load twist config
            TwistProvider twistProvider = new TwistProvider(twistsDataFile);

            // Twist rating
            TwistRating twistRating = new TwistRatingEventStore(commandGateway, twistProvider);


            // Bootstrap aggregates
            twistProvider.getTwists().stream().forEach(twist -> {
                commandGateway.send(new CreateTwistCommand(twist.id));
            });

            // Set up bindings
            bind(TwistRating.class).toInstance(twistRating);
            bind(TwistProvider.class).toInstance(twistProvider);

            Logger.info("Injector configured");
        }
    });
}
 

import org.axonframework.eventstore.EventStore; //导入依赖的package包/类
@SuppressWarnings("SpringJavaAutowiringInspection")
@Bean
public EventSourcingRepositoryRegistrar eventSourcingRepositoryRegistrar(
        final CommandBus commandBus, final EventBus eventBus,
        final EventStore eventStore) {
    return new EventSourcingRepositoryRegistrar(commandBus, eventBus,
            eventStore);
}
 

import org.axonframework.eventstore.EventStore; //导入依赖的package包/类
@Bean(name = "testAggregateEventsourcingRepository")
@Autowired
public EventSourcingRepository<MyTestAggregate> respository(final EventStore eventStore, final EventBus eventBus, final Cache cache) {
   final CachingEventSourcingRepository<MyTestAggregate> repository = new CachingEventSourcingRepository<>(new GenericAggregateFactory<>(MyTestAggregate.class), eventStore);
   repository.setCache(cache);
   repository.setEventBus(eventBus);
   return repository;
}
 

import org.axonframework.eventstore.EventStore; //导入依赖的package包/类
@Bean
@Autowired
public EventStore eventStore() {
   final EsEventStore esEventStore = new EsEventStore(new EventStoreClient(new EsContextDefaultImpl(EventStoreSettings.withDefaults()
         .host("http://127.0.0.1:4445")
         .build())));
   return esEventStore;
}
 

import org.axonframework.eventstore.EventStore; //导入依赖的package包/类
@Bean(name = "testAggregateEventsourcingRepository")
@Autowired
public EventSourcingRepository<MyTestAggregate> respository(final EventStore eventStore, final EventBus eventBus) {
   final EventSourcingRepository<MyTestAggregate> repository = new EventSourcingRepository<>(MyTestAggregate.class, eventStore);
   repository.setEventBus(eventBus);
   return repository;
}
 

import org.axonframework.eventstore.EventStore; //导入依赖的package包/类
@Bean
public AutoEventSourcingRepositoryCreator autoEventSourcingRepositoryCreator(CommandBus commandBus, EventBus eventBus, EventStore eventStore){
    AutoEventSourcingRepositoryCreator bean = new AutoEventSourcingRepositoryCreator();
    bean.setCommandBus(commandBus);
    bean.setEventBus(eventBus);
    bean.setEventStore(eventStore);
    return bean;
}
 

import org.axonframework.eventstore.EventStore; //导入依赖的package包/类
@Test
public void autoConfiguration() throws Exception {
    this.context.register(AxonAutoConfiguration.class);
    this.context.refresh();
    assertNotNull(this.context.getBean(CommandBus.class));
    assertNotNull(this.context.getBean(CommandGateway.class));
    assertNotNull(this.context.getBean(EventBus.class));
    assertNotNull(this.context.getBean(EventStore.class));
    assertNotNull(this.context.getBean(IdentifierFactory.class));
}
 

import org.axonframework.eventstore.EventStore; //导入依赖的package包/类
@Test
public void testSaveStreamAndReadBack() {
    assertNotNull("HazelcastInstance is null",m_instance);

    String     type  = "org.axonframework.ext.store.chronicle.test";
    String     aid   = UUID.randomUUID().toString();
    EventStore store = new HzEventStore(m_instance);
    int        evts  = 10;

    List<DomainEventMessage<?>> demWrite = Lists.newArrayListWithCapacity(evts);
    for(int i=0;i<evts;i++) {
        demWrite.add(new HzAxonEventMessage(aid,i,"evt-" + i));
    }

    store.appendEvents(type,new SimpleDomainEventStream(demWrite));

    List<DomainEventMessage<?>> demRead = Lists.newArrayListWithCapacity(evts);
    DomainEventStream des = store.readEvents(type,aid);
    while (des.hasNext()) {
        demRead.add(des.next());
    }

    assertEquals(demWrite.size(),demRead.size());

    for(int i=0;i<evts;i++) {
        assertEquals(
            demWrite.get(i).getIdentifier(),
            demRead.get(i).getIdentifier());
    }
}
 

import org.axonframework.eventstore.EventStore; //导入依赖的package包/类
@Bean
public EventStore eventStore() {
    return new VolatileEventStore();
}
 

import org.axonframework.eventstore.EventStore; //导入依赖的package包/类
@Bean
@Autowired
public EventStore eventStore(final com.github.msemys.esjc.EventStore eventStoreClient) {
   return new EsjcEventStore(eventStoreClient);
}
 

import org.axonframework.eventstore.EventStore; //导入依赖的package包/类
public EsjcEventStore(final com.github.msemys.esjc.EventStore client) {
   this.client = client;
}
 

import org.axonframework.eventstore.EventStore; //导入依赖的package包/类
@Produces @Default public EventStore produceEventStore() {
	return eventStore;
}
 

import org.axonframework.eventstore.EventStore; //导入依赖的package包/类
private EventStore getEventStore() {
    return new FileSystemEventStore(new SimpleEventFileResolver(new File("data/eventstore")));
}
 

import org.axonframework.eventstore.EventStore; //导入依赖的package包/类
@Bean
public EventStore eventStore() {
	return mongoEventStore();
}
 

import org.axonframework.eventstore.EventStore; //导入依赖的package包/类
public void setEventStore(EventStore eventStore) {
    this.eventStore = eventStore;
}
 

import org.axonframework.eventstore.EventStore; //导入依赖的package包/类
@Bean
@ConditionalOnMissingBean
public EventStore eventStore() throws Exception {
    File baseDir = Files.createTempDirectory("events").toFile();
    return new FileSystemEventStore(new SimpleEventFileResolver(baseDir));
}
 

import org.axonframework.eventstore.EventStore; //导入依赖的package包/类
@Bean
    public EventStore eventStore() {
//        return new FileSystemEventStore(new SimpleEventFileResolver(new File("./target/events")));
        return new ReplayableFileSystemEventStore(new File("./target/events"));
    }
 

import org.axonframework.eventstore.EventStore; //导入依赖的package包/类
public EventStore getEventStore() {
    return m_eventStore;
}
 

import org.axonframework.eventstore.EventStore; //导入依赖的package包/类
public void setEventStore(EventStore eventStore) {
    m_eventStore = eventStore;
}