SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Use commons-logging

Browse Source 
This resolves #490
This commit is contained in:
Ilayaperumal Gopinathan
2016-04-18 10:42:01 +05:30
committed by Marius Bogoevici
parent bfff729b81
commit ca101ba9e9
7 changed files with 19 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-cloud-stream-test-support-internal/src/main/java/org/springframework/cloud/stream/test/junit/AbstractExternalResourceTestSupport.java
View File

@@ -18,13 +18,13 @@ package org.springframework.cloud.stream.test.junit;
import static org.junit.Assert.fail;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.junit.Assume;
import org.junit.Rule;
import org.junit.rules.TestRule;
import org.junit.runner.Description;
import org.junit.runners.model.Statement;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.util.Assert;
@@ -46,7 +46,7 @@ public abstract class AbstractExternalResourceTestSupport<R> implements TestRule
private String resourceDescription;
protected final Logger logger = LoggerFactory.getLogger(this.getClass());
protected final Log logger = LogFactory.getLog(getClass());
protected AbstractExternalResourceTestSupport(String resourceDescription) {
Assert.hasText(resourceDescription, "resourceDescription is required");

6
spring-cloud-stream-test-support-internal/src/main/java/org/springframework/cloud/stream/test/junit/kafka/KafkaTestSupport.java
View File

@@ -21,9 +21,9 @@ import java.util.Properties;
import org.I0Itec.zkclient.ZkClient;
import org.I0Itec.zkclient.exception.ZkInterruptedException;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.junit.Rule;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.stream.test.junit.AbstractExternalResourceTestSupport;
import org.springframework.util.SocketUtils;
@@ -46,7 +46,7 @@ import kafka.utils.ZkUtils;
*/
public class KafkaTestSupport extends AbstractExternalResourceTestSupport<String> {
private static final Logger log = LoggerFactory.getLogger(KafkaTestSupport.class);
private static final Log log = LogFactory.getLog(KafkaTestSupport.class);
private static final String SCS_KAFKA_TEST_EMBEDDED = "SCS_KAFKA_TEST_EMBEDDED";