Skip to content

Commit 980a386

Browse files
xavifrdereuromark
authored andcommitted
Add datasource connection (app_queue option) to queue tables. (dereuromark#156)
Add datasource connection (app_queue option) to queue tables.
1 parent 955bdd4 commit 980a386

File tree

3 files changed

+31
-0
lines changed

3 files changed

+31
-0
lines changed

config/app_queue.php

+3
Original file line numberDiff line numberDiff line change
@@ -36,5 +36,8 @@
3636

3737
// set default Mailer class
3838
'mailerClass' => 'Cake\Mailer\Email',
39+
40+
// set default datasource connection
41+
'connection' => null,
3942
],
4043
];

src/Model/Table/QueueProcessesTable.php

+14
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,20 @@
2121
*/
2222
class QueueProcessesTable extends Table {
2323

24+
/**
25+
* set connection name
26+
*
27+
* @return string
28+
*/
29+
public static function defaultConnectionName() {
30+
$connection = Configure::read('Queue.connection');
31+
if (!empty($connection)) {
32+
return $connection;
33+
};
34+
35+
return parent::defaultConnectionName();
36+
}
37+
2438
/**
2539
* Initialize method
2640
*

src/Model/Table/QueuedJobsTable.php

+14
Original file line numberDiff line numberDiff line change
@@ -53,6 +53,20 @@ class QueuedJobsTable extends Table {
5353
*/
5454
protected $_key = null;
5555

56+
/**
57+
* set connection name
58+
*
59+
* @return string
60+
*/
61+
public static function defaultConnectionName() {
62+
$connection = Configure::read('Queue.connection');
63+
if (!empty($connection)) {
64+
return $connection;
65+
};
66+
67+
return parent::defaultConnectionName();
68+
}
69+
5670
/**
5771
* initialize Table
5872
*

0 commit comments

Comments
 (0)