Package com.inductiveautomation.ignition.gateway.tags.model

Class TagSubscriptionModel

java.lang.Object

com.inductiveautomation.ignition.gateway.tags.model.TagSubscriptionModel

public class TagSubscriptionModel
extends Object

The TagSubscriptionModel holds subscriptions to tags, broken up by provider. Providers can add listeners in order to be notified of subscription changes. Subscription change notifications are published asynchronously

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	TagSubscriptionModel.ChangeNotificationJob

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<String,EventListenerList>	listenerLists	These are the entities that listen to changes in the model, keyed off of lcase(provider) name.
protected final Map<String,Set<TagSubscription>>	subscriptions	SyncronizedMap - Key on both of these maps is the source name.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TagSubscriptionModel()
	TagSubscriptionModel(ExecutionManager executionManager)
	TagSubscriptionModel(GatewayContext context)

Method Summary

Modifier and Type	Method	Description
void	addListener(String sourceName, TagSubscriptionChangeListener listener)
Map<String,Set<TagSubscription>>	getAllSubscriptions()
protected EventListenerList	getListenerList(String sourceName)	gets the listener list for the given server, and creates one if one doesn't exist
Collection<TagSubscription>	getSubscriptions(String sourceName)
void	removeListener(String sourceName, TagSubscriptionChangeListener listener)
void	subscribe(TagPath path, TagChangeListener listener)
void	subscribe(List<TagPath> paths, List<TagChangeListener> listeners)
void	unsubscribe(TagPath path, TagChangeListener listener)
void	unsubscribe(List<TagPath> paths, List<TagChangeListener> listeners)
protected List<TagSubscription>	zipper(List<TagPath> paths, List<TagChangeListener> listeners)

Methods inherited from class java.lang.Object

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

Field Details

subscriptions

protected final Map<String,Set<TagSubscription>> subscriptions

SyncronizedMap - Key on both of these maps is the source name.

listenerLists

protected final Map<String,EventListenerList> listenerLists

These are the entities that listen to changes in the model, keyed off of lcase(provider) name. SynchronizedMap

Constructor Details

TagSubscriptionModel

protected TagSubscriptionModel()

TagSubscriptionModel

public TagSubscriptionModel(GatewayContext context)

TagSubscriptionModel

public TagSubscriptionModel(ExecutionManager executionManager)

Method Details

getSubscriptions

public Collection<TagSubscription> getSubscriptions(String sourceName)

getAllSubscriptions

public Map<String,Set<TagSubscription>> getAllSubscriptions()

getListenerList

protected EventListenerList getListenerList(String sourceName)

gets the listener list for the given server, and creates one if one doesn't exist

addListener

public void addListener(String sourceName,
 TagSubscriptionChangeListener listener)

removeListener

public void removeListener(String sourceName,
 TagSubscriptionChangeListener listener)

subscribe

public void subscribe(TagPath path,
 TagChangeListener listener)

unsubscribe

public void unsubscribe(TagPath path,
 TagChangeListener listener)

subscribe

public void subscribe(List<TagPath> paths,
 List<TagChangeListener> listeners)

unsubscribe

public void unsubscribe(List<TagPath> paths,
 List<TagChangeListener> listeners)

zipper

protected List<TagSubscription> zipper(List<TagPath> paths,
 List<TagChangeListener> listeners)