Provides support to run multi-node clusters of JWorkflow, by providing a distributed shared work queue.
<dependencies>
<dependency>
<groupId>net.jworkflow</groupId>
<artifactId>jworkflow.providers.rabbitmq</artifactId>
<version>0.5-SNAPSHOT</version>
</dependency>
</dependencies>
dependencies {
compile 'net.jworkflow:jworkflow.providers.rabbitmq:0.5-SNAPSHOT'
}
import com.rabbitmq.client.ConnectionFactory;
import net.jworkflow.providers.rabbitmq.RabbitMQProvider;
...
WorkflowModule module = new WorkflowModule();
ConnectionFactory cf = new ConnectionFactory();
cf.setUsername("guest");
cf.setPassword("guest");
cf.setVirtualHost("/");
cf.setHost("localhost");
cf.setPort(5672);
module.useQueue(new RabbitMQProvider(cf));
module.build();
WorkflowHost host = module.getHost();