@Test public void testSetBufferLimit() throws Exception { handler.setBufferLimit(25); exception.expect(IllegalArgumentException.class); handler.setBufferLimit(-10); }
public void setBufferLimit(int limit) { if (limit > 0) { bufferLimit.set(limit); } else { throw new IllegalArgumentException("Buffer limit must be at least 1"); } }
BindingHandler { public void setBufferLimit(int limit) { if (limit > 0) { bufferLimit.set(limit); } else { throw new IllegalArgumentException("Buffer limit must be at least 1"); } } }
BindingHandler { public void setBufferLimit(int limit) { if (limit > 0) { bufferLimit.set(limit); } else { throw new IllegalArgumentException("Buffer limit must be at least 1"); } } BindingHandler(SxpNode node, BindingDispatcher dispatcher);  BindingHandler(SxpNode node, BindingDispatcher dispatcher, int bufferSize); }
BindingHandler { public void setBufferLimit(int limit) { if (limit > 0) { bufferLimit.set(limit); } else { throw new IllegalArgumentException("Buffer limit must be at least 1"); } } BindingHandler(SxpNode node, BindingDispatcher dispatcher);  BindingHandler(SxpNode node, BindingDispatcher dispatcher, int bufferSize); void setBufferLimit(int limit); static Stream<T> loopDetection(NodeId nodeId, Stream<T> bindings); static List<SxpDatabaseBinding> processMessageAddition(UpdateMessageLegacy message, SxpBindingFilter filter,
            NodeId nodeIdRemote); static List<SxpDatabaseBinding> processMessageAddition(UpdateMessage message, SxpBindingFilter filter); static List<SxpDatabaseBinding> processMessageDeletion(UpdateMessage message); static List<SxpDatabaseBinding> processMessageDeletion(UpdateMessageLegacy message); ListenableFuture<Void> processPurgeAllMessage(final SxpConnection connection); void processUpdate(final List<T> databaseDelete, final List<T> databaseAdd,
            final SxpConnection connection); }
BindingHandler { public void setBufferLimit(int limit) { if (limit > 0) { bufferLimit.set(limit); } else { throw new IllegalArgumentException("Buffer limit must be at least 1"); } } BindingHandler(SxpNode node, BindingDispatcher dispatcher);  BindingHandler(SxpNode node, BindingDispatcher dispatcher, int bufferSize); void setBufferLimit(int limit); static Stream<T> loopDetection(NodeId nodeId, Stream<T> bindings); static List<SxpDatabaseBinding> processMessageAddition(UpdateMessageLegacy message, SxpBindingFilter filter,
            NodeId nodeIdRemote); static List<SxpDatabaseBinding> processMessageAddition(UpdateMessage message, SxpBindingFilter filter); static List<SxpDatabaseBinding> processMessageDeletion(UpdateMessage message); static List<SxpDatabaseBinding> processMessageDeletion(UpdateMessageLegacy message); ListenableFuture<Void> processPurgeAllMessage(final SxpConnection connection); void processUpdate(final List<T> databaseDelete, final List<T> databaseAdd,
            final SxpConnection connection);  }