Best practice of initializing a queue (producer only)

[stefan-g]

I have 2 different instances. One instance produces jobs and one consumes it. It does only work correct when i register the queue manually by the manager. Is that the way how it should be?

@log4j2
@service
public class RQueueMessageService {

private final RqueueMessageEnqueuer rqueueMessageEnqueuer;
private final RqueueEndpointManager manager;

public RQueueMessageService(final RqueueMessageEnqueuer rqueueMessageEnqueuer, final RqueueEndpointManager manager) {
this.rqueueMessageEnqueuer = rqueueMessageEnqueuer;
this.manager = manager;
this.manager.registerQueue("import-job");
}

public void createJOB(ImportMessage message) {
rqueueMessageEnqueuer.enqueueWithRetry("import-job", message,3);
}

}

[sonus21]

Hi @stefan-g
Which version of Rqueue do you have?
In this doc, we've explained a different way to use it, https://sonus21.github.io/rqueue/producer-consumer

If you're using the same application code for producer and consumer in that case you don't have to call register queue method.

You can just rqueue.scheduler.enabled=false and rqueue.system.mode=PRODUCER in the producer application instance. In consumer you can let it be default behaviour.

A sample test app

rqueue/rqueue-spring-boot-starter/src/test/java/com/github/sonus21/rqueue/spring/boot/tests/integration/ProducerOnlyTest.java

Line 53 in a8cb236

@TestPropertySource(properties = {"rqueue.system.mode=PRODUCER"})