[Questions] Create Exchange pgsql_listen_worker failure (sock_closed)

[tantonj]

Community Support Policy

• I have read RabbitMQ's Community Support Policy
• I run RabbitMQ 4.x, the only series currently covered by community support
• I promise to provide all relevant information (versions, logs from all nodes, rabbitmq-diagnostics output, detailed reproduction steps)

RabbitMQ version used

4.1.2

Erlang version used

27.3.x

Operating system (distribution) used

Windows Server 2019

How is RabbitMQ deployed?

Windows installer

rabbitmq-diagnostics status output

See https://www.rabbitmq.com/docs/cli to learn how to use rabbitmq-diagnostics

Status of node rabbit@WIN-QGOPUJ0C8BE ...
Runtime

OS PID: 4872
OS: Windows
Uptime (seconds): 6263
Is under maintenance?: false
RabbitMQ version: 4.1.4
RabbitMQ release series support status: see https://www.rabbitmq.com/release-information
Node name: rabbit@WIN-QGOPUJ0C8BE
Erlang configuration: Erlang/OTP 27 [erts-15.2.7.2] [source] [64-bit] [smp:24:24] [ds:24:24:10] [async-threads:1] [jit:ns]
Crypto library: OpenSSL 3.1.0 14 Mar 2023
Erlang processes: 454 used, 1048576 limit
Scheduler run queue: 1
Cluster heartbeat timeout (net_ticktime): 60

Plugins

Enabled plugin file: c:/Users/jtanton/AppData/Roaming/RabbitMQ/enabled_plugins
Enabled plugins:

 * listen-pg-exchange
 * epgsql
 * rabbitmq_management
 * rabbitmq_management_agent
 * rabbitmq_web_dispatch
 * amqp_client
 * cowboy
 * oauth2_client
 * jose

Data directory

Node data directory: c:/Users/jtanton/AppData/Roaming/RabbitMQ/db/rabbit@WIN-QGOPUJ0C8BE-mnesia
Raft data directory: c:/Users/jtanton/AppData/Roaming/RabbitMQ/db/rabbit@WIN-QGOPUJ0C8BE-mnesia/quorum/rabbit@WIN-QGOPUJ0C8BE

Config files

 * c:/Users/jtanton/AppData/Roaming/RabbitMQ/advanced.config

Log file(s)

 * <stdout>
 * c:/Users/jtanton/AppData/Roaming/RabbitMQ/log/rabbit@WIN-QGOPUJ0C8BE.log

Alarms

(none)

Tags

(none)

Memory

Total memory used: 0.1189 gb
Calculation strategy: rss
Memory high watermark setting: 0.6 of available memory, computed to: 33.1985 gb

allocated_unused: 0.0309 gb (25.97 %)
other_system: 0.0287 gb (24.18 %)
other_proc: 0.0257 gb (21.61 %)
code: 0.0241 gb (20.25 %)
metrics: 0.0028 gb (2.32 %)
reserved_unallocated: 0.0021 gb (1.76 %)
binary: 0.0013 gb (1.12 %)
atom: 0.0011 gb (0.95 %)
plugins: 0.0009 gb (0.74 %)
msg_index: 0.0005 gb (0.41 %)
other_ets: 0.0004 gb (0.31 %)
metadata_store: 0.0002 gb (0.17 %)
mgmt_db: 0.0002 gb (0.15 %)
mnesia: 0.0001 gb (0.06 %)
quorum_ets: 0.0 gb (0.01 %)
metadata_store_ets: 0.0 gb (0.0 %)
connection_other: 0.0 gb (0.0 %)
quorum_queue_procs: 0.0 gb (0.0 %)
quorum_queue_dlx_procs: 0.0 gb (0.0 %)
stream_queue_procs: 0.0 gb (0.0 %)
stream_queue_replica_reader_procs: 0.0 gb (0.0 %)
connection_readers: 0.0 gb (0.0 %)
connection_writers: 0.0 gb (0.0 %)
connection_channels: 0.0 gb (0.0 %)
queue_procs: 0.0 gb (0.0 %)
stream_queue_coordinator_procs: 0.0 gb (0.0 %)

File Descriptors

Total: 0, limit: 65439

Free Disk Space

Low free disk space watermark: 0.05 gb
Free disk space: 59.9711 gb

Totals

Connection count: 0
Queue count: 0
Virtual host count: 1

Listeners

Interface: [::], port: 15672, protocol: http, purpose: HTTP API
Interface: [::], port: 25672, protocol: clustering, purpose: inter-node and CLI tool communication
Interface: [::], port: 5672, protocol: amqp, purpose: AMQP 0-9-1 and AMQP 1.0
Interface: 0.0.0.0, port: 5672, protocol: amqp, purpose: AMQP 0-9-1 and AMQP 1.0

Logs from node 1 (with sensitive values edited out)

See https://www.rabbitmq.com/docs/logging to learn how to collect logs

2025-09-24 15:51:50.115000-04:00 [warning] <0.1816.0> Declare exchange error: pgsql_listen_worker failure (sock_closed)
2025-09-24 15:51:50.114000-04:00 [error] <0.1817.0> ** Generic server <0.1817.0> terminating
2025-09-24 15:51:50.114000-04:00 [error] <0.1817.0> ** Last message in was {tcp_closed,#Port<0.127>}
2025-09-24 15:51:50.114000-04:00 [error] <0.1817.0> ** When Server state == {state,gen_tcp,undefined,<<>>,undefined,on_message,
2025-09-24 15:51:50.114000-04:00 [error] <0.1817.0>                                undefined,
2025-09-24 15:51:50.114000-04:00 [error] <0.1817.0>                                {[],[]},
2025-09-24 15:51:50.114000-04:00 [error] <0.1817.0>                                undefined,undefined,undefined,<0.1440.0>,[],
2025-09-24 15:51:50.114000-04:00 [error] <0.1817.0>                                information_redacted,[],undefined,undefined,
2025-09-24 15:51:50.114000-04:00 [error] <0.1817.0>                                undefined,undefined,
2025-09-24 15:51:50.114000-04:00 [error] <0.1817.0>                                #{timeout => 2500,async => <0.1440.0>,
2025-09-24 15:51:50.114000-04:00 [error] <0.1817.0>                                  port => 5432,host => "localhost",
2025-09-24 15:51:50.114000-04:00 [error] <0.1817.0>                                  database => "VCR"}}
2025-09-24 15:51:50.114000-04:00 [error] <0.1817.0> ** Reason for termination ==
2025-09-24 15:51:50.114000-04:00 [error] <0.1817.0> ** sock_closed
2025-09-24 15:51:50.114000-04:00 [error] <0.1817.0> 
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>   crasher:
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>     initial call: epgsql_sock:init/1
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>     pid: <0.1817.0>
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>     registered_name: []
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>     exception exit: sock_closed
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>       in function  gen_server:handle_common_reply/8 (gen_server.erl, line 2476)
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>     ancestors: [pgsql_listen_worker,pgsql_listen_sup,rabbit_sup,<0.207.0>]
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>     message_queue_len: 0
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>     messages: []
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>     links: [<0.1440.0>]
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>     dictionary: []
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>     trap_exit: false
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>     status: running
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>     heap_size: 6772
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>     stack_size: 29
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>     reductions: 12697
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>   neighbours:
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>     neighbour:
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>       pid: <0.1440.0>
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>       registered_name: pgsql_listen_worker
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>       initial call: pgsql_listen_worker:init/1
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>       current_function: {gen_server,loop,7}
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>       ancestors: [pgsql_listen_sup,rabbit_sup,<0.207.0>]
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>       message_queue_len: 0
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>       links: [<0.470.0>,<0.1817.0>]
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>       trap_exit: false
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>       status: waiting
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>       heap_size: 987
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>       stack_size: 11
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>       reductions: 390
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>       current_stacktrace: [{gen_server,loop,7,[{file,"gen_server.erl"},{line,2250}]},
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>                   {proc_lib,init_p_do_apply,3,
2025-09-24 15:51:50.117000-04:00 [error] <0.1817.0>                             [{file,"proc_lib.erl"},{line,329}]}]
2025-09-24 15:51:50.119000-04:00 [error] <0.470.0>     supervisor: {local,pgsql_listen_sup}
2025-09-24 15:51:50.119000-04:00 [error] <0.470.0>     errorContext: child_terminated
2025-09-24 15:51:50.119000-04:00 [error] <0.470.0>     reason: sock_closed
2025-09-24 15:51:50.119000-04:00 [error] <0.470.0>     offender: [{pid,<0.1440.0>},
2025-09-24 15:51:50.119000-04:00 [error] <0.470.0>                {id,pgsql_listen_worker},
2025-09-24 15:51:50.119000-04:00 [error] <0.470.0>                {mfargs,{pgsql_listen_worker,start_link,[]}},
2025-09-24 15:51:50.119000-04:00 [error] <0.470.0>                {restart_type,permanent},
2025-09-24 15:51:50.119000-04:00 [error] <0.470.0>                {significant,false},
2025-09-24 15:51:50.119000-04:00 [error] <0.470.0>                {shutdown,5000},
2025-09-24 15:51:50.119000-04:00 [error] <0.470.0>                {child_type,worker}]
2025-09-24 15:51:50.119000-04:00 [error] <0.470.0> 

Logs from node 2 (if applicable, with sensitive values edited out)

See https://www.rabbitmq.com/docs/logging to learn how to collect logs

# PASTE LOG HERE, BETWEEN BACKTICKS

Logs from node 3 (if applicable, with sensitive values edited out)

See https://www.rabbitmq.com/docs/logging to learn how to collect logs

rabbitmq.conf

See https://www.rabbitmq.com/docs/configure#config-location to learn how to find rabbitmq.conf file location

This file does not exist in the APPDATA, only the advanced config file does

Steps to deploy RabbitMQ cluster

• Installed Erlang windows installer.
• Installed RabbitMQ windows installer.
• Use sbin console to enable plugin rabbitmq_management
• Restart RabbitMQ service

Steps to reproduce the behavior in question

tldr; When I first created this question I thought I was not able to make any exchanges (edits have been made). I now see it is specific to the plugin. The plugin I am trying to use is this one here https://github.com/anshmain/listen-pg-exchange it was updated to support a newer version of RabbitMQ than the original author's branch. However it still isn't made for my version of RabbitMQ, it enables fine but it's dependency is not detected as an available plugin and does not get enabled when enabling it. I'm guessing the dependency (which actually connects with postgresql) is not properly enabled and so the connection always fails. If anybody has experience with this kind of thing, help is appreciated. But I'm guessing this in the wrong repo to ask this question.

Replication 1

• Navigate to Management UI
• Login as guest administrator account
• Navigate to Exchanges tab
• Dropdown Add a new exchange
• Fill in Name and select Type x-pgsql-listen
• Press Add Exchange
• Receive Dialog "pgsql_listen_worker failure (sock_closed)

Replication 2

• Navigate to Admin Tab
• Add User with Admin tag and username/password
• Edit User
• Set permissions for '/' as .* .* .*
• Logout of guest
• Login as new user
• Repeat replication steps 1
• Receive same results

Replication 3

• Install and launch Postman
• Setup a PUT request to localhost:15672/api/exchanges/%2F/{exchange_name}
• Set appropriate payload
• Set Basic auth with either guest or other user
• Send request. Receive same results as previous replications

Replication 4

• Using Administrator UI Add again using Arguments
• Filled out all necessary arguments same results occur
• Check log file, correct database, port, and host shows in log (user and pass do not)

You can see in the logs above what happens when attempting to create the exchange.

Please note that erlang cookie is synchronized properly. I don't understand why I cannot create an exchange, it makes no sense. Any help here would be GREATLY appreciated

advanced.config

See https://www.rabbitmq.com/docs/configure#config-location to learn how to find advanced.config file location

[{pgsql_listen_exchange,
  [
    {host, "localhost"},
    {port, 5432},
    {dbname, "dbname"},
    {user, "postgres"},
    {password, "password"}
  ]}
].

Application code

# PASTE CODE HERE, BETWEEN BACKTICKS

Kubernetes deployment file

# Relevant parts of K8S deployment that demonstrate how RabbitMQ is deployed
# PASTE YAML HERE, BETWEEN BACKTICKS

What problem are you trying to solve?

I'm trying to create an exchange of x-pgsql-listen type to receive NOTIFY updates from postgresql

[lukebakken]

The plugin I am trying to use is this one here https://github.com/anshmain/listen-pg-exchange ... But I'm guessing this in the wrong repo to ask this question.

anshmain/listen-pg-exchange#1