@ Override public void createConnector ( ArbitrationResult result ) { connector = connectorFactory . create ( proxyParticipantId , result , qosSettings , statelessAsyncParticipantId ) ; connectorStatusLock . lock ( ) ; try { connectorStatus = ConnectorStatus . ConnectorSuccesful ; connectorSuccessfullyFinished . signalAll ( ) ; if ( connector != null ) { sendQueuedInvocations ( ) ; sendQueuedSubscriptionInvocations ( ) ; sendQueuedUnsubscribeInvocations ( ) ; sendQueuedStatelessAsyncInvocations ( ) ; } } finally { connectorStatusLock . unlock ( ) ; } }
Sets the connector for this ProxyInvocationHandler after the DiscoveryAgent got notified about a successful arbitration . Should be called from the DiscoveryAgent