bpmn/MSOCommonBPMN/src/test/java/org/openecomp/mso/bpmn/common/SDNCAdapterCallbackRule.java


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

package org.openecomp.mso.bpmn.common;

import javax.xml.ws.Endpoint;

import org.camunda.bpm.engine.ProcessEngineServices;
import org.junit.rules.TestRule;
import org.junit.runner.Description;
import org.junit.runners.model.Statement;
import org.openecomp.mso.bpmn.common.workflow.service.SDNCAdapterCallbackServiceImpl;

/**
 * A JUnit rule that starts the SDNC Adapter Callback Service before
 * every test, and tears it down after every test.  Example:
 * <pre>
 *     @Rule
 *     public final SDNCAdapterCallbackRule sdncAdapterCallbackRule =
 *         new SDNCAdapterCallbackRule(processEngineRule);
 * </pre>
 */
public class SDNCAdapterCallbackRule implements TestRule {
	public static final String DEFAULT_ENDPOINT_URL =
		"http://localhost:28080/mso/SDNCAdapterCallbackService";

	private final ProcessEngineServices processEngineServices;
	private final String endpointUrl;

	public SDNCAdapterCallbackRule(ProcessEngineServices processEngineServices) {
		this(processEngineServices, DEFAULT_ENDPOINT_URL);
	}

	public SDNCAdapterCallbackRule(ProcessEngineServices processEngineServices,
			String endpointUrl) {
		this.processEngineServices = processEngineServices;
		this.endpointUrl = endpointUrl;
	}

	@Override
	public Statement apply(final Statement baseStmt, Description description) {
		return new Statement() {
			@Override
			public void evaluate() throws Throwable {
				Endpoint endpoint = null;

				try {
					SDNCAdapterCallbackServiceImpl sdncCallbackService = new SDNCAdapterCallbackServiceImpl();
					sdncCallbackService.setProcessEngineServices4junit(processEngineServices);

					System.setProperty("com.sun.xml.ws.transport.http.HttpAdapter.dump", "true");
					System.setProperty("com.sun.xml.internal.ws.transport.http.HttpAdapter.dump", "true");

					System.out.println("Publishing Endpoint - " + endpointUrl);
					endpoint = Endpoint.publish(endpointUrl, sdncCallbackService);

					baseStmt.evaluate();
				} finally {
					if (endpoint != null) {
						System.out.println("Stopping Endpoint - " + endpointUrl);
						endpoint.stop();
					}
				}
			}
		};
	}
}