![\"Adonis](\"https://user-images.githubusercontent.com/16545335/71373449-f2146880-2595-11ea-8a8c-9f51384a3f22.png\")
\n\n A Bull provider for the Adonis framework. \n Adonis Bull provides an easy way to start using Bull. The fastest, most reliable, Redis-based queue for Node.\n
\n\n## Install\n\nYARN\n\n```\nyarn add @rocketseat/adonis-bull\n```\n\nNPM\n\n```\nnpm install @rocketseat/adonis-bull\n```\n\n\n## Setup\n\n`node ace invoke @ashokgelal/adonis-bull`\n\n## Use\n\nAdd the config file at `config/bull.ts`:\n\n```ts\nimport Env from '@ioc:Adonis/Core/Env'\nimport { BullConfig } from '@ioc:Rocketseat/Bull'\n\n\nconst bullConfig: BullConfig = {\n connection: Env.get('BULL_CONNECTION', 'bull'),\n connections: {\n bull: {\n \t host: Env.get('BULL_REDIS_HOST'),\n \t port: Env.get('BULL_REDIS_PORT'),\n \t password: Env.get('BULL_REDIS_PASSWORD', ''),\n \t db: 0,\n \t keyPrefix: '',\n },\n }\n}\n\nexport default bullConfig\n```\n\nIn the above file you can define redis connections, there you can pass all `Bull` queue configurations described [here](https://github.com/OptimalBits/bull/blob/develop/REFERENCE.md#queue).\n\n\nCreate a file with the `jobs` that will be processed at `start/jobs.ts`:\n\n```ts\nconst jobs = [\"App/Jobs/UserRegisterEmail\"]\n\nexport default jobs\n```\n\nOr use the magic way, it will declare all jobs for you:\n\n```ts\nimport { listDirectoryFiles } from '@adonisjs/ace'\nimport Application from '@ioc:Adonis/Core/Application'\nimport { join } from 'path'\n\n/*\n|--------------------------------------------------------------------------\n| Exporting an array of jobs\n|--------------------------------------------------------------------------\n|\n| Instead of manually exporting each file from the app/Jobs directory, we\n| use the helper `listDirectoryFiles` to recursively collect and export\n| an array of filenames.\n*/\nconst jobs = listDirectoryFiles(\n join(Application.appRoot, 'app/Jobs'),\n Application.appRoot\n).map((name) => {\n return name\n .replace(/^\\.\\/app\\/Jobs\\//, 'App/Jobs/')\n .replace(/\\.(?:t|j)s$/, '')\n})\n\nexport default jobs\n```\n\nCreate a new preload file by executing the following ace command.\n\n```bash\nnode ace make:prldfile bull\n\n# ✔ create start/bull.ts\n```\n\n```js\nimport Bull from '@ioc:Rocketseat/Bull'\n\nBull.process()\n // Optionally you can start BullBoard:\n .ui(9999); // http://localhost:9999\n // You don't need to specify the port, the default number is 9999\n```\n\n## Creating your job\n\nCreate a new job file by executing the following ace command.\n\n```bash\nnode ace make:job userRegisterEmail\n\n# ✔ create app/Jobs/UserRegisterEmail.ts\n```\n\n```ts\nimport { JobContract } from '@ioc:Rocketseat/Bull'\nimport Mail from '@ioc:Adonis/Addons/Mail'\n\nexport default class UserRegisterEmail implements JobContract {\n public key = 'UserRegisterEmail'\n\n public async handle(job) {\n const { data } = job; // the 'data' variable has user data\n\n await Mail.send(\"emails.welcome\", data, message => {\n message\n .to(data.email)\n .from(\" \n\n A Bull provider for the Adonis framework. \n Adonis Bull provides an easy way to start using Bull. The fastest, most reliable, Redis-based queue for Node.\n
\n\n## Install\n\nYARN\n\n```\nyarn add @rocketseat/adonis-bull\n```\n\nNPM\n\n```\nnpm install @rocketseat/adonis-bull\n```\n\n\n## Setup\n\n`node ace invoke @ashokgelal/adonis-bull`\n\n## Use\n\nAdd the config file at `config/bull.ts`:\n\n```ts\nimport Env from '@ioc:Adonis/Core/Env'\nimport { BullConfig } from '@ioc:Rocketseat/Bull'\n\n\nconst bullConfig: BullConfig = {\n connection: Env.get('BULL_CONNECTION', 'bull'),\n connections: {\n bull: {\n \t host: Env.get('BULL_REDIS_HOST'),\n \t port: Env.get('BULL_REDIS_PORT'),\n \t password: Env.get('BULL_REDIS_PASSWORD', ''),\n \t db: 0,\n \t keyPrefix: '',\n },\n }\n}\n\nexport default bullConfig\n```\n\nIn the above file you can define redis connections, there you can pass all `Bull` queue configurations described [here](https://github.com/OptimalBits/bull/blob/develop/REFERENCE.md#queue).\n\n\nCreate a file with the `jobs` that will be processed at `start/jobs.ts`:\n\n```ts\nconst jobs = [\"App/Jobs/UserRegisterEmail\"]\n\nexport default jobs\n```\n\nOr use the magic way, it will declare all jobs for you:\n\n```ts\nimport { listDirectoryFiles } from '@adonisjs/ace'\nimport Application from '@ioc:Adonis/Core/Application'\nimport { join } from 'path'\n\n/*\n|--------------------------------------------------------------------------\n| Exporting an array of jobs\n|--------------------------------------------------------------------------\n|\n| Instead of manually exporting each file from the app/Jobs directory, we\n| use the helper `listDirectoryFiles` to recursively collect and export\n| an array of filenames.\n*/\nconst jobs = listDirectoryFiles(\n join(Application.appRoot, 'app/Jobs'),\n Application.appRoot\n).map((name) => {\n return name\n .replace(/^\\.\\/app\\/Jobs\\//, 'App/Jobs/')\n .replace(/\\.(?:t|j)s$/, '')\n})\n\nexport default jobs\n```\n\nCreate a new preload file by executing the following ace command.\n\n```bash\nnode ace make:prldfile bull\n\n# ✔ create start/bull.ts\n```\n\n```js\nimport Bull from '@ioc:Rocketseat/Bull'\n\nBull.process()\n// Optionally you can start BullBoard:\nBull.ui(9999); // http://localhost:9999\n// You don't need to specify the port, the default number is 9999\n```\n\n## Creating your job\n\nCreate a new job file by executing the following ace command.\n\n```bash\nnode ace make:job userRegisterEmail\n\n# ✔ create app/Jobs/UserRegisterEmail.ts\n```\n\n```ts\nimport { JobContract } from '@ioc:Rocketseat/Bull'\nimport Mail from '@ioc:Adonis/Addons/Mail'\n\nexport default class UserRegisterEmail implements JobContract {\n public key = 'UserRegisterEmail'\n\n public async handle(job) {\n const { data } = job; // the 'data' variable has user data\n\n await Mail.send(\"emails.welcome\", data, message => {\n message\n .to(data.email)\n .from(\"