org.rifidi.app.rifidiservices

Class RifidiServicesApp

java.lang.Object

org.rifidi.edge.api.AbstractRifidiApp

org.rifidi.app.rifidiservices.RifidiServicesApp

All Implemented Interfaces:

java.lang.Comparable<RifidiApp>, RifidiApp, RifidiAppCommonProperties

public class RifidiServicesApp
extends AbstractRifidiApp

An application which shows all services supported by rifidi-sdk

Author:

Manuel Tobon - manuel@transcends.co

Field Summary

Fields inherited from class org.rifidi.edge.api.AbstractRifidiApp

readZones

Fields inherited from interface org.rifidi.edge.api.RifidiAppCommonProperties

LAZY_START

Constructor Summary

Constructors

Constructor and Description
RifidiServicesApp(java.lang.String group, java.lang.String name) Constructor called by spring injection

Method Summary

Methods

Modifier and Type	Method and Description
void	_start() Subclasses should use this method to add statements.
void	_stop() Subclasses should override this method do any work they need to do when the application is stopping.
java.lang.Integer	getCountThreshold()
java.lang.Float	getDepartureTime()
java.lang.Integer	getLimitOfTags()
LimitStableSetService	getLimitStableSetService()
java.lang.Double	getMinAvgRSSIThreshold()
MqttClient	getMqttClient()
int	getMqttQos()
java.lang.Float	getNotifyInterval()
ReadZoneMonitoringService	getReadZoneMonitoringService()
RSSIMonitoringService	getRssiMonitoringService()
StableSetService	getStableSetService()
java.lang.Float	getStableSetTime()
UniqueTagBatchIntervalService	getUniqueTagBatchIntervalService()
java.lang.Float	getWindowTime()
void	initialize() The initialize method can be used to do any work that needs to be done right before the start method is called.
void	setCountThreshold(java.lang.Integer countThreshold)
void	setDepartureTime(java.lang.Float departureTime)
void	setLimitOfTags(java.lang.Integer limitOfTags)
void	setLimitStableSetService(LimitStableSetService limitStableSetService)
void	setMinAvgRSSIThreshold(java.lang.Double minAvgRSSIThreshold)
void	setMqttClient(MqttClient mqttClient)
void	setMqttQos(int mqttQos)
void	setNotifyInterval(java.lang.Float notifyInterval)
void	setReaderDAO(ReaderDAO readerDAO) Inject the reader DAO to allow this app to stop the reader.
void	setReadZoneMonitoringService(ReadZoneMonitoringService readZoneMonitoringService)
void	setRssiMonitoringService(RSSIMonitoringService rssiMonitoringService)
void	setStableSetService(StableSetService stableSetService)
void	setStableSetTime(java.lang.Float stableSetTime)
void	setUniqueTagBatchIntervalService(UniqueTagBatchIntervalService uniqueTagBatchIntervalService)
void	setWindowTime(java.lang.Float windowTime)
void	stopReaderSession(java.lang.String readerID) Stop any currently running sessions for the given reader ID.
void	subscribeToLimitStableSetService(ReadZone readZone)
void	subscribeToReadZoneService(ReadZone readZone)
void	subscribeToRSSIMonitoringService(java.util.HashMap<java.lang.String,ReadZone> allReadZones)
void	subscribeToStableSetService(ReadZone readZone)
void	subscribeToUniqueTagBatchIntervalService(ReadZone readZone)
void	unsubscribeFromLimitStableSetService(MyLimitStableSetSubscriber myLimitStableSetSubscriber)
void	unsubscribeFromReadZoneService(MyReadZoneSubscriber myReadZoneSubscriber)
void	unsubscribeFromRSSIMonitoringService(MyRSSIReadZoneSubscriber myRSSIReadZoneSubscriber)
void	unsubscribeFromStableSetService(MyStableSetSubscriber myStableSetSubscriber)
void	unsubscribeFromUniqueTagBatchIntervalService(MyUniqueTagBatchSubscriber myUniqueTagBatchSubscriber)

Methods inherited from class org.rifidi.edge.api.AbstractRifidiApp

compareTo, equals, getGroup, getName, getState, hashCode, lazyStart, setAppProperties, setBundleContext, setEsperService, start, stop, toString

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

RifidiServicesApp

public RifidiServicesApp(java.lang.String group,
                 java.lang.String name)

Constructor called by spring injection

Parameters:

group - the group name of application

name - the name of application

Method Detail

getMqttClient

public MqttClient getMqttClient()

Returns:

the mqttClient

setMqttClient

public void setMqttClient(MqttClient mqttClient)

Parameters:

mqttClient - the mqttClient to set

getMqttQos

public int getMqttQos()

Returns:

the mqttQos

setMqttQos

public void setMqttQos(int mqttQos)

Parameters:

mqttQos - the mqttQos to set

getStableSetService

public StableSetService getStableSetService()

Returns:

the stableSetService

setStableSetService

public void setStableSetService(StableSetService stableSetService)

Parameters:

stableSetService - the stableSetService to set

getLimitStableSetService

public LimitStableSetService getLimitStableSetService()

Returns:

the limitStableSetService

setLimitStableSetService

public void setLimitStableSetService(LimitStableSetService limitStableSetService)

Parameters:

limitStableSetService - the limitStableSetService to set

getReadZoneMonitoringService

public ReadZoneMonitoringService getReadZoneMonitoringService()

Returns:

the readZoneMonitoringService

setReadZoneMonitoringService

public void setReadZoneMonitoringService(ReadZoneMonitoringService readZoneMonitoringService)

Parameters:

readZoneMonitoringService - the readZoneMonitoringService to set

getUniqueTagBatchIntervalService

public UniqueTagBatchIntervalService getUniqueTagBatchIntervalService()

Returns:

the uniqueTagBatchIntervalService

setUniqueTagBatchIntervalService

public void setUniqueTagBatchIntervalService(UniqueTagBatchIntervalService uniqueTagBatchIntervalService)

Parameters:

uniqueTagBatchIntervalService - the uniqueTagBatchIntervalService to set

getRssiMonitoringService

public RSSIMonitoringService getRssiMonitoringService()

Returns:

the rssiMonitoringService

setRssiMonitoringService

public void setRssiMonitoringService(RSSIMonitoringService rssiMonitoringService)

Parameters:

rssiMonitoringService - the rssiMonitoringService to set

setReaderDAO

public void setReaderDAO(ReaderDAO readerDAO)

Inject the reader DAO to allow this app to stop the reader.

Parameters:

readerDAO -

getDepartureTime

public java.lang.Float getDepartureTime()

Returns:

the departureTime

setDepartureTime

public void setDepartureTime(java.lang.Float departureTime)

Parameters:

departureTime - the departureTime to set

getNotifyInterval

public java.lang.Float getNotifyInterval()

Returns:

the notifYInterval

setNotifyInterval

public void setNotifyInterval(java.lang.Float notifyInterval)

Parameters:

notifYInterval - the notifYInterval to set

getWindowTime

public java.lang.Float getWindowTime()

Returns:

the windowTime

setWindowTime

public void setWindowTime(java.lang.Float windowTime)

Parameters:

windowTime - the windowTime to set

getCountThreshold

public java.lang.Integer getCountThreshold()

Returns:

the countThreshold

setCountThreshold

public void setCountThreshold(java.lang.Integer countThreshold)

Parameters:

countThreshold - the countThreshold to set

getMinAvgRSSIThreshold

public java.lang.Double getMinAvgRSSIThreshold()

Returns:

the minAvgRSSIThreshold

setMinAvgRSSIThreshold

public void setMinAvgRSSIThreshold(java.lang.Double minAvgRSSIThreshold)

Parameters:

minAvgRSSIThreshold - the minAvgRSSIThreshold to set

_start

public void _start()

Description copied from class: AbstractRifidiApp

Subclasses should use this method to add statements.

_stop

public void _stop()

Description copied from class: AbstractRifidiApp

Subclasses should override this method do any work they need to do when the application is stopping. Make sure to unregister any listeners here.

getStableSetTime

public java.lang.Float getStableSetTime()

Returns:

the stableSetTime

setStableSetTime

public void setStableSetTime(java.lang.Float stableSetTime)

Parameters:

stableSetTime - the stableSetTime to set

getLimitOfTags

public java.lang.Integer getLimitOfTags()

Returns:

the limitOfTags

setLimitOfTags

public void setLimitOfTags(java.lang.Integer limitOfTags)

Parameters:

limitOfTags - the limitOfTags to set

unsubscribeFromStableSetService

public void unsubscribeFromStableSetService(MyStableSetSubscriber myStableSetSubscriber)

Parameters:

stableSetSubscriber -

unsubscribeFromLimitStableSetService

public void unsubscribeFromLimitStableSetService(MyLimitStableSetSubscriber myLimitStableSetSubscriber)

unsubscribeFromReadZoneService

public void unsubscribeFromReadZoneService(MyReadZoneSubscriber myReadZoneSubscriber)

unsubscribeFromUniqueTagBatchIntervalService

public void unsubscribeFromUniqueTagBatchIntervalService(MyUniqueTagBatchSubscriber myUniqueTagBatchSubscriber)

unsubscribeFromRSSIMonitoringService

public void unsubscribeFromRSSIMonitoringService(MyRSSIReadZoneSubscriber myRSSIReadZoneSubscriber)

subscribeToStableSetService

public void subscribeToStableSetService(ReadZone readZone)

Parameters:

readZone - the readZone to subscribe

subscribeToLimitStableSetService

public void subscribeToLimitStableSetService(ReadZone readZone)

Parameters:

readZone - the readZone to subscribe

subscribeToReadZoneService

public void subscribeToReadZoneService(ReadZone readZone)

Parameters:

readZone - the readzone to subscribe

subscribeToUniqueTagBatchIntervalService

public void subscribeToUniqueTagBatchIntervalService(ReadZone readZone)

Parameters:

readZone - the readzone to subscribe

subscribeToRSSIMonitoringService

public void subscribeToRSSIMonitoringService(java.util.HashMap<java.lang.String,ReadZone> allReadZones)

Parameters:

allReadZones - all the readzones to subscribe

initialize

public void initialize()

Description copied from interface: RifidiApp

The initialize method can be used to do any work that needs to be done right before the start method is called. It can be used to set properties read in from the properties file.

Specified by:

initialize in interface RifidiApp

Overrides:

initialize in class AbstractRifidiApp

stopReaderSession

public void stopReaderSession(java.lang.String readerID)

Stop any currently running sessions for the given reader ID.

Parameters:

readerID -