Right now it's possible to communicate with queue as client in following way:
TarantoolClientConfig config = new TarantoolClientConfig();
config.username = "test";
config.password = "pass";
TarantoolClientImpl connection = new TarantoolClientImpl("host:port", config);
Future<?> task = connection.call("queue.tube.tubename:take");
Object taskId = task.get();
connection.call("queue.tube.tubename:ack", taskId);
But this is not really obvious and it defenetly would be better to create an interface that could manage those operations.
Right now it's possible to communicate with queue as client in following way:
But this is not really obvious and it defenetly would be better to create an interface that could manage those operations.