com.sitewhere.spi.device.communication

Interface IInboundProcessingStrategy

All Superinterfaces:

ILifecycleComponent, ITenantLifecycleComponent

public interface IInboundProcessingStrategy
extends ITenantLifecycleComponent

Provides a strategy for moving decoded events from an IInboundEventSource onto the IInboundEventProcessorChain.

Method Summary

Modifier and Type	Method and Description
void	processCreateDeviceMapping(IDecodedDeviceRequest<IDeviceMappingCreateRequest> request) Process an IDeviceMappingCreateRequest.
void	processDeviceAlert(IDecodedDeviceRequest<IDeviceAlertCreateRequest> request) Process an IDeviceAlertCreateRequest.
void	processDeviceCommandResponse(IDecodedDeviceRequest<IDeviceCommandResponseCreateRequest> request) Process an IDeviceCommandResponseCreateRequest.
void	processDeviceLocation(IDecodedDeviceRequest<IDeviceLocationCreateRequest> request) Process an IDeviceLocationCreateRequest.
void	processDeviceMeasurements(IDecodedDeviceRequest<IDeviceMeasurementsCreateRequest> request) Process an IDeviceMeasurementsCreateRequest.
void	processDeviceStateChange(IDecodedDeviceRequest<IDeviceStateChangeCreateRequest> request) Process an IDeviceStateChangeCreateRequest.
void	processDeviceStream(IDecodedDeviceRequest<IDeviceStreamCreateRequest> request) Process an IDeviceStreamCreateRequest.
void	processDeviceStreamData(IDecodedDeviceRequest<IDeviceStreamDataCreateRequest> request) Process an IDeviceStreamDataCreateRequest.
void	processRegistration(IDecodedDeviceRequest<IDeviceRegistrationRequest> request) Process an IDeviceRegistrationRequest.
void	processSendDeviceStreamData(IDecodedDeviceRequest<ISendDeviceStreamDataRequest> request) Process an ISendDeviceStreamDataRequest.
void	sendToInboundProcessingChain(IDecodedDeviceRequest<?> request) Sends a decoded request to the inbound processing chain.

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

processRegistration

void processRegistration(IDecodedDeviceRequest<IDeviceRegistrationRequest> request)
                  throws SiteWhereException

Process an IDeviceRegistrationRequest.

Parameters:

request -

Throws:

SiteWhereException

processDeviceCommandResponse

void processDeviceCommandResponse(IDecodedDeviceRequest<IDeviceCommandResponseCreateRequest> request)
                           throws SiteWhereException

Process an IDeviceCommandResponseCreateRequest.

Parameters:

request -

Throws:

SiteWhereException

processDeviceMeasurements

void processDeviceMeasurements(IDecodedDeviceRequest<IDeviceMeasurementsCreateRequest> request)
                        throws SiteWhereException

Process an IDeviceMeasurementsCreateRequest.

Parameters:

request -

Throws:

SiteWhereException

processDeviceLocation

void processDeviceLocation(IDecodedDeviceRequest<IDeviceLocationCreateRequest> request)
                    throws SiteWhereException

Process an IDeviceLocationCreateRequest.

Parameters:

request -

Throws:

SiteWhereException

processDeviceAlert

void processDeviceAlert(IDecodedDeviceRequest<IDeviceAlertCreateRequest> request)
                 throws SiteWhereException

Process an IDeviceAlertCreateRequest.

Parameters:

request -

Throws:

SiteWhereException

processDeviceStateChange

void processDeviceStateChange(IDecodedDeviceRequest<IDeviceStateChangeCreateRequest> request)
                       throws SiteWhereException

Process an IDeviceStateChangeCreateRequest.

Parameters:

request -

Throws:

SiteWhereException

processDeviceStream

void processDeviceStream(IDecodedDeviceRequest<IDeviceStreamCreateRequest> request)
                  throws SiteWhereException

Process an IDeviceStreamCreateRequest.

Parameters:

request -

Throws:

SiteWhereException

processDeviceStreamData

void processDeviceStreamData(IDecodedDeviceRequest<IDeviceStreamDataCreateRequest> request)
                      throws SiteWhereException

Process an IDeviceStreamDataCreateRequest.

Parameters:

request -

Throws:

SiteWhereException

processSendDeviceStreamData

void processSendDeviceStreamData(IDecodedDeviceRequest<ISendDeviceStreamDataRequest> request)
                          throws SiteWhereException

Process an ISendDeviceStreamDataRequest.

Parameters:

request -

Throws:

SiteWhereException

processCreateDeviceMapping

void processCreateDeviceMapping(IDecodedDeviceRequest<IDeviceMappingCreateRequest> request)
                         throws SiteWhereException

Process an IDeviceMappingCreateRequest.

Parameters:

request -

Throws:

SiteWhereException

sendToInboundProcessingChain

void sendToInboundProcessingChain(IDecodedDeviceRequest<?> request)
                           throws SiteWhereException

Sends a decoded request to the inbound processing chain.

Parameters:

request -

Throws:

SiteWhereException