diff --git a/source/src/cip/appcontype.c b/source/src/cip/appcontype.c
index ab6042a0b..8b57fa90d 100644
--- a/source/src/cip/appcontype.c
+++ b/source/src/cip/appcontype.c
@@ -190,7 +190,7 @@ CipConnectionObject *GetExclusiveOwnerConnection(
       /* check if on other connection point with the same output assembly is currently connected */
       const CipConnectionObject *const exclusive_owner =
         GetConnectedOutputAssembly(
-          connection_object->produced_path.instance_id);
+          connection_object->consumed_path.instance_id);
       if ( NULL
            != exclusive_owner ) {
         if(kConnectionObjectStateEstablished ==
diff --git a/source/src/cip/cipconnectionmanager.c b/source/src/cip/cipconnectionmanager.c
index 5dc1f1fe5..8c7bf9fcc 100644
--- a/source/src/cip/cipconnectionmanager.c
+++ b/source/src/cip/cipconnectionmanager.c
@@ -1234,7 +1234,7 @@ CipConnectionObject *GetConnectedOutputAssembly(
            || kConnectionObjectStateTimedOut ==
            ConnectionObjectGetState(iterator->data) )
        && output_assembly_id ==
-       ( (CipConnectionObject *) iterator->data )->produced_path.instance_id) {
+       ( (CipConnectionObject *) iterator->data )->consumed_path.instance_id) {
       return iterator->data;
     }
     iterator = iterator->next;