org.eclipse.kapua.gateway.client

Interface Data

All Superinterfaces:

Sender<Exception>

All Known Implementing Classes:

AbstractData

public interface Data
extends Sender<Exception>

An interface for control data

An instance of this is bound to a topic and can be looked up by a call to Application.data(Topic).

Method Summary

Modifier and Type	Method and Description
default void	subscribe(MessageHandler handler) Receive messages on this data topic
void	subscribe(MessageHandler handler, ErrorHandler<? extends Throwable> errorHandler) Receive messages and handle reception errors on this data topic

Methods inherited from interface org.eclipse.kapua.gateway.client.Sender

errors, send, send

Method Detail

subscribe

default void subscribe(MessageHandler handler)
                throws Exception

Receive messages on this data topic

Subscriptions will automatically be re-established after a connection loss.

Parameters:

handler - the handler which should process received messages

Throws:

Exception - if anything goes wrong on the subscription process

subscribe

void subscribe(MessageHandler handler,
               ErrorHandler<? extends Throwable> errorHandler)
        throws Exception

Receive messages and handle reception errors on this data topic

Subscriptions will automatically be re-established after a connection loss.

Parameters:

handler - the handler which should process received messages

errorHandler - the handler which should process received messages which got received but could not be properly parsed

Throws:

Exception - if anything goes wrong on the subscription process