rest - Mule 3.6 and Server Sent Events -

-

i trying add server sent events rest component of mule 3.6 esb flow. having trouble getting data browser. connect java method after eventsource sent error occurs in browser. appreciated. 

<http:listener-config name="http_listener_configuration" host="0.0.0.0" port="8082" doc:name="http listener configuration"/>  <flow name="restservice" > <http:listener config-ref="http_listener_configuration" path="/*" doc:name="http"> <http:response-builder> <http:header headername="access-control-allow-origin" value="*"/> <http:header headername="access-control-allow-methods" value="get,post"/> </http:response-builder> </http:listener> <jersey:resources doc:name="rest"> <component> <spring-object bean="restservice"/> </component> </jersey:resources> </flow>

java code using example on jersey 2 sse 

@get @path("/notifications") @produces(ssefeature.server_sent_events) public eventoutput getnotificationevents() { final eventoutput eventoutput = new eventoutput();           new thread(new runnable() {          @override          public void run() {             try {                  (int = 0; < 10; i++) {                       // ... code waits 1 second                       final outboundevent.builder eventbuilder                              = new outboundevent.builder();                       eventbuilder.name("message-to-client");                       eventbuilder.data(string.class,                       "hello world " + + "!");                       final outboundevent event = eventbuilder.build();                       eventoutput.write(event);                   }              } catch (ioexception e) {                     throw new runtimeexception(                           "error when writing event.", e);              } {                   try {                         eventoutput.close();                   } catch (ioexception ioclose) {                       throw new runtimeexception(                        "error when closing event output.", ioclose);                   }              }           }        }).start();        return eventoutput;  }

javascript connection code 

var notifications= new eventsource("http://localhost:8082/notifications");  notifications.onopen = function (e) {       console.log("waiting message.."); }; notifications.onerror = function (e) {       console.log("error");       console.log(e); };  notifications.onmessage=function (e) {        console.log(e); };

javascript console logs onopen waiting message.. error , e event following. bubbles: false cancelbubble: false cancelable: false currenttarget: eventsource defaultprevented: false eventphase: 0 path: array[0] returnvalue: true srcelement: eventsource target: eventsource timestamp: 1433120172045 type: "error"


Comments

Post a Comment

Popular posts from this blog

Java 3D LWJGL collision -

-
i making 3d java game lwjgl library, , wondering how add collision detection, player not go through models. i using obj models. here objloader class, loads models: package renderengine; import java.io.bufferedreader; import java.io.file; import java.io.filenotfoundexception; import java.io.filereader; import java.util.arraylist; import java.util.list; import models.rawmodel; import org.lwjgl.util.vector.vector2f; import org.lwjgl.util.vector.vector3f; public class objloader { public static rawmodel loadobjmodel(string filename, loader loader){ filereader fr = null; try { fr = new filereader(new file("res/"+filename+".obj")); } catch (filenotfoundexception e) { system.err.println("couldn't load file!"); e.printstacktrace(); } bufferedreader reader = new bufferedreader(fr); string line; list<vector3f> vertices = new arraylist<vector3f...
Read more

spring - SubProtocolWebSocketHandler - No handlers -

-
i have ugly error during deploying spring app on jboss. 18:11:16,025 error [org.apache.catalina.core.containerbase.[jboss.web].[default-host].[/consumer]] (msc service thread 1-7) exception sending context initialized event listener instance of class org.springframework.web.context.contextloaderlistener: org.springframework.context.applicationcontextexception: failed start bean 'subprotocolwebsockethandler'; nested exception java.lang.illegalargumentexception: no handlers @ org.springframework.context.support.defaultlifecycleprocessor.dostart(defaultlifecycleprocessor.java:176) [spring-context-4.1.3.release.jar:4.1.3.release] @ org.springframework.context.support.defaultlifecycleprocessor.access$200(defaultlifecycleprocessor.java:51) [spring-context-4.1.3.release.jar:4.1.3.release] @ org.springframework.context.support.defaultlifecycleprocessor$lifecyclegroup.start(defaultlifecycleprocessor.java:346) [spring-context-4.1.3.release.jar:4.1.3.release] @ org.s...
Read more

methods - python can't use function in submodule -

-
my folder structure this: pythonstuff/ program.py modulea/ __init__.py foo.py bar.py here's code bar.py : def hello(): print("hello, world!") here's code program.py : #!/usr/bin/env python3 modulea import bar bar.hello() i run $ python3 program.py somehow error: file "program.py", line 3, in <module> bar.hello() attributeerror: 'module' object has no attribute 'hello' edit: __init__.py file empty. edit2: after trying realized had bar.py in root directory contained hello() method. bar.py in modulea/ directory empty. add it import os __all__ = [] module in os.listdir(os.path.dirname(__file__)): if module != '__init__.py' , module[-3:] == '.py': __all__.append(module[:-3]) the init .py files required make python treat directories containing packages; done prevent directories common name, such string, unintentionally hiding v...
Read more