local queue_name = ARGV[1];
local partition  = ARGV[2];
local message = ARGV[3];

local queue_key = 'rrq:queue:' .. queue_name .. ':' .. partition;
local partitions_for_queue_key = 'rrq:queue:' .. queue_name .. ':all_partitions';
local added_partition = redis.call('sadd', partitions_for_queue_key, partition);

if added_partition == 1 then
  local active_partitions_key = 'rrq:queue:' .. queue_name .. ':active_partitions';
  redis.call('lpush', active_partitions_key, partition);
  redis.call('sadd', 'rrq:queues', queue_name);
end

redis.call('lpush', queue_key, message);
return { 1, false };