gCubeSystem
/
event-publisher-library
16
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

EventSender now sends Event instead of its superclass JSONObject

This commit is contained in:
Mauro Mugnaini 2020-06-23 13:09:44 +02:00
parent fc227213ef
commit b1d6ce25e3
2 changed files with 7 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/org/gcube/event/publisher/EventSender.java
View File

@ -1,9 +1,7 @@
package org.gcube.event.publisher; package org.gcube.event.publisher;
import org.json.simple.JSONObject;
public interface EventSender { public interface EventSender {
void send(JSONObject event); void send(Event event);
} }

13
src/main/java/org/gcube/event/publisher/HTTPEventSender.java
View File

@ -8,7 +8,6 @@ import java.net.URL;
import org.gcube.oidc.rest.JWTToken; import org.gcube.oidc.rest.JWTToken;
import org.gcube.oidc.rest.OpenIdConnectRESTHelper; import org.gcube.oidc.rest.OpenIdConnectRESTHelper;
import org.json.simple.JSONObject;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@ -29,19 +28,19 @@ public class HTTPEventSender implements EventSender {
} }
@Override @Override
public void send(JSONObject event) { public void send(Event event) {
if (log.isDebugEnabled()) { if (log.isDebugEnabled()) {
log.debug("Starting HTTP POST thread to: " + endpoint); log.debug("Starting HTTP POST thread to: " + endpoint);
} }
new Thread(new HTTPost(event)).start(); new Thread(new HTTPost(event.toJSONString())).start();
} }
public class HTTPost implements Runnable { public class HTTPost implements Runnable {
private JSONObject data; private String json;
public HTTPost(JSONObject data) { public HTTPost(String json) {
this.data = data; this.json = json;
} }
@Override @Override
@ -65,7 +64,7 @@ public class HTTPEventSender implements EventSender {
if (log.isTraceEnabled()) { if (log.isTraceEnabled()) {
log.trace("Sending event JSON"); log.trace("Sending event JSON");
} }
os.write(data.toJSONString().getBytes("UTF-8")); os.write(json.getBytes("UTF-8"));
os.close(); os.close();
StringBuilder sb = new StringBuilder(); StringBuilder sb = new StringBuilder();