diff --git a/skywalking-collector/pom.xml b/skywalking-collector/pom.xml index e695b2868483c3f1c8c0014d3617e076029fb4da..79845cfe7241fce9e6f45e32f40462d77dc1a596 100644 --- a/skywalking-collector/pom.xml +++ b/skywalking-collector/pom.xml @@ -36,6 +36,16 @@ log4j-api ${log4j.version} + + org.apache.logging.log4j + log4j-slf4j-impl + ${log4j.version} + + + org.apache.logging.log4j + log4j-jcl + ${log4j.version} + com.typesafe.akka akka-testkit_2.11 diff --git a/skywalking-collector/skywalking-collector-cluster/src/main/java/com/a/eye/skywalking/collector/AkkaSystem.java b/skywalking-collector/skywalking-collector-cluster/src/main/java/com/a/eye/skywalking/collector/AkkaSystem.java index 5c1252c34ac70698d4e16ef33de04c6fa9e84d66..cbf4df4f2aee80171691973e954f629155d0f11c 100644 --- a/skywalking-collector/skywalking-collector-cluster/src/main/java/com/a/eye/skywalking/collector/AkkaSystem.java +++ b/skywalking-collector/skywalking-collector-cluster/src/main/java/com/a/eye/skywalking/collector/AkkaSystem.java @@ -18,8 +18,11 @@ public enum AkkaSystem { public ActorSystem create() { final Config config = ConfigFactory.parseString("akka.remote.netty.tcp.HOSTNAME=" + ClusterConfig.Cluster.Current.HOSTNAME). - withFallback(ConfigFactory.parseString("akka.remote.netty.tcp.PORT=" + ClusterConfig.Cluster.Current.PORT)). - withFallback(ConfigFactory.load("application.conf")); + withFallback(ConfigFactory.parseString("akka.remote.netty.tcp.PORT=" + ClusterConfig.Cluster.Current.PORT)). + withFallback(ConfigFactory.parseString("akka.loggers=[\"akka.event.slf4j.Slf4jLogger\"]")). + withFallback(ConfigFactory.parseString("akka.loglevel=\"ERROR\"")). + + withFallback(ConfigFactory.load("application.conf")); if (!StringUtil.isEmpty(ClusterConfig.Cluster.SEED_NODES)) { config.withFallback(ConfigFactory.parseString("akka.cluster.seed-nodes=" + generateSeedNodes())); }