org.eclipse.kapua.service.stream.internal

Class StreamServiceImpl

java.lang.Object

org.eclipse.kapua.service.stream.internal.StreamServiceImpl

All Implemented Interfaces:

org.eclipse.kapua.service.KapuaService, StreamService

public class StreamServiceImpl
extends java.lang.Object
implements StreamService

StreamService implementation.

Since:

1.0.0

Constructor Summary

Constructors

Constructor and Description
StreamServiceImpl()

Method Summary

Modifier and Type	Method and Description
protected TransportFacade<?,?,?,?>	borrowClient(org.eclipse.kapua.message.device.data.KapuaDataMessage kapuaDataMessage) Picks a TransportFacade to send the KuraResponseMessage.
protected <F extends org.eclipse.kapua.message.Message<?,?>,T extends org.eclipse.kapua.message.Message<?,?>> Translator<F,T>	getTranslator(java.lang.Class<F> from, java.lang.Class<T> to) Gets the translator for the given Message types.
org.eclipse.kapua.service.device.management.message.response.KapuaResponseMessage<?,?>	publish(org.eclipse.kapua.message.device.data.KapuaDataMessage kapuaDataMessage, java.lang.Long timeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamServiceImpl

public StreamServiceImpl()

Method Detail

publish

public org.eclipse.kapua.service.device.management.message.response.KapuaResponseMessage<?,?> publish(org.eclipse.kapua.message.device.data.KapuaDataMessage kapuaDataMessage,
                                                                                                      java.lang.Long timeout)
                                                                                               throws org.eclipse.kapua.KapuaException

Specified by:

publish in interface StreamService

Throws:

org.eclipse.kapua.KapuaException

borrowClient

protected TransportFacade<?,?,?,?> borrowClient(org.eclipse.kapua.message.device.data.KapuaDataMessage kapuaDataMessage)
                                         throws KuraDeviceCallException

Picks a TransportFacade to send the KuraResponseMessage.

Parameters:

kapuaDataMessage - The K

Returns:

The TransportFacade to use to send the KuraDataMessage.

Throws:

KuraDeviceCallException - If getting the TransportFacade causes any Exception.

Since:

1.0.0

getTranslator

protected <F extends org.eclipse.kapua.message.Message<?,?>,T extends org.eclipse.kapua.message.Message<?,?>> Translator<F,T> getTranslator(java.lang.Class<F> from,
                                                                                                                                            java.lang.Class<T> to)
                                                                                                                                     throws KuraDeviceCallException

Gets the translator for the given Message types.

Type Parameters:

F - The Message classfrom which to translate.

T - The Message class to which to translate.

Parameters:

from - The Message type from which to translate.

to - The Message type to which to translate.

Returns:

The Translator found.

Throws:

KuraDeviceCallException - If error occurs while loojing for the Translator.

Since:

1.0.0