15,6 → 15,10 |
*/ |
package net.brutex.emitter; |
|
import java.io.BufferedReader; |
import java.io.IOException; |
import java.io.InputStreamReader; |
|
import org.apache.http.HttpEntity; |
import org.apache.http.HttpResponse; |
import org.apache.http.client.ClientProtocolException; |
22,12 → 26,9 |
import org.apache.http.client.methods.HttpPost; |
import org.apache.http.impl.client.CloseableHttpClient; |
import org.apache.http.impl.client.HttpClients; |
import org.apache.http.util.EntityUtils; |
import org.apache.log4j.Logger; |
|
import java.io.BufferedReader; |
import java.io.IOException; |
import java.io.InputStreamReader; |
|
/** |
* Construct a HTTP POST and send it. |
* |
51,30 → 52,30 |
this.url = url; |
this.soapBody = soapBody; |
} |
|
|
/** |
* Send soap. |
* |
* @param isDropResponse show interest in response or not |
* @param url the url |
* @param soapBody the soap body |
* @throws ClientProtocolException the client protocol exception |
* @throws IOException Signals that an I/O exception has occurred. |
* @throws IOException Signals that an I/O exception has occurred. |
*/ |
public void sendSoap(boolean isDropResponse) throws ClientProtocolException, IOException { |
long start = System.currentTimeMillis(); |
HttpPost post = new HttpPost(url); |
post.addHeader("Accept", "text/xml"); |
post.addHeader("Content-Type", "text/xml; charset=utf-8"); |
post.addHeader("SOAPAction", ""); |
EntityBuilder entitybuilder = EntityBuilder.create(); |
entitybuilder.setContentEncoding("UTF-8"); |
entitybuilder.setText(soapBody); |
HttpEntity entity = entitybuilder.build(); |
post.setEntity(entity); |
|
CloseableHttpClient httpclient = HttpClients.createDefault(); |
HttpResponse r = httpclient.execute(post); |
logger.debug("Sending event to ALF event manager"); |
if (!isDropResponse) { |
post.addHeader("Accept" , "text/xml"); |
post.addHeader("SOAPAction",""); |
EntityBuilder entitybuilder = EntityBuilder.create(); |
entitybuilder.setContentEncoding("UTF-8"); |
entitybuilder.setText(soapBody); |
HttpEntity entity = entitybuilder.build(); |
post.setEntity(entity); |
|
CloseableHttpClient httpclient = HttpClients.createDefault(); |
HttpResponse r = httpclient.execute(post); |
logger.debug("Sending event to ALF event manager"); |
if(! isDropResponse) { |
HttpEntity e = r.getEntity(); |
StringBuilder sb = new StringBuilder(); |
BufferedReader in = new BufferedReader(new InputStreamReader(e.getContent())); |