@Test public void pauseMessageScheduler() { final Connector connector = createConnector(); newConnection( connector ); connector.pauseMessageScheduler(); assertTrue( connector.isSchedulerPaused() ); assertFalse( connector.isSchedulerActive() ); connector.requestSubscribe( new ChannelAddress( 1, 0, 1 ), null ); assertTrue( connector.isSchedulerActive() ); connector.resumeMessageScheduler(); assertFalse( connector.isSchedulerPaused() ); assertFalse( connector.isSchedulerActive() ); connector.pauseMessageScheduler(); assertTrue( connector.isSchedulerPaused() ); assertFalse( connector.isSchedulerActive() ); assertFalse( connector.progressMessages() ); Disposable.dispose( connector ); assertFalse( connector.isSchedulerActive() ); assertTrue( connector.isSchedulerPaused() ); assertNull( connector.getSchedulerLock() ); }
void pauseMessageScheduler() { _schedulerPaused = true; }
Connector extends ReplicantService { void pauseMessageScheduler() { _schedulerPaused = true; } }
Connector extends ReplicantService { void pauseMessageScheduler() { _schedulerPaused = true; } Connector( @Nullable final ReplicantContext context,
             @Nonnull final SystemSchema schema,
             @Nonnull final Transport transport ); }
Connector extends ReplicantService { void pauseMessageScheduler() { _schedulerPaused = true; } Connector( @Nullable final ReplicantContext context,
             @Nonnull final SystemSchema schema,
             @Nonnull final Transport transport ); @Override String toString(); }
Connector extends ReplicantService { void pauseMessageScheduler() { _schedulerPaused = true; } Connector( @Nullable final ReplicantContext context,
             @Nonnull final SystemSchema schema,
             @Nonnull final Transport transport ); @Override String toString();  }