Skip to main content

ZMQSink

Publishes metadata on a ZMQ socket.

This module contains the ZMQ sink. It is responsible for connecting to a ZMQ socket, and publishing the metadata. Depending on the configuration of the connected sources and pipeline elements the metadata may contain an encoded JPEG image, or a presentation timestamp for synchronizing the MP4 Proxy Stream.

For a detailed description, please refer to: Data Publishing Endpoint (PUB-SUB) in the ZMQ API.

For a detailed example, please refer to Subscriber Example.

Examples:

REST API:

WIP

Configuration File:

Publish all channels:

sink:
- address: tcp://*:22952
- filter: []
- type: zmq

Publish channels 1 and 2:
```yaml
sink:
- address: tcp://*:22952
- filter: [1,2]
- type: zmq

ZMQSink Objects

class ZMQSink(SinkNode)

Publishes metadata on a ZMQ socket.

Attributes:

  • sink_address str - The address of the ZMQ socket.
  • sink_filter function - A function that filters the metadata.

Examples:

sink = ZMQSink("tcp://*:22952", lambda x: True)