@Test public void testSetPartitionSize() throws Exception { dispatcher.setPartitionSize(25); exception.expect(IllegalArgumentException.class); dispatcher.setPartitionSize(-10); }
public void setPartitionSize(int partitionSize) { if (partitionSize > 1 && partitionSize < 151) { this.partitionSize.set(partitionSize); } else { throw new IllegalArgumentException("Partition size must be between 2-150. Current value: " + partitionSize); } }
BindingDispatcher { public void setPartitionSize(int partitionSize) { if (partitionSize > 1 && partitionSize < 151) { this.partitionSize.set(partitionSize); } else { throw new IllegalArgumentException("Partition size must be between 2-150. Current value: " + partitionSize); } } }
BindingDispatcher { public void setPartitionSize(int partitionSize) { if (partitionSize > 1 && partitionSize < 151) { this.partitionSize.set(partitionSize); } else { throw new IllegalArgumentException("Partition size must be between 2-150. Current value: " + partitionSize); } } BindingDispatcher(SxpNode owner); }
BindingDispatcher { public void setPartitionSize(int partitionSize) { if (partitionSize > 1 && partitionSize < 151) { this.partitionSize.set(partitionSize); } else { throw new IllegalArgumentException("Partition size must be between 2-150. Current value: " + partitionSize); } } BindingDispatcher(SxpNode owner); void setPartitionSize(int partitionSize); void propagateUpdate(List<T> deleteBindings, List<T> addBindings,
                                                             List<SxpConnection> connections); static ListenableFuture<Boolean> sendPurgeAllMessage(final SxpConnection connection); static boolean sendPurgeAllMessageSync(final SxpConnection connection); SxpNode getOwner(); }
BindingDispatcher { public void setPartitionSize(int partitionSize) { if (partitionSize > 1 && partitionSize < 151) { this.partitionSize.set(partitionSize); } else { throw new IllegalArgumentException("Partition size must be between 2-150. Current value: " + partitionSize); } } BindingDispatcher(SxpNode owner); void setPartitionSize(int partitionSize); void propagateUpdate(List<T> deleteBindings, List<T> addBindings,
                                                             List<SxpConnection> connections); static ListenableFuture<Boolean> sendPurgeAllMessage(final SxpConnection connection); static boolean sendPurgeAllMessageSync(final SxpConnection connection); SxpNode getOwner();  }