packages feed

message-db-temp-0.0.1.0: official-message-db-upstream/test/_controls/write-message-correlated.sh

function write-message-correlated {
  local stream_name=${1:-$(stream-name)}
  local instances=${2:-1}
  local correlation_stream_name=${3:-"someCorrelation"}

  if [ ! -z ${CORRELATION+x} ]; then
    correlation_stream_name=$CORRELATION
  fi

  metadata="'{\"correlationStreamName\": \"$correlation_stream_name\"}'"

  METADATA=$metadata STREAM_NAME=$stream_name INSTANCES=$instances database/write-test-message.sh > /dev/null
}