format code

Author: MatthieuMAIF

thoth-jooq/src/test/java/fr/maif/eventsourcing/impl/JooqKafkaTckImplementation.java

@@ -17,7 +17,7 @@
 
 import fr.maif.eventsourcing.Projection;
 import fr.maif.eventsourcing.datastore.TestConsistentProjection;
-import fr.maif.eventsourcing.datastore.TestProjection;
+import fr.maif.eventsourcing.datastore.TestInstransactionProjection;
 import org.apache.kafka.clients.consumer.ConsumerConfig;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
 import org.apache.kafka.clients.consumer.ConsumerRecords;
@@ -108,7 +108,7 @@ public void initClass() {
 
     @BeforeMethod(alwaysRun = true)
     public void init() throws SQLException {
-        this.testProjection = new TestProjection();
+        this.testProjection = new TestInstransactionProjection();
         this.dataSource = new PGSimpleDataSource();
         dataSource.setUrl(postgres.getJdbcUrl());
         dataSource.setUser(postgres.getUsername());
@@ -237,7 +237,7 @@ public List<EventEnvelope<TestEvent, Tuple0, Tuple0>> readPublishedEvents(String
 
     @Override
     public Integer readProjection() {
-        return ((TestProjection)this.testProjection).getCount();
+        return ((TestInstransactionProjection)this.testProjection).getCount();
     }
 
     @Override