public class ForeignConfigRequester extends Object
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 |
Modifier and Type | Field and Description |
---|---|
private ArrayList<ForeignConfigRequester.RemoteObjectRequest> |
_activeObjectRequests |
private CopyOnWriteArrayList<ForeignConfigRequester.ForeignCommunicationStateListener> |
_communicationStateListeners |
private boolean |
_communicationTimedOut |
private boolean |
_communicatorConnected |
private boolean |
_communicatorStarted |
private static Debug |
_debug
DebugLogger für Debug-Ausgaben
|
private ForeignConfigCommunicator |
_foreignConfigCommunicator |
private ForeignObjectManager |
_foreignObjectManager |
private SystemObject |
_localAuthority |
private Map<ForeignConfigRequester.ProxyKey,ForeignMutableCollectionProxy> |
_mutableCollectionProxies |
private AttributeGroup |
_requestAtg |
private int |
_requestIndex |
private Set<ForeignMutableCollectionProxy> |
_subscribedProxies |
private HashMap<Integer,ForeignConfigRequester.DataQueryInfo> |
_waitingObjectDataQueries |
private HashMap<Long,List<ForeignObjectTransferListener>> |
_waitingObjectQueries |
Constructor and Description |
---|
ForeignConfigRequester(ForeignObjectManager foreignObjectManager,
ConfigurationAuthority foreignAuthority,
ForeignConfigReceiveCommunicator foreignConfigReceiveCommunicator) |
private static final Debug _debug
private int _requestIndex
private ForeignObjectManager _foreignObjectManager
private final Map<ForeignConfigRequester.ProxyKey,ForeignMutableCollectionProxy> _mutableCollectionProxies
private ForeignConfigCommunicator _foreignConfigCommunicator
private AttributeGroup _requestAtg
private boolean _communicatorStarted
private boolean _communicatorConnected
private boolean _communicationTimedOut
private Set<ForeignMutableCollectionProxy> _subscribedProxies
private SystemObject _localAuthority
private HashMap<Long,List<ForeignObjectTransferListener>> _waitingObjectQueries
private HashMap<Integer,ForeignConfigRequester.DataQueryInfo> _waitingObjectDataQueries
private CopyOnWriteArrayList<ForeignConfigRequester.ForeignCommunicationStateListener> _communicationStateListeners
private ArrayList<ForeignConfigRequester.RemoteObjectRequest> _activeObjectRequests
public ForeignConfigRequester(ForeignObjectManager foreignObjectManager, ConfigurationAuthority foreignAuthority, ForeignConfigReceiveCommunicator foreignConfigReceiveCommunicator)
public ForeignMutableCollectionProxy getForeignMutableCollectionProxy(short internalSimVariant, MutableCollection mutableCollection)
public 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(Long id, ForeignObjectTransferListener transferListener)
public void queryObjectData(ForeignDynamicObject object)
public void addCommunicationStateListener(ForeignConfigRequester.ForeignCommunicationStateListener listener)
public void removeCommunicationStateListener(ForeignConfigRequester.ForeignCommunicationStateListener listener)
public int sendRequest(String messageType, byte[] data) throws SendSubscriptionNotConfirmed, IllegalStateException
public int sendRequest(String messageType, byte[] data, int requestIndex) throws SendSubscriptionNotConfirmed, 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(Long key)
public boolean isCommunicatorConnected()