Merge Connector

Overview

The Merge connector combines payloads from multiple sources using different strategies.

Connector Type: MeddleMerge

Timed Release Mode

Release combined data at regular intervals:

{
  "type": "MeddleMerge",
  "config": {
    "mode": "TimedRelease",
    "releaseInterval": 5000
  }
}

Collects data for 5 seconds, then releases combined payload.

Wait For Keys Mode

Wait until all required keys are present:

{
  "type": "MeddleMerge",
  "config": {
    "mode": "WaitForKeys",
    "requiredKeys": ["temperature", "pressure", "humidity"],
    "timeout": 10000
  }
}

Waits for all three keys, releases when complete or after 10 seconds.

Example

Input Stream:

{"temperature": 25.5}
{"pressure": 101.3}
{"humidity": 60}

Output (WaitForKeys):

{
  "temperature": 25.5,
  "pressure": 101.3,
  "humidity": 60
}

Configuration Parameters

mode: TimedRelease or WaitForKeys
releaseInterval: (TimedRelease) Interval in milliseconds
requiredKeys: (WaitForKeys) Array of required keys
timeout: (WaitForKeys) Maximum wait time in milliseconds
maxRetained: (Optional) Maximum payloads to retain in memory

Use Cases

Synchronize multiple sensors reading at different rates
Batch data from high-frequency sources
Combine related measurements from different systems

Best Practices

Set appropriate maxRetained to limit memory usage
Use timeout to handle missing data
Consider data freshness when using TimedRelease

Cron - Schedule-based release
Conveyor - Simple routing