Use connection property for errors in message receiver.

SignalServiceKit/src/Messages/OWSMessageReceiver.m

@@ -380,12 +380,11 @@ NSString *const OWSMessageDecryptJobFinderExtensionGroup = @"OWSMessageProcessin
         OWSFailDebug(@"Could not parse proto.");
         // TODO: Add analytics.
 
-        [[OWSPrimaryStorage.sharedManager newDatabaseConnection]
+        [self.dbConnection readWriteWithBlock:^(YapDatabaseReadWriteTransaction *transaction) {
-            readWriteWithBlock:^(YapDatabaseReadWriteTransaction *transaction) {
+            TSErrorMessage *errorMessage = [TSErrorMessage corruptedMessageInUnknownThread];
-                TSErrorMessage *errorMessage = [TSErrorMessage corruptedMessageInUnknownThread];
+            [SSKEnvironment.shared.notificationsManager notifyUserForThreadlessErrorMessage:errorMessage
-                [SSKEnvironment.shared.notificationsManager notifyUserForThreadlessErrorMessage:errorMessage
+                                                                                transaction:transaction];
-                                                                                    transaction:transaction];
+        }];
-            }];
 
         dispatch_async(self.serialQueue, ^{
             completion(NO);