com.sitewhere.spi.device.communication

Interface IInboundEventSource<T>

All Superinterfaces:

ILifecycleComponent, ITenantLifecycleComponent

public interface IInboundEventSource<T>
extends ITenantLifecycleComponent

Entity that receives events from one or more IInboundEventReceiver, decodes them, and forwards them for processing.

Method Summary

Modifier and Type	Method and Description
java.lang.String	getSourceId() Get unique id for event source.
void	onEncodedEventReceived(IInboundEventReceiver<T> receiver, T encodedEvent, java.util.Map<java.lang.String,java.lang.Object> metadata) Called by IInboundEventReceiver when an encoded event is received.
void	setDeviceEventDecoder(IDeviceEventDecoder<T> decoder) Set the device event decoder.
void	setInboundEventReceivers(java.util.List<IInboundEventReceiver<T>> receivers) Set the list of IInboundEventReceiver that feed this processor.
void	setInboundProcessingStrategy(IInboundProcessingStrategy strategy) Set the strategy for submitting inbound events into the bus.

Methods inherited from interface com.sitewhere.spi.server.lifecycle.ITenantLifecycleComponent

getTenant, setTenant

Methods inherited from interface com.sitewhere.spi.server.lifecycle.ILifecycleComponent

canPause, findComponentsOfType, getComponentId, getComponentName, getComponentType, getCreatedDate, getLifecycleComponents, getLifecycleError, getLifecycleStatus, getLogger, initialize, initializeNestedComponent, lifecycleInitialize, lifecyclePause, lifecycleStart, lifecycleStop, lifecycleStop, logState, pause, start, startNestedComponent, stop, stop

Method Detail

getSourceId

java.lang.String getSourceId()

Get unique id for event source.

Returns:

setDeviceEventDecoder

void setDeviceEventDecoder(IDeviceEventDecoder<T> decoder)

Set the device event decoder.

Parameters:

decoder -

setInboundProcessingStrategy

void setInboundProcessingStrategy(IInboundProcessingStrategy strategy)

Set the strategy for submitting inbound events into the bus.

Parameters:

strategy -

setInboundEventReceivers

void setInboundEventReceivers(java.util.List<IInboundEventReceiver<T>> receivers)

Set the list of IInboundEventReceiver that feed this processor.

Parameters:

receivers -

onEncodedEventReceived

void onEncodedEventReceived(IInboundEventReceiver<T> receiver,
                            T encodedEvent,
                            java.util.Map<java.lang.String,java.lang.Object> metadata)
                     throws EventDecodeException

Called by IInboundEventReceiver when an encoded event is received.

Parameters:

receiver -

encodedEvent -

metadata -

Throws:

EventDecodeException