How to create a queue?

[Uttam92477]

I am getting the error com.github.sonus21.rqueue.exception.QueueDoesNotExist when attempting to write a message.
Using following code to insert a message when we call the endpoint. The controller is @RestController

if ("/test/rq".equals(request.getRequestURI())) {
response.setStatus(HttpStatus.OK.value());
response.getOutputStream().print("Sending action to queue" + RQueueTaskScheduler.scheduleAction());
return;
}

RQueueTaskScheduler.java

import com.github.sonus21.rqueue.core.RqueueMessageEnqueuer;

// import com.github.sonus21.rqueue.core.RqueueMessageEnqueuer;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

@Component
public class RQueueTaskScheduler {
  static final Logger logger = LoggerFactory.getLogger(RQueueTaskScheduler.class);

  // @Autowired
  private static RqueueMessageEnqueuer rqueueMessageEnqueuer;

  public RQueueTaskScheduler(RqueueMessageEnqueuer rqueueMessageEnqueuer) {
    RQueueTaskScheduler.rqueueMessageEnqueuer = rqueueMessageEnqueuer;
  }

  // @Value("${rqueue.action.queue.name:sv.actions.queue}")
  private static String sVActionsQueue = "sv.actions.queue";

  public static String scheduleAction() {
    logger.info("Scheduling action");
    return rqueueMessageEnqueuer.enqueueIn(sVActionsQueue, "Test message, yay", 10000);
  }

}

Configuration

    @Bean
    LettuceConnectionFactory lettuceConnectionFactory() {
        try {
            logger.error("Initializing Redis Cache");
            RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration(redisHostName,
                    redisPort);
            if (!("default".equals(redisPassword))) {
                redisStandaloneConfiguration.setPassword(redisPassword);
            }
            LettuceClientConfiguration lettuceClientConfiguration = LettuceClientConfiguration.builder()
                    .readFrom(ReadFrom.ANY).build();
            return new LettuceConnectionFactory(redisStandaloneConfiguration, lettuceClientConfiguration);
        } catch (Throwable e) {
            logger.error("Error while initializing Redis Cache", e);
        }
        return null;
    }

Any help is appreciated, feel free to ask for any further info.

Thank you.

[sonus21]

You're missing @RqueueListener annotated methods, Your configuration is incomplete, you can't push data without registering a queue, if you don't want to use listener method, than you can call RqueueEndpointManager.registerQueue( ...)

[Uttam92477]

Do we need @RqueueListener even when we want to just write to the queue?

[sonus21]

You can check example directory or https://github.com/sonus21/rqueue-task-executor

Also, see wiki page.

[Uttam92477]

Already went through the above repo @sonus21 . I wanted to know specifically, do we need to create a queue before writing into it? And, in the repo you mentioned, there is no Queue creation logic. In the rqueue-task-executor we are directly attempting to enqueue things into emailQueueName and invoiceQueueName without creating or registering, I am attempting the same.

[sonus21]

Yes, you need to create one before writing to it, you need to call rqueueEndpointManager.registerQueue once application has started.

[sonus21]

It will wipeout registered queue if you have not setup rqueue.system.mode=PRODUCER but again if you want to use listener as well than you need to just RqueueListener annotated components.