java - How to initialize initial context in JMS -


i create message queue in standalone application using jms queue. not using kind of container tomcat , jboss. should arguments passed initial context object.? s standalone application..

note: if wishes give down vote question, please give reason in comment , give down vote. thanks!

       initialcontext ctx = new initialcontext(?????);        queue queue = (queue) ctx.lookup("queue/queue1");        queueconnectionfactory connfactory = (queueconnectionfactory) ctx.lookup("queue/connectionfactory");        queueconnection queueconn = connfactory.createqueueconnection();        queuesession queuesession = queueconn.createqueuesession(false,session.auto_acknowledge);        queuesender queuesender = queuesession.createsender(queue);        queuesender.setdeliverymode(deliverymode.non_persistent);        textmessage message = queuesession.createtextmessage("hello");        queuesender.send(message);        system.out.println("sent: " + message.gettext());        queueconn.close();

you can't resolve connectionfactory via jndi there no container provide it.

you have instantiate connectionfactory providing necessary (transport) parameters.

as don't retrieve java ee container behavior not covered related jsr , provider specific.

below example using hornetq :

// transport parameters final map< string, object > connectionparams = new hashmap< string, object >(); connectionparams.put(transportconstants.port_prop_name, port); connectionparams.put(transportconstants.host_prop_name, host);  final transportconfiguration transportconfiguration = new transportconfiguration(     nettyconnectorfactory.class.getname(), connectionparams);  // should created once , reused whole app lifecycle connectionfactory = (connectionfactory) org.hornetq.api.jms.hornetqjmsclient     .createconnectionfactorywithoutha(jmsfactorytype.queue_cf, transportconfiguration);  final jmsqueue = hornetqjmsclient.createqueue(queuename)     try {     // connection thread safe     connection connection = null;      // session not     session session = null;      connection = connectionfactory.createconnection(user, password);     connection.start();     /* following objects must propper thread (but should reused if possible) */      // create non transacted session (no xa support outside of java ee container)     session = connection.createsession(false, session.auto_acknowledge);      final messageproducer producer = session.createproducer(jmsqueue);     final objectmessage objectmessage = session.createobjectmessage();      objectmessage.setobject(mymessageserializableobject);      producer.send(objectmessage); } {     // release resources     try {         if (session != null) {           session.close();         }         if (connection != null) {           connection.close();         }     }     catch (final jmsexception e) {         log.warn("an error occurs while releasing jms resources", e);     } }

note connections, sessions , producers should reused (not created , released each use but not shared between threads) , ideally pooled.

see https://developer.jboss.org/wiki/shouldicachejmsconnectionsandjmssessions


-

Comments

Post a Comment

Popular posts from this blog

OpenCV OpenCL: Convert Mat to Bitmap in JNI Layer for Android -

there several posts converting mat bitmap using utils.mattobitmap() function. i'm assuming function can called in java layer after importing utils class. i want transfer data memory address pointed uint32_t* bmpcontent; in code below. jniexport void jnicall java_com_nod_nodcv_nodcvactivity_runfilter( jnienv *env, jclass clazz, jobject outbmp, jbytearray indata, jint width, jint height, jint choice, jint filter) { int outsz = width*height; int insz = outsz + outsz/2; androidbitmapinfo bmpinfo; if (androidbitmap_getinfo(env, outbmp, &bmpinfo) < 0) { throwjavaexception(env,"gaussianblur","error retrieving bitmap meta data"); return; } if (bmpinfo.format != android_bitmap_format_rgba_8888) { throwjavaexception(env,"gaussianblur","expecting rgba_8888 format"); return; } uint32_t* bmpcontent; if (androidbitmap_lockpixels(env, outbmp,(void**)&bmpcontent)...
Read more

android - org.xmlpull.v1.XmlPullParserException: expected: START_TAG {http://schemas.xmlsoap.org/soap/envelope/}Envelope -

i trying hit soap api in application login purpose , getting above mentioned error , can 1 tell me going wrong , first time soap apis. here code hit soap :- vector<object> args = new vector<object>(); hashtable<string, object> hashtable = new hashtable<string, object>(); hashtable.put("email", "mss.siddhart28@gmail.com"); hashtable.put("password", "siddharth"); args.add(hashtable); soapserializationenvelope envelope = new soapserializationenvelope( soapenvelope.ver11); envelope.dotnet = true; envelope.xsd = soapserializationenvelope.xsd; envelope.enc = soapserializationenvelope.enc; (new marshalhashtable()).register(envelope); httptransportse androidhttptransport = new httptransportse( "http://tempuri.org/", 15000); androidhttptransport.debug = true; string result = ""; try { soapobject request = new soapobject("http:...
Read more

python - How to remove the Xframe Options header in django? -

i have made page has iframe . inside iframe want show multiple different links article facebook, or news, or youtube video or other possible url. but, due xframe header, unable so. referred following link: https://docs.djangoproject.com/en/1.8/ref/clickjacking/ , django xframeoptionsmiddleware (x-frame-options) - allow iframe client ip but didn't help. my settings.py file's middleware_classes is: middleware_classes = ( 'django.contrib.sessions.middleware.sessionmiddleware', 'django.middleware.common.commonmiddleware', 'django.middleware.csrf.csrfviewmiddleware', 'django.contrib.auth.middleware.authenticationmiddleware', 'django.contrib.auth.middleware.sessionauthenticationmiddleware', 'django.contrib.messages.middleware.messagemiddleware', 'django.middleware.clickjacking.xframeoptionsmiddleware', ) from http://django-secure.readthedocs.org/en/latest/middleware.html , found using ...
Read more