Package | Description |
---|---|
org.rvpf.base.exception |
Exception classes.
|
org.rvpf.base.rmi |
RMI support classes.
|
org.rvpf.base.som |
Simple object messaging base classes.
|
org.rvpf.base.store | |
org.rvpf.http |
HTTP server modules container.
|
org.rvpf.jmx |
JMX agent service.
|
org.rvpf.processor.engine.executor.remote |
Remote executor Engine.
|
org.rvpf.service.rmi |
Service helper classes (RMI).
|
org.rvpf.service.som |
Service helper classes (SOM).
|
org.rvpf.som.queue | |
org.rvpf.som.topic | |
org.rvpf.store.client |
Store client common definitions.
|
org.rvpf.store.server |
Store server common definitions.
|
org.rvpf.store.server.rmi |
RMI session support.
|
Constructor and Description |
---|
ServiceNotReadyException(SessionException cause)
Constructs an instance.
|
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 |
SessionNotConnectedException
Not connected exception.
|
static class |
SessionProxy.SessionConnectVetoException
Connect veto exception.
|
class |
SessionProxyException
Session proxy exception.
|
class |
UnauthorizedAccessException
Unauthorized access exception.
|
Modifier and Type | Method and Description |
---|---|
protected SessionException |
SessionProxy.sessionException(Exception exception)
Throws a session exception.
|
Modifier and Type | Method and Description |
---|---|
protected abstract Session |
SessionProxy.createSession()
Creates a session.
|
protected Session |
SessionProxy.getSession()
Gets the session.
|
void |
Session.login(String identifier,
char[] password)
Identifies and authenticates the identity associated with the Session.
|
void |
Session.logout()
Logs out.
|
Modifier and Type | Class and Description |
---|---|
class |
ReceiverActiveException
Receiver active exception.
|
Modifier and Type | Method and Description |
---|---|
void |
SOMSession.close()
Closes the session.
|
void |
SOMProxy.close()
Closes the session.
|
void |
SenderSession.commit()
Commits uncommitted messages.
|
void |
ReceiverSession.commit()
Commits uncommitted messages.
|
void |
QueueProxy.Receiver.commit()
Commits uncommitted messages.
|
void |
QueueProxy.Sender.commit()
Commits uncommitted messages.
|
PublisherSession |
TopicServer.createPublisherSession(UUID uuid,
String clientName)
Creates a publisher session.
|
ReceiverSession |
QueueServer.createReceiverSession(UUID uuid,
String clientName)
Creates a receiver session.
|
SenderSession |
QueueServer.createSenderSession(UUID uuid,
String clientName)
Creates a sender session.
|
protected Session |
TopicProxy.createSession()
Creates a session.
|
protected Session |
TopicProxy.Publisher.createSession()
Creates a session.
|
protected Session |
TopicProxy.Subscriber.createSession()
Creates a session.
|
protected Session |
QueueProxy.createSession()
Creates a session.
|
protected Session |
QueueProxy.Receiver.createSession()
Creates a session.
|
protected Session |
QueueProxy.Sender.createSession()
Creates a session.
|
SubscriberSession |
TopicServer.createSubscriberSession(UUID uuid,
String clientName)
Creates a subscriber session.
|
long |
ReceiverSession.purge()
Purges the queue.
|
long |
QueueProxy.Receiver.purge()
Purges the queue.
|
Serializable[] |
TopicProxy.Subscriber.receive(int limit,
long timeout)
Receives messages.
|
Serializable[] |
SubscriberSession.receive(int limit,
long timeout)
Receives messages.
|
Serializable[] |
ReceiverSession.receive(int limit,
long timeout)
Receives messages.
|
Serializable[] |
QueueProxy.Receiver.receive(int limit,
long timeout)
Receives messages.
|
void |
SenderSession.rollback()
Rolls back uncommitted messages.
|
void |
ReceiverSession.rollback()
Rolls back uncommitted messages.
|
void |
QueueProxy.Receiver.rollback()
Rolls back uncommitted messages.
|
void |
QueueProxy.Sender.rollback()
Rolls back uncommitted messages.
|
void |
TopicProxy.Publisher.send(Serializable[] messages)
Sends messages.
|
void |
PublisherSession.send(Serializable[] messages)
Sends messages.
|
void |
SenderSession.send(Serializable[] messages,
boolean commit)
Sends messages.
|
void |
QueueProxy.Sender.send(Serializable[] messages,
boolean commit)
Sends messages.
|
Modifier and Type | Method and Description |
---|---|
SessionException |
StoreAccessException.getCause() |
Modifier and Type | Method and Description |
---|---|
protected Session |
StoreSessionProxy.createSession()
Creates a session.
|
StoreSession |
StoreSessionFactory.createStoreSession(UUID uuid,
String clientName)
Creates a store session.
|
StoreValues |
StoreSessionProxy.deliver(int limit,
long timeout)
Delivers point value events.
|
StoreValues |
StoreSession.deliver(int limit,
long timeout)
Delivers point value events.
|
Optional<List<PointBinding>> |
StoreSessionProxy.getPointBindings(Collection<PointBinding.Request> bindingRequests)
Gets point binding informations on selected points.
|
Optional<PointBinding[]> |
StoreSessionProxy.getPointBindings(PointBinding.Request bindingRequest)
Gets point binding informations on selected points.
|
PointBinding[] |
StoreSessionProxy.getPointBindings(PointBinding.Request[] bindingRequests)
Gets point binding informations on selected points.
|
PointBinding[] |
StoreSession.getPointBindings(PointBinding.Request[] bindingRequests)
Gets point binding informations on selected points.
|
Optional<State.Group> |
StoreSessionProxy.getStateGroup(Optional<String> name)
Gets a state group by its name.
|
State.Group[] |
StoreSessionProxy.getStateGroups()
Gets the state groups.
|
State.Group[] |
StoreSession.getStateGroups()
Gets the state groups.
|
void |
StoreSessionProxy.impersonate(String user)
Impersonates an other user.
|
void |
StoreSession.impersonate(String user)
Impersonates an other user.
|
void |
StoreSessionProxy.interrupt()
Interrupts the current delivery.
|
void |
StoreSession.interrupt()
Interrupts the current delivery.
|
boolean |
StoreSessionProxy.probe()
Probes the state of a session.
|
boolean |
StoreSession.probe()
Probes the state of a session.
|
StoreValues |
StoreSessionProxy.pull(StoreValuesQuery query,
long timeout)
Pulls points values.
|
int |
StoreSessionProxy.purge(UUID[] pointUUIDs,
TimeInterval timeInterval)
Purges point values.
|
int |
StoreSession.purge(UUID[] pointUUIDs,
TimeInterval timeInterval)
Purges point values.
|
int |
StoreSessionProxy.purge(UUID pointUUID,
TimeInterval timeInterval)
Purges point values.
|
State |
StoreSessionProxy.resolve(State state)
Resolves a global state.
|
State |
StoreSessionProxy.resolve(State state,
Point point)
Resolves a state for a point.
|
State |
StoreSessionProxy.resolve(State state,
UUID pointUUID)
Resolves a state for a point.
|
State |
StoreSession.resolve(State state,
UUID pointUUID)
Resolves a state for a point.
|
List<StoreValues> |
StoreSessionProxy.select(Collection<StoreValuesQuery> queries)
Selects point values.
|
Optional<StoreValues> |
StoreSessionProxy.select(StoreValuesQuery storeQuery)
Selects point values.
|
StoreValues[] |
StoreSessionProxy.select(StoreValuesQuery[] queries)
Selects point values.
|
StoreValues[] |
StoreSession.select(StoreValuesQuery[] queries)
Selects point values.
|
List<StoreValues> |
StoreSessionProxy.subscribe(Collection<UUID> pointUUIDs)
Subscribes to point values events.
|
Optional<StoreValues> |
StoreSessionProxy.subscribe(UUID pointUUID)
Subscribes to a point values events.
|
StoreValues[] |
StoreSessionProxy.subscribe(UUID[] pointUUIDs)
Subscribes to point values events.
|
StoreValues[] |
StoreSession.subscribe(UUID[] pointUUIDs)
Subscribes to point values events.
|
boolean |
StoreSessionProxy.subscribeAndCheck(Collection<UUID> pointUUIDs,
Logger logger)
Subscribes to point values events and check the responses.
|
boolean |
StoreSessionProxy.subscribeAndCheck(UUID[] pointUUIDs,
Logger logger)
Subscribes to point values events and check the responses.
|
boolean |
StoreSessionProxy.subscribeAndCheck(UUID pointUUID,
Logger logger)
Subscribes to point value events and check the response.
|
String |
StoreSessionProxy.supportedValueTypeCodes()
Returns a string of supported value type codes.
|
EnumSet<Externalizer.ValueType> |
StoreSessionProxy.supportedValueTypes()
Returns the set of supported value types.
|
boolean |
StoreSessionProxy.supportsCount()
Asks if the server supports count.
|
boolean |
StoreSession.supportsCount()
Asks if the server supports count.
|
boolean |
StoreSessionProxy.supportsDelete()
Asks if the server supports delete.
|
boolean |
StoreSession.supportsDelete()
Asks if the server supports delete.
|
boolean |
StoreSessionProxy.supportsDeliver()
Asks if the server supports deliver.
|
boolean |
StoreSession.supportsDeliver()
Asks if the server supports deliver.
|
boolean |
StoreSessionProxy.supportsPull()
Asks if the server supports pull.
|
boolean |
StoreSession.supportsPull()
Asks if the server supports pull.
|
boolean |
StoreSessionProxy.supportsPurge()
Asks if the server supports purge.
|
boolean |
StoreSession.supportsPurge()
Asks if the server supports purge.
|
boolean |
StoreSessionProxy.supportsSubscribe()
Asks if the server supports subscribe.
|
boolean |
StoreSession.supportsSubscribe()
Asks if the server supports subscribe.
|
List<Exception> |
StoreSessionProxy.unsubscribe(Collection<UUID> pointUUIDs)
Unsubscribes from point values events.
|
Exception |
StoreSessionProxy.unsubscribe(UUID pointUUID)
Usubscribes from a point values events.
|
Exception[] |
StoreSessionProxy.unsubscribe(UUID[] pointUUIDs)
Unsubscribes from point values events.
|
Exception[] |
StoreSession.unsubscribe(UUID[] pointUUIDs)
Unsubscribes from point values events.
|
boolean |
StoreSessionProxy.unsubscribeAndCheck(Collection<UUID> pointUUIDs,
Logger logger)
Subscribes to point values events and check the responses.
|
boolean |
StoreSessionProxy.unsubscribeAndCheck(UUID[] pointUUIDs,
Logger logger)
Subscribes to point values events and check the responses.
|
boolean |
StoreSessionProxy.unsubscribeAndCheck(UUID pointUUID,
Logger logger)
Subscribes to point value events and check the response.
|
List<Exception> |
StoreSessionProxy.update(Collection<PointValue> pointValues)
Updates point values.
|
Optional<Exception> |
StoreSessionProxy.update(PointValue pointValue)
Updates a point value.
|
Exception[] |
StoreSessionProxy.update(PointValue[] pointValues)
Updates point values.
|
boolean |
StoreSessionProxy.updateAndCheck(Collection<PointValue> pointValues,
Logger logger)
Updates point values and check the responses.
|
boolean |
StoreSessionProxy.updateAndCheck(PointValue[] pointValues,
Logger logger)
Updates point values and check the responses.
|
boolean |
StoreSessionProxy.updateAndCheck(PointValue pointValue,
Logger logger)
Updates a point value and check the response.
|
Constructor and Description |
---|
StoreAccessException(Optional<UUID> storeUUID,
SessionException cause)
Creates an instance.
|
Modifier and Type | Class and Description |
---|---|
class |
ServiceSessionException
Service session exception.
|
Constructor and Description |
---|
ServiceSessionException(SessionException exception) |
Modifier and Type | Method and Description |
---|---|
AgentSession |
AgentSessionFactory.createAgentSession(UUID uuid,
String clientName)
Creates a JMX agent session.
|
protected Session |
AgentSessionProxy.createSession()
Creates a session.
|
MBeanServerConnection |
AgentSessionProxy.getConnection()
Gets the MBean server connection.
|
<T> T |
AgentSessionProxy.getMBeanProxy(Class<T> objectClass)
Gets a proxy to the MBean.
|
<T> T |
AgentSessionProxy.getMBeanProxy(ObjectName objectName,
Class<T> objectClass,
boolean notificationBroadcaster)
Gets a proxy to a MBean.
|
String |
AgentSessionProxy.getObjectClassName(ObjectName objectName)
Gets an object class name.
|
ObjectName[] |
AgentSessionProxy.getObjectNames()
Gets the object names.
|
void |
AgentSessionImpl.login(String identifier,
char[] password)
Identifies and authenticates the identity associated with the Session.
|
Modifier and Type | Method and Description |
---|---|
RemoteEngineSession |
RemoteEngineFactoryImpl.createEngineSession(UUID uuid,
String clientName)
Creates a remote engine session.
|
RemoteEngineSession |
RemoteEngineFactory.createEngineSession(UUID uuid,
String clientName)
Creates a remote engine session.
|
protected Session |
RemoteEngineProxy.createSession()
Creates a session.
|
void |
RemoteEngineSession.disposeContext(Serializable context)
Disposes of a context.
|
void |
RemoteEngineProxy.disposeContext(Serializable context)
Disposes of a context.
|
List<PointValue> |
RemoteEngineProxy.execute(ResultValue resultValue,
String[] params,
Serializable context)
Executes the processing of a request for a result value.
|
Serializable |
RemoteEngineSession.newContext(Params params,
Logger logger)
Returns a new context.
|
Serializable |
RemoteEngineProxy.newContext(Params params,
Logger logger)
Returns a new context.
|
boolean |
RemoteEngineSessionImpl.setUp(String name,
Params params,
Config config,
Logger logger)
Sets up this engine executor.
|
boolean |
RemoteEngineSession.setUp(String name,
Params params,
Config config,
Logger logger)
Sets up this engine executor.
|
boolean |
RemoteEngineProxy.setUp(String name,
Params params,
Config config,
Logger logger)
Sets up this engine executor.
|
Modifier and Type | Method and Description |
---|---|
protected Session |
SessionFactoryImpl.createSession(Session.ConnectionMode connectionMode,
Optional<RMIClientSocketFactory> clientSocketFactory,
Optional<RMIServerSocketFactory> serverSocketFactory,
Object reference)
Creates a session.
|
protected Session |
SessionFactoryImpl.createSession(UUID uuid,
Object reference)
Creates a session.
|
protected abstract Session |
SessionFactoryImpl.newSession(Session.ConnectionMode connectionMode,
Optional<RMIClientSocketFactory> clientSocketFactory,
Optional<RMIServerSocketFactory> serverSocketFactory,
Object reference)
Returns a new session
|
Modifier and Type | Method and Description |
---|---|
Optional<SessionException> |
SOMEndPoint.getException()
Gets the exception.
|
Optional<SessionException> |
SOMEndPoint.Abstract.getException()
Gets the exception.
|
Modifier and Type | Method and Description |
---|---|
protected void |
SOMEndPoint.Abstract.setException(SessionException exception)
Sets the exception.
|
Modifier and Type | Method and Description |
---|---|
void |
SenderSessionImpl.commit()
Commits uncommitted messages.
|
void |
ReceiverSessionImpl.commit()
Commits uncommitted messages.
|
ReceiverSession |
QueueServerImpl.createReceiverSession(UUID uuid,
String clientName)
Creates a receiver session.
|
SenderSession |
QueueServerImpl.createSenderSession(UUID uuid,
String clientName)
Creates a sender session.
|
long |
ReceiverSessionImpl.purge()
Purges the queue.
|
Serializable[] |
ReceiverSessionImpl.receive(int limit,
long timeout)
Receives messages.
|
void |
SenderSessionImpl.rollback()
Rolls back uncommitted messages.
|
void |
ReceiverSessionImpl.rollback()
Rolls back uncommitted messages.
|
void |
SenderSessionImpl.send(Serializable[] messages,
boolean commit)
Sends messages.
|
Modifier and Type | Method and Description |
---|---|
PublisherSession |
TopicServerImpl.createPublisherSession(UUID uuid,
String clientName)
Creates a publisher session.
|
SubscriberSession |
TopicServerImpl.createSubscriberSession(UUID uuid,
String clientName)
Creates a subscriber session.
|
Serializable[] |
SubscriberSessionImpl.receive(int limit,
long timeout)
Receives messages.
|
void |
PublisherSessionImpl.send(Serializable[] messages)
Sends messages.
|
Modifier and Type | Method and Description |
---|---|
protected StoreAccessException |
AbstractStore.accessException(SessionException cause)
Returns an access exception.
|
Modifier and Type | Method and Description |
---|---|
Optional<StoreValues> |
StoreServer.pull(StoreValuesQuery query,
long timeout,
StoreSessionImpl storeSession,
Optional<Identity> identity)
Pulls points values.
|
Optional<StoreValues> |
StoreServer.Abstract.pull(StoreValuesQuery query,
long timeout,
StoreSessionImpl storeSession,
Optional<Identity> identity)
Pulls points values.
|
StoreValues[] |
StoreServer.select(StoreValuesQuery[] queries,
Optional<Identity> identity)
Selects point values.
|
String |
StoreServer.supportedValueTypeCodes()
Returns a string of supported value type codes.
|
Modifier and Type | Method and Description |
---|---|
StoreSession |
StoreSessionFactoryImpl.createStoreSession(UUID uuid,
String clientName)
Creates a store session.
|
StoreValues |
StoreSessionImpl.deliver(int limit,
long timeout)
Delivers point value events.
|
PointBinding[] |
StoreSessionImpl.getPointBindings(PointBinding.Request[] bindingRequests)
Gets point binding informations on selected points.
|
State.Group[] |
StoreSessionImpl.getStateGroups()
Gets the state groups.
|
void |
StoreSessionImpl.impersonate(String user)
Impersonates an other user.
|
boolean |
StoreSessionImpl.probe()
Probes the state of a session.
|
int |
StoreSessionImpl.purge(UUID[] pointUUIDs,
TimeInterval timeInterval)
Purges point values.
|
State |
StoreSessionImpl.resolve(State state,
UUID pointUUID)
Resolves a state for a point.
|
StoreValues[] |
StoreSessionImpl.select(StoreValuesQuery[] queries)
Selects point values.
|
StoreValues[] |
StoreSessionImpl.subscribe(UUID[] pointUUIDs)
Subscribes to point values events.
|
boolean |
StoreSessionImpl.supportsCount()
Asks if the server supports count.
|
boolean |
StoreSessionImpl.supportsDelete()
Asks if the server supports delete.
|
boolean |
StoreSessionImpl.supportsDeliver()
Asks if the server supports deliver.
|
boolean |
StoreSessionImpl.supportsPull()
Asks if the server supports pull.
|
boolean |
StoreSessionImpl.supportsPurge()
Asks if the server supports purge.
|
boolean |
StoreSessionImpl.supportsSubscribe()
Asks if the server supports subscribe.
|
Exception[] |
StoreSessionImpl.unsubscribe(UUID[] pointUUIDs)
Unsubscribes from point values events.
|
Copyright © 2003-2019 Serge Brisson. All Rights Reserved.