Merge pull request #785 from lasanthaDLPDS/master

fixes wso2/product-iots/#1266
revert-dabc3590
Madhawa Perera 7 years ago committed by GitHub
commit b35436797a

@ -73,9 +73,9 @@ $(window).load(function () {
connect(websocketUrl) connect(websocketUrl)
}); });
$(window).unload(function () { window.onbeforeunload = function() {
disconnect(); disconnect();
}); };
//websocket connection //websocket connection
function connect(target) { function connect(target) {

@ -73,13 +73,13 @@ public class EventReceiverServiceImpl implements EventReceiverService {
String eventPayload = eventBeanWrapper.getPayload(); String eventPayload = eventBeanWrapper.getPayload();
JsonObject jsonObject = gson.fromJson(eventPayload, JsonObject.class); JsonObject jsonObject = gson.fromJson(eventPayload, JsonObject.class);
Object payload[] = { Object payload[] = {
jsonObject.get(TIME_STAMP), jsonObject.get(TIME_STAMP).getAsLong(),
jsonObject.get(LONGITUDE), jsonObject.get(LONGITUDE).getAsDouble(),
jsonObject.get(LATITUDE) jsonObject.get(LATITUDE).getAsDouble()
}; };
try { try {
if (AndroidAPIUtils.getEventPublisherService().publishEvent( if (AndroidAPIUtils.getEventPublisherService().publishEvent(
EVENT_STREAM_DEFINITION, "1.0.0", new Object[0], new Object[0], payload)) { EVENT_STREAM_DEFINITION, "1.0.0", metaData, new Object[0], payload)) {
message.setResponseCode("Event is published successfully."); message.setResponseCode("Event is published successfully.");
return Response.status(Response.Status.CREATED).entity(message).build(); return Response.status(Response.Status.CREATED).entity(message).build();
} else { } else {

Loading…
Cancel
Save