Database connection in Queue Component

[drjoju]

Hello,

I'm trying to add a database connection to Queue component. Something like:

$capsule = new Capsule;
$capsule->addConnection([
    'driver' =>'mysql',
    'host' => $dbhost,
    'database' => $dbname,
    'username' => $dbuname,
    'password' => $dbpass,
    'charset' => 'utf8',
    'collation' => 'utf8_unicode_ci',
    'prefix' => $prefix."_",
]);
$capsule->setAsGlobal();
$capsule->bootEloquent();


$container->instance("capsule", $capsule);

// Sistema de colas
$queue = new Queue();

$queue->addConnection([
    'driver' => 'sync',
]);
$queue->addConnection([
    'driver' => 'database',
    'table' => 'jobs',
    'queue' => 'default',
    'connection' => 'default',
    'host'      => 'localhost',
], 'database');

$manager = $queue->getQueueManager();
$container['queue'] = $manager;
$connection = Capsule::schema()->getConnection();
$resolver = new \Illuminate\Database\ConnectionResolver(['default' => $connection]);
$manager->addConnector('database', function () use ($resolver) {
    return new DatabaseConnector($resolver);
});
$queue->setAsGlobal();

I created the table like Laravel does. I'm trying to do the same as Laravel, that is,
WorklistOrderJob :: dispatch ($order);
with this code

$orden = Orden::where('idorden', 2015111100000000054)->first();
$queue->connection('database')->push('App\\Jobs\\WorklistOrderJob', $orden);

Where Orden is a Eloquent Model.

My goal is to insert in the database the instance of the model so another application in Laravel consumes the model inserted in the Jobs table.
I can see the model in the database but when I call

 php artisan queue:work --once

an error appears "Call to undefined method fire".

When I add fire method to the Job the database entrance is procesed.

public function fire()
    {
        $this->handle();
    }

Why fire thas not exists?
Laravel is in version 5.7 and I'm using Torch 5.5.
Incompatibilty problem?
Is it correct what I am saying?

Any suggestions or comments are welcomed.

Thanks in advance

[atefBB]

Hey @drjoju!
I have the same problem and I wonder how did you solve this issue?

[chamanrastogi]

use Illuminate\Database\Capsule\Manager as Capsule;
use Illuminate\Events\Dispatcher;
use Illuminate\Container\Container;
use Illuminate\Support\Facades\Facade;
$capsule = new Capsule;

$capsule->addConnection([
'driver' => DBDRIVER,
'host' => DB_SERVER,
'database' => DB_NAME,
'username' => DB_USER,
'password' => DB_PASS,
'charset' => 'utf8',
'collation' => 'utf8_unicode_ci',
'prefix' => PREFIX,
]);

// Set the event dispatcher used by Eloquent models... (optional)

$capsule->setEventDispatcher(new Dispatcher(new Container));

// Make this Capsule instance available globally via static methods... (optional)
$capsule->setAsGlobal();

// Setup the Eloquent ORM... (optional; unless you've used setEventDispatcher())
$capsule->bootEloquent();

$database = new Capsule();
$db = & $database;

---

Global $database;
$database->table('users')->where('votes', '>', 100)->get();
or you can make model
User::find(1)-get();