From e1cf34dc43564551ace8d2564abbcd775cedc41c Mon Sep 17 00:00:00 2001
From: Gunnar Morling <gunnar.morling@googlemail.com>
Date: Tue, 3 Jul 2018 13:40:45 +0200
Subject: [PATCH] DBZ-713 Extracting constaint for expected exception message

---
 .../main/java/io/debezium/connector/mongodb/Replicator.java  | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/Replicator.java b/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/Replicator.java
index 7185a6719..a526d517f 100644
--- a/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/Replicator.java
+++ b/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/Replicator.java
@@ -86,6 +86,9 @@
 public class Replicator {
 
     private final Logger logger = LoggerFactory.getLogger(getClass());
+
+    private static final String AUTHORIZATION_FAILURE_MESSAGE = "Command failed with error 13";
+
     private final MongoDbTaskContext context;
     private final ExecutorService copyThreads;
     private final ReplicaSet replicaSet;
@@ -168,7 +171,7 @@ protected boolean establishConnectionToPrimary() {
                 context.filters(),
                 (desc, error) -> {
                     // propagate authorization failures
-                    if (error.getMessage() != null && error.getMessage().startsWith("Command failed with error 13")) {
+                    if (error.getMessage() != null && error.getMessage().startsWith(AUTHORIZATION_FAILURE_MESSAGE)) {
                         throw new ConnectException("Error while attempting to " + desc, error);
                     }
                     else {