diff --git a/schbrain-canal-client/src/main/java/com/schbrain/canal/client/transfer/AbstractBasicMessageTransponder.java b/schbrain-canal-client/src/main/java/com/schbrain/canal/client/transfer/AbstractBasicMessageTransponder.java index 2d7c73a5771f41bf11f934f129a7e87aa4421ed0..518c5821f709c5d9d4a8917179982c8da95bac24 100644 --- a/schbrain-canal-client/src/main/java/com/schbrain/canal/client/transfer/AbstractBasicMessageTransponder.java +++ b/schbrain-canal-client/src/main/java/com/schbrain/canal/client/transfer/AbstractBasicMessageTransponder.java @@ -154,9 +154,11 @@ public abstract class AbstractBasicMessageTransponder extends AbstractMessageTra Object[] args = getInvokeArgs(method,header,eventType, rowData); method.invoke(point.getTarget(), args); } catch (Exception e) { - log.error("{}: Error occurred when invoke the listener's interface! class:{}, method:{}", - Thread.currentThread().getName(), - point.getTarget().getClass().getName(), method.getName()); + String message = String.format("%s: Error occurred when invoke the listener's interface! class:%s, method:%s" + ,Thread.currentThread().getName() + ,point.getTarget().getClass().getName() + ,method.getName()); + log.error(message,e); } })); }