private void restoreQueuedSubscription ( String providerId , ProviderContainer providerContainer ) { Collection < PublicationInformation > queuedRequests = queuedSubscriptionRequests . get ( providerId ) ; Iterator < PublicationInformation > queuedRequestsIterator = queuedRequests . iterator ( ) ; while ( queuedRequestsIterator . hasNext ( ) ) { PublicationInformation publicationInformation = queuedRequestsIterator . next ( ) ; queuedRequestsIterator . remove ( ) ; if ( ! isExpired ( publicationInformation ) ) { addSubscriptionRequest ( publicationInformation . getProxyParticipantId ( ) , publicationInformation . getProviderParticipantId ( ) , publicationInformation . subscriptionRequest , providerContainer ) ; } } }
Called every time a provider is registered to check whether there are already subscriptionRequests waiting .