diff options
Diffstat (limited to 'incubation')
| -rw-r--r-- | incubation/bundles/org.eclipse.ecf.osgi.services.remoteserviceadmin/src/org/eclipse/ecf/osgi/services/remoteserviceadmin/AbstractTopologyManager.java | 13 |
1 files changed, 9 insertions, 4 deletions
diff --git a/incubation/bundles/org.eclipse.ecf.osgi.services.remoteserviceadmin/src/org/eclipse/ecf/osgi/services/remoteserviceadmin/AbstractTopologyManager.java b/incubation/bundles/org.eclipse.ecf.osgi.services.remoteserviceadmin/src/org/eclipse/ecf/osgi/services/remoteserviceadmin/AbstractTopologyManager.java index ad70d0977..8882477af 100644 --- a/incubation/bundles/org.eclipse.ecf.osgi.services.remoteserviceadmin/src/org/eclipse/ecf/osgi/services/remoteserviceadmin/AbstractTopologyManager.java +++ b/incubation/bundles/org.eclipse.ecf.osgi.services.remoteserviceadmin/src/org/eclipse/ecf/osgi/services/remoteserviceadmin/AbstractTopologyManager.java @@ -54,7 +54,7 @@ public abstract class AbstractTopologyManager { return context;
}
- protected IEndpointDescriptionAdvertiser getEndpointDescriptionAdvertiser() {
+ protected IEndpointDescriptionAdvertiser getEndpointDescriptionAdvertiser(EndpointDescription endpointDescription) {
synchronized (endpointDescriptionAdvertiserTrackerLock) {
if (endpointDescriptionAdvertiserTracker == null) {
endpointDescriptionAdvertiserTracker = new ServiceTracker(
@@ -125,7 +125,7 @@ public abstract class AbstractTopologyManager { protected void advertiseEndpointDescription(
EndpointDescription endpointDescription) {
- IEndpointDescriptionAdvertiser advertiser = getEndpointDescriptionAdvertiser();
+ IEndpointDescriptionAdvertiser advertiser = getEndpointDescriptionAdvertiser(endpointDescription);
if (advertiser == null) {
logWarning("advertiseExportedRegistration",
"No endpoint description advertiser available for endpointDescription="
@@ -143,7 +143,7 @@ public abstract class AbstractTopologyManager { protected void unadvertiseEndpointDescription(
EndpointDescription endpointDescription) {
- IEndpointDescriptionAdvertiser advertiser = getEndpointDescriptionAdvertiser();
+ IEndpointDescriptionAdvertiser advertiser = getEndpointDescriptionAdvertiser(endpointDescription);
if (advertiser == null) {
logError(
"unadvertiseEndpointDescription",
@@ -328,7 +328,12 @@ public abstract class AbstractTopologyManager { }
}
}
- // adversitise valid exported registrations
+ // advertise valid exported registrations
+ advertiseEndpointDescriptions(endpointDescriptions);
+ }
+
+ protected void advertiseEndpointDescriptions(
+ List<EndpointDescription> endpointDescriptions) {
for (EndpointDescription ed : endpointDescriptions)
advertiseEndpointDescription(ed);
}
|