Github user kchilton2 commented on a diff in the pull request:

    https://github.com/apache/incubator-rya/pull/272#discussion_r168275881
  
    --- Diff: 
extras/rya.streams/api/src/test/java/org/apache/rya/streams/api/queries/InMemoryQueryRepositoryTest.java
 ---
    @@ -85,11 +92,16 @@ public void initializedWithPopulatedChangeLog() throws 
Exception {
                 queries.delete( deletedMeId );
     
                 // Create a new totally in memory QueryRepository.
    -            try(final QueryRepository initializedQueries = new 
InMemoryQueryRepository( changeLog )) {
    +            final QueryRepository initializedQueries = new 
InMemoryQueryRepository( changeLog, SCHEDULE );
    +            try {
                     // Listing the queries should work using an initialized 
change log.
                     final Set<StreamsQuery> stored = initializedQueries.list();
                     assertEquals(expected, stored);
    +            } finally {
    +                queries.stop();
    --- End diff --
    
    Removed.


---

Reply via email to