@@ -73,7 +73,9 @@ void initialize(PositionImpl position, Map<String, Long> properties, VoidCallbac
73
73
recoverFromCursorPosition (pos );
74
74
callback .operationComplete ();
75
75
}).exceptionally (throwable -> {
76
- callback .operationFailed (ManagedLedgerException .getManagedLedgerException (throwable ));
76
+ String errMsg = String .format ("[%s] initialize cursor %s failed." , ledger .getName (), name );
77
+ log .error (errMsg , throwable );
78
+ callback .operationFailed (new ManagedLedgerException (errMsg , throwable ));
77
79
return null ;
78
80
});
79
81
}
@@ -111,8 +113,9 @@ void recover(VoidCallback callback) {
111
113
recoverFromCursorPosition (positionInfo );
112
114
callback .operationComplete ();
113
115
}).exceptionally (throwable -> {
114
- //TODO opt define this exception.
115
- callback .operationFailed (new ManagedLedgerException (throwable ));
116
+ String errMsg = String .format ("[%s] recover existing cursor %s failed" , ledger .getName (), name );
117
+ log .error (errMsg , throwable );
118
+ callback .operationFailed (new ManagedLedgerException (errMsg , throwable ));
116
119
return null ;
117
120
});
118
121
}
@@ -174,8 +177,7 @@ protected void persistPosition(MarkDeleteEntry mdEntry, VoidCallback callback) {
174
177
.thenRun (callback ::operationComplete )
175
178
.exceptionally (throwable -> {
176
179
callback .operationFailed (
177
- new ManagedLedgerException ("Persist position to remote writer broker failed." ,
178
- throwable ));
180
+ new ManagedLedgerException ("Persist position to remote writer broker failed." , throwable ));
179
181
return null ;
180
182
});
181
183
}
0 commit comments