blob: 262a3135189b4022f40ece487b4816f7d9c43dd9 (
plain) (
blame)
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
|
/****************************************************************************
* Copyright (c) 2010-2011 Composent, Inc. and others.
*
* This program and the accompanying materials are made
* available under the terms of the Eclipse Public License 2.0
* which is available at https://www.eclipse.org/legal/epl-2.0/
*
* Contributors:
* Composent, Inc. - initial API and implementation
*
* SPDX-License-Identifier: EPL-2.0
*****************************************************************************/
package org.eclipse.ecf.osgi.services.remoteserviceadmin;
import java.util.List;
import org.eclipse.ecf.core.identity.ID;
import org.eclipse.ecf.internal.osgi.services.remoteserviceadmin.PropertiesUtil;
import org.eclipse.ecf.remoteservice.IRemoteServiceContainer;
/**
* Default implementation of {@link IConsumerContainerSelector}.
*
*/
public class ConsumerContainerSelector extends
AbstractConsumerContainerSelector implements IConsumerContainerSelector {
private static final boolean reuseExistingContainers = new Boolean(
System.getProperty(
"org.eclipse.ecf.osgi.services.remoteserviceadmin.ConsumerContainerSelector.reuseExistingContainers", //$NON-NLS-1$
"true")).booleanValue(); //$NON-NLS-1$
private boolean autoCreateContainer = false;
public ConsumerContainerSelector(boolean autoCreateContainer) {
this.autoCreateContainer = autoCreateContainer;
}
public IRemoteServiceContainer selectConsumerContainer(
EndpointDescription endpointDescription)
throws SelectContainerException {
trace("selectConsumerContainer", "endpointDescription=" + endpointDescription); //$NON-NLS-1$ //$NON-NLS-2$
// Get service.imported.configs
List<String> sic = PropertiesUtil
.getStringPlusProperty(
endpointDescription.getProperties(),
org.osgi.service.remoteserviceadmin.RemoteConstants.SERVICE_IMPORTED_CONFIGS);
String[] serviceImportedConfigs = sic.toArray(new String[sic.size()]);
// Get the endpointID
ID endpointContainerID = endpointDescription.getContainerID();
// Get connect targetID
ID connectTargetID = endpointDescription.getConnectTargetID();
IRemoteServiceContainer rsContainer = (reuseExistingContainers) ? selectExistingConsumerContainer(
endpointContainerID, serviceImportedConfigs, connectTargetID)
: null;
// If we haven't found any existing containers then we create one
// from the remoteSupportedConfigs...*iff* autoCreateContainer is
// set to true
if (rsContainer == null && autoCreateContainer)
rsContainer = createAndConfigureConsumerContainer(
serviceImportedConfigs, endpointDescription.getProperties());
// Get the connect target ID from the endpointDescription
// and connect the given containers to the connect targetID
// This is only needed when when the endpointID is different from
// the connect targetID, and the containers are not already
// connected
connectContainerToTarget(rsContainer, connectTargetID);
trace("selectConsumerContainer", "rsContainer selected=" + rsContainer); //$NON-NLS-1$ //$NON-NLS-2$
return rsContainer;
}
public void close() {
}
}
|
