Skip to content

Commit a9d36c6

Browse files
Don't close the database when it is working
1 parent 91bd73b commit a9d36c6

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

README.md

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -128,12 +128,12 @@ return [
128128
'rabbitmq' => [
129129
// ...
130130
'on before_consume' => function ($event) {
131-
if (isset(\Yii::$app->db)) {
132-
$db = \Yii::$app->db;
133-
if ($db->getIsActive()) {
134-
$db->close();
131+
if (isset(\Yii::$app->db) && \Yii::$app->db->isActive) {
132+
try {
133+
Yii::$app->db->createCommand('SELECT 1')->query();
134+
} catch (\yii\db\Exception $exception) {
135+
Yii::$app->db->close();
135136
}
136-
$db->open();
137137
}
138138
},
139139
],

0 commit comments

Comments
 (0)