public class TestDistributedQueue extends BaseClassForTests
server
Constructor and Description |
---|
TestDistributedQueue() |
Modifier and Type | Method and Description |
---|---|
void |
testCustomExecutor() |
void |
testErrorMode() |
void |
testFlush() |
void |
testMultiPutterSingleGetter() |
void |
testNoDuplicateProcessing() |
void |
testPutListener() |
void |
testPutMulti() |
void |
testRetryAfterFailure_Curator56() |
void |
testSafetyBasic() |
void |
testSafetyWithCrash() |
void |
testSimple() |
createAndStartCluster, createServer, setup, teardown
@Test public void testRetryAfterFailure_Curator56() throws Exception
Exception
@Test public void testNoDuplicateProcessing() throws Exception
Exception
@Test public void testMultiPutterSingleGetter() throws Exception
Exception
Copyright © 2011–2023 The Apache Software Foundation. All rights reserved.