org.eclipse.kapua.gateway.client.spi

Class AbstractData

java.lang.Object

org.eclipse.kapua.gateway.client.spi.AbstractData

All Implemented Interfaces:

Data, Sender<Exception>

public class AbstractData
extends Object
implements Data

Constructor Summary

Constructors

Constructor and Description
AbstractData(AbstractApplication application, Topic topic)

Method Summary

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

Methods inherited from class java.lang.Object

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

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

subscribe

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

errors, send

Constructor Detail

AbstractData

public AbstractData(AbstractApplication application,
                    Topic topic)

Method Detail

send

public void send(Payload payload)
          throws Exception

Specified by:

send in interface Sender<Exception>

Throws:

Exception

subscribe

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

Description copied from interface: Data

Receive messages and handle reception errors on this data topic

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

Specified by:

subscribe in interface Data

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