dk.tbsalling.aismessages.nmea

Class NMEAMessageHandler

java.lang.Object

dk.tbsalling.aismessages.nmea.NMEAMessageHandler

All Implemented Interfaces:

java.util.function.Consumer<NMEAMessage>

public class NMEAMessageHandler
extends Object
implements java.util.function.Consumer<NMEAMessage>

This class receives NMEA messages containing armoured and encoded AIS strings. An AIS message can span several NMEA messages. Whenever a complete AIS message is observed in the input, an AISMessage is constructed and passed on to all registered receivers of encoded AIS messages.

Author:

tbsalling

Constructor Summary

Constructors

Constructor and Description
NMEAMessageHandler(String source, java.util.function.Consumer<? super AISMessage>... aisMessageReceivers)

Method Summary

Modifier and Type	Method and Description
void	accept(NMEAMessage nmeaMessage) Receive a single NMEA amoured AIS string
void	addAisMessageReceiver(java.util.function.Consumer<? super AISMessage> aisMessageReceiver) Add a consumer of encoded AIS messages.
ArrayList<NMEAMessage>	flush() Empty buffer of unhandled messages and return those not handled.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.Consumer

andThen

Constructor Detail

NMEAMessageHandler

public NMEAMessageHandler(String source,
                          java.util.function.Consumer<? super AISMessage>... aisMessageReceivers)

Method Detail

accept

public void accept(NMEAMessage nmeaMessage)

Receive a single NMEA amoured AIS string

Specified by:

accept in interface java.util.function.Consumer<NMEAMessage>

Parameters:

nmeaMessage - the NMEAMessage to handle.

addAisMessageReceiver

public void addAisMessageReceiver(java.util.function.Consumer<? super AISMessage> aisMessageReceiver)

Add a consumer of encoded AIS messages.

Parameters:

aisMessageReceiver - The consumer to add.

flush

public ArrayList<NMEAMessage> flush()

Empty buffer of unhandled messages and return those not handled.

Returns:

List of unhandled NMEAMessages.