CommandProcessor implements RestProcessor { void remove( Request request ) { Preconditions.checkNotNull( request ); commands.remove( request.getCommandId() ); } CommandProcessor( final HostRegistry hostRegistry, final IdentityManager identityManager ); void addListener( HeartbeatListener listener ); void removeListener( HeartbeatListener listener ); void dispose(); @Override void handleHeartbeat( final HeartBeat heartBeat ); @Override Set<String> getRequests( final String hostId ); @Override void handleResponse( final Response response );  }
@Test public void testRemove() throws Exception { commandProcessor.remove( request ); verify( commands ).remove( COMMAND_ID ); }