mirror of https://github.com/apache/nifi.git
NIFI-164: Fixed MockContentRepository that existed in a unit test
This commit is contained in:
parent
55d4b1c099
commit
d57861d8b5
|
@ -977,6 +977,10 @@ public class TestStandardProcessSession {
|
||||||
|
|
||||||
private ConcurrentMap<ContentClaim, AtomicInteger> claimantCounts = new ConcurrentHashMap<>();
|
private ConcurrentMap<ContentClaim, AtomicInteger> claimantCounts = new ConcurrentHashMap<>();
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void shutdown() {
|
||||||
|
}
|
||||||
|
|
||||||
public Set<ContentClaim> getExistingClaims() {
|
public Set<ContentClaim> getExistingClaims() {
|
||||||
final Set<ContentClaim> claims = new HashSet<>();
|
final Set<ContentClaim> claims = new HashSet<>();
|
||||||
|
|
||||||
|
|
|
@ -169,6 +169,8 @@ public class VolatileProvenanceRepository implements ProvenanceEventRepository {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void close() throws IOException {
|
public void close() throws IOException {
|
||||||
|
queryExecService.shutdownNow();
|
||||||
|
scheduledExecService.shutdown();
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
Loading…
Reference in New Issue