User Tools

Site Tools


data_core:msmqeventsourcesink

MSMQ Event Source/Sink

Overview

Data Core can read and write Alarm & Event (A&E) data from Microsoft message queues. This can be used for temporary data caching when configuring resilient data flows.

For example, imagine a Data Core Node is responsible for subscribing to A&E data from an ephemeral data source such as a serial printer feed, then sending it to a downstream server. Introducing an intermediate message queue will protect us from data loss if the downstream network connection is interupted.

Getting Started

1. Enable MSMQ on Windows Server

Enable Message Queuing Services via Server Features.

2. Create Queue(s)

Create a queue using Computer Management.

NB. Data Core can only communicate with private queues on the local server.

3. Queue Config

We recommend configuring transactional queues with an explicit storage capacity.

If “Authenticated” is selected and Data Core is running under a service account, then the service account must have send/receive/delete security privileges.

4. Configure an Event Sink

A Microsoft Message Queue Event Sink will write any messages arriving on an event subscription flow to a MSMQ.

The key settings are listed under Message Queue Settings. Configure these to reference your local queue with equivalent properties.

5. Configure an Event Source

A Microsoft Message Queue Event Source reads messages from the MSMQ and relays to downstream subscribers. Note that the message will only be removed from the queue if all subscribers respond with a successful acknowledgement, therefore we recommended one event sink subscription per MSMQ event source.

The key settings are listed under Message Queue Settings. Configure these to reference your local queue.

data_core/msmqeventsourcesink.txt · Last modified: 2022/04/18 11:37 by su