-type QueueParam = { activities: Activity[], signatureActor?: MActorSignature, inboxActor?: MActorDefault }
-const inboxQueue = queue<QueueParam, Error>((task, cb) => {
- const options = { signatureActor: task.signatureActor, inboxActor: task.inboxActor }
-
- processActivities(task.activities, options)
- .then(() => cb())
- .catch(err => {
- logger.error('Error in process activities.', { err })
- cb()
- })
-})
-