File tree Expand file tree Collapse file tree 3 files changed +6
-5
lines changed
src/gr/phaistosnetworks/tank Expand file tree Collapse file tree 3 files changed +6
-5
lines changed Original file line number Diff line number Diff line change @@ -91,7 +91,7 @@ public static void main(String[] args) throws Exception {
91
91
System .out .println ("Error, topic " + tr .getTopic () + " does not exist !" );
92
92
} else if (tr .getError () == TankClient .ERROR_NO_SUCH_PARTITION ) {
93
93
System .out .println (
94
- "Error, topic " + tr .getTopic () + " doe not have a partition " + tr .getPartition ());
94
+ "Error, topic " + tr .getTopic () + " does not have a partition " + tr .getPartition ());
95
95
} else {
96
96
System .out .println (
97
97
"Unknown error for topic: " + tr .getTopic () + " partition: " + tr .getPartition ());
@@ -110,7 +110,7 @@ public static void main(String[] args) throws Exception {
110
110
response = tc .consume (consume );
111
111
consume = new TankRequest (TankClient .CONSUME_REQ );
112
112
for (TankResponse tr : response ) {
113
- System .out .println ("topic: " + tr .getTopic () + " partition: " + tr .getPartition ());
113
+ // System.out.println("topic: " + tr.getTopic() + " partition: " + tr.getPartition());
114
114
for (TankMessage tm : tr .getMessages ()) {
115
115
System .out .println ("seq: " + tm .getSeqId ()
116
116
+ " ts: " + tm .getTimestamp ()
Original file line number Diff line number Diff line change 1
1
handlers = java.util.logging.ConsoleHandler
2
2
.level = ALL
3
- java.util.logging.ConsoleHandler.level = FINE
3
+ java.util.logging.ConsoleHandler.level = INFO
4
4
# 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
5
5
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
Original file line number Diff line number Diff line change 1
1
package gr .phaistosnetworks .tank ;
2
2
3
3
import java .util .ArrayList ;
4
+ import java .util .List ;
4
5
5
6
/**
6
7
* Response data per partition / topic combo.
@@ -26,7 +27,7 @@ void addMessage(TankMessage message) {
26
27
/**
27
28
* Returns the messages.
28
29
*/
29
- public ArrayList <TankMessage > getMessages () {
30
+ public List <TankMessage > getMessages () {
30
31
return messages ;
31
32
}
32
33
@@ -99,7 +100,7 @@ public long getNextSeqId() {
99
100
}
100
101
}
101
102
102
- private ArrayList <TankMessage > messages ;
103
+ private List <TankMessage > messages ;
103
104
private String topic ;
104
105
private long partition = 0L ;
105
106
private boolean hasError = false ;
You can’t perform that action at this time.
0 commit comments