Skip to content

Commit

Permalink
Merge pull request #1212 from mebigfatguy/master
Browse files Browse the repository at this point in the history
fix logging contexts
  • Loading branch information
mattrjacobs committed May 23, 2016
2 parents bf56d90 + 9266004 commit bca8d89
Show file tree
Hide file tree
Showing 4 changed files with 6 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ public class HystrixCodaHaleMetricsPublisherThreadPool implements HystrixMetrics
private final String metricGroup;
private final String metricType;

static final Logger logger = LoggerFactory.getLogger(HystrixCodaHaleMetricsPublisherCollapser.class);
static final Logger logger = LoggerFactory.getLogger(HystrixCodaHaleMetricsPublisherThreadPool.class);

public HystrixCodaHaleMetricsPublisherThreadPool(HystrixThreadPoolKey threadPoolKey, HystrixThreadPoolMetrics metrics, HystrixThreadPoolProperties properties, MetricRegistry metricRegistry) {
this.key = threadPoolKey;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@
@ThreadSafe
public class BatchHystrixCommand extends AbstractHystrixCommand<List<Object>> {

private static final Logger LOGGER = LoggerFactory.getLogger(GenericCommand.class);
private static final Logger LOGGER = LoggerFactory.getLogger(BatchHystrixCommand.class);

public BatchHystrixCommand(HystrixCommandBuilder builder) {
super(builder);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,6 @@
import rx.functions.Action0;
import rx.functions.Action1;

import com.netflix.hystrix.HystrixCollapser;
import com.netflix.hystrix.HystrixCollapser.CollapsedRequest;
import com.netflix.hystrix.HystrixCollapserProperties;

Expand All @@ -41,7 +40,7 @@
*/
public class RequestBatch<BatchReturnType, ResponseType, RequestArgumentType> {

private static final Logger logger = LoggerFactory.getLogger(HystrixCollapser.class);
private static final Logger logger = LoggerFactory.getLogger(RequestBatch.class);

private final HystrixCollapserBridge<BatchReturnType, ResponseType, RequestArgumentType> commandCollapser;
private final int maxBatchSize;
Expand Down Expand Up @@ -273,4 +272,4 @@ public void shutdown() {
public int getSize() {
return count.get();
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,6 @@

import rx.Observable;

import com.netflix.hystrix.HystrixCollapser;
import com.netflix.hystrix.HystrixCollapserProperties;
import com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy;
import com.netflix.hystrix.strategy.concurrency.HystrixContextCallable;
Expand All @@ -41,7 +40,7 @@
* @ThreadSafe
*/
public class RequestCollapser<BatchReturnType, ResponseType, RequestArgumentType> {
static final Logger logger = LoggerFactory.getLogger(HystrixCollapser.class);
static final Logger logger = LoggerFactory.getLogger(RequestCollapser.class);

private final HystrixCollapserBridge<BatchReturnType, ResponseType, RequestArgumentType> commandCollapser;
// batch can be null once shutdown
Expand Down Expand Up @@ -178,4 +177,4 @@ public int getIntervalTimeInMilliseconds() {

}

}
}

0 comments on commit bca8d89

Please sign in to comment.