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
|
/*******************************************************************************
* Copyright (c) 2004 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.provider.remoteservice.generic;
import java.util.Dictionary;
import org.eclipse.ecf.core.ContainerConnectException;
import org.eclipse.ecf.core.identity.ID;
import org.eclipse.ecf.core.identity.Namespace;
import org.eclipse.ecf.core.security.IConnectContext;
import org.eclipse.ecf.core.sharedobject.ISharedObjectContainerConfig;
import org.eclipse.ecf.provider.generic.TCPClientSOContainer;
import org.eclipse.ecf.remoteservice.*;
import org.eclipse.equinox.concurrent.future.IFuture;
import org.osgi.framework.InvalidSyntaxException;
public class RemoteServiceContainer extends TCPClientSOContainer implements IRemoteServiceContainerAdapter {
protected IRemoteServiceContainerAdapter registry;
protected void createRegistry() {
registry = new RegistrySharedObject();
}
public RemoteServiceContainer(ISharedObjectContainerConfig config) {
super(config);
createRegistry();
}
public RemoteServiceContainer(ISharedObjectContainerConfig config, int ka) {
super(config, ka);
createRegistry();
}
public void addRemoteServiceListener(IRemoteServiceListener listener) {
registry.addRemoteServiceListener(listener);
}
public IRemoteService getRemoteService(IRemoteServiceReference ref) {
return registry.getRemoteService(ref);
}
public IRemoteServiceReference[] getRemoteServiceReferences(ID[] idFilter, String clazz, String filter) throws InvalidSyntaxException {
return registry.getRemoteServiceReferences(idFilter, clazz, filter);
}
public IRemoteServiceRegistration registerRemoteService(String[] clazzes, Object service, Dictionary properties) {
return registry.registerRemoteService(clazzes, service, properties);
}
public void removeRemoteServiceListener(IRemoteServiceListener listener) {
registry.removeRemoteServiceListener(listener);
}
public boolean ungetRemoteService(IRemoteServiceReference ref) {
return registry.ungetRemoteService(ref);
}
/**
* @since 3.0
*/
public IFuture asyncGetRemoteServiceReferences(ID[] idFilter, String clazz, String filter) {
return registry.asyncGetRemoteServiceReferences(idFilter, clazz, filter);
}
/**
* @since 3.0
*/
public Namespace getRemoteServiceNamespace() {
return registry.getRemoteServiceNamespace();
}
/**
* @since 3.0
*/
public IRemoteFilter createRemoteFilter(String filter) throws InvalidSyntaxException {
return registry.createRemoteFilter(filter);
}
/**
* @since 3.0
*/
public IRemoteServiceReference getRemoteServiceReference(IRemoteServiceID serviceID) {
return registry.getRemoteServiceReference(serviceID);
}
/**
* @since 3.0
*/
public IRemoteServiceID getRemoteServiceID(ID containerID, long containerRelativeID) {
return registry.getRemoteServiceID(containerID, containerRelativeID);
}
/**
* @since 3.0
*/
public void setConnectContextForAuthentication(IConnectContext connectContext) {
registry.setConnectContextForAuthentication(connectContext);
}
/**
* @since 3.0
*/
public IRemoteServiceReference[] getRemoteServiceReferences(ID target, String clazz, String filter) throws InvalidSyntaxException, ContainerConnectException {
return registry.getRemoteServiceReferences(target, clazz, filter);
}
/**
* @since 3.0
*/
public IFuture asyncGetRemoteServiceReferences(ID target, String clazz, String filter) {
return registry.asyncGetRemoteServiceReferences(target, clazz, filter);
}
/**
* @since 3.0
*/
public IRemoteServiceReference[] getAllRemoteServiceReferences(String clazz, String filter) throws InvalidSyntaxException {
return registry.getAllRemoteServiceReferences(clazz, filter);
}
}
|
