Meta tags:

Headings (most frequently used words):

march, 2009, blog, wednesday, tuesday, me, jms, using, apache, activemq, introduction, to, java, ndung, 25, 24, 11, october, 07, 2008, about, chat, with, certification, archive, guest, book, recent, comments, my, site, link, ceo, stats, counter, campaign, map, quick, start, message, oriented, middleware, mom, and, messaging, service, eai, iso, 8583, jpos, log4j, in, socket, programming,

Text of the page (most frequently used words):
#message (93), import (82), public (76), new (72), java (72), the (60), this (59), ndung (58), and (57), com (56), class (56), string (48), private (46), null (42), properties (42), application (37), queueconnection (37), textmessage (36), create (35), package (35), queue (35), queuesession (35), close (32), that (32), for (31), org (31), void (30), catch (29), jms (28), socket (28), bean (28), util (28), var (27), logger (27), jmsexception (27), arg (26), highlighter (25), named (25), main (25), client (25), props (25), connectionfactory (25), session (25), log4j (24), constructor (24), config (24), printstacktrace (24), start (23), will (23), one (23), int (23), isomsg (23), messagehandler (22), iso (22), system (22), throws (22), javax (22), apache (21), context (21), mqwriter (21), return (20), try (20), map (19), out (19), from (19), connection (19), queuereceiver (19), match (18), activemq (18), function (17), first (17), server (17), ioexception (17), use (17), read (16), run (16), document (15), can (15), xml (15), thread (15), str (14), middleware (14), jndi (14), jndicontext (14), div (13), value (13), false (13), result (13), static (13), jpos (13), mysession (13), queueconnectionfactory (13), calc (13), info (12), are (12), topic (12), mqsyncreader (12), index (11), eai (11), more (11), configuration (11), applicationcontext (11), ref (11), local (11), serversocket (11), appender (11), point (11), naming (11), listener (11), mqasyncreader (11), write (10), name (10), sender (10), then (10), used (10), args (10), format (10), another (10), destination (10), two (10), receiver (10), myconnection (10), queuesender (10), mqconfig (10), processor (10), arg1 (10), doc (9), replace (9), cmd (9), while (9), true (9), regexp (9), length (9), code (9), mom (9), using (9), localhost (9), stop (9), library (9), need (9), applications (9), wait (9), createconnection (9), receive (9), println (9), namingexception (9), iframe (8), version (8), createelement (8), matches (8), flashcopier (8), socketserverhandlerfactory (8), socketconnectionserver (8), spring (8), example (8), bufferedreader (8), error (8), exception (8), springframework (8), beans (8), property (8), roll (8), packager (8), tostring (8), each (8), other (8), make (8), ptp (8), setproperty (8), get (8), selector (8), init (8), reader (8), window (7), toolbar (7), css (7), input (7), data (7), iso8583 (7), there (7), process (7), request (7), have (7), which (7), initialcontext (7), lookup (7), active (7), queuename (7), auto_acknowledge (7), createqueue (7), arg2 (7), operator (7), scanner (7), print (6), label (6), func (6), wnd (6), utils (6), else (6), regex (6), comments (6), with (6), classes (6), our (6), myclient (6), means (6), dataoutputstream (6), ctx (6), dtd (6), port (6), outtoclient (6), file (6), chapter (6), fileinputstream (6), response (6), 8583 (6), all (6), between (6), tcp (6), next (6), instance (6), myconnectionfactory (6), activemqconnectionfactory (6), consumer (6), mqhandler (6), src (6), method (6), transid (6), 2008 (5), introduction (5), 2009 (5), manik (5), text (5), http (5), serverconfig (5), socketserverhandler (5), inputstreamreader (5), final (5), infromserver (5), readline (5), handlerfactory (5), infromclient (5), based (5), programming (5), isoexception (5), isopackager (5), integer (5), framework (5), here (5), jar (5), different (5), must (5), communication (5), asynchronous (5), many (5), publish (5), messages (5), activemqinitialcontextfactory (5), 61616 (5), mytopic (5), createqueuesession (5), createreceiver (5), instanceof (5), implements (5), terminate (5), streammessage (5), body (4), classname (4), commands (4), check (4), lines (4), min (4), view (4), march (4), style (4), subscribe (4), posted (4), received (4), download (4), logging (4), myserver (4), also (4), net (4), clientsocket (4), ioe (4), datafromclient (4), konsole (4), layout (4), packagerfactory (4), time (4), netbeans (4), above (4), factory (4), uses (4), software (4), rpc (4), after (4), simplequeuesender (4), simplequeuereceiver (4), simpletopicpublisher (4), post (4), initial_context_factory (4), provider_url (4), topicconnection (4), hello (4), world (4), gettext (4), createtextmessage (4), send (4), vendor (4), delivery (4), messagelistener (4), filesystemxmlapplicationcontext (4), transactionid (4), root (4), openconnection (4), stockmessage (4), contentwindow (3), width (3), height (3), copystyles (3), continue (3), innerhtml (3), link (3), fixforblogger (3), prototype (3), getmatches (3), exec (3), test (3), appendchild (3), oriented (3), blog (3), clipboardswf (3), clipboarddata (3), www (3), console (3), enter (3), quit (3), getlogger (3), getclass (3), outtoserver (3), boolean (3), isquit (3), writebytes (3), support (3), getbean (3), runnable (3), finally (3), myapp (3), prop (3), inputstream (3), coding (3), prepare (3), set (3), these (3), architecture (3), standard (3), adapter (3), products (3), into (3), types (3), done (3), systems (3), messaging (3), talking (3), setting (3), folder (3), simpletopicsubscriber (3), got (3), clean (3), mypublisher (3), settext (3), specific (3), producer (3), timeout (3), last (3), dom4j (3), second (3), reqconfig (3), respconfig (3), processoradd (3), destroy (3), arg0 (3), saxreader (3), msg (3), txtmsg (3), rqmsg (3), hashmap (3), parseint (3), elementtext (3), please (3), append (3), load (3), getqueuename (3), focus (2), alert (2), removechild (2), about (2), open (2), _blank (2), scrollbars (2), tools (2), indexof (2), parentnode (2), sourcedoc (2), addcontrols (2), collapse (2), showcolumns (2), span (2), split (2), push (2), attribute (2), book (2), october (2), quick (2), syntaxhighlighter (2), source (2), originalcode (2), 400 (2), clipboard (2), your (2), 0px (2), 500px (2), posts (2), home (2), handle (2), four (2), before (2), default (2), look (2), both (2), either (2), you (2), my_port (2), 50000 (2), targethost (2), infromuser (2), getoutputstream (2), getinputstream (2), equals (2), classpathxmlapplicationcontext (2), encoding (2), utf (2), doctype (2), getport (2), createhandler (2), unpackrequest (2), category (2), patternlayout (2), date (2), 8601 (2), conversionpattern (2), log (2), getpackager (2), loadxmlproperties (2), getbytes (2), dump (2), iso87asciiproperties (2), genericpackager (2), filename (2), iso87ascii (2), explanation (2), opensource (2), but (2), written (2), just (2), ide (2), besides (2), section (2), tuesday (2), enterprise (2), integration (2), project (2), than (2), sun (2), communicate (2), its (2), convert (2), way (2), program (2), material (2), wednesday (2), previous (2), transfer (2), distributed (2), remote (2), procedure (2), calls (2), has (2), until (2), synchronized (2), coupled (2), such (2), allow (2), compliant (2), market (2), mqseries (2), ibm (2), impression (2), model (2), publishers (2), subscribers (2), styles (2), typically (2), could (2), web (2), pub (2), sub (2), topicsession (2), createtopicsession (2), createtopic (2), subscriber (2), mysubscriber (2), publisher (2), differents (2), vendors (2), createsender (2), simple (2), instantiate (2), createsession (2), messageconsumer (2), 1000 (2), messageproducer (2), register (2), object (2), calculator (2), user (2), synchronously (2), asynchronously (2), third (2), interface (2), operation (2), several (2), mqrespwriter (2), mqreqwriter (2), mqrespsyncreader (2), maxhandler (2), put (2), valueof (2), nextint (2), execute (2), queuepullrequest (2), lookupfromqueue (2), stringbuffer (2), thisthread (2), setmessagelistener (2), gettimeout (2), long (2), called (2), header (2), consists (2), optional (2), synchronous (2), printing, dialog, 300, 150, strings, aboutdialog, command, destdoc, links, getelementsbytagname, isbloggermode, regexlib, multilineccomments, singlelineccomments, singlelineperlcomments, doublequotedstring, singlequotedstring, nogutter, tabstospaces, wrapcolumn, sortcallback, addbit, html, bar, columns, showevery, trim, math, cdata, undefined, tag, larger, template, isnaini, dot, campaign, counter, ceo, stats, site, loading, recent, shoutbox, guest, august, september, archive, certification, chat, complete, profile, cool, bandung, west, indonesia, humble, opinion, expandsource, expand, collapsed, viewsource, plain, 750, location, resizable, menubar, copytoclipboard, copy, setdata, now, printsource, csstext, position, absolute, left, top, 2004, 2007, alex, gorbatchev, dreamprojections, atom, older, 307, translate, bits, become, easily, injection, much, want, twice, 0210723a00010a808400185936001410010999990110000000100000001007021533000001191533, 10061007065656561006090102240000000901360020100236c0102240000000, what, see, btw, happy, eid, mubarak, touppercase, accept, extends, super, sockethandler, getinetaddress, gethostaddress, override, ready, connected, infoserver, setport, rootlogger, consoleappender, rollingfileappender, netbeansprojects, maxfilesize, 10kb, maxbackupindex, mti, getmti, incoming, isincoming, outgoing, isoutgoing, isrequest, isresponse, 128, hasfield, getproperty, getvalue, setpackager, unpack, packresponse, pack, loadfromxml, getresourceasstream, free, documentation, comercial, mini, basic, knowledge, network, let, mentioned, still, xercesimpl, jakarta, 1987, place, commons, xerces, parser, endy, wikipedia, 249, imagine, large, company, softwares, platforms, say, windows, linux, solaris, common, case, edi, webservice, accommodate, transactions, coordination, characteristics, below, channel, following, aspects, sure, arrive, coordinate, transaction, monitoring, components, implementation, usually, built, router, validate, route, appropriate, technology, hub, spoke, taken, 327, been, introduced, flash, fundamentally, approach, they, latter, processing, thus, type, proceeds, lock, step, manner, communicating, processes, tightly, examples, include, rmi, corba, etc, best, described, loosely, reliable, scalable, enabled, amongst, spesification, defines, interfaces, associated, semantics, access, services, any, product, plenty, available, including, sonicmq, progress, even, players, connections, factories, sessions, destinations, should, often, replacement, multiple, connect, their, producers, consumers, important, difference, senders, hand, enhance, sample, broker, configuring, tomcat, container, extract, rar, downloaded, edit, placed, conf, delete, multicast, bin, same, packages, know, differences, didn, simpletopicsubsriber, monitor, running, 8161, admin, browser, better, topicsubscriber, createsubscriber, forever, arrives, display, topicpublisher, createpublisher, helloworld, helloworldconsumer, createconsumer, helloworldproducer, createproducer, tell, sent, service, 322, fragment, indefinitely, alternatively, specified, milliseconds, instead, waiting, polling, not, least, like, calculatormq, utility, needed, registered, listed, represent, handled, files, inputs, introducing, industry, 20000, entry, key, initial, provider, url, runtime, getruntime, addshutdownhook, shutdownhook, onmessage, getstringproperty, bytearrayinputstream, element, getrootelement, documentexception, currenttimemillis, 1024, volatile, interrupt, currentthread, sleep, 500, interruptedexception, break, size, keyset, setstringproperty, setintproperty, setlongproperty, parselong, getter, setter, come, don, receivenowait, seconds, only, three, parts, jmsdestination, jmsdeliverymode, jmsexpiration, jmspriority, jmsmessageid, jmstimestamp, jmscorrelationid, jmsreplyto, jmstype, jmsredelivered, addition, values, fields, api, defined, five, formats, mapmessage, bytesmessage, objectmessage, supports, methods, variations, poll,

Text of the page (random words):
no wait at all don t wait stockmessage streammessage receiver receivenowait 2 asynchronous delivery instead of waiting polling the message consumer for messages a client can register a message listener with a message consumer a message listener is an object that implements the messagelistener asynchronous reader register a message listener listener will be called for each message that come into the queue receiver setmessagelistener listener at last but not at least we will make a point to point simple calculator application client will write message in queue in xml format after got request from user and read synchronously a response queue from server with specific time out by using a selector server will read request queue asynchronously and write response in response queue i m using netbeans 6 5 and spring framework also prepare the other library like jms jar dom4j jar and apache activemq library create a new java application named calculatormq create new package named com ndung mq util in this package we will write all utility class that needed by jms and mq vendor the first class named mqconfig java package com ndung mq util public class mqconfig private string queuename private int timeout getter setter the second class named mqwriter java this class will be used to write message in queue package com ndung mq util import java io import java util map import java util properties import javax jms import javax naming public class mqwriter private connectionfactory queueconnectionfactory private queueconnection queueconnection private queuesession queuesession private queue queue private queuesender queuesender private mqconfig config public mqwriter mqconfig config this config config public void init openconnection public void terminate try if queueconnection null queueconnection close queueconnection null catch jmsexception e e printstacktrace public void openconnection try properties props new properties props load new fileinputstream new file src jndi properties context jndicontext new initialcontext props queueconnectionfactory connectionfactory jndicontext lookup connectionfactory queueconnection queueconnection queueconnectionfactory createconnection queueconnection start catch namingexception ne ne printstacktrace catch jmsexception je je printstacktrace catch ioexception ie ie printstacktrace public void write string message map properties throws jmsexception queuesender null queuesession null try queuesession queueconnection createqueuesession false session auto_acknowledge queue queuesession createqueue config getqueuename queuesender queuesession createsender queue textmessage textmessage queuesession createtextmessage if properties null properties size 0 for object o properties keyset if o instanceof string textmessage setstringproperty o tostring properties get o tostring if o instanceof integer textmessage setintproperty o tostring integer parseint properties get o tostring if o instanceof long textmessage setlongproperty o tostring long parselong properties get o tostring textmessage settext message queuesender send textmessage catch jmsexception e e printstacktrace finally if queuesender null queuesender close if queuesession null queuesession close the third class named mqsyncreader java this class will read message in queue synchronously package com ndung mq util import java io import java util properties import javax jms import javax naming public class mqsyncreader private connectionfactory queueconnectionfactory private queueconnection queueconnection private queuesession queuesession private queue queue private queuereceiver queuereceiver private mqconfig config public mqsyncreader mqconfig config this config config public void init openconnection public void terminate try if queuesession null queuesession close if queueconnection null queueconnection close catch jmsexception e e printstacktrace public void openconnection try properties props new properties props load new fileinputstream new file src jndi properties context jndicontext new initialcontext props queueconnectionfactory connectionfactory jndicontext lookup connectionfactory queueconnection queueconnection queueconnectionfactory createconnection queuesession queueconnection createqueuesession false session auto_acknowledge queueconnection start catch namingexception ne ne printstacktrace catch jmsexception je je printstacktrace catch ioexception ie ie printstacktrace public string read string selector throws jmsexception queuereceiver null string out try queue queuesession createqueue config getqueuename if selector null selector equals queuereceiver queuesession createreceiver queue selector else queuereceiver queuesession createreceiver queue textmessage textmessage null if config gettimeout 1 textmessage textmessage queuereceiver receive config gettimeout else textmessage textmessage queuereceiver receive if textmessage null out textmessage gettext catch jmsexception je je printstacktrace finally if queuereceiver null queuereceiver close return out the third class named mqasyncreader java this class will read message in queue asynchronously package com ndung mq util import java io import java util properties import javax jms import javax naming public class mqasyncreader implements runnable private connectionfactory queueconnectionfactory private queueconnection queueconnection private queuesession queuesession private queue queue private queuereceiver queuereceiver private mqconfig config private messagelistener listener private volatile thread thread null public mqasyncreader mqconfig config messagelistener listener this config config this listener listener public void start try properties props new properties props load new fileinputstream new file src jndi properties context jndicontext new initialcontext props queueconnectionfactory connectionfactory jndicontext lookup connectionfactory queueconnection queueconnection queueconnectionfactory createconnection queuesession queueconnection createqueuesession false session auto_acknowledge queueconnection start queue queuesession createqueue config getqueuename queuereceiver queuesession createreceiver queue thread new thread this thread start catch namingexception ne ne printstacktrace catch jmsexception je je printstacktrace catch ioexception ie ie printstacktrace public void stop throws jmsexception thread interrupt thread null if queuereceiver null queuereceiver close if queuesession null queuesession close if queueconnection null queueconnection close public void run thread thisthread thread currentthread while thisthread thread try thread sleep 500 catch interruptedexception ie ie printstacktrace break try queuereceiver setmessagelistener listener catch jmsexception ex ex printstacktrace then we will make client application create package named com ndung calc client create two classes named client java and main java package com ndung calc client import com ndung mq util mqsyncreader import com ndung mq util mqwriter import java util hashmap import java util map import javax jms jmsexception public class client private mqwriter mqwriter private mqsyncreader mqsyncreader private string transid public client mqwriter mqwriter mqsyncreader mqsyncreader this mqwriter mqwriter this mqsyncreader mqsyncreader public string execute int arg1 string operator int arg2 throws jmsexception this transid string valueof system currenttimemillis string message n n arg1 n operator n arg2 n queuepullrequest message string result lookupfromqueue return result private void queuepullrequest string message throws jmsexception map map new hashmap map put transactionid transid mqwriter write message map private string lookupfromqueue throws jmsexception stringbuffer selector new stringbuffer 1024 selector append transactionid append transid append return mqsyncreader read selector tostring package com ndung calc client import java util scanner import javax jms jmsexception import javax naming namingexception import org springframework context applicationcontext import org springframework context support filesystemxmlapplicationcontext public class main public static void main string args throws namingexception jmsexception scanner scanner new scanner system in system out print please input the first arg int arg1 scanner nextint system out print please input the operation example string operator scanner next system out print please input the second arg int arg2 scanner nextint applicationcontext ctx new filesystemxmlapplicationcontext src applicationcontext xml client client client ctx getbean client system out println the result is client execute arg1 operator arg2 after that we make server application create package named com ndung calc server first make a listener class that will be registered to catch for each message that listed in request queue this class named mqhandler java then make an interface named processor java that used to process request and then four classes that implements processor these classes represent each calculator operation that will be handled last make a main class for server application named main java package com ndung calc server import com ndung mq util mqwriter import java io import java util import javax jms import org dom4j import org dom4j io saxreader public class mqhandler implements messagelistener map string processor map mqwriter mqwriter public mqhandler map string processor map mqwriter mqwriter this map map this mqwriter mqwriter public void onmessage message msg try if msg instanceof textmessage textmessage txtmsg textmessage msg string rqmsg txtmsg gettext system out println rqmsg string transid txtmsg getstringproperty transactionid map properties new hashmap properties put transactionid transid process response message inputstream in new bytearrayinputstream rqmsg getbytes saxreader reader new saxreader document document reader read in element root document getrootelement int arg1 integer parseint root elementtext arg1 int arg2 integer parseint root elementtext arg2 string operator root elementtext operator processor processor map get operator int result 0 if processor null result processor process arg1 arg2 system out println result result mqwriter write string valueof result properties catch jmsexception e e printstacktrace catch documentexception de de printstacktrace package com ndung calc server public interface processor public int process int arg0 int arg1 package com ndung calc server public class processoradd implements processor public processoradd public int process int arg0 int arg1 int result arg0 arg1 return result package com ndung calc server import com ndung mq util mqasyncreader import javax jms jmsexception import javax naming namingexception import org springframework context applicationcontext import org springframework context support filesystemxmlapplicationcontext public class main private boolean active true mqasyncreader reader private int maxhandler 1 static applicationcontext ctx new filesystemxmlapplicationcontext src applicationcontext xml public void start throws jmsexception mqasyncreader r mqasyncreader ctx getbean mqasyncreader if active reader new mqasyncreader maxhandler for int i 0 i reader i r reader i start else system out println start no active public synchronized void stop throws jmsexception for int i 0 i reader i stop public static void main string args throws namingexception jmsexception final main main new main runtime getruntime addshutdownhook new thread new runnable public void run try main stop catch jmsexception ex ex printstacktrace shutdownhook main start last make two configuration files in folder src first named jndi properties that used for jndi configuration and the second named applicationcontext xml that used for spring configuration file java naming factory initial org apache activemq jndi activemqinitialcontextfactory java naming provider url tcp localhost 61616 xml version 1 0 encoding utf 8 doctype beans public spring dtd bean en http www springframework org dtd spring beans dtd beans bean id mqasyncreader class com ndung mq util mqasyncreader constructor arg ref local reqconfig constructor arg constructor arg ref local mqhandler constructor arg bean bean id reqconfig class com ndung mq util mqconfig property name queuename value q request value property bean bean id respconfig class com ndung mq util mqconfig property name queuename value q response value property property name timeout value 20000 value property bean bean id mqhandler class com ndung calc server mqhandler constructor arg map entry key bean class com ndung calc server processoradd bean map constructor arg constructor arg ref local mqrespwriter constructor arg bean bean id mqreqwriter class com ndung mq util mqwriter init method init destroy method terminate constructor arg ref local reqconfig constructor arg bean bean id mqrespsyncreader class com ndung mq util mqsyncreader init method init destroy method terminate constructor arg ref local respconfig constructor arg bean bean id client class com ndung calc client client constructor arg ref local mqreqwriter constructor arg constructor arg ref local mqrespsyncreader constructor arg bean bean id mqrespwriter class com ndung mq util mqwriter init method init destroy method terminate constructor arg ref local respconfig constructor arg bean beans run one instance of com ndung calc server main run and enter user inputs for several instance of com ndung calc client main next post introducing into mq vendor that so many used in market and industry it is mqseries from ibm read more posted by l p manik at 11 23 am 322 comments tuesday march 24 2009 introduction to message oriented middleware mom and java messaging service jms using apache activemq package com ndung import javax jms import org apache activemq activemqconnectionfactory public class helloworldproducer public static void main string args throws jmsexception instantiate connection factory specific to the vendor activemqconnectionfactory connectionfactory new activemqconnectionfactory vm localhost create a connection connection connection connectionfactory createconnection connection start create a session session session connection createsession false session auto_acknowledge create the destination topic or queue destination destination session createqueue test mq create a messageproducer from the session to the topic or queue messageproducer producer session createproducer destination create a messages string text hello world from ndung textmessage message session createtextmessage text tell the producer to send the message system out println message sent producer send message clean up session close connection close package com ndung import javax jms import org apache activemq activemqconnectionfactory public class helloworldconsumer public static void main string args throws jmsexception instantiate connection factory specific to the vendor activemqconnectionfactory connectionfactory new activemqconnectionfactory...