worksmith_rascal

Rascal activities for worksmith

This package contains the following activities/tasks:

name | description --- | --- publish | Publishes a message a rascal publication receiveOne | Receives a message from a rascal publication

publish activity

Publish as message to a rascal publication

params

name | type | description --- | --- | --- broker | Rascal Broker | Will look in context.broker if not specified publication | Publication id | Where to send the message payload | The payload to publish routingKey | Routing key to use when publishing the message. Will override the routing key defined in the publication options | Other publication options (see rascal documentation)

example

var worksmith = require('worksmith')
worksmith.use('rascal', require('worksmith_rascal'))
var workflow = worksmith({task:"sequence", items : [{
    task:'rascal/publish',
    broker: '@broker',
    publication: 'p1',
    payload: 'test message',
    resultTo: 'messageId'
}])

receiveOne activity

Receives exactly one message from a subscription within a given timeout. Causes an error if no message could be received.

When a message is received the result is { message: rabbitMsg, content: parsed<message.content> }

params

name | type | description --- | --- | --- broker | Rascal Broker | Will look in context.broker if not specified subscription | Subscription id | Rascal subscription name to receive from timeOut | milliseconds | amount of time to wait for a message options | Other subscription options (see rascal documentation)

example

var worksmith = require('worksmith')
worksmith.use('rascal', require('worksmith_rascal'))
var workflow = worksmith({task:"sequence", items : [{
    task:'rascal/receiveOne',
    broker: '@broker',
    subscription: 's1',
    resultTo: 'message'
}])

Running tests

You need an rabbitmq server running on localhost:5672 for the tests to pass. If you have docker and docker-compose installed simply run docker-compose up in the route of this project.