bayeux - CometD Issues with Publishing Data -



bayeux - CometD Issues with Publishing Data -

i'm new cometd , having problems publishing info on channel. i'm getting next error not invoking handshake() on channel:

sender : null sender : l:/abc/1? exception in thread "thread-9" java.lang.illegalstateexception: method handshake() not invoked local session l:/abc/1? @ org.cometd.server.localsessionimpl.getid(localsessionimpl.java:161) @ org.cometd.server.serverchannelimpl.publish(serverchannelimpl.java:309) @ packagename.cometdsender.senddata(cometdsender.java:64) @ packagename.processorimp.processdata(processorimp.java:18) @ packagename.testsource.processnewdata(testsource.java:50) @ packagename.testsource.run(testsource.java:36) @ java.lang.thread.run(unknown source)

but when include sender.handshake() next exception

sender : null sender : l:/abc/1? exception in thread "thread-9" java.lang.nullpointerexception @ org.cometd.server.bayeuxserverimpl.freeze(bayeuxserverimpl.java:868) @ org.cometd.server.bayeuxserverimpl.dopublish(bayeuxserverimpl.java:823) @ org.cometd.server.bayeuxserverimpl.handle(bayeuxserverimpl.java:649) @ org.cometd.server.localsessionimpl.dosend(localsessionimpl.java:214) @ org.cometd.server.localsessionimpl.handshake(localsessionimpl.java:125) @ org.cometd.server.localsessionimpl.handshake(localsessionimpl.java:110) @ packagename.cometdsender.senddata(cometdsender.java:62) @ packagename.processorimp.processdata(processorimp.java:18) @ packagename.testsource.processnewdata(testsource.java:50) @ packagename.testsource.run(testsource.java:36) @ java.lang.thread.run(unknown source)

i've included class below. can tell me if i'm missing something:

@service

public class cometdsender implements sender {

@inject private bayeuxserver bayeuxserver; @session private localsession sender; private string channelname = null; // setup cometd channel public cometdsender() { this.channelname = "/abc/1"; system.out.println("bayeuxserver : " + (bayeuxserver == null ? "is null" : "is not null")); if (bayeuxserver == null) { bayeuxserver = new bayeuxserverimpl(); } bayeuxserver.createifabsent(channelname, new configurableserverchannel.initializer() { public void configurechannel(configurableserverchannel channelname) { system.out.println("channel : " + (channelname == null ? "is null" : "is not null")); channelname.setpersistent(true); channelname.setlazy(true); } }); } public void senddata(agent data) { // convert update business object cometd-friendly format map<string, object> cometdata = new hashmap<string, object>(4); cometdata.put("id", data.getid()); // publish subscribers serverchannel channel = bayeuxserver.getchannel(channelname); system.out.println("sender : " + sender); if (sender == null) { sender = bayeuxserver.newlocalsession(channelname); system.out.println("sender : " + sender); sender.handshake(); } channel.publish(sender, cometdata, null); }

}

you must not create bayeuxserverimpl instances unless know you're doing, , same applies localsession. since using cometd services, fields must non-null , must not create them yourself. null, , due fact have misconfiguration in web.xml (which did not post).

please read documentation cometd services , follow tutorials: guide step step in solving problems cometd services.

cometd bayeux

Comments

Post a Comment

Popular posts from this blog

web services - java.lang.NoClassDefFoundError: Could not initialize class net.sf.cglib.proxy.Enhancer -

web services - java.lang.NoClassDefFoundError: Could not initialize class net.sf.cglib.proxy.Enhancer - when trying request rest service @ time of response getting exception.. feb 21, 2013 2:34:49 pm com.sun.jersey.spi.container.containerresponse mapmappablecontainerexception severe: exception contained within mappablecontainerexception not mapped response, re-throwing http container java.lang.noclassdeffounderror: not initialize class net.sf.cglib.proxy.enhancer @ org.hibernate.proxy.pojo.cglib.cgliblazyinitializer.getproxyfactory(cgliblazyinitializer.java:117) @ org.hibernate.proxy.pojo.cglib.cglibproxyfactory.postinstantiate(cglibproxyfactory.java:43) @ org.hibernate.tuple.entity.pojoentitytuplizer.buildproxyfactory(pojoentitytuplizer.java:162) @ org.hibernate.tuple.entity.abstractentitytuplizer.<init>(abstractentitytuplizer.java:135) @ org.hibernate.tuple.entity.pojoentitytuplizer.<init>(pojoentitytuplizer.java:55) @ org.hibernate.tuple.e...
Read more

Accessing MATLAB's unicode strings from C -

Accessing MATLAB's unicode strings from C - how can access underlying unicode info of matlab strings through matlab engine or mex c interfaces? here's example. let's set unicode characters in utf-8 encoded file test.txt, read as fid=fopen('test.txt','r','l','utf-8'); s=fscanf(fid, '%s') in matlab. now if first feature('defaultcharacterset', 'utf-8') , c engevalstring(ep, "s") , output text file utf-8. proves matlab stores unicode internally. if mxarraytostring(enggetvariable(ep, "s")) , unicode2native(s, 'latin-1') give me in matlab: non-latin-1 characters replaced character code 26. need getting access underlying unicode info c string in unicode format (utf-8, utf-16, etc.), , preserving non-latin-1 characters. is possible? my platform os x, matlab r2012b. addendum: documentation explicitly states "[mxarraytostring()] supports multibyte encoded characters...
Read more

javascript - mongodb won't find my schema method in nested container -

javascript - mongodb won't find my schema method in nested container - i trying access method of schema stored within mixed container. here situation : have cases model can many different things, have schema each of these things stored in "casecontent" mixed property. var caseschema = mongoose.schema({ casecontent : {}, object : {type:string, default : "null"}, collision : {type : boolean, default : false} }); the casecontent property filled model of 1 of schemas, 1 exemple : var treeschema = new mongoose.schema({ applecount : {type : number, default : 3} }); treeschema.methods.dostuff = function (data) { console.log('hey, listen'); homecoming true; }; then, want utilize method of schema original container : caseschema.methods.dostuff = function (data) { if (this.casecontent.dostuff !== undefined) { this.casecontent.dostuff(); console.log('it worked'); } else { ...
Read more