public interface Subscription extends SubscriptionServiceProvider, SubscriptionStatsProvider
SubscriptionServiceProvider.SetTriggeringResult
Modifier and Type | Method and Description |
---|---|
void |
addMonitoredItems(java.util.List<IMonitoredItem> itemsToAdd) |
long |
getMaxKeepAliveCount()
Gets this
Subscription 's max keep-alive count. |
long |
getMaxLifetimeCount()
Gets this Subscription's max lifetime count.
|
long |
getMaxNotificationsPerPublish()
The maximum number of notifications that the client wishes to receive in a single
PublishResponse . |
byte |
getPriority()
Gets the priority byte for this
Subscription . |
double |
getPublishingInterval()
Gets the publishing interval for this
Subscription . |
java.util.Set<UInt32> |
getRetransmissionSequenceNumbers() |
UInt32 |
getSubscriptionId()
Gets the id of this
Subscription . |
boolean |
isLate() |
boolean |
isNotificationAvailable() |
boolean |
isPublishingEnabled()
Checks if publishing is enabled or disabled for this
Subscription . |
java.util.List<java.lang.Boolean> |
removeMonitoredItems(java.util.List<IMonitoredItem> itemsToRemove) |
void |
resetLifetimeCounter() |
void |
setSession(Session session) |
void |
start()
Starts this
Subscription . |
void |
stop()
Stops this
Subscription . |
modify, modifyMonitoringMode, republish, setPublishingEnabled, setTriggering
acknowledge, consume
getSubscriptionStats
void start() throws java.lang.Exception
Subscription
. Registers its publishing timer with the
ExecutionManager
, resets the keep-alive counter, and begins operations.java.lang.Exception
- Thrown if there is an error registering with the ExecutionManager
.void stop()
Subscription
. Its publishing timer is unregistered and the state is set to
closed.long getMaxKeepAliveCount()
Subscription
's max keep-alive count.long getMaxLifetimeCount()
long getMaxNotificationsPerPublish()
PublishResponse
. Zero indicates no limit.PublishResponse
.double getPublishingInterval()
Subscription
.UInt32 getSubscriptionId()
Subscription
.UInt32
identifying this Subscription
.boolean isPublishingEnabled()
Subscription
.byte getPriority()
Subscription
.Subscription
's priority compared to others.boolean isLate()
boolean isNotificationAvailable()
java.util.Set<UInt32> getRetransmissionSequenceNumbers()
void setSession(Session session)
void addMonitoredItems(java.util.List<IMonitoredItem> itemsToAdd)
java.util.List<java.lang.Boolean> removeMonitoredItems(java.util.List<IMonitoredItem> itemsToRemove)
void resetLifetimeCounter()