org.kaaproject.kaa.client.notification

Class AbstractNotificationListener<T extends org.apache.avro.specific.SpecificRecordBase>

java.lang.Object

org.kaaproject.kaa.client.notification.AbstractNotificationListener<T>

All Implemented Interfaces:

NotificationListener

public abstract class AbstractNotificationListener<T extends org.apache.avro.specific.SpecificRecordBase>
extends Object
implements NotificationListener

Abstract listener for received notifications.

Responsible for processing notifications either on a specific topic or all at once.

// Assume, BasicNotification is a notification class auto-generated according to predefined Avro schema public class UserNotificationListener extends AbstractNotificationListener<BasicNotification> { \@Override protected Class<BasicNotification> getNotificationClass() { return BasicNotification.class; } \@Override public void onNotification(String topicId, BasicNotification notification) { System.out.println("Got notification: " + notification.toString()); } }

Author:

Yaroslav Zeygerman

Constructor Summary

Constructors

Constructor and Description
AbstractNotificationListener()

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract Class<T>	getNotificationClass() Retrieves the notification's class.
abstract void	onNotification(String topicId, T notification) Called on each received notification.
void	onNotificationRaw(String topicId, ByteBuffer notification) Convert raw Avro-encoded data to specific notification class according to predefined Avro schema.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractNotificationListener

public AbstractNotificationListener()

Method Detail

onNotificationRaw

public final void onNotificationRaw(String topicId,
                     ByteBuffer notification)
                             throws IOException

Convert raw Avro-encoded data to specific notification class according to predefined Avro schema.

Specified by:

onNotificationRaw in interface NotificationListener

Parameters:

topicId - Unique topic identifier

notification - Raw Avro-encoded data

Throws:

IOException

getNotificationClass

protected abstract Class<T> getNotificationClass()

Retrieves the notification's class.

Returns:

The notification's class object.

onNotification

public abstract void onNotification(String topicId,
                  T notification)

Called on each received notification.

Parameters:

topicId - Unique topic identifier

notification - Received notification.