StreamPersister

StreamPersister is a JMS message consumer that persists the content of messages to an OutputStream. StreamPersister supports flow control and allows object control from its owner. It is fault tolerant with retry and idle options.

StreamPersister supports various types of stream based destinations, in terms of the scheme such as tcp, comm or file. The operations of write, request and echo are supported. For example, it can be used to persist messages to a serial port.

Apart from the common properties, there are many implementation specific properties for StreamPersister.
Property Name Data Type Requirement Description Examples
Template string optional template for the content ##body##

Here is an example of StreamPersister:

{
  "Name": "pstr_serial",
  "ClassName": "org.qbroker.persister.StreamPersister",
  "URI": "comm:///dev/term/b",
  "Device": "/dev/term/b",
  "LinkName": "stream",
  "Operation": "write",
  "XAMode": "1",
  "BaudRate": "9600",
  "DataBits": "8",
  "StopBits": "1",
  "Parity": "None",
  "DisplayMask": "4"
}