org.kaaproject.kaa.client.schema

Class DefaultSchemaProcessor

java.lang.Object

org.kaaproject.kaa.client.schema.DefaultSchemaProcessor

All Implemented Interfaces:

SchemaObservable, SchemaProcessor

public class DefaultSchemaProcessor
extends Object
implements SchemaProcessor, SchemaObservable

Default implementation of @{link SchemaProcessor} using the avro schema

Author:

Yaroslav Zeygerman

Constructor Summary

Constructors

Constructor and Description
DefaultSchemaProcessor()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.avro.Schema	getSchema() Retrieves current schema object.
void	loadSchema(ByteBuffer buffer) Loads new schema from the buffer.
void	subscribeForSchemaUpdates(SchemaUpdatesReceiver receiver) Subscribes new receiver for schema updates
void	unsubscribeFromSchemaUpdates(SchemaUpdatesReceiver receiver) Unsubscribes receiver from schema updates

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSchemaProcessor

public DefaultSchemaProcessor()

Method Detail

getSchema

public org.apache.avro.Schema getSchema()

Description copied from interface: SchemaProcessor

Retrieves current schema object.

Specified by:

getSchema in interface SchemaProcessor

Returns:

current schema.

See Also:

Schema

loadSchema

public void loadSchema(ByteBuffer buffer)
                throws IOException

Description copied from interface: SchemaProcessor

Loads new schema from the buffer.

Specified by:

loadSchema in interface SchemaProcessor

Parameters:

buffer - schema buffer

Throws:

IOException - in case of loading schema failure

subscribeForSchemaUpdates

public void subscribeForSchemaUpdates(SchemaUpdatesReceiver receiver)

Description copied from interface: SchemaObservable

Subscribes new receiver for schema updates

Specified by:

subscribeForSchemaUpdates in interface SchemaObservable

Parameters:

receiver - receiver to get schema updates

unsubscribeFromSchemaUpdates

public void unsubscribeFromSchemaUpdates(SchemaUpdatesReceiver receiver)

Description copied from interface: SchemaObservable

Unsubscribes receiver from schema updates

Specified by:

unsubscribeFromSchemaUpdates in interface SchemaObservable

Parameters:

receiver - receiver to be unsubscribed from schema updates