Connectors

Messaging & Event Streaming

NATS

Lightweight cloud messaging: publish, subscribe, and request-reply on subjects and JetStream
NATS API referenceAPI checked August 18, 2026
Signs in with
Connection details
Runs on
Cloud or On-Prem Worker
Operations
45
Ready-made triggers
0

Connect NATS

  1. In Neblex open Connect › Connections and click New Connection.
  2. Search for NATS and give the connection a clear name.
  3. Fill in the fields. Secret values are encrypted and never shown again.
  4. Click Test, then Create Connection.
If the system is only reachable inside your network, choose an On-Prem Worker under Test from and run the flow on that Worker. See On-Prem Workers.
FieldWhat to enter
Connection setupRequired
HostRequired
PortOptionalExample: 4222
UsernameOptionalOptional NATS user name. With no password this is transported as token authentication by the deployed runtime.
PasswordOptionalSecret
Use TLSOptionalTurning this off sends traffic and credentials without transport encryption. Use plaintext only for a customer-controlled endpoint that explicitly requires it.
Connection stringRequiredSecretPaste a root-only nats:// or tls:// URL. The deployed runtime supports one broker, anonymous/token/user-password authentication, and no path/query/fragment.

Use it in a flow

  1. Open a flow, open the node library and search for NATS.
  2. Drag it onto the canvas and choose an Operation and your connection.
  3. Map the operation's fields from earlier steps, or click Map with Matt.
  4. Use Test this step to see what it returns, then save.

To start a flow from NATS without a ready-made trigger: a Live stream trigger with NATS as the stream source starts a run for each message as it arrives (see Streaming triggers).

Operations

45 operations in 7 groups. Each one is a step you can add to a flow.

Connection1
Test the connectionpingComplete a guarded NATS request/reply round trip.
Consumers7
Create consumercreate_consumerCreate a pull or push consumer from the official consumer config.
Delete consumerdelete_consumerDelete a consumer.
Get consumerget_consumerGet consumer configuration and delivery state.
List consumerslist_consumersList consumers for a stream with a bounded result count.
Pause consumerpause_consumerPause message delivery until the requested deadline.
Resume consumerresume_consumerResume a paused consumer.
Update consumerupdate_consumerUpdate an existing pull or push consumer.
Core3
PublishpublishPublish one Core NATS message.
RequestrequestRequest one reply with bounded timeout.
Request manyrequest_manyCollect multiple replies until timeout or the response limit.
JetStream2
Account infoget_account_infoGet JetStream account usage and limits.
Publishjs_publishPublish persistently and wait for the JetStream acknowledgement.
Key Value13
Create bucketcreate_kv_bucketCreate a JetStream Key Value bucket.
Create valuekv_createCreate a value only when the key does not exist.
Delete bucketdelete_kv_bucketDelete a Key Value bucket.
Delete valuekv_deleteDelete a key, optionally at an expected revision.
Get bucketget_kv_bucketGet Key Value bucket status.
Get valuekv_getGet the current value and revision.
List bucketslist_kv_bucketsList Key Value buckets with a bounded result count.
List keyskv_keysList bucket keys with a bounded result count.
Purge valuekv_purgePurge a key and its history, optionally at an expected revision.
Put valuekv_putPut a value and return its revision.
Update bucketupdate_kv_bucketUpdate a Key Value bucket configuration.
Update valuekv_updateCompare-and-set a value at an expected revision.
Value historykv_historyList bounded history for a key.
Object Store11
Create bucketcreate_object_bucketCreate a JetStream Object Store bucket.
Delete bucketdelete_object_bucketDelete an Object Store bucket.
Delete objectobject_deleteDelete an object.
Get bucketget_object_bucketGet Object Store bucket status.
Get objectobject_getDownload a bounded object and its metadata.
Get object infoobject_infoGet object metadata without downloading its content.
List bucketslist_object_bucketsList Object Store buckets with a bounded result count.
List objectsobject_listList object metadata with a bounded result count.
Put objectobject_putUpload a bounded object and return its metadata.
Seal bucketobject_sealSeal an Object Store bucket against further writes.
Update metadataobject_update_metadataUpdate object name, description, headers, or metadata.
Streams8
Create streamcreate_streamCreate a stream; fail if it already exists.
Delete messagedelete_stream_messageDelete a stored message by sequence.
Delete streamdelete_streamDelete a stream.
Get messageget_stream_messageGet a stored message by sequence or subject selector.
Get streamget_streamGet stream configuration and state.
List streamslist_streamsList stream configurations and states with a bounded result count.
Purge streampurge_streamPurge all or a filtered subset of stream messages.
Update streamupdate_streamUpdate an existing stream configuration.