And ability to define how many messages can be hanle by the redis worker before stopping (usefull for tests)