Subversion Repositories XServices

Rev

Rev 201 | Show entire file | Regard whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 201 Rev 203
Line 20... Line 20...
20
import org.apache.http.HttpEntity;
20
import org.apache.http.HttpEntity;
21
import org.apache.http.client.ClientProtocolException;
21
import org.apache.http.client.ClientProtocolException;
22
import org.apache.http.client.entity.EntityBuilder;
22
import org.apache.http.client.entity.EntityBuilder;
23
import org.apache.http.client.fluent.Request;
23
import org.apache.http.client.fluent.Request;
24
import org.apache.http.client.fluent.Response;
24
import org.apache.http.client.fluent.Response;
-
 
25
import org.apache.http.entity.ContentType;
Line 25... Line 26...
25
 
26
 
26
import java.io.BufferedReader;
27
import java.io.BufferedReader;
27
import java.io.IOException;
28
import java.io.IOException;
28
import java.io.InputStreamReader;
29
import java.io.InputStreamReader;
-
 
30
import java.io.Reader;
-
 
31
import java.nio.charset.Charset;
29
import java.io.Reader;
32
import java.nio.charset.StandardCharsets;
Line 30... Line 33...
30
import java.util.concurrent.atomic.AtomicBoolean;
33
import java.util.concurrent.atomic.AtomicBoolean;
31
 
34
 
Line 67... Line 70...
67
		 * @throws IOException             Signals that an I/O exception has occurred.
70
		 * @throws IOException             Signals that an I/O exception has occurred.
68
		 */
71
		 */
69
		public Reader sendSoap(boolean isDropResponse) {
72
		public Reader sendSoap(boolean isDropResponse) {
70
			Reader response = null;
73
			Reader response = null;
71
			long start = System.currentTimeMillis();
74
			long start = System.currentTimeMillis();
-
 
75
 
72
			EntityBuilder entitybuilder = EntityBuilder.create();
76
			HttpEntity entity = EntityBuilder.create()
-
 
77
					.setText(soapBody)
73
			entitybuilder.setContentEncoding("UTF-8");
78
					.setContentType(ContentType.create("text/xml", StandardCharsets.UTF_8))
74
			entitybuilder.setText(soapBody);
79
					.setContentEncoding("UTF-8")
75
			HttpEntity entity = entitybuilder.build();
80
					.build();
Line 76... Line 81...
76
 
81
 
Line 77... Line 82...
77
			log.trace("Sending event '{}' to target ALF Event Manager.", id);
82
			log.trace("Sending event '{}' to target ALF Event Manager.", id);
Line 78... Line 83...
78
 
83
 
79
			if(isInterrupted.get()) return null;
84
			if(isInterrupted.get()) return null;
80
 
85
 
81
			try {
86
			try {
82
				Response resp = Request.Post(url)
87
				Response resp = Request.Post(url)
83
						.addHeader("Accept", "text/xml")
88
						.addHeader("Accept", "text/xml")
Line 84... Line 89...
84
						.addHeader("Content-Type", "text/xml; charset=utf-8")
89
						//.addHeader("Content-Type", "text/xml; charset=utf-8")
85
						.addHeader("SOAPAction", "")
90
						.addHeader("SOAPAction", "")