Okanjo / okanjo-app-queue / 12 / 1
100%
master: 100%

DEFAULT BRANCH: master
Ran
Files 3
Run time 0s
Badge
Embed ▾
README BADGES
x

If you need to use a raster PNG badge, change the '.svg' to '.png' in the link

Markdown

Textile

RDoc

HTML

Rst
coverage: 16.0% (-84.0%) from 100.0%
12.1

push

travis-ci

kfitzgerald 
Rewrite using Rascal as our underlying driver

# Breaking Changes
 * Underlying driver has changed from forked-version of postwait's `amqp` to rascal/amqplib
 * Queue configuration has changed, see rascal's configuration scheme
 * QueueService
   * constructor no longer takes `queues` param, this is setup in the rascal config
   * `queues` property has been removed
   * `connect` is now an async function (no more callback)
   * many internal member functions have been removed
 * QueueWorker
   * constructor option `queueName` is now `subscriptionName`
   * constructor requires option `service` (instance of QueueService)
   * many internal members have been removed
   * `init` is now an async function (no more callback)
   * `subscribe` is now an async function (no more callback)
   * `onReady` has been removed
   * `onSubscribed` no longer has arguments
   * `onUnsubscribed` no longer has arguments
   * `onMessage` signature has changed to `(message, content, ackOrNack)`
   * `onMessageHandled` has been removed
   * `handleMessage` signature has changed to `(message, content, ackOrNack)`
   * `onServiceError` has been removed
 * BatchQueueWorker
   * option `batchSize` now translates to a prefetch of (batchSize * 2), so Async.Cargo can optimally deliver the desired batch size to the app.
   * `handleMessageBatch` has changed signature to (messages, defaultAckOrNack)
     * Messages are wrapped, and can be individually acknowledged via `messages[i].ackOrNack(...)`. Likewise, `defaultAckOrNAck(...)` will handle the remaining messages in the batch.
   * `onMessage` signature has changed to `(message, content, ackOrNack)`
   * `onMessageHandled` has been removed
   * `prepareForShutdown` override has been removed

Other notable changes:

 * QueueService
   * Vastly simplified logic, 40% reduction in code thanks to Rascal taking on error handling and recovery
   * `publish` returns a promise, callback is optional.
   * Added `QueueService.generateConfigFro... (continued)

20 of 125 relevant lines covered (16.0%)

0.32 hits per line

Source Files on job 12.1