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 = worksmithvar workflow =
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 = worksmithvar workflow =
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.