connection stuff

This commit is contained in:
2021-03-30 20:44:29 +09:00
parent 3c1278db82
commit 38176274ff
12 changed files with 12 additions and 47 deletions

View File

@@ -48,7 +48,7 @@ class PurgeUsersJob implements ShouldQueue
*/
public function __construct()
{
//
$this->connection = 'redis';
}
/**

View File

@@ -16,11 +16,6 @@ class ItemPricesUpdateJob implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
/**
* The queue connection that should handle the job
*/
public $connection = 'queue';
/**
* Create a new job instance.
*
@@ -28,7 +23,7 @@ class ItemPricesUpdateJob implements ShouldQueue
*/
public function __construct()
{
//
$this->connection = 'redis';
}
/**

View File

@@ -29,11 +29,6 @@ class ProcessSendEveMailJob implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
/**
* The queue connection that should handle the job
*/
public $connection = 'queue';
/**
* Retries
* With new rate limiting, we need a retry basis versus timeout basis
@@ -54,7 +49,7 @@ class ProcessSendEveMailJob implements ShouldQueue
*/
public function __construct($body, $recipient, $recipient_type, $subject, $sender) {
//Set the connection
//$this->connection = 'redis';
$this->connection = 'redis';
//Set the middleware for the job
$this->middleware = $this->middleware();

View File

@@ -28,11 +28,6 @@ class ProcessSendEveMailJobRL implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
/**
* The queue connection that should handle the job
*/
public $connection = 'queue';
/**
* Timeout in seconds
* With new rate limiting, we shouldn't use this timeout
@@ -60,7 +55,7 @@ class ProcessSendEveMailJobRL implements ShouldQueue
*/
public function __construct($body, $recipient, $recipient_type, $subject, $sender) {
//Set the connection
//$this->connection = 'redis';
$this->connection = 'redis';

View File

@@ -42,7 +42,7 @@ class UpdateAllianceWalletJournalJob implements ShouldQueue
*/
public function __construct()
{
//
$this->connection = 'redis';
}
/**

View File

@@ -35,7 +35,7 @@ class UpdateItemPricesJob implements ShouldQueue
*/
public function __construct()
{
//
$this->connection = 'redis';
}
/**

View File

@@ -31,11 +31,6 @@ class FetchMiningTaxesLedgersJob implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
/**
* The queue connection that should handle the job
*/
public $connection = 'queue';
/**
* Timeout in seconds
*
@@ -65,7 +60,7 @@ class FetchMiningTaxesLedgersJob implements ShouldQueue
public function __construct($charId, $corpId, $observerId)
{
//Set the connection for the job
//$this->connection = 'redis';
$this->connection = 'redis';
//Import the variables from the calling function
$this->charId = $charId;

View File

@@ -41,7 +41,7 @@ class FetchMiningTaxesObserversJob implements ShouldQueue
*/
public function __construct()
{
//
$this->connection = 'redis';
}
/**

View File

@@ -23,11 +23,6 @@ class ProcessMiningTaxesLedgersJob implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
/**
* The queue connection that should handle the job
*/
public $connection = 'queue';
/**
* Timeout in seconds
*
@@ -56,7 +51,7 @@ class ProcessMiningTaxesLedgersJob implements ShouldQueue
public function __construct($ledger, $observerId)
{
//Set the connection for the job
//$this->connection = 'redis';
$this->connection = 'redis';
//Import variables from the calling function
$this->ledger = $ledger;

View File

@@ -23,11 +23,6 @@ class ProcessMiningTaxesPaymentsJob implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
/**
* The queue connection that should handle the job
*/
public $connection = 'queue';
/**
* Create a new job instance.
*
@@ -35,7 +30,7 @@ class ProcessMiningTaxesPaymentsJob implements ShouldQueue
*/
public function __construct()
{
//$this->connection = 'redis';
$this->connection = 'redis';
}
/**

View File

@@ -48,7 +48,7 @@ class SendMiningTaxesInvoicesJob implements ShouldQueue
*/
public function __construct()
{
//
$this->connection = 'redis';
}
/**

View File

@@ -24,11 +24,6 @@ class EndSupplyChainContractJob implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
/**
* The queue connection that should handle the job
*/
public $connection = 'queue';
/**
* Timeout in seconds
*
@@ -64,7 +59,7 @@ class EndSupplyChainContractJob implements ShouldQueue
public function __construct(SupplyChainContract $contract)
{
//Set the queue connection up
//$this->connection = 'redis';
$this->connection = 'redis';
//Set the variables
$contractId = $contract->contract_id;