Skip to content

Commit

Permalink
Remove outdated method doc (apache#5422)
Browse files Browse the repository at this point in the history
  • Loading branch information
liketic authored and sijie committed Nov 6, 2019
1 parent 86ccfe8 commit c70e143
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -62,8 +62,6 @@ protected AbstractBaseDispatcher(Subscription subscription) {
*
* @param sendMessageInfo
* an object where the total size in messages and bytes will be returned back to the caller
* @param subscription
* the subscription object
*/
public void filterEntriesForConsumer(List<Entry> entries, EntryBatchSizes batchSizes,
SendMessageInfo sendMessageInfo) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -39,8 +39,10 @@ public class PulsarChannelInitializer extends ChannelInitializer<SocketChannel>
private final ServiceConfiguration brokerConf;

/**
*
* @param brokerService
* @param pulsar
* An instance of {@link PulsarService}
* @param enableTLS
* Enable tls or not
*/
public PulsarChannelInitializer(PulsarService pulsar, boolean enableTLS) throws Exception {
super();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -141,8 +141,7 @@ protected String parseNamespaceFromLedgerName(String ledgerName) {
* Creates a dimension key for metrics
*
* @param namespace
* @param fromClusterName
* @param toClusterName
* Namespace of metric
* @return
*/
protected Metrics createMetricsByDimension(String namespace) {
Expand Down Expand Up @@ -223,8 +222,8 @@ protected void populateMaxMap(Map<String, Long> map, String mkey, long value) {
* Helper to manage populating topics map
*
* @param ledgersByDimensionMap
* @param dimensionKey
* @param destStats
* @param metrics
* @param ledger
*/
protected void populateDimensionMap(Map<Metrics, List<ManagedLedgerImpl>> ledgersByDimensionMap, Metrics metrics,
ManagedLedgerImpl ledger) {
Expand Down

0 comments on commit c70e143

Please sign in to comment.