#codec #tokio #transport #message #protocol #super #tokio-codec

hl7-mllp-codec

A Tokio codec for HL7 Minimal Lower Layer Message Transport protocol (MLLP)

6 releases

0.0.6 Nov 29, 2019
0.0.5 Nov 10, 2019

31 downloads per month

MIT license

13KB
171 lines

A HL7 MLLP Codec for Tokio

This is a tokio play project, implementing support for HL7 Minimal Lower Layer Message Transport protocol (MLLP) within a tokio codec.

Latest version Documentation

Run an example listener at 127.0.0.1:8080 by cargo r --release --example listener, or run an example publisher using cargo r --release --example publisher

Docs are available as usual from cargo doc --lib --open


lib.rs:

A tokio codec implementation for the HL7 MLLP network protocol.

HL7's MLLP is a simple, single-byte-text based protocol for framing HL7 messages over a TCP (or similar) transport. The full specification is available at the HL7 site (Note that they place the standards behind a free membership/login form).

This crate provides a Codec implementation that encodes/decodes MLLP frames from a Tokio stream, allowing simple programmatic access to the messages (both primary and ack/nack).

Tokio (and the rust async ecosystem) is currently in a state of flux, however there are two simple (not production ready!) examples in the source, of both a publisher and a listener. NB. These examples just write output to the console, and this can seriously limit throughput. If you want to run some simple perf tests with the samples, ensure you minimise the amount of data written out.

Example

This is a highly simplified example, lifted from the Examples included in source control.

Publisher

use bytes::*;
use tokio;
use tokio_util::codec::Framed;
use tokio::net::TcpStream;
use futures::{SinkExt, StreamExt};

use hl7_mllp_codec::MllpCodec;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
   	// Open a TCP stream to the socket address.
   	let stream = TcpStream::connect("127.0.0.1:8080").await?;

	// Construct a MLLP transport using our codec
   	let mut transport = Framed::new(stream, MllpCodec::new());

   	// Send some bytes wrapped in MLLP (Note: not a valid HL7 message)
   	transport.send(BytesMut::from("Hello World")).await?; //because this is through the codec it gets wrapped in MLLP header/footer for us

   	if let Some(response) = transport.next().await {
   		match response{
   			Ok(msg) => println!("  Received response: {:?}", msg),
   			Err(e) => println!("  ERROR: {:?}", e)
   		}
   	}

   Ok(())
}

Dependencies

~2MB
~33K SLoC