Assert.assertFalse(worker.isPaused());
try {
final AdminClient adminClient = new AdminClientImpl(config);
try {
adminClient.togglePausedWorkers(true);
try {
Thread.sleep(1000L);
} catch (InterruptedException ie) {
}
Assert.assertTrue(worker.isPaused());