Skip to content

Commit a449609

Browse files
author
chengyitian
committed
AJ-949: modify some logs out from 'System' to 'log';
1 parent 5733b35 commit a449609

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/com/xxdb/streaming/client/cep/EventClient.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ public void subscribe(String host, int port, String tableName, String actionName
4747

4848
BlockingQueue<List<IMessage>> queue = subscribeInternal(host, port, tableName, actionName, handler, offset, reconnect, filter, null, false, userName, password, false);
4949
if (queue == null) {
50-
System.err.println("Subscription already made, handler loop not created.");
50+
log.error("Subscription already made, handler loop not created.");
5151
return;
5252
}
5353

@@ -75,7 +75,7 @@ public void subscribe(String host, int port, String tableName, String actionName
7575

7676
// todo notice, here MessageParser handled col to row;
7777
if (!eventHandler.deserializeEvent(msgs, eventTypes, attributes, errorInfo)) {
78-
System.out.println("deserialize fail " + errorInfo.getErrorInfo());
78+
log.error("deserialize fail " + errorInfo.getErrorInfo());
7979
continue;
8080
}
8181

0 commit comments

Comments
 (0)