Unit testing simple JPA route

["erars+jonathan.cook" <jo...@erars.plus.com>]

Hello,

I've spent a long time with this so this request is a bit of a last 
resort.

I have a very simple route:
@Component
public class IngestRouteBuilder extends RouteBuilder {

     @Override
     public void configure() throws Exception {

         
from("seda:ingest_database_queue?concurrentConsumers={{seda.ingest.concurrent.consumers}}")
             .routeId("ingest-database-persisting")
             .to("jpa:esac.archive.p2sa.ingest.entity.ingest.IngestLog")
             .log(LoggingLevel.INFO, "Finished Inserting IngestLog")
             .bean(MessageBodySetterBean.class)
             
.recipientList(simple("file://${headers.FileDestination}/?fileName=${headers.Filename}"))
             .log(LoggingLevel.INFO, "Finished Ingesting File: 
${headers.Filename}}");

     }

}

Which persists an entity to the database and moves a file somewhere.

My idea was to make use of @DataJpaTest which loads up all the in memory 
database etc for unit tests and it nearly works.

This is my test (sorry to paste large code):
@RunWith(SpringRunner.class)
@DataJpaTest
//@Transactional(propagation = Propagation.NOT_SUPPORTED)
public class IngestRouteBuilderTest extends CamelTestSupport {

     @Autowired
     private TestEntityManager entityManager;

     private static final String TARGET_DIR = "target/repository";
     @Override
     public void setUp() throws Exception {
         deleteDirectory(TARGET_DIR);
         super.setUp();
     }

     @Override
     public void tearDown() throws Exception {
         deleteDirectory(TARGET_DIR);
         super.tearDown();
     }

     @Override
     public String isMockEndpoints() {
         // override this method and return the pattern for which 
endpoints to mock.
         return "file:" + TARGET_DIR + "*";
     }

     @Test
     public void testDeadLetterChannel() throws Exception {


         // This is a notify wait condition
         NotifyBuilder notify = new 
NotifyBuilder(context).from("seda:*").whenDone(1).create();

         // notice we have automatic mocked all endpoints and the name of 
the endpoints is "mock:uri"
         MockEndpoint mock = getMockEndpoint("mock:file:" + TARGET_DIR + 
"/");
         mock.expectedMessageCount(1);

         // Mock the headers
         Map<String, Object> headers = new HashMap<>();
         headers.put(Constants.FILE_NAME_HEADER, 
"lyra_20160708-000000_lev1_met.fits");
         headers.put(Constants.FILE_CONTENT_HEADER,
                     
TestUtils.getFile("/data/lyra/level1/lyra_20160708-000000_lev1_met.fits"));

         // Setup the exchange
         Exchange exchange = new DefaultExchange(context);
         exchange.getOut().setHeaders(headers);

         exchange.getIn().setBody(createIngestLog());

         // Send the message
         template.send("seda:ingest_database_queue", exchange);

         //unwrap.getSession().beginTransaction().begin();

         // Verify the outcome
         assertMockEndpointsSatisfied(5, TimeUnit.SECONDS);
         boolean done = notify.matches(5, TimeUnit.SECONDS);
         assertTrue("Should be done", done);
         assertTrue("File should exist", new 
File("target/failed-test/lyra_20160708-000000_lev1_met.fits").exists());
     }

     @Override
     protected Properties useOverridePropertiesWithPropertiesComponent() 
{
         Properties extra = new Properties();
         extra.put("seda.ingest.concurrent.consumers", "1");
         return extra;
     }

     @Override
     protected RouteBuilder createRouteBuilder() throws Exception {
         JpaComponent component = 
(JpaComponent)context.getComponent("jpa");
         
component.setEntityManagerFactory(entityManager.getEntityManager().getEntityManagerFactory());

         //Map<String, Object> properties = 
entityManager.getEntityManager().getProperties();
         //EntityManagerFactory createEntityManagerFactory = 
javax.persistence.Persistence.createEntityManagerFactory("camel", 
properties);
         //component.setEntityManagerFactory(createEntityManagerFactory);


         IngestRouteBuilder route = new IngestRouteBuilder();
         //ReflectionTestUtils.setField(route, "failed", 
"file:target/failed-test");
         return route;
     }

     private IngestLog createIngestLog() {
         IngestLog ingestLog = new IngestLog();
         ingestLog.setStatus(IngestStatus.INGEST_DONE.name());
         ingestLog.setDataType(DataType.SCIENCE.name());

         Instant ingested = 
Instant.from(Instant.now().atOffset(ZoneOffset.UTC));
         ingestLog.setDateIngested(Date.from(ingested));
         ingestLog.setFileFormat(FileExtension.FITS.name());

         ingestLog.setFileName("filename");
         ingestLog.setFileSize(500);
         ingestLog.setPathStage("/stage/path");
         ingestLog.setPathRepository("/final/path");
         return ingestLog;
     }
}

It fails with the following error:
2018-04-10 17:37:19 WARN  o.a.c.component.seda.SedaConsumer - Error 
processing exchange. Exchange[]. Caused by: 
[javax.persistence.TransactionRequiredException - no transaction is in 
progress]
javax.persistence.TransactionRequiredException: no transaction is in 
progress
	at 
org.hibernate.internal.SessionImpl.checkTransactionNeeded(SessionImpl.java:3430)
	at org.hibernate.internal.SessionImpl.doFlush(SessionImpl.java:1397)
	at org.hibernate.internal.SessionImpl.flush(SessionImpl.java:1393)
	at 
org.apache.camel.component.jpa.JpaProducer$2.doInTransaction(JpaProducer.java:247)
	at 
org.springframework.transaction.support.TransactionTemplate.execute(TransactionTemplate.java:133)
	at 
org.apache.camel.component.jpa.JpaProducer.processEntity(JpaProducer.java:210)
	at 
org.apache.camel.component.jpa.JpaProducer.process(JpaProducer.java:162)
	at 
org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)
...

I'm not really interested in transactions, however if I uncomment this 
at the top //@Transactional(propagation = Propagation.NOT_SUPPORTED) 
then I get a different failure - java.lang.IllegalStateException: No 
transactional EntityManager found.

If I remove the test entity manager then I get the following error:\
endpoint: jpa://esac.archive.p2sa.ingest.entity.ingest.IngestLog. 
Reason: javax.persistence.PersistenceException: No Persistence provider 
for EntityManager named camel

I looked at some of the tests in the component and I don't see what I'm 
doing differently really.

Thanks
Jonathan