Modifier and Type | Class and Description |
---|---|
class |
ConnectFailedException
Connect failed exception.
|
class |
ServiceNotReadyException
Not ready exception.
|
Modifier and Type | Class and Description |
---|---|
class |
CatchedSessionException
Catched session exception.
|
class |
LoginFailedException
Login failed exception.
|
class |
ServiceClosedException
Service closed exception.
|
class |
SessionConnectFailedException
Connect failed exception.
|
class |
SessionException
Session exception.
|
class |
SessionNotConnectedException
Not connected exception.
|
static class |
SessionProxy.SessionConnectVetoException
Connect veto exception.
|
class |
SessionProxyException
Session proxy exception.
|
class |
UnauthorizedAccessException
Unauthorized access exception.
|
Modifier and Type | Class and Description |
---|---|
class |
ReceiverActiveException
Receiver active exception.
|
Modifier and Type | Class and Description |
---|---|
class |
StoreAccessException
Access exception.
|
Modifier and Type | Method and Description |
---|---|
StoreValues |
StoreSession.pull(StoreValuesQuery query,
long timeout)
Pulls points values.
|
String |
StoreSession.supportedValueTypeCodes()
Returns a string of supported value type codes.
|
Exception[] |
StoreSession.update(PointValue[] pointValues)
Updates point values.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamedMessagesPortClient.flush()
Flushes pending entries.
|
void |
StreamedMessagesPortClient.login(LoginInfo loginInfo)
Logs in.
|
void |
StreamedMessagesPortClient.login(Optional<String> user,
Optional<char[]> password)
Logs in.
|
void |
XMLPointValuesPortClient.open(String addressString,
Optional<SecurityContext> securityContext)
Opens a connection to the XML Port.
|
void |
StreamedMessagesPortClient.open(String addressString,
Optional<SecurityContext> securityContext)
Opens a connection to the XML Port.
|
void |
StreamedMessagesPortClient.sendMessages(boolean flush)
Sends messages.
|
Modifier and Type | Method and Description |
---|---|
protected Serializable[] |
ForwarderModule.Abstract.filter(Serializable[] messages)
Filters messages.
|
boolean |
ForwarderServiceAppImpl.output(Serializable[] messages)
Output messages.
|
void |
ForwarderModule.start()
Starts this module.
|
Modifier and Type | Method and Description |
---|---|
Serializable[] |
ProcessorFilter.filter(Serializable message)
Filters a message.
|
Serializable[] |
ForwarderFilter.filter(Serializable message)
Filters a message.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
InputModule.output(Serializable[] messages)
Outputs messages.
|
Modifier and Type | Method and Description |
---|---|
boolean |
OutputModule.commit()
Commits the messages transmission.
|
protected void |
OutputModule.open(OutputModule.ModuleOutput output)
Opens the output.
|
boolean |
OutputModule.output(Serializable[] messages)
Outputs messages.
|
void |
OutputModule.start()
Starts this module.
|
Modifier and Type | Class and Description |
---|---|
class |
ServiceSessionException
Service session exception.
|
Modifier and Type | Method and Description |
---|---|
Optional<PointValue> |
Transform.applyTo(ResultValue resultValue,
Batch batch)
Applies the program to provide the specified result value.
|
Optional<Collection<PointValue>> |
Processor.process(Collection<PointValue> pointValues)
Processes point values.
|
Modifier and Type | Method and Description |
---|---|
Optional<Collection<PointValue>> |
ProcessorServiceAppImpl.process(Collection<PointValue> pointValues)
Processes point values.
|
Modifier and Type | Method and Description |
---|---|
List<PointValue> |
EngineExecutor.execute(ResultValue resultValue,
String[] params,
Serializable context)
Executes the processing of a request for a result value.
|
Modifier and Type | Method and Description |
---|---|
List<PointValue> |
RemoteEngineSessionImpl.execute(ResultValue resultValue,
String[] params,
Serializable context)
Executes the processing of a request for a result value.
|
List<PointValue> |
RemoteEngineSession.execute(ResultValue resultValue,
String[] params,
Serializable context)
Executes the processing of a request for a result value.
|
Modifier and Type | Method and Description |
---|---|
void |
Receptionist.commit()
Registers that the notices have been processed.
|
void |
Receptionist.Abstract.commit()
Registers that the notices have been processed.
|
protected void |
StoreListenerReceptionist.doCommit()
Registers that the notices have been processed.
|
protected void |
SOMReceptionist.doCommit()
Registers that the notices have been processed.
|
protected abstract void |
Receptionist.Abstract.doCommit()
Registers that the notices have been processed.
|
protected Optional<PointValue> |
StoreListenerReceptionist.doFetchNotice(int limit,
long wait)
Fetches a notice.
|
protected Optional<PointValue> |
SOMReceptionist.doFetchNotice(int limit,
long wait)
Fetches a notice.
|
protected abstract Optional<PointValue> |
Receptionist.Abstract.doFetchNotice(int limit,
long wait)
Fetches a notice.
|
protected void |
StoreListenerReceptionist.doRollback()
Forgets that the notices have been received.
|
protected void |
SOMReceptionist.doRollback()
Forgets that the notices have been received.
|
protected abstract void |
Receptionist.Abstract.doRollback()
Forgets that the notices have been received.
|
List<PointValue> |
Receptionist.fetchNotices(int limit,
long wait)
Fetches notices.
|
List<PointValue> |
Receptionist.Abstract.fetchNotices(int limit,
long wait)
Fetches notices.
|
void |
Receptionist.rollback()
Forgets that the notices have been received.
|
void |
Receptionist.Abstract.rollback()
Forgets that the notices have been received.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
ServiceImpl.doPendingActions()
Does pending actions.
|
protected abstract void |
Alerter.Abstract.doSend(Alert alert)
Does send an alert.
|
void |
Alerter.send(Alert alert)
Sends an alert.
|
void |
Alerter.Abstract.send(Alert alert)
Sends an alert.
|
Modifier and Type | Method and Description |
---|---|
protected void |
ServiceAppImpl.onServiceNotAvailableException(ServiceNotAvailableException exception)
Called on service not available exception.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
ServiceAppHolderImpl.doPendingActions()
Does pending actions.
|
Modifier and Type | Method and Description |
---|---|
void |
MetadataServiceImpl.resetPointsStore()
Resets the association of the points to their store.
|
void |
MetadataService.resetPointsStore()
Resets the association of the points to their store.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
MetadataServiceAppHolderImpl.doPendingActions()
Does pending actions.
|
Modifier and Type | Method and Description |
---|---|
protected void |
SOMAlerter.doSend(Alert alert)
Does send an alert.
|
Modifier and Type | Method and Description |
---|---|
protected void |
StoreServiceAppImpl.doPendingActions()
Does pending actions.
|
void |
UpdatesListener.onMetadataRefreshed(Metadata metadata)
Called when the metadata has been refreshed.
|
int |
StoreServer.purge(UUID[] pointUUIDs,
TimeInterval timeInterval,
Optional<Identity> identity)
Purges points values.
|
int |
StoreServer.Abstract.purge(UUID[] pointUUIDs,
TimeInterval timeInterval,
Optional<Identity> identity)
Purges points values.
|
protected boolean |
StoreServiceAppImpl.refreshMetadata()
Refreshes the metadata.
|
void |
UpdatesListener.Abstract.run()
Runs.
|
Exception[] |
StoreServer.update(PointValue[] pointValues,
Optional<Identity> identity)
Updates point values.
|
Modifier and Type | Method and Description |
---|---|
protected void |
Archiver.Abstract.archive(Archiver.Abstract.PointReference pointReference,
DateTime scanTime)
Archives a point.
|
void |
JiTArchiver.archive(Point point)
Archives a point.
|
void |
Archiver.archive(Point point)
Archives a point.
|
void |
Archiver.Abstract.archive(Point point)
Archives a point.
|
void |
ScheduledArchiver.run()
Runs.
|
Modifier and Type | Method and Description |
---|---|
protected void |
ProxyStoreServiceAppImpl.doPendingActions()
Does pending actions.
|
Modifier and Type | Method and Description |
---|---|
StoreValues |
StoreSessionImpl.pull(StoreValuesQuery query,
long timeout)
Pulls points values.
|
String |
StoreSessionImpl.supportedValueTypeCodes()
Returns a string of supported value type codes.
|
Exception[] |
StoreSessionImpl.update(PointValue[] updates)
Updates point values.
|
Modifier and Type | Method and Description |
---|---|
void |
BackEnd.open()
Opens.
|
Modifier and Type | Method and Description |
---|---|
void |
BDBBackEnd.open()
Opens.
|
Modifier and Type | Method and Description |
---|---|
void |
SQLBackEnd.open()
Opens.
|
Copyright © 2003-2019 Serge Brisson. All Rights Reserved.