Package mocka.persistence

Class BulkPersistenceManager

java.lang.Object

mocka.persistence.BulkPersistenceManager

@Component
public class BulkPersistenceManager
extends Object

Constructor Summary

Constructors

Constructor	Description
BulkPersistenceManager(org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor bulkProducerExecutor, org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor bulkConsumerExecutor, JdbcBatchWriter jdbcBatchWriter)

Method Summary

Modifier and Type	Method	Description
<T> void	start(EntityGenerator<T> generator, long totalCount, int batchSize, Class<T> entityType)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BulkPersistenceManager

public BulkPersistenceManager(org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor bulkProducerExecutor,
 org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor bulkConsumerExecutor,
 JdbcBatchWriter jdbcBatchWriter)

Method Details

start

public <T> void start(EntityGenerator<T> generator,
 long totalCount,
 int batchSize,
 Class<T> entityType)
               throws InterruptedException

Throws:

InterruptedException