Skip to content

Commit

Permalink
Deprecate StatsdConfig.queueSize()
Browse files Browse the repository at this point in the history
See gh-568
  • Loading branch information
izeye authored and jkschneider committed May 3, 2018
1 parent e3511b6 commit d493157
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -110,7 +110,9 @@ default Duration pollingFrequency() {
* Governs the maximum size of the queue of items waiting to be sent to a StatsD agent over UDP.
*
* @return Maximum queue size.
* @deprecated No longer configurable and unbounded queue will be always used instead.
*/
@Deprecated
default int queueSize() {
String v = get(prefix() + ".queueSize");
return v == null ? Integer.MAX_VALUE : Integer.parseInt(v);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -63,6 +63,7 @@ public class StatsdProperties {
/**
* Maximum size of the queue of items waiting to be sent to the StatsD server.
*/
@Deprecated
private Integer queueSize = Integer.MAX_VALUE;

/**
Expand Down Expand Up @@ -118,10 +119,12 @@ public void setPollingFrequency(Duration pollingFrequency) {
this.pollingFrequency = pollingFrequency;
}

@Deprecated
public Integer getQueueSize() {
return this.queueSize;
}

@Deprecated
public void setQueueSize(Integer queueSize) {
this.queueSize = queueSize;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -69,6 +69,7 @@ public Duration pollingFrequency() {
StatsdConfig.super::pollingFrequency);
}

@Deprecated
@Override
public int queueSize() {
return get(StatsdProperties::getQueueSize, StatsdConfig.super::queueSize);
Expand Down

0 comments on commit d493157

Please sign in to comment.