Hi, I'm setting my producer up using new P

<a class="user-mention notranslate" data-hovercard-type="user" data-hovercard-url="/us

<a class="user-mention notranslate" data-hovercard-type="user" data-hover

Producer & Consumer seem to be ignoring config about redis-smq HOT 6 CLOSED

franzwarning commented on September 28, 2024

Producer & Consumer seem to be ignoring config

from redis-smq.

Comments (6)

weyoss commented on September 28, 2024

@franzwarning Thank you for opening this issue.

Are you using the latest release candidate (7.0.0-rc.6)?

from redis-smq.

franzwarning commented on September 28, 2024

@franzwarning Thank you for opening this issue.

Are you using the latest release candidate (7.0.0-rc.6)?

Yes

from redis-smq.

weyoss commented on September 28, 2024

You have probably something wrong with your setup.

Please provide an example to reproduce your issue.

I have just verified that consumers and producers do not ignore the provided configuration.

Check this out.

import { Consumer } from 'redis-smq';
import { logger } from 'redis-smq-common';
import { RedisClientName } from 'redis-smq-common/dist/types'

logger.setLogger(console);

const consumer = new Consumer({
    redis: {
        client: RedisClientName.REDIS,
        options: {
            host: '127.0.0.199' // <--- wrong host
        }
    },
    logger: {
        enabled: true,
    }
});
consumer.run();

Outputs:

$ node dist/index.js

[consumer:247d0cd7-20f6-4508-9bdd-38b893b5debd] Going up...
node:events:498
      throw er; // Unhandled 'error' event
      ^

Error: connect ECONNREFUSED 127.0.0.199:6379
    at TCPConnectWrap.afterConnect [as oncomplete] (node:net:1157:16)
Emitted 'error' event on RedisClient instance at:
    at RedisClient.on_error (/test-redis-smq/node_modules/redis-smq-common/node_modules/redis/index.js:342:14)
    at Socket.<anonymous> (/test-redis-smq/node_modules/redis-smq-common/node_modules/redis/index.js:223:14)
    at Socket.emit (node:events:520:28)
    at emitErrorNT (node:internal/streams/destroy:157:8)
    at emitErrorCloseNT (node:internal/streams/destroy:122:3)
    at processTicksAndRejections (node:internal/process/task_queues:83:21) {
  errno: -111,
  code: 'ECONNREFUSED',
  syscall: 'connect',
  address: '127.0.0.199',
  port: 6379
}

from redis-smq.

weyoss commented on September 28, 2024

Also the config is not ignored when using RedisClientName.IOREDIS client.

$ node dist/index.js
[consumer:95c36796-f86c-437b-bae5-3f689e1652a7] Going up...
[ioredis] Unhandled error event: Error: connect ECONNREFUSED 127.0.0.199:6379
    at TCPConnectWrap.afterConnect [as oncomplete] (node:net:1157:16)
[ioredis] Unhandled error event: Error: connect ECONNREFUSED 127.0.0.199:6379
    at TCPConnectWrap.afterConnect [as oncomplete] (node:net:1157:16)
...

from redis-smq.

weyoss commented on September 28, 2024

Closing as irrelevant.

from redis-smq.

Recommend Projects