@Test public void testNonBlockingStart_NoSharedConnection() throws Exception { Adapter adapter = new Adapter(); adapter.setUniqueId(getName()); try { adapter.getSharedComponents().setLifecycleStrategy(new FilteredSharedComponentStart(true)); adapter.requestInit(); assertEquals(InitialisedState.getInstance(), adapter.retrieveComponentState()); } finally { stop(adapter); } }
@Override public void stop(Collection<AdaptrisConnection> conns) { shutdownExecutors(); for (AdaptrisConnection c : conns) { LifecycleHelper.stop(c); } }
FilteredSharedComponentStart implements SharedComponentLifecycleStrategy { @Override public void stop(Collection<AdaptrisConnection> conns) { shutdownExecutors(); for (AdaptrisConnection c : conns) { LifecycleHelper.stop(c); } } }
FilteredSharedComponentStart implements SharedComponentLifecycleStrategy { @Override public void stop(Collection<AdaptrisConnection> conns) { shutdownExecutors(); for (AdaptrisConnection c : conns) { LifecycleHelper.stop(c); } } FilteredSharedComponentStart();  FilteredSharedComponentStart(Boolean threaded); }
FilteredSharedComponentStart implements SharedComponentLifecycleStrategy { @Override public void stop(Collection<AdaptrisConnection> conns) { shutdownExecutors(); for (AdaptrisConnection c : conns) { LifecycleHelper.stop(c); } } FilteredSharedComponentStart();  FilteredSharedComponentStart(Boolean threaded); @Override void init(Collection<AdaptrisConnection> conns); @Override void start(Collection<AdaptrisConnection> conns); @Override void stop(Collection<AdaptrisConnection> conns); @Override void close(Collection<AdaptrisConnection> conns); Boolean getThreadedStart(); void setThreadedStart(Boolean b); List<String> getIncludes(); void setIncludes(List<String> l); List<String> getExcludes(); void setExcludes(List<String> l); void addInclude(String pattern); void addExclude(String pattern); Collection<AdaptrisConnection> filter(Collection<AdaptrisConnection> original); }
FilteredSharedComponentStart implements SharedComponentLifecycleStrategy { @Override public void stop(Collection<AdaptrisConnection> conns) { shutdownExecutors(); for (AdaptrisConnection c : conns) { LifecycleHelper.stop(c); } } FilteredSharedComponentStart();  FilteredSharedComponentStart(Boolean threaded); @Override void init(Collection<AdaptrisConnection> conns); @Override void start(Collection<AdaptrisConnection> conns); @Override void stop(Collection<AdaptrisConnection> conns); @Override void close(Collection<AdaptrisConnection> conns); Boolean getThreadedStart(); void setThreadedStart(Boolean b); List<String> getIncludes(); void setIncludes(List<String> l); List<String> getExcludes(); void setExcludes(List<String> l); void addInclude(String pattern); void addExclude(String pattern); Collection<AdaptrisConnection> filter(Collection<AdaptrisConnection> original);  }