diff options
Diffstat (limited to 'lib/input/replStream.cpp')
| -rw-r--r-- | lib/input/replStream.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/lib/input/replStream.cpp b/lib/input/replStream.cpp index 1ec696a..90f26d6 100644 --- a/lib/input/replStream.cpp +++ b/lib/input/replStream.cpp @@ -30,7 +30,7 @@ namespace MyGrate::Input { mariadb_rpl_optionsv(rpl.get(), MARIADB_RPL_START, position); mariadb_rpl_optionsv(rpl.get(), MARIADB_RPL_FLAGS, MARIADB_RPL_BINLOG_SEND_ANNOTATE_ROWS); - verify<std::runtime_error>(!mariadb_rpl_open(rpl.get()), "Failed to mariadb_rpl_open"); + verify<MySQLErr>(!mariadb_rpl_open(rpl.get()), "Failed to mariadb_rpl_open", this); while (MyGrate::MariaDB_Event_Ptr event {mariadb_rpl_fetch(rpl.get(), nullptr), &mariadb_free_rpl_event}) { position = event->next_event_pos; |