public class ForeignConfigRequester
extends java.lang.Object
TBD RS dokumentieren.
Modifier and Type | Class and Description |
---|---|
(package private) class |
ForeignConfigRequester.CommunicationHandler |
private class |
ForeignConfigRequester.DataQueryInfo |
static interface |
ForeignConfigRequester.ForeignCommunicationStateListener |
(package private) static class |
ForeignConfigRequester.ProxyKey |
static interface |
ForeignConfigRequester.RemoteObjectRequest |
Constructor and Description |
---|
ForeignConfigRequester(ForeignObjectManager foreignObjectManager,
ConfigurationAuthority foreignAuthority,
ForeignConfigReceiveCommunicator foreignConfigReceiveCommunicator) |
private static final Debug _debug
DebugLogger für Debug-Ausgaben
private int _requestIndex
private ForeignObjectManager _foreignObjectManager
private final java.util.Map<ForeignConfigRequester.ProxyKey,ForeignMutableCollectionProxy> _mutableCollectionProxies
private ForeignConfigCommunicator _foreignConfigCommunicator
private AttributeGroup _requestAtg
private boolean _communicatorStarted
private boolean _communicatorConnected
private boolean _communicationTimedOut
private java.util.Set<ForeignMutableCollectionProxy> _subscribedProxies
private SystemObject _localAuthority
private java.util.HashMap<java.lang.Long,java.util.List<ForeignObjectTransferListener>> _waitingObjectQueries
private java.util.HashMap<java.lang.Integer,ForeignConfigRequester.DataQueryInfo> _waitingObjectDataQueries
private java.util.concurrent.CopyOnWriteArrayList<ForeignConfigRequester.ForeignCommunicationStateListener> _communicationStateListeners
private java.util.ArrayList<ForeignConfigRequester.RemoteObjectRequest> _activeObjectRequests
public ForeignConfigRequester(ForeignObjectManager foreignObjectManager, ConfigurationAuthority foreignAuthority, ForeignConfigReceiveCommunicator foreignConfigReceiveCommunicator)
public java.lang.String toString()
toString
in class java.lang.Object
public ForeignMutableCollectionProxy getForeignMutableCollectionProxy(short internalSimVariant, MutableCollection mutableCollection)
public java.util.concurrent.ScheduledExecutorService getExecutor()
public void subscribe(ForeignMutableCollectionProxy proxy)
public void activateObjectRequest(ForeignConfigRequester.RemoteObjectRequest remoteObjectRequest)
public boolean isStartedAndUnconnectedAndTimedOut()
public void subscribeProxyOrActivateObjectRequest(ForeignMutableCollectionProxy proxy, ForeignConfigRequester.RemoteObjectRequest remoteObjectRequest)
public void unsubscribe(ForeignMutableCollectionProxy proxy)
public void deactivateObjectRequest(ForeignConfigRequester.RemoteObjectRequest remoteObjectRequest)
public ForeignObjectManager getForeignObjectManager()
public void queryObject(java.lang.Long id, ForeignObjectTransferListener transferListener)
public void queryObjectData(ForeignDynamicObject object)
public void addCommunicationStateListener(ForeignConfigRequester.ForeignCommunicationStateListener listener)
public void removeCommunicationStateListener(ForeignConfigRequester.ForeignCommunicationStateListener listener)
public int sendRequest(java.lang.String messageType, byte[] data) throws SendSubscriptionNotConfirmed, java.lang.IllegalStateException
SendSubscriptionNotConfirmed
java.lang.IllegalStateException
public int sendRequest(java.lang.String messageType, byte[] data, int requestIndex) throws SendSubscriptionNotConfirmed, java.lang.IllegalStateException
SendSubscriptionNotConfirmed
java.lang.IllegalStateException
public int getNewRequestIndex()
void sendSubscription(ForeignMutableCollectionProxy proxy)
private void sendObjectQuery(long id)
private void sendObjectDataQuery(ForeignDynamicObject object)
private void notifyObjectDataComplete(long id, ForeignDynamicObject foreignDynamicObject)
public void notifyObjectDataTimeout(long id)
private void notifyObjectQueryDone(java.lang.Long key)
public boolean isCommunicatorConnected()