fix defaults

This commit is contained in:
fjy 2014-08-08 10:42:58 -07:00
parent 627447c6f8
commit b3eb4cc5da
2 changed files with 2 additions and 2 deletions

View File

@ -38,7 +38,7 @@ public class PriorityTieredBrokerSelectorStrategy implements TieredBrokerSelecto
@JsonProperty("maxPriority") Integer maxPriority @JsonProperty("maxPriority") Integer maxPriority
) )
{ {
this.minPriority = minPriority == null ? 0 : minPriority; this.minPriority = minPriority == null ? 1 : minPriority;
this.maxPriority = maxPriority == null ? 1 : maxPriority; this.maxPriority = maxPriority == null ? 1 : maxPriority;
} }

View File

@ -60,7 +60,7 @@ public class TieredBrokerConfig
@NotNull @NotNull
private List<TieredBrokerSelectorStrategy> strategies = Arrays.asList( private List<TieredBrokerSelectorStrategy> strategies = Arrays.asList(
new TimeBoundaryTieredBrokerSelectorStrategy(), new TimeBoundaryTieredBrokerSelectorStrategy(),
new PriorityTieredBrokerSelectorStrategy(0, 0) new PriorityTieredBrokerSelectorStrategy(1, 1)
); );
// tier, <bard, numThreads> // tier, <bard, numThreads>