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
|
/*******************************************************************************
* Copyright (c) 2009 EclipseSource 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:
* EclipseSource - initial API and implementation
******************************************************************************/
package org.eclipse.ecf.tests.osgi.services.distribution;
import java.util.Collection;
import java.util.Dictionary;
import java.util.Hashtable;
import junit.framework.TestCase;
import org.eclipse.ecf.core.IContainer;
import org.eclipse.ecf.core.IContainerManager;
import org.eclipse.ecf.osgi.services.discovery.RemoteServicePublication;
import org.eclipse.ecf.osgi.services.discovery.ServicePublication;
import org.eclipse.ecf.osgi.services.distribution.IDistributionConstants;
import org.eclipse.ecf.tests.internal.osgi.services.distribution.Activator;
import org.osgi.framework.BundleContext;
import org.osgi.framework.ServiceReference;
import org.osgi.framework.ServiceRegistration;
import org.osgi.util.tracker.ServiceTracker;
public abstract class AbstractServicePublicationTest extends TestCase implements IDistributionConstants, RemoteServicePublication {
protected static void assertStringsEqual(final String[] s1, final String[] s2) {
assertEquals(s1.length, s2.length);
for (int i = 0; i < s1.length; i++) {
assertEquals(s1[i], s2[i]);
}
}
// Member variables that should be set by subclasses
protected IContainer container;
protected String[] ifaces;
protected ServiceRegistration registration;
protected abstract IContainer createContainer() throws Exception;
protected abstract String[] createInterfaces() throws Exception;
protected ServiceReference reference;
public ServiceReference getReference() {
return reference;
}
protected void setUp() throws Exception {
super.setUp();
setContainer(createContainer());
setInterfaces(createInterfaces());
}
void removeFromContainerManager(IContainer container) {
ServiceTracker st = new ServiceTracker(Activator.getDefault().getContext(),IContainerManager.class.getName(),null);
st.open();
IContainerManager containerManager = (IContainerManager) st.getService();
if (containerManager != null) {
containerManager.removeContainer(container);
}
st.close();
}
protected void tearDown() throws Exception {
super.tearDown();
if (container != null) {
container.dispose();
removeFromContainerManager(container);
container = null;
}
if (ifaces != null) {
ifaces = null;
}
if (registration != null) {
try {
registration.unregister();
registration = null;
} catch (Exception e) {
e.printStackTrace();
}
}
}
public IContainer getContainer() {
return container;
}
public String[] getInterfaces() {
return ifaces;
}
public void setContainer(IContainer container) {
this.container = container;
}
public void testServicePublication() throws InterruptedException {
final BundleContext context = Activator.getDefault().getContext();
// register a service with the marker property set
final Dictionary props = new Hashtable();
props.put(IDistributionConstants.SERVICE_EXPORTED_INTERFACES, getInterfaces());
// prepare a service tracker
final ServiceTracker tracker = new ServiceTracker(context,
TestServiceInterface1.class.getName(), null);
tracker.open();
// register the (remote-enabled) service
registration = context.registerService(TestServiceInterface1.class.getName(),
new TestService1(), props);
// wait for service to become registered
tracker.waitForService(10000);
// expected behavior: an endpoint is published
final ServiceReference ref = context
.getServiceReference(ServicePublication.class.getName());
assertTrue(ref != null);
// check the service publication properties
final Object o = ref
.getProperty(ServicePublication.SERVICE_INTERFACE_NAME);
assertTrue(o instanceof Collection);
final Collection refIfaces = (Collection) o;
assertStringsEqual(getInterfaces(), (String []) refIfaces.toArray(new String[] {}));
Thread.sleep(10000);
}
public void setInterfaces(String [] interfaces) {
this.ifaces = interfaces;
}
}
|
