hiqdev / asset-packagist

    public $tableName = '{{%queue}}';

    public $tableOptions = 'CHARACTER SET utf8 COLLATE utf8_unicode_ci ENGINE=InnoDB';

    public function up()

    {

        $this->createTable($this->tableName, [

            'id' => $this->primaryKey(),

            'channel' => $this->string()->notNull(),

            'job' => $this->binary()->notNull(),

            'created_at' => $this->integer()->notNull(),

            'started_at' => $this->integer(),

            'finished_at' => $this->integer(),

        ], $this->tableOptions);

        $this->createIndex('channel', $this->tableName, 'channel');

        $this->createIndex('started_at', $this->tableName, 'started_at');

    }

    public function down()

    {

        $this->createIndex('priority', $this->tableName, 'priority');

    }

    public function down()

    {

        $this->dropTable($this->tableName);

        $this->createTable($this->tableName, [

            'id' => $this->primaryKey(),

            'channel' => $this->string()->notNull(),

            'job' => $this->binary()->notNull(),

            'created_at' => $this->integer()->notNull(),

            'started_at' => $this->integer(),

            'finished_at' => $this->integer(),

        ]);

        $this->createIndex('channel', $this->tableName, 'channel');

        $this->createIndex('started_at', $this->tableName, 'started_at');

    }

}