JMS Request Reply Pattern, No Output -

-

testrequestresponse:

public static void main(string args[]) throws jmsexception {     tibjmsconnectionfactory connectionfactory = new tibjmsconnectionfactory(             "tcp://localhost:7222");     connection con = connectionfactory.createconnection("admin", "");     con.start();     session s = con.createsession();     system.out.println("successfully created jms connection , session!");     queue q1 = s.createqueue("train.ems.queue.test");     system.out.println(q1);     system.out.println("queue created!");     temporaryqueue tq = s.createtemporaryqueue();     messageproducer mp = s.createproducer(q1);     messageconsumer mc = s.createconsumer(tq);     textmessage tm = s.createtextmessage("hi abhishek!");     tm.setstringproperty("country", "in");     tm.setjmscorrelationid("sender");     tm.setjmsreplyto(tq);     mp.settimetolive(30000);     mp.setdeliverymode(deliverymode.non_persistent);     mp.setpriority(message.default_priority);     mp.send(tm);     message recv = mc.receive(60000);     if (recv != null) {         system.out.println(recv.getbody(string.class));     }     mp.close();     s.close();     con.close();  }

testasyncreceivemessage:

public class testasyncreceivemessage implements messagelistener { session s; queue q1;  messageproducer mp;  public static void main(string ars[]) throws jmsexception {     testasyncreceivemessage obj = new testasyncreceivemessage();     obj.createsession();     obj.createqueue();     obj.msgconsumer();  }  private void msgconsumer() throws jmsexception {     // todo auto-generated method stub     messageconsumer mc = s.createconsumer(q1, "country='in'");     mc.setmessagelistener(new testasyncreceivemessage()); }  private void createqueue() throws jmsexception {     // todo auto-generated method stub     q1 = s.createqueue("train.ems.queue.test");     // t1=s.createtopic("train.ems.topic.test"); }  private void createsession() throws jmsexception {     // todo auto-generated method stub     tibjmsconnectionfactory connectionfactory = new tibjmsconnectionfactory(             "tcp://localhost:7222");     connection con = connectionfactory.createconnection("admin", "");     s = con.createsession();     system.out.println("successfully created jms connection , session!");  }  public void onmessage(message arg0) {      try {         system.out.println(arg0.getbody(string.class));         textmessage tm = s.createtextmessage("ack");         queue t = (queue) arg0.getjmsreplyto();         mp = s.createproducer(t);         mp.send(tm);     } catch (jmsexception e) {         // todo auto-generated catch block         e.printstacktrace();     }  }

well first showed me nullpointerexception when creating textmessage in onmessage, changed , theres no more exception, theres no putput either. help! :)

you have not called connection.start() method after creating in testasyncreceivemessage code. application has call connection.start() inform messaging provider start delivering messages. otherwise messages not delivered consumer.

connection.start typically called after consumer created , message listeners attached consumer consumer ready receive messages.


Comments

Post a Comment

Popular posts from this blog

python - pip install -U PySide error -

-
does know how avoid following error when running pip install -u pyside per official website instructions here: https://pypi.python.org/pypi/pyside/#installing-pyside-on-a-mac-os-x-system note have done brew install qt successfully. you using pip version 7.0.3, version 7.1.2 available. should consider upgrading via 'pip install --upgrade pip' command. collecting pyside using cached pyside-1.2.4.tar.gz installing collected packages: pyside running setup.py install pyside complete output command /applications/anaconda/bin/python -c "import setuptools, tokenize;__file__='/private/var/folders/dy/ttgqhqqx3g9bsbsnqnxsk2z80000gq/t/pip-build-cpxemt/pyside/setup.py';exec(compile(getattr(tokenize, 'open', open)(__file__).read().replace('\r\n', '\n'), __file__, 'exec'))" install --record /var/folders/dy/ttgqhqqx3g9bsbsnqnxsk2z80000gq/t/pip-0r7hri-record/install-record.txt --single-version-externally-managed --compile: ...
Read more

arrays - C++ error: a brace-enclosed initializer is not allowed here before ‘{’ token -

-
simple question: i'm trying initialize array within c++ class declaration: using namespace std; #include <string> class myclass{ public: string myarray[] = {"a","b","c"}; }; and i'm getting error: error: brace-enclosed initializer not allowed here before ‘{’ token no, without complied c++11 compiler, cannot initialize member array in declaration. have initialize array member in constructor. , don't use open array if know number of elements initialize array.
Read more

cytoscape.js - How to add nodes to Dagre layout with Cytoscape -

-
i trying add nodes dagre graph through cityscape.js. problem nodes not painted. code have: cy.add({ group: "nodes", data: { id:"n0",name:"n0",weight: 75 }, }); $.ajax(url).done(function(jsontree){ var newnodes=[]; for(var i=1;i<6;i++){ //var child = jsontree.result[i]; newnodes.push( { group: "nodes", data: { id: "n"+i, name:"n"+i}}, { group: "edges", data: { id: "e"+i, source: "n0", target: "n"+i } } ); } cy.add(newnodes); any ideas? have used loaded function reload graph not work. not know if have use specific function reload graph. thank in advance. you need add positions new nodes. cytoscape.js docs : it important note positions of newly added nodes must defined when calling cy.add(). nodes can not placed in graph without valid position — otherwise not displayed. yo...
Read more