@Test public void testRun() throws Exception { isisLspQueueConsumer.run(); assertThat(isisLspQueueConsumer, is(notNullValue())); }
@Override public void run() { log.debug("LSPQueueConsumer:run...!!!"); try { while (true) { if (!queue.isEmpty()) { LspWrapper wrapper = (LspWrapper) queue.take(); String lspProcessing = wrapper.lspProcessing(); switch (lspProcessing) { case IsisConstants.REFRESHLSP: log.debug("LSPQueueConsumer: Message - " + IsisConstants.REFRESHLSP + " consumed."); processRefreshLsp(wrapper); break; case IsisConstants.MAXAGELSP: log.debug("LSPQueueConsumer: Message - " + IsisConstants.MAXAGELSP + " consumed."); processMaxAgeLsa(wrapper); break; default: log.debug("Unknown command to process the LSP in queue ...!!!"); break; } } } } catch (Exception e) { log.debug("Error::LSPQueueConsumer::{}", e.getMessage()); } }
IsisLspQueueConsumer implements Runnable { @Override public void run() { log.debug("LSPQueueConsumer:run...!!!"); try { while (true) { if (!queue.isEmpty()) { LspWrapper wrapper = (LspWrapper) queue.take(); String lspProcessing = wrapper.lspProcessing(); switch (lspProcessing) { case IsisConstants.REFRESHLSP: log.debug("LSPQueueConsumer: Message - " + IsisConstants.REFRESHLSP + " consumed."); processRefreshLsp(wrapper); break; case IsisConstants.MAXAGELSP: log.debug("LSPQueueConsumer: Message - " + IsisConstants.MAXAGELSP + " consumed."); processMaxAgeLsa(wrapper); break; default: log.debug("Unknown command to process the LSP in queue ...!!!"); break; } } } } catch (Exception e) { log.debug("Error::LSPQueueConsumer::{}", e.getMessage()); } } }
IsisLspQueueConsumer implements Runnable { @Override public void run() { log.debug("LSPQueueConsumer:run...!!!"); try { while (true) { if (!queue.isEmpty()) { LspWrapper wrapper = (LspWrapper) queue.take(); String lspProcessing = wrapper.lspProcessing(); switch (lspProcessing) { case IsisConstants.REFRESHLSP: log.debug("LSPQueueConsumer: Message - " + IsisConstants.REFRESHLSP + " consumed."); processRefreshLsp(wrapper); break; case IsisConstants.MAXAGELSP: log.debug("LSPQueueConsumer: Message - " + IsisConstants.MAXAGELSP + " consumed."); processMaxAgeLsa(wrapper); break; default: log.debug("Unknown command to process the LSP in queue ...!!!"); break; } } } } catch (Exception e) { log.debug("Error::LSPQueueConsumer::{}", e.getMessage()); } } IsisLspQueueConsumer(BlockingQueue queue); }
IsisLspQueueConsumer implements Runnable { @Override public void run() { log.debug("LSPQueueConsumer:run...!!!"); try { while (true) { if (!queue.isEmpty()) { LspWrapper wrapper = (LspWrapper) queue.take(); String lspProcessing = wrapper.lspProcessing(); switch (lspProcessing) { case IsisConstants.REFRESHLSP: log.debug("LSPQueueConsumer: Message - " + IsisConstants.REFRESHLSP + " consumed."); processRefreshLsp(wrapper); break; case IsisConstants.MAXAGELSP: log.debug("LSPQueueConsumer: Message - " + IsisConstants.MAXAGELSP + " consumed."); processMaxAgeLsa(wrapper); break; default: log.debug("Unknown command to process the LSP in queue ...!!!"); break; } } } } catch (Exception e) { log.debug("Error::LSPQueueConsumer::{}", e.getMessage()); } } IsisLspQueueConsumer(BlockingQueue queue); @Override void run(); }
IsisLspQueueConsumer implements Runnable { @Override public void run() { log.debug("LSPQueueConsumer:run...!!!"); try { while (true) { if (!queue.isEmpty()) { LspWrapper wrapper = (LspWrapper) queue.take(); String lspProcessing = wrapper.lspProcessing(); switch (lspProcessing) { case IsisConstants.REFRESHLSP: log.debug("LSPQueueConsumer: Message - " + IsisConstants.REFRESHLSP + " consumed."); processRefreshLsp(wrapper); break; case IsisConstants.MAXAGELSP: log.debug("LSPQueueConsumer: Message - " + IsisConstants.MAXAGELSP + " consumed."); processMaxAgeLsa(wrapper); break; default: log.debug("Unknown command to process the LSP in queue ...!!!"); break; } } } } catch (Exception e) { log.debug("Error::LSPQueueConsumer::{}", e.getMessage()); } } IsisLspQueueConsumer(BlockingQueue queue); @Override void run();  }