diff --git a/Tool.java b/Tool.java index d9a1d95..0f3b3d4 100644 --- a/Tool.java +++ b/Tool.java @@ -91,7 +91,7 @@ public static void main(String[] args) throws Exception { System.out.println("Error, topic " + tr.getTopic() + " does not exist !"); } else if (tr.getError() == TankClient.ERROR_NO_SUCH_PARTITION) { System.out.println( - "Error, topic " + tr.getTopic() + " doe not have a partition " + tr.getPartition()); + "Error, topic " + tr.getTopic() + " does not have a partition " + tr.getPartition()); } else { System.out.println( "Unknown error for topic: " + tr.getTopic() + " partition: " + tr.getPartition()); @@ -110,7 +110,7 @@ public static void main(String[] args) throws Exception { response = tc.consume(consume); consume = new TankRequest(TankClient.CONSUME_REQ); for (TankResponse tr : response) { - System.out.println("topic: " + tr.getTopic() + " partition: " + tr.getPartition()); + //System.out.println("topic: " + tr.getTopic() + " partition: " + tr.getPartition()); for (TankMessage tm : tr.getMessages()) { System.out.println("seq: " + tm.getSeqId() + " ts: " + tm.getTimestamp() diff --git a/logging.properties b/logging.properties index ec52a40..e35a803 100644 --- a/logging.properties +++ b/logging.properties @@ -1,5 +1,5 @@ handlers= java.util.logging.ConsoleHandler .level = ALL -java.util.logging.ConsoleHandler.level = FINE +java.util.logging.ConsoleHandler.level = INFO #java.util.logging.SimpleFormatter.format=%1$tb %1$td, %1$tY %1$tl:%1$tM:%1$tS %1$Tp %2$s %4$s: %5$s%n java.util.logging.SimpleFormatter.format=%1$tY-%1$tm-%1$td %1$tH:%1$tM:%1$tS %4$s %2$s %5$s%6$s%n diff --git a/src/gr/phaistosnetworks/tank/TankResponse.java b/src/gr/phaistosnetworks/tank/TankResponse.java index 12d1a1e..6f8cdb6 100644 --- a/src/gr/phaistosnetworks/tank/TankResponse.java +++ b/src/gr/phaistosnetworks/tank/TankResponse.java @@ -1,6 +1,7 @@ package gr.phaistosnetworks.tank; import java.util.ArrayList; +import java.util.List; /** * Response data per partition / topic combo. @@ -26,7 +27,7 @@ void addMessage(TankMessage message) { /** * Returns the messages. */ - public ArrayList getMessages() { + public List getMessages() { return messages; } @@ -99,7 +100,7 @@ public long getNextSeqId() { } } - private ArrayList messages; + private List messages; private String topic; private long partition = 0L; private boolean hasError = false;