+ public void deleteMessages(final long sequenceNumber) {
+ // no-op
+ }
+
+ @Override
+ public long getLastSequenceNumber() {
+ return -1;
+ }
+
+ @SuppressWarnings("checkstyle:IllegalCatch")
+ static <T> void invokeProcedure(final Procedure<T> procedure, final T argument) {
+ try {
+ procedure.apply(argument);
+ } catch (Exception e) {
+ LOG.error("An unexpected error occurred", e);
+ }