1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
|
/*******************************************************************************
* Copyright (c) 2010-2011 Composent, Inc. and others. All rights reserved. This
* program and the accompanying materials are made available under the terms of
* the Eclipse Public License v1.0 which accompanies this distribution, and is
* available at http://www.eclipse.org/legal/epl-v10.html
*
* Contributors:
* Composent, Inc. - initial API and implementation
******************************************************************************/
package org.eclipse.ecf.osgi.services.remoteserviceadmin;
import java.util.ArrayList;
import java.util.List;
import org.eclipse.core.runtime.Assert;
import org.eclipse.core.runtime.IStatus;
import org.eclipse.core.runtime.MultiStatus;
import org.eclipse.core.runtime.Status;
import org.eclipse.ecf.discovery.IDiscoveryAdvertiser;
import org.eclipse.ecf.discovery.IServiceInfo;
import org.eclipse.ecf.internal.osgi.services.remoteserviceadmin.Activator;
import org.osgi.service.remoteserviceadmin.EndpointDescription;
public class EndpointDescriptionAdvertiser implements
IEndpointDescriptionAdvertiser {
private EndpointDescriptionLocator endpointDescriptionLocator;
public EndpointDescriptionAdvertiser(
EndpointDescriptionLocator endpointDescriptionLocator) {
this.endpointDescriptionLocator = endpointDescriptionLocator;
}
public IStatus advertise(EndpointDescription endpointDescription) {
return doDiscovery(endpointDescription, true);
}
protected IStatus doDiscovery(IDiscoveryAdvertiser discoveryAdvertiser,
IServiceInfo serviceInfo, boolean advertise) {
try {
if (advertise)
discoveryAdvertiser.registerService(serviceInfo);
else
discoveryAdvertiser.unregisterService(serviceInfo);
return Status.OK_STATUS;
} catch (Exception e) {
return createErrorStatus((advertise ? "registerService"
: "unregisterService")
+ " with serviceInfo="
+ serviceInfo
+ " for discoveryAdvertiser="
+ discoveryAdvertiser
+ " failed", e);
}
}
protected IServiceInfoFactory getServiceInfoFactory() {
return endpointDescriptionLocator.getServiceInfoFactory();
}
protected IDiscoveryAdvertiser[] getDiscoveryAdvertisers() {
return endpointDescriptionLocator.getDiscoveryAdvertisers();
}
protected IStatus createErrorStatus(String message) {
return createErrorStatus(message, null);
}
protected IStatus createErrorStatus(String message, Throwable e) {
return new Status(IStatus.ERROR, Activator.PLUGIN_ID, message, e);
}
protected IStatus doDiscovery(EndpointDescription endpointDescription,
boolean advertise) {
Assert.isNotNull(endpointDescription);
String messagePrefix = advertise ? "Advertise" : "Unadvertise";
List<IStatus> statuses = new ArrayList<IStatus>();
if (endpointDescription instanceof org.eclipse.ecf.osgi.services.remoteserviceadmin.EndpointDescription) {
org.eclipse.ecf.osgi.services.remoteserviceadmin.EndpointDescription eed = (org.eclipse.ecf.osgi.services.remoteserviceadmin.EndpointDescription) endpointDescription;
// First get serviceInfoFactory
IServiceInfoFactory serviceInfoFactory = getServiceInfoFactory();
if (serviceInfoFactory == null)
return createErrorStatus(messagePrefix
+ " endpointDescription="
+ endpointDescription
+ ". No IServiceInfoFactory is available. Cannot unpublish endpointDescription="
+ eed);
IDiscoveryAdvertiser[] discoveryAdvertisers = getDiscoveryAdvertisers();
if (discoveryAdvertisers == null
|| discoveryAdvertisers.length == 0)
return createErrorStatus(messagePrefix
+ " endpointDescription="
+ endpointDescription
+ ". No endpointDescriptionLocator advertisers available. Cannot unpublish endpointDescription="
+ eed);
for (int i = 0; i < discoveryAdvertisers.length; i++) {
IServiceInfo serviceInfo = (advertise ? serviceInfoFactory
.createServiceInfoForDiscovery(discoveryAdvertisers[i],
eed) : serviceInfoFactory
.removeServiceInfoForUndiscovery(
discoveryAdvertisers[i], eed));
if (serviceInfo == null) {
statuses.add(createErrorStatus(messagePrefix
+ " endpointDescription="
+ endpointDescription
+ ". Service Info is null. Cannot publish endpointDescription="
+ eed));
continue;
}
// Now actually unregister with advertiser
statuses.add(doDiscovery(discoveryAdvertisers[i], serviceInfo,
advertise));
}
} else {
statuses.add(createErrorStatus(messagePrefix
+ " endpointDescription="
+ endpointDescription
+ " is not of understood EndpointDescription type. Not advertising."));
}
return createResultStatus(statuses, messagePrefix
+ " endpointDesription=" + endpointDescription
+ ". Problem in unadvertise");
}
public IStatus unadvertise(EndpointDescription endpointDescription) {
return doDiscovery(endpointDescription, false);
}
private IStatus createResultStatus(List<IStatus> statuses,
String errorMessage) {
List<IStatus> errorStatuses = new ArrayList<IStatus>();
for (IStatus status : statuses)
if (!status.isOK())
errorStatuses.add(status);
if (errorStatuses.size() > 0)
return new MultiStatus(Activator.PLUGIN_ID, IStatus.ERROR,
(IStatus[]) statuses.toArray(new IStatus[statuses.size()]), errorMessage, null);
else
return Status.OK_STATUS;
}
public void close() {
this.endpointDescriptionLocator = null;
}
}
|
