Publishers

Publishers are communication actions that send data to the system. Every publisher creates an Input in SessionData with its own name.

Table Property Path - Sessions[].Publishers[]

RabbitMq

Publishes messages to a RabbitMQ exchange or queue.

Table Property Path - Sessions[].Publishers[].RabbitMq

RabbitMq: {}

KafkaTopic

Publishes messages to a Kafka topic.

Table Property Path - Sessions[].Publishers[].KafkaTopic

KafkaTopic: {}

Redis

Publishes messages to a Redis cache.

Table Property Path - Sessions[].Publishers[].Redis

Redis: {}

Batch Publishing

Redis publisher uses batch publishing by default. When BatchSize is 1, it behaves like single-message publishing. When batch publishing is enabled, policies apply per batch rather than per message.

OracleSqlTable

Publishes messages to an Oracle SQL database table.

Table Property Path - Sessions[].Publishers[].OracleSqlTable

OracleSqlTable: {}

MsSqlTable

Publishes messages to an MS SQL database table.

Table Property Path - Sessions[].Publishers[].MsSqlTable

MsSqlTable: {}

PostgreSqlTable

Publishes messages to a PostgreSQL database table.

Table Property Path - Sessions[].Publishers[].PostgreSqlTable

PostgreSqlTable: {}

MongoDbCollection

Publishes documents to a MongoDB collection.

Table Property Path - Sessions[].Publishers[].MongoDbCollection

MongoDbCollection: {}

S3Bucket

Publishes messages to an S3 bucket.

Table Property Path - Sessions[].Publishers[].S3Bucket

S3Bucket: {}

ElasticIndex

Publishes documents to an Elasticsearch index.

Table Property Path - Sessions[].Publishers[].ElasticIndex

ElasticIndex: {}

ElasticSearch server timeout

When sending requests to the Elasticsearch server, remember that it can enforce its own request timeout. If increasing RequestTimeoutMilliseconds does not help, the server-side timeout may still be the limiting factor.

Socket

Publishes messages using a socket to a remote host.

Table Property Path - Sessions[].Publishers[].Socket

Socket: {}

Sftp

Publishes messages to a remote SFTP server.

Table Property Path - Sessions[].Publishers[].Sftp

Sftp: {}