GetSender returns the singleton sender.

InitKafkaSender constructs the singleton instance of a messagesender using the kafka transport.

NewKafkaMessageSender creates and configures a Sender that uses a compact kafka topic as its transport.

NewKafkaReceiver creates a new instance of the messagereceiver.

ShutdownKafkaSender stops the kafka producer and unsets the singleton.

KafkaMessageReceiver consumes messages from the configured 'messagetopic'.

KafkaMessageSender is a message Sender for Kafka.

Message is a single message to be delivered to a source or node.

Receiver receives messages using the configured transport.

Sender sends messages using the configured transport.

NotificationFunc is the method used to send a new message to all sources / nodes that accept it.