File tree Expand file tree Collapse file tree 1 file changed +10
-1
lines changed
lib/internal/Magento/Framework/Amqp Expand file tree Collapse file tree 1 file changed +10
-1
lines changed Original file line number Diff line number Diff line change 99use Magento \Framework \Amqp \Connection \FactoryOptions ;
1010use Magento \Framework \App \DeploymentConfig ;
1111use Magento \Framework \App \ObjectManager ;
12+ use Magento \Framework \ObjectManager \ResetAfterRequestInterface ;
1213use PhpAmqpLib \Channel \AMQPChannel ;
1314use PhpAmqpLib \Connection \AbstractConnection ;
1415
1819 * @api
1920 * @since 103.0.0
2021 */
21- class Config
22+ class Config implements ResetAfterRequestInterface
2223{
2324 /**
2425 * Queue config key
@@ -123,6 +124,14 @@ public function __destruct()
123124 }
124125 }
125126
127+ /**
128+ * @inheritDoc
129+ */
130+ public function _resetState (): void
131+ {
132+ $ this ->closeConnection ();
133+ }
134+
126135 /**
127136 * Returns the configuration set for the key.
128137 *
You can’t perform that action at this time.
0 commit comments