@imqueueRPC enqueued!
intro docs blog
commercial ↗ $ npm i -g @imqueue/cli
intro docs blog commercial ↗
theme
$ npm i -g @imqueue/cli
@imqueue/pg-pubsub v3.0.5 · API reference
Classes
NoLock PgIpLock PgPubSub
Functions
channel(payload) close() connect() enableGracefulShutdown() end() error(err) listen(channels) message(chan, payload) notify(chan, payload) pack(input, logger, pretty) reconnect(retries) signature(processId, channel, payload) unlisten(channels) unpack(input, logger)
Interfaces
AnyLock AnyLogger JsonMap PgClient PgPubSubOptions
Variables
ACQUIRE_INTERVAL DefaultOptions EXECUTION_LOCK IS_ONE_PROCESS RETRY_DELAY RETRY_LIMIT RX_LOCK_CHANNEL SCHEMA_NAME SHUTDOWN_TIMEOUT UNIQUE_LOCK_TTL
Type Aliases
AnyJson JsonArray
Home/API reference/@imqueue/pg-pubsub/DefaultOptions

DefaultOptions variable

Hard-coded pre-set of PgPubSubOptions

Signature:

DefaultOptions: PgPubSubOptions

Read this page as plain markdown — no HTML, no navigation. For pasting into an LLM, or for an agent to fetch.

@imqueue

RPC over an inter-communication messaging queue. For TypeScript & NodeJS back-ends. Friendly to AI assistants.

Docs

Get started Tutorial CLI API MCP

Packages

@imqueue/cli ↗ @imqueue/rpc ↗ @imqueue/core ↗ @imqueue/mcp ↗ Other ↗

Project

GitHub ↗ Sandbox ↗ Contributing License Commercial ↗

Legal

Privacy Policy Terms Of UseSupport ContactCookie settings
@imqueue open source · GPL-3.0 Need a commercial license? imqueue.com ↗

Cookies We'd like to measure how these docs are used. Nothing runs and nothing is stored unless you allow it, you can change your mind any time, and we never sell or share your data. Privacy · Terms · Support