@Test public void testTimeout() throws Exception { try { System.clearProperty("sun.rmi.transport.tcp.responseTimeout"); ConsumerConfig consumer = new ConsumerConfig(); consumer.setTimeout(10); assertThat(consumer.getTimeout(), is(10)); assertThat(System.getProperty("sun.rmi.transport.tcp.responseTimeout"), equalTo("10")); } finally { System.clearProperty("sun.rmi.transport.tcp.responseTimeout"); } }
@Override public void setTimeout(Integer timeout) { super.setTimeout(timeout); String rmiTimeout = System.getProperty("sun.rmi.transport.tcp.responseTimeout"); if (timeout != null && timeout > 0 && (rmiTimeout == null || rmiTimeout.length() == 0)) { System.setProperty("sun.rmi.transport.tcp.responseTimeout", String.valueOf(timeout)); } }
ConsumerConfig extends AbstractReferenceConfig { @Override public void setTimeout(Integer timeout) { super.setTimeout(timeout); String rmiTimeout = System.getProperty("sun.rmi.transport.tcp.responseTimeout"); if (timeout != null && timeout > 0 && (rmiTimeout == null || rmiTimeout.length() == 0)) { System.setProperty("sun.rmi.transport.tcp.responseTimeout", String.valueOf(timeout)); } } }
ConsumerConfig extends AbstractReferenceConfig { @Override public void setTimeout(Integer timeout) { super.setTimeout(timeout); String rmiTimeout = System.getProperty("sun.rmi.transport.tcp.responseTimeout"); if (timeout != null && timeout > 0 && (rmiTimeout == null || rmiTimeout.length() == 0)) { System.setProperty("sun.rmi.transport.tcp.responseTimeout", String.valueOf(timeout)); } }  }
ConsumerConfig extends AbstractReferenceConfig { @Override public void setTimeout(Integer timeout) { super.setTimeout(timeout); String rmiTimeout = System.getProperty("sun.rmi.transport.tcp.responseTimeout"); if (timeout != null && timeout > 0 && (rmiTimeout == null || rmiTimeout.length() == 0)) { System.setProperty("sun.rmi.transport.tcp.responseTimeout", String.valueOf(timeout)); } }  @Override void setTimeout(Integer timeout); Boolean isDefault(); void setDefault(Boolean isDefault); String getClient(); void setClient(String client); String getThreadpool(); void setThreadpool(String threadpool); Boolean getDefault(); Integer getCorethreads(); void setCorethreads(Integer corethreads); Integer getThreads(); void setThreads(Integer threads); Integer getQueues(); void setQueues(Integer queues); }
ConsumerConfig extends AbstractReferenceConfig { @Override public void setTimeout(Integer timeout) { super.setTimeout(timeout); String rmiTimeout = System.getProperty("sun.rmi.transport.tcp.responseTimeout"); if (timeout != null && timeout > 0 && (rmiTimeout == null || rmiTimeout.length() == 0)) { System.setProperty("sun.rmi.transport.tcp.responseTimeout", String.valueOf(timeout)); } }  @Override void setTimeout(Integer timeout); Boolean isDefault(); void setDefault(Boolean isDefault); String getClient(); void setClient(String client); String getThreadpool(); void setThreadpool(String threadpool); Boolean getDefault(); Integer getCorethreads(); void setCorethreads(Integer corethreads); Integer getThreads(); void setThreads(Integer threads); Integer getQueues(); void setQueues(Integer queues);  }