Organize imports
Project: http://git-wip-us.apache.org/repos/asf/brooklyn-library/repo Commit: http://git-wip-us.apache.org/repos/asf/brooklyn-library/commit/dee689a4 Tree: http://git-wip-us.apache.org/repos/asf/brooklyn-library/tree/dee689a4 Diff: http://git-wip-us.apache.org/repos/asf/brooklyn-library/diff/dee689a4 Branch: refs/heads/0.5.0 Commit: dee689a492130ce5117c9a3b5246b7f61cc330de Parents: 2ca3ea7 Author: Andrew Kennedy <[email protected]> Authored: Wed Mar 20 21:49:58 2013 +0000 Committer: Andrew Kennedy <[email protected]> Committed: Fri Apr 19 10:36:06 2013 +0100 ---------------------------------------------------------------------- .../java/brooklyn/entity/messaging/kafka/KafkaBrokerImpl.java | 1 - .../brooklyn/entity/messaging/kafka/KafkaBrokerSshDriver.java | 4 +--- .../java/brooklyn/entity/messaging/kafka/KafkaZookeeperImpl.java | 2 -- .../brooklyn/entity/messaging/kafka/KafkaZookeeperSshDriver.java | 2 +- 4 files changed, 2 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/brooklyn-library/blob/dee689a4/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/KafkaBrokerImpl.java ---------------------------------------------------------------------- diff --git a/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/KafkaBrokerImpl.java b/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/KafkaBrokerImpl.java index 0abdf45..625fe3f 100644 --- a/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/KafkaBrokerImpl.java +++ b/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/KafkaBrokerImpl.java @@ -22,7 +22,6 @@ import java.util.Set; import java.util.concurrent.Callable; import java.util.concurrent.TimeUnit; -import javax.management.MalformedObjectNameException; import javax.management.ObjectName; import org.slf4j.Logger; http://git-wip-us.apache.org/repos/asf/brooklyn-library/blob/dee689a4/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/KafkaBrokerSshDriver.java ---------------------------------------------------------------------- diff --git a/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/KafkaBrokerSshDriver.java b/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/KafkaBrokerSshDriver.java index e6c9e4e..b3cd0f0 100644 --- a/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/KafkaBrokerSshDriver.java +++ b/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/KafkaBrokerSshDriver.java @@ -15,10 +15,8 @@ */ package brooklyn.entity.messaging.kafka; -import static com.google.common.base.Preconditions.checkNotNull; import static java.lang.String.format; -import java.util.ArrayList; import java.util.LinkedList; import java.util.List; import java.util.Map; @@ -50,7 +48,7 @@ public class KafkaBrokerSshDriver extends JavaSoftwareProcessSshDriver implement } @Override - protected String getLogFileLocation() { return getRunDir()+"/kafka-log"; } + protected String getLogFileLocation() { return getRunDir()+"/console.out"; } @Override public Integer getKafkaPort() { return entity.getAttribute(KafkaBroker.KAFKA_PORT); } http://git-wip-us.apache.org/repos/asf/brooklyn-library/blob/dee689a4/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/KafkaZookeeperImpl.java ---------------------------------------------------------------------- diff --git a/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/KafkaZookeeperImpl.java b/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/KafkaZookeeperImpl.java index a572a75..8d9d4f4 100644 --- a/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/KafkaZookeeperImpl.java +++ b/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/KafkaZookeeperImpl.java @@ -29,7 +29,6 @@ import org.slf4j.LoggerFactory; import brooklyn.entity.Entity; import brooklyn.entity.basic.SoftwareProcessImpl; -import brooklyn.entity.messaging.qpid.QpidBroker; import brooklyn.event.feed.function.FunctionFeed; import brooklyn.event.feed.function.FunctionPollConfig; import brooklyn.event.feed.jmx.JmxAttributePollConfig; @@ -38,7 +37,6 @@ import brooklyn.event.feed.jmx.JmxHelper; import brooklyn.util.MutableMap; import brooklyn.util.exceptions.Exceptions; -import com.google.common.base.Function; import com.google.common.base.Functions; import com.google.common.base.Objects.ToStringHelper; import com.google.common.collect.Sets; http://git-wip-us.apache.org/repos/asf/brooklyn-library/blob/dee689a4/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/KafkaZookeeperSshDriver.java ---------------------------------------------------------------------- diff --git a/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/KafkaZookeeperSshDriver.java b/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/KafkaZookeeperSshDriver.java index 4310489..bbaaa0d 100644 --- a/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/KafkaZookeeperSshDriver.java +++ b/software/messaging/src/main/java/brooklyn/entity/messaging/kafka/KafkaZookeeperSshDriver.java @@ -44,7 +44,7 @@ public class KafkaZookeeperSshDriver extends JavaSoftwareProcessSshDriver implem } @Override - protected String getLogFileLocation() { return getRunDir()+"/kafka-log"; } + protected String getLogFileLocation() { return getRunDir()+"/console.out"; } @Override public Integer getZookeeperPort() { return entity.getAttribute(KafkaZookeeper.ZOOKEEPER_PORT); }
