Skip to content

Commit 2d7b220

Browse files
committed
Merge remote-tracking branch 'origin/AC-11673' into Hammer_248beta1_Scope03072024
2 parents 35278d5 + 730e570 commit 2d7b220

File tree

2 files changed

+5
-13
lines changed

2 files changed

+5
-13
lines changed

lib/internal/Magento/Framework/Amqp/Connection/Factory.php

Lines changed: 1 addition & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -38,15 +38,7 @@ public function create(FactoryOptions $options): AbstractConnection
3838
$parameters['ssl_options'] = $options->getSslOptions() !== null
3939
? $options->getSslOptions()
4040
: ['verify_peer' => true];
41-
return ObjectManager::getInstance()->create($connectionType, $parameters);
4241
}
43-
// need to revert the changes in scope of this ticket - AC-11673
44-
return new AMQPStreamConnection(
45-
$parameters['host'],
46-
$parameters['port'],
47-
$parameters['user'],
48-
$parameters['password'],
49-
$parameters['vhost']
50-
);
42+
return ObjectManager::getInstance()->create($connectionType, $parameters);
5143
}
5244
}

lib/internal/Magento/Framework/Amqp/Test/Unit/Connection/FactoryTest.php

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -121,10 +121,10 @@ public static function connectionDataProvider()
121121
'ssl_enabled' => true,
122122
'connection_class' => AMQPSSLConnection::class,
123123
],
124-
// [ // Need to revert in scope of this ticket - AC-11673
125-
// 'ssl_enabled' => false,
126-
// 'connection_class' => AMQPStreamConnection::class,
127-
// ],
124+
[
125+
'ssl_enabled' => false,
126+
'connection_class' => AMQPStreamConnection::class,
127+
],
128128
];
129129
}
130130

0 commit comments

Comments
 (0)