brooklyn-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From henev...@apache.org
Subject [23/50] brooklyn-library git commit: Organize imports
Date Mon, 01 Feb 2016 17:46:41 GMT
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 <andrew.kennedy@cloudsoftcorp.com>
Authored: Wed Mar 20 21:49:58 2013 +0000
Committer: Andrew Kennedy <andrew.kennedy@cloudsoftcorp.com>
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);
}


Mime
View raw message