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 9
9
use Magento \Framework \Amqp \Connection \FactoryOptions ;
10
10
use Magento \Framework \App \DeploymentConfig ;
11
11
use Magento \Framework \App \ObjectManager ;
12
+ use Magento \Framework \ObjectManager \ResetAfterRequestInterface ;
12
13
use PhpAmqpLib \Channel \AMQPChannel ;
13
14
use PhpAmqpLib \Connection \AbstractConnection ;
14
15
18
19
* @api
19
20
* @since 103.0.0
20
21
*/
21
- class Config
22
+ class Config implements ResetAfterRequestInterface
22
23
{
23
24
/**
24
25
* Queue config key
@@ -123,6 +124,14 @@ public function __destruct()
123
124
}
124
125
}
125
126
127
+ /**
128
+ * @inheritDoc
129
+ */
130
+ public function _resetState (): void
131
+ {
132
+ $ this ->closeConnection ();
133
+ }
134
+
126
135
/**
127
136
* Returns the configuration set for the key.
128
137
*
You can’t perform that action at this time.
0 commit comments