diff --git a/src/plans.js b/src/plans.js index 0b809f6..67b903f 100644 --- a/src/plans.js +++ b/src/plans.js @@ -224,7 +224,7 @@ function getPartitionFunction (schema) { return ` CREATE FUNCTION ${schema}.get_partition(queue_name text, out name text) AS $$ - SELECT 'j' || left(regexp_replace(queue_name, '\\W', '', 'g'),10) || left(encode(sha224(queue_name::bytea), 'hex'),10); + SELECT 'j' || lower(left(regexp_replace(queue_name, '\\W', '', 'g'),10)) || left(encode(sha224(queue_name::bytea), 'hex'),10); $$ LANGUAGE SQL IMMUTABLE diff --git a/test/publishTest.js b/test/publishTest.js index 7fa156f..8496aa0 100644 --- a/test/publishTest.js +++ b/test/publishTest.js @@ -80,8 +80,8 @@ describe('pubsub', function () { it('should use subscriptions to map to more than one queue', async function () { const boss = this.test.boss = await helper.start({ ...this.test.bossConfig, noDefault: true }) - const queue1 = 'queue1' - const queue2 = 'queue2' + const queue1 = 'subqueue1' + const queue2 = 'subqueue2' await boss.createQueue(queue1) await boss.createQueue(queue2)