utopia_queue 0.2.0

Light and easy to use queue library for Dart server projects

example/utopia_queue_example.dart

import 'package:utopia_queue/utopia_queue.dart';

void main(List<String> arguments) async {
  final connection = ConnectionRedis('localhost', 6379);
  final Server server = Server(connection, queue: 'myqueue');

  server.job().inject('message').action((Message message) {
    print(message.toMap());
  });
  server.start(threads: 2);
}