class ConfigurationRequesterCommunicator extends Object
Modifier and Type | Class and Description |
---|---|
private class |
ConfigurationRequesterCommunicator.ClientInfo
Verschickt die Antworten einer Konfigurationsanfrage
|
private class |
ConfigurationRequesterCommunicator.RequestReceiver
Nimmt Konfigurationsanfragen entgegen und leitet sie an eine Methode zum verarbeiten weiter.
|
Modifier and Type | Field and Description |
---|---|
private DataDescription |
_answerDataDescription |
private AsyncRequestQueue |
_asyncRequestQueue |
private Authentication |
_authentication
Wird benötigt um "isUserValid" zu bearbeiten
|
private Map |
_clientInfos |
private Map |
_code2AuthorityMap |
private ConfigurationAuthority |
_configAuthority |
private ClientDavInterface |
_connection |
private ConfigDataModel |
_dataModel |
private static Debug |
_debug
DebugLogger für Debug-Ausgaben
|
private ConfigurationArea |
_defaultConfigArea |
private ForeignObjectManager |
_foreignObjectManager |
private SystemObject[] |
_metaDataObjects
Enthält die Objekte, die in der Antwort auf die von Applikationen initial gestellte Anfrage nach Meta-Objekten enthalten sind.
|
private SystemObject[] |
_metaDataObjectsMinimal
Enthält die minimalen Objekte zum Stellen von neuartigen Konfigurationsanfragen
|
private RemoteRequestManager |
_remoteRequestManager
Dient zum anfragen anderer Konfigurationen
|
private SimulationHandler |
_simulationHandler
Klasse mit Informationen über Simulationen (kann initial null sein)
|
private DataDescription |
_writeAnswerDataDescription |
static String[] |
META_OBJECTS_MINIMAL |
static String[] |
META_TYPES |
static String[] |
META_TYPES_MINIMAL |
private SenderRole |
SENDER_ROLE |
private boolean |
WAIT_FOR_SEND_CONTROL |
Constructor and Description |
---|
ConfigurationRequesterCommunicator(AsyncRequestQueue asyncRequestQueue,
ConfigDataModel dataModel,
Authentication authentication,
ClientDavInterface connection) |
ConfigurationRequesterCommunicator(ConfigDataModel dataModel,
Authentication authentication,
ClientDavInterface connection) |
Modifier and Type | Method and Description |
---|---|
(package private) static void |
addObject(Set<ConfigurationObject> relevantObjects,
SystemObject object) |
private void |
appendDataValues(List valueList,
List dataValueList) |
private void |
buildAndSendReply(boolean isWriteRequest,
SystemObject sender,
String senderReference,
ConfigTelegram answer,
ConfigurationRequesterCommunicator.ClientInfo clientInfo) |
private SystemObjectAnswerInfo |
buildIdsToObjectsAnswerInfo(long[] ids,
SystemObject[] objects) |
private ConfigurationAuthority |
getConfigurationAuthority(long id) |
private static long[] |
getIds(List systemObjects) |
private static ArrayList |
getIdsAsLongArrayList(List systemObjects) |
private MetaDataAnswer |
getMetaDataAnswer(Collection<SystemObject> objects,
long protocolVersion)
Ermittelt die Antwort auf die von Applikationen initial gestellte Anfrage nach Meta-Objekten.
|
private ConfigurationObject[] |
getMetaDataObjects()
Ermittelt die Objekte, die in der Antwort auf die von Applikationen initial gestellte Anfrage nach Meta-Objekten enthalten sind.
|
private ConfigurationObject[] |
getMetaDataObjectsMinimal() |
(package private) static DafSystemObject |
getMetaObject(SystemObject object) |
private boolean |
oldDataModel()
Gibt true zurück, wenn die neuen Konfigurationsanfragen nicht verfügbar sind, sonst false.
|
private void |
processRequest(boolean isWriteRequest,
Data data) |
void |
setForeignObjectManager(ForeignObjectManager foreignObjectManager) |
void |
setSimulationHandler(SimulationHandler simulationHandler) |
private static final Debug _debug
private final AsyncRequestQueue _asyncRequestQueue
private final ConfigDataModel _dataModel
private final ClientDavInterface _connection
private final ConfigurationAuthority _configAuthority
private final DataDescription _answerDataDescription
private final DataDescription _writeAnswerDataDescription
private final RemoteRequestManager _remoteRequestManager
private final Authentication _authentication
private final Map _clientInfos
private Map _code2AuthorityMap
private final ConfigurationArea _defaultConfigArea
private final boolean WAIT_FOR_SEND_CONTROL
private final SenderRole SENDER_ROLE
private SystemObject[] _metaDataObjects
private SystemObject[] _metaDataObjectsMinimal
private ForeignObjectManager _foreignObjectManager
private SimulationHandler _simulationHandler
public static final String[] META_TYPES
public static final String[] META_TYPES_MINIMAL
public static final String[] META_OBJECTS_MINIMAL
ConfigurationRequesterCommunicator(ConfigDataModel dataModel, Authentication authentication, ClientDavInterface connection)
ConfigurationRequesterCommunicator(AsyncRequestQueue asyncRequestQueue, ConfigDataModel dataModel, Authentication authentication, ClientDavInterface connection)
private ConfigurationObject[] getMetaDataObjects()
private ConfigurationObject[] getMetaDataObjectsMinimal()
static void addObject(Set<ConfigurationObject> relevantObjects, SystemObject object)
private MetaDataAnswer getMetaDataAnswer(Collection<SystemObject> objects, long protocolVersion)
objects
- Array mit den Konfigurationsobjekten, die in der Antwort enthalten sein sollen.protocolVersion
- public void setForeignObjectManager(ForeignObjectManager foreignObjectManager)
public void setSimulationHandler(SimulationHandler simulationHandler)
private void processRequest(boolean isWriteRequest, Data data) throws IOException, ConfigurationChangeException, DataNotSubscribedException, OneSubscriptionPerSendData, SendSubscriptionNotConfirmed
private boolean oldDataModel()
private SystemObjectAnswerInfo buildIdsToObjectsAnswerInfo(long[] ids, SystemObject[] objects)
private void buildAndSendReply(boolean isWriteRequest, SystemObject sender, String senderReference, ConfigTelegram answer, ConfigurationRequesterCommunicator.ClientInfo clientInfo) throws IOException, SendSubscriptionNotConfirmed
private ConfigurationAuthority getConfigurationAuthority(long id)
private static long[] getIds(List systemObjects)
static DafSystemObject getMetaObject(SystemObject object) throws ConfigurationException
ConfigurationException