<commit_before>mqemitter&nbsp;&nbsp;[![Build Status](https://travis-ci.org/mcollina/mqemitter.png)](https://travis-ci.org/mcollina/mqemitter)
=================================================================

An Opinionated Message Queue with an emitter-style API, but with
callbacks.

  * <a href="#install">Installation</a>
  * <a href="#basic">Basic Example</a>
  * <a href="#api">API</a>
  * <a href="#contributing">Contributing</a>
  * <a href="#licence">Licence &amp; copyright</a>

<a name="install"></a>
## Installation

```
$ npm install mqemitter --save
```

<a name="basic"></a>
## Basic Example

```js
var mq = require('mqemitter')
  , emitter = mq({ concurrency: 5 })
  , message

emitter.on('hello world', function(message, cb) {
  // call callback when you are done
  // do not pass any errors, the emitter cannot handle it.
  cb()
})

// topic is mandatory<commit_msg>Little readme fix.<commit_after>mqemitter&nbsp;&nbsp;[![Build Status](https://travis-ci.org/mcollina/mqemitter.png)](https://travis-ci.org/mcollina/mqemitter)
=================================================================

An Opinionated Message Queue with an emitter-style API, but with
callbacks.

  * <a href="#install">Installation</a>
  * <a href="#basic">Basic Example</a>
  * <a href="#api">API</a>
  * <a href="#wildcards">Wildcards</a>
  * <a href="#licence">Licence &amp; copyright</a>

<a name="install"></a>
## Installation

```
$ npm install mqemitter --save
```

<a name="basic"></a>
## Basic Example

```js
var mq = require('mqemitter')
  , emitter = mq({ concurrency: 5 })
  , message

emitter.on('hello world', function(message, cb) {
  // call callback when you are done
  // do not pass any errors, the emitter cannot handle it.
  cb()
})

// topic is mandatory
{'fraction_non_alphanumeric': 0.2461799660441426, 'fraction_numerical': 0.0011318619128466328, 'mean_word_length': 4.815789473684211, 'pattern_counts': {'":': 0, '<': 31, '<?xml version=': 0, '>': 31, 'https://': 4, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '431602', 'n_tokens_mistral': 609, 'n_tokens_neox': 565, 'n_words': 143}