ࡱ> `! șوX-*>L4Q8 *`? x PVU>sQeEK$%ROLI-FubbL C4SILa̯rdt5U>ZF5,9{lM=s(=swt3hi/!}#WZm.y['vI!|)$䕭b>s^GO}q>1cff= q:;/W~5Ryjc=DQ7b~;P'T.y˭ӂ|֛_lkfhkU݃[zآcWEd֖-;9h 5rVkt3,_lzSs;m{cu7*Rz_$LsE˵7b^m6vpu=QNova4;gw@N\@(MzK,"{}U k-u`NY-J5j"f֊f=ۈf1ŘmJ'w1˔f7>d S&0b/'81 1T#8aR$*I$2ݜ4v6g0ƜQ"F:b|DN+qNS:DatLaFԑTDR݁bXzMlj% <@t7zT:=EMtJDt]8=-LV*jRCa5>SSJ;5\S#hJBugϨbXKf# Y+FMLjnvU VN~msmh [ZHwG#EAqWa4\ Jt]GS{>ۚ !TL*Lq>@_M5؇coz{|LCa7"X~cGFx0haD".A : J Q%ԡu.b,ӸNP$b+Ta1T(nq-EPb% .b1|P& =\%( ]|c>P`k#΅lGs~x,Ṡ,ʇ)ȥ3"ȣx if#\Z :,EBJŰLlV]B7D9IMu.'k;gS*Bp7?~q??*Rυ<'XsůxtT7<*r-yRyVܭUynD??#Y,D᧋ğ:^{![J>mbV TU˔ `1,^F(]YQ3|UkPJuצF];2g$ ^A^(󚿟A'/]3J9KdQ)S,c6fś7yC2EdVfH6+hY&Wi)$)"cq&\J7sf6eCIh(#4R"rLL1d4ﺏHg<5+-BԪH:T֭0Z8u&6"YGbn+F(LAuxT_t'1OwƗuo[|MNju:7nb'ޢ\Ń:I(NAxJ'sz(N"Œ1NE)c'4d9&In8L~ifcfpyL9<%08='2sRωE1,$U M!'",µjәl:μfYslBRMhM4КJi^R)Kj65'yi5ԚּfӚlZ Nl6yͦlbRMl6ymt3[DPrmܼ'(TzMo9A魩g[slkN\c)Kr6yIΦlҜMri&9/$ל4%:~mRMt^T%;$;/խJujJ̃lBp K"9_|/ω0)Jx0C4[yY2bƵ'a,t{~HqRRY /PA!8HE'Lx+n|S ݄p,10;άOȟ\l{wg̛:}JI9 93nN['{m^(oC8 mJZBޖ:0|h '5%?޽''̜45Wځ+5u u""m۵O_CǩVf]S;cLU[nEm3Us5PHhl~v{kdʩ/m;?OjTq#f`! QQNIH!U͈d *`?] xPUUwA@EAQ{PD423iS2b ;2ZkdLfԸTf)CqQqLo4fi{b.·{}{{׋jeYֲ`я$3^^&\ž Vfn.'V[޴M~:?/,h8͇]^+~S_{v{[ݜq{{ZLw}C,lA'| ?s?v.\V^^驦U=#ͧ_j{tt`ğѣh 辵wm ; *rȔ촶tѾ}I+lK[X[ ic@YĴnsjr#gw.C|{Y0{q]U9oպy&nz Mk5H> e8/ J|H?o%h[$w%=]FY.*^Q#+اs}- Wޏ(խ5|QSr5;wm5f{s7d(+Eד Y`f@1$2wBtC/]bu5t5n"1C>! g!@3_kkvE}%8./wpZ]eu:*/(`L =Ep fU\BJ0,QKWq`3T$NSʍ*UwbpRUOLRbT?TY B%e"^^bur0ɬRdLar(؛>,Xl+9K#8Oz"JZټ ~kk '.Rrb!1,'0Cqa8IoLfn8(k.A<6@(j*7n zR;[ ѸܸaC :atd hB|HTd,ł:DUvp%ok /ᲨgY8/Nqq8#avL@âՈP-*AP)>1TWlfb#ރb=yǶ"8I:+O^4qJa3xPLjjDVLcLvR3bAb(XȮExJX:e#,X`~5]Xk»tӵ+ec}XlkV[/|D}b+2+;E}h*gۡ^(TS5@ Cw3IwQ}OY"{8u, ?{ˢ0Oѽ3O= { ݃gY)ق=SENb=toxI+J"I9'Cm4y,yƘ34֜fsI,Mt՟e843 | /V2VV`HؠFPaQ8ưqƳ*zRE&RҘ,2詔LrYΣĒu!"J4ϲ(=s,VϣP**fqz!E,Q/U’kdYAkm5%5͔FJ3 4'$5~JRsҚIjNZ3I%iIlҚLZkIbsRIlNjsLbsRIlͥ6'$7'7ڜfR[K~$֒$F n- Τ$8'ř8Kq&5$gRLOLkIs4$:Dg\sIu&9ItN3Iu&ѵ$9ΤΤfj~mm+R{} 8YX@踟cubϳ(,d "?]TT)᡺Mb0ST'XSdzX}1c e(6>Ck90 ͤ-$V `1$%+! *'9 1 .ё^7؍zZ$ Ǯc#Xoa'6 !1;@-`:9۳WrR!l E-;BNȷ6/[榧L͍ 9sMy7,UmZ~ђsME`:M$!pA@HO^^_nqv~{{vvysnklqnfgpvniv{ulnspspgfnvqgilxyupquyysllpnklqvspsyyv{}~~xx~xxuq}qgkpxskkpqlillniggglibb_bfipppuy~~}~{xsv{xvy{}}~{~}yxvvpkilpnigdgkgd__gkkkfdfinnllkpnsvusy~~y}~{}upkklklklnqslllnnkkkidadiib\_dfiiiinvuxxyxx~{xxupipnfifdggfaffgipliiiffafddglgknpv~~unkpvysx~}~~~}{y}{nglsupnsv{{{{{{{~~yx{yxqquvyxuqqy}upqnvvx~}yyvvspxypqs{yi\^^YWPJKKMTY\^Z^ipssxqpuuusuppu{up~x~uǦqx}s^HCUP=..33+"!01+)18>JOT_nsu¾}vlf_UTWRJGJMTWRORY\UUYW^a^^bilkfadluqnusv{{xpifksld_fg\RRYbdWT^inliabgkgffdkibiqvqsx}~qnxsd\lvnYTagaYPUa^WMMRMKKPTRUW\_Yaknnls~xvy}}pilppkbdbZUZ^ZWUYZ^_a\^bdknlllqyyy}vvvqifadZY\UZURUTRYU\\UTW_d_\abipsx}}{v}}xpsxqukbgl_bgnigqqnnkflvg_d_dkdZUgyndaluliianxunpx˹ǵǾqqd_UOKC90=;03>CCJRUZYUP__UTgidpx{vx}{~}xnuuҸxdRRJ9,&!  '>;=Tlvxý½yppsxgUWWYMB=BRYTC66EJKKMMRWaa\\bgldZdqx{vv{nZ^lkWKHKJCB813==9CHC>BUYPRfnkq»{vxy{l\dnliffbgfWMMR\\Y\\^TR\dbZdqplv}{nyssy}~~}{~vquyvvuqusligZPRYUKHPWYY\abkilsux~xpuupnxqqnnnpnqkdaYWWPKKORYWZ\^^iknyua\nxupv~vy~}xgiqpkddffkiinnk_fnnq^ZnyibqsvyŶxnlvpfTKO^_WY\W\^^\\\ZW\^RP^b\WYadbbd_bigdk}~^vȶxffu_E835, '+!$9MRWdxyx~Խ~sx{xnggdWPPPH@GJHKRMGMWfaKRi~xbd{~ln¹¹}~{lbpqdRKOMC86335056BJGEG^pxux~~Ŷ}~~yps}yv~~}xu{upgbdb_\Z^ZY^bdpuu~xss~}xxv}~}vupkgaWTY_YMMZddY\gsxsu~}{~xy}xqqpvxsslpslinlafffnifpx}}~qdikbZUZYa_\inffsvssllpi_\iaMKYkpgTY~basöŽ»pn{udWOR_bJ;COYYPMMKC@MKEG;BPROU\_by}pxʾn\YOB60,$ !.8EPZdyʾy~{xuqlZOOCCORMG9=JKGJKMask^^daap}ó}x{yqy}qdWKEYRJY_TJPWRPWYafdb^anlgu~}yv{x{pln_R_iliaggafffgfblqllns{vpivui_^bg_Ublfb_ipkki_bfpnggip~}xnillf\YUJJKMPU_ag_^gu~~lfu{lTRlxiUECOYE>GGHKEMMZbZds}{Ǿugpyssifvsdddf__^^ZREMYTJGC_kPMi{kks{\yҾ}ugUEEH>'$')"'55,1=HHHKM\kx~}y~skia\adUM\YYgZEM_iaKJk~y{}gZZaaZR\b_ZZaafpkZbkgddY\nvvu~vnxy~~~ndgkknkpnklxskfkvpgfggUYssgiks}x~vy{~vy~~}npuyqlnsy}sknp}{qx}~vy~xpuxvqkqpgbbgngggkpqx{~{yupqqkad\TROUUMPRT_fZOYdspiny~lWWsbMGYqkWPTUWYZTHR\\HEWfnYRuxg{°qupaWMG8+6$"+'0356BH@CMUMUpq{xy}vxu~~silZEGOYUTYOdx{}x~y~vvxq\TfdZZ\nuigkpnnqvyyuux{v{uv}}upx~sdp{xvvnyyvqik}vbsxipubv~ysy~{{uvuq}uxuux{y}x{up{~vpqspkkllnssgW^bgqpqvu{~~yniys^JGbqaP56^iH@Y^xx~~xiuuiakqxsdgnuviTYbquiWUfZYqu^Yfafyv\iäŮͳusbldTEGE55@RUWYWTfu}qadikpdYdq_dynfnuqpk\gns~{sknvya\nnfg_akd^\ik_p{}}}y½ydfs~{nUTppbYYgnlkqpiluqvqxysyxpvy{ysl}{~vysilk_glgsuiu{plpngkpnqplpkbYTbiuqs}ys}xs{qsnklYPOfsZWdlxvi{{}{}un~{slv~qysnu}}gZ}~kqn~{pnqf_Zpxvvfv~~sY_qiRPZ\da\\\Pp}{uu}pq}}pu^aqsuniy~vs}i{~q{y~{~}}nknplld_Y^gb^Zdqv}~}{}{}y~~yxxnqkq~xx~y{yxv~y~qlxqlg_ax{snki{{}xx}sy}{ylgy}}{}~xss_lpgbZbiuulpsp}}y~svyganuyp\^pvsigu~svyv{~~vplqubqvu}pdnqs~~uvq^p{~ilqyub^fvsd\\\b_PHOTHYpsl^f{sbnvv}}ifdaaiiWbqsqlku{{qx{{v}vy{vuqdknvupqxux~~~{}{qpux{vsuqqssvu{uxyx{{vx}{}}yy}{}{vxvxsvuqqkinnkkisyvv}yvxxsnnspnqsxvuux}~}}~}~~xx{}~xnnquxvppssu{}y~~xux}}yx}~}~yxy~yyxpsvxxuqs{~}yyvyvkiffgfgiiikkfilkfkpy}}y{yuuvqlgiiggkklqpqsvxysv{{xpgkqsqvvvvsspqxx{uuy{sssp}gZ_dp{us}upk^RKd}sgvk\^ny~}qdbix~fPCMfsuslbpii\M{ykYa}dvTa}^g~lGba;>UnlkKO^{kP^akv\9HfOTlqE;C=\{G^g{bGZ¬nPikPTqUs{aTUl{¸W>KaMTx>G;Kg80TpxB)KuyqdPZxǕuglp§TllE09O^uqlfG3K^Ug}ǸsPWlZCRgvö}^PW\UbpsWWYC>Kas~W=EEqff͹bn_qTHbg_M_qxT61Hfvp”RfC6U{i^~xJKk_@CZl}ùZ^}RBRfyçisZ@Jf}xծqxiCYuP6Jlg9UxuiqbJ3HgaWk¹laidsyǹvdB)!&3WZYu~}bJ95EgZWvŹqdvbGBKi}kK@RM}vnŗ{uJYqG9K\{qgT89TRMdy~pgZGEUZkԾuB1B@asWPl\=GRig\nZJpuTERk}˸nYsg@3CayybusP9CHsv{ʶnvJ{q{R>;pKsŦv9Yl_HuGRvKYOJlplvnl_dvˍWpȩlC\xvu^d}qBHOidKJi}\ulgig~{ȳpCun\~}BWuC.Ck;=ZsG8Osn{xu}pOdbORflyfYYaZ356J_lûlMbWTduxȾ—_iROHRi}Ƚ~\dC^i^Y_Uiudzd_qu;66^~k\_y~TGGkd=)9TgžԽuEpgOTp˅Z~ÙWbZ6'1JfffJ9Jb{}b;=gpunnű_g}kKP^x͵ulxiZJ;KTp{ňxqC>;~Y5JJ~guJ+ig>HCT@avԅ{¬sskPUqʾa@6=BZixŸ{~d85KaGK^vxsPEgyPZvжiO059GZZp~ylaM+$>Uk}ŤsiPaladsŬf8CKWaB;MfnqfE3=EYbp~dBETqg_sň~yf\p}as{lR;;TTMZllM'.ZYBHT}yY@W\uv϶fBOYYJ\}\Wnu}__E8Jbu}ŮRPygOfKKgyȱgU\bp^yqB58KGMbyvP;MWnYnǜU=BaaPbpYlO!)d}=MfnHGYfϧY{vM9\E\l{WniYaPa\}xM$MiEyuygȳqdH6Gqbu}xUq96TE.Rbf{Y}Zq\u~paqv_CCUnfaTi}T9HxTgg{Ȟ\dslnU{MdxgÏOWx_{iuikRk}gOWYWqsq^=8EiMps>anU9,6Zk±^^vsxnRKfy¦lMi{d\U@0JbubJqvkxb@@OWZW}s{q~\H{yUdpWMixMPOgiJsK>Zn_}yklYabZvs_ZYH\i_k{~nP6=U}}{l~dGG_yxbõu~M=Yn{pyqZaY66G\{}qiaM>Rk{NJUg}vfW@.3C^fslkgfGuWfUlx˙ͱsUa_;>Pndsg}lYWORCayvv}dOK>Rafq©ldvaREKdp~Ⱦ_ygRKH__dxld{vnqgUEgYlaagYJnu\9OTCfyf~fdf{»n_RW_Z6EEJ_p}xkG=;ffšpB+B}saZsŸ_5PlifRdyl6=yJKWky˻qU8UpPWf{¹xfO3+@TbqvxlaJ15Rnd_{öǹ^OTubxyyʳ~l\C6Kpqu\vnW.3lkZbv~ydC5T}YpqP3@Zx^pq}siG&.E^}p}«~pMRl{GWs٦\Yqf^ZfsxJ'GM_Wql{\36q~iTiʻfH1B\p\~ùg@,;TgPl{xkM,Gi\Y{axqqqfa\T^YivkWaUluagyukf~ulUKp{ZniYKbyqHRKJguxfdaUUWb~~yypyqiYKPduödi_^^b_U_snO@EUku}~kM39;GWiuvdHUTYalpȹlHGd^\dx~kE&B}fRMkxkM9Epgký}pdYB8P~lfЩpdWG05O{abangM,Bsa^uȻxy~ZHP~kMTn~ëvv_9)dfasufuеqyRE_nxqdP8Eqgf{{gOHWYTkxq_WkgdxsisZnpfanl{{qkUkifk{g^}xqnbi\u~nHn{l\qu}u}xP@y~viuxsgqqvkuY@HKduǾ}KOk}_\TWguaYUnsOH{gffds{¤vxpfvZ\{ngbPHdqvxvd_xukWp{susdU\_RRqpdKOfÊi{iY9O}u{v}f{pW@@\lynvxupx~n@6RsUugdUWa{vß}vuO~\akg_lDZgg1Ex}KOqxuM@akx\qaa~lPYfU\v}y~}qakMPq{d_Wp}~iYksg\y{}6@s>>bqG_lqunTkp^kayaqqluvf^Tisvdqn~xiskZHk^vx}~vbqlWqq~_~qdqqaGaivn_RY^b=WiUpiR_\MYxyqgxxvuffuJBPng~Z~^8=\{{l~âuqqlkxfqqqlbqgxuu~~Zinfgdlvl{suvvsyP>;bs\ya}ZZbb^qRdyKBv{~}x{GM{kqZuf^TGEkki~xnfsMavU\yZM{palÏ_pdx~qUUdbf}~~y{udMs~dx{}}du}yxsbPfq}}ngxklnRJR{iRk}nBa{vYpWnubk_^ypk{}{i{qdvy{vfYWR~k}U5Znsxp}udapx{~~}qgfyxKTxk~uRanPOguJOdbnx}iWpuqZ_fu^~}i}sgki_pykslxuqpkxaas^\sxud_x~vW~_i{~pgxq\JZf\PqxRbqunWkiyknvsugW_vksn}{pklppa}qWf~ukGYfkdppfUk^\pnxq@;xdYvunnd\pqxsfU{qndssqyvZpvyybkkpkgau{v}xlbMCT_gppq~}\UnfYi{~}bZsnZWxiukdy{~fJasukJZbnd~qYkifi{\K^uxubTk~p\kklPJabaxaf{~~svUv{ZWis{plu~bCJ_nnvflfdv{}gM^}u}}x{~}uyWHE}xd~ZEMg}xk>B}nqupgsMnMRkskn}s_R9=OZ_\usgKJnsanfiJYdgT\Wkv~p^^lu~qkU>BP\gnivvnl^PEYddid_g~vp}x~ZRfvpsu~usvRkTP^isuiv˩yy~qgWEZba_uqfdibTEPguȰ}nqZCBWgvͶnkavYKT^yuȫfPp{kigqlq{iy^OUUfv{sTTdaUdqk^KRTn~î}lsTfxsYp{Y_{^EUWUi{uvg}d^Ydin{n_KP^iRav~udRZibi}sifaUHZnba~kTPnpy~_x\yORviYsx^YfygZf}nx}pgZP_q~nxlda\KHWgxknibfdbuydO~~iZi~nkZs{vqYan{}pdROfkxk~nPZuynl}y}v_aRYlyixq^pyU_gYiy^nqaf}_Y{WYg^\~U^pggaUssYl^Zq{fl}a^p{fx^Zni\y\Raxy_yyPTklnaTp{snZuvaxv_dysykgxy~ub\bsup~{niuylnpiqn}sb_n{qsysunvy}xp{{~~ldiky~y}kfnqqynpu{lbgy{s}kgvxp}}llpqx{lfgq{yuxyx{{qpu{vnv}skuy~vp{~vsqnv~vvssqv~y{unqyx{ss}}plv}pluy~yy}xllv}}xsss{vnqyyuux{yy{ysy}~}}yy~{vsqqsx~xxy~xqqx}xy}uppy~xsv{uv}{y{}y}~~~~{y~~yxy}~}}~~{{~{{~{xy}~~{vvy~}xy{{}~}}yxxy~yvy~}{y{{yy}~~~}{}~~~{yx{~yy{}~}{{{~~{{}~{}~~~~~~~~}}{{~~~~~}}}~~}{}~}{}~~~~}~~~}~~~~~{yy}~~~~}~~~}~~~~~}}}~~~~}}~~}}}~~~~}~~}~~~~~~~~~~~~~~~~~~~~}~~~~}~~~~~~~~~~~~~}}~~~~~~~~~~}}}~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ h`LT            6 7 8 ;<=>ADEFGHIJKLMNOP QR/X2$șوX-*>L4Q 2$QQNIH!U͈  0AA@8/0ʚ;?2ʚ;g4qdqd@č<T0ppp@ <4dddd=!0POw g4KdKdō<T0pH px"___PPT10DSimSunt<~0d POPOt<T0t<DArialt<~0d POPOt<T0t< 66___PPT9{?  %O  =pJXMessages: Building Reliable, Persistent Messaging Middleware for the GridKK0Yogesh L. Simmhan Aleksander Slominski, Dennis Gannon, Mathew Farrellee, Albert Rossi, Octav Chipara Extreme! Computing Lab Indiana Universitye*GridBGroups of collaborating users Share collective access to resourcesGrid Messaging & NotificationBasic service level Changes in state of service System level Hardware performance monitor Application level Workflow messaging User level Application steering     /Messaging Requirements: Bandwidth vs. Latency00$  Messaging Requirements (contd.)FReliability Security Location independence Persistence ScalabilityZG     Existing Messaging Systems^CORBA notification ECho event delivery system Java Messaging System (JMS) Narada Brokering H_    XMessages: Key features~Arbitrary XML messages Reliability Publisher and listener agents Persistent storage RDBMS, Native XML DB Historical message retrieval  Push and  Pull message notification SQL, XPath queriest#2'#2' XMessages Architecture  XMessages APIXMessageSink void handleMessages ( XMessageBatch messages ) XMessageSource XMessageBatch requestMessages ( XMessageRequest request )  ! @~      XMessages API (contd.)XMessageBatch Array of XMessages Tokens  soft state XMessageRequest Query/token Max. messages, time-range b'&'&$ )( XMessages ImplementationClient side  Agent library Wrapper around channel Publisher agent provides reliability Listener agent allows  pull and  push Implementation Java and C/C++ publisher agent Java listener agent 633 !XMessages Implementation (contd.)  Publishing MessagesClient Get reference to channel Create publisher agent for channel Call handleMessages on agent with the message Publisher agent Buffer and log message to store (File, DBMS) Try to send If success, mark in log. Else retry sending. rkfAfH Retrieving MessagesClient Get reference to channel Create listener agent for channel Get  pull or  push subscription from agent based on query If  pull , call pullMessages on agent. Else implement handleMessages Renew leasefq  ,  Retrieving Messages (contd.)lListener agent If  push subscription, start thread to pull from channel using query Call handleMessages on client when messages have been retrieved from channel If  pull subscription, wait for user to invoke pullMessages on agent Call requestMessages on channel with query or token. Return result to client.|(@j 9>Zk :Message handling in the ChannelWhen handleMessages is called, store message in database Data, meta-data stored separately Xindice, MySQL, HypersonicSQL RDBMS vs. Native XML When requestMessages is called Extract query from token Execute query on database Return messages and next token9VR&V 2bH ] PerformancePerformance of publisher agent Future workZAdd security layer Bridge to other messaging systems JMS Narada OGSA Plug-in architecture 655 Questions /8 P[  0` f̙f` \'݉f̙ft` 3v;̙3fff` Q%]m6fft` JU;f̙ft` fffff` f33f̙f3` fff̙>?" dd@,?pKd@n pA@d`hP n?" dd@   @@``PT    @ ` `:p>> ` X(    6 " `}  T Click to edit Master title style! !$  0 " `  RClick to edit Master text styles Second level Third level Fourth level Fifth level!     S  0$ "` `  @*   0  "`    B*   0  "` `   B*   6T " 20B  s *DjJ" ,$0  6D "@  20  6 "@  20H  0޽h ? fff̙___PPT10i. η+D='  = @B +  Level /0 p s(    6  #" `   T Click to edit Master title style! !  0  " ` |    W#Click to edit Master subtitle style$ $  0\  "` `   @*   0\  "`    B*   0  "` `   \*     ",$D 0h  s *" h   s *" h   s *" H  0޽h ? fff̙___PPT10i. η+D='  = @B +(/0 8(     N@ Kf&Kf& W!  @  v* B!!BBcc  N#@ Kf&Kf&  ! @  x* B!!BBccd  c $ ?'  @ 4  N,@ Kf&Kf&  > @  RClick to edit Master text styles Second level Third level Fourth level Fifth level!     S  T48@ Kf&Kf& nW  @  v* B!!BBcc  T<@ Kf&Kf& n  @  x* B!!BBccH  0!i ? 3380___PPT10.u 00aN0  0(  x  c $    x  c $  ` `   H  0޽h ? 33___PPT10i.u /m+D='  = @B + /0 L(  r  S n  `}   r  S o  `     0|  "` ` ! Grid Servicesl  0o ` `   0t P [GSecurity Remote execution Information services Data services MonitoringRB  s *D1 H  0޽h ? fff̙___PPT10i.u+D='  = @B +} /0 $(  r  S t  `}   r  S tu P `v   H  0޽h ? fff̙___PPT10i.u+D='  = @B + /0  (  r  S ~  `}   dB  <DjJ@dB  <DjJ@@  6 "`  HDecreasing latency   0 "`\A0 JIncreasing bandwidth   0 "`p  P  CUser level messaging Asynchronous group comm Application steering4 / /!  0 "` `  cApplication level services Workflow notification Error condition reporting Metadata/data logging4 I I)  0ܖ ff"`@`  IBasic grid service notif. Service state changes Service error reporting4 0 02  0X{ ff"` ` p [System level event stream Instrument monitors Sensor data stream CPU performance monitor4 B BH  0޽h ? fff̙___PPT10i.u+D='  = @B +} /0 @$(  r  S   `}   r  S ĩ  `p   H  0޽h ? fff̙___PPT10i.u (+D='  = @B +} /0 P$(  r  S \  `}   r  S  P    H  0޽h ? fff̙___PPT10i.u`+D='  = @B +} /0 `$(  r  S   `}   r  S `  `   H  0޽h ? fff̙___PPT10i.u+D='  = @B +'  /0 > 6 p (  r  S   `}     B "``P Z$Web services client pushes messages% %  < "``  UXPortlet uses Java API to send      <d ff"`0 `  V Fortran program makes C API call! !R   H "`   <Sink     H G&3"`   QPersistent Message Channel R   HL "` P 0  >Source    BX "`0 P  TClient subscribes for messages   < "` P  RXPortlet pulls From channel   <L ff"`PP X"Web services client pulls messages# #dB  <D>``` dB @ <D>`P` dB  <D> ` dB @ <D> P dB  <D> ` dB  <D> P H  0޽h ? fff̙___PPT10i.uI+D='  = @B +} /0  $(   r   S p  `}   r   S   `   H   0޽h ? fff̙___PPT10i.u %+D='  = @B +} /0 $$(  $r $ S   `}    r $ S   `   H $ 0޽h ? fff̙___PPT10i.u*+D='  = @B +} /0 ($(  (r ( S    `}    r ( S    `   H ( 0޽h ? fff̙___PPT10i.uE+D='  = @B + /0 1), (  ,r , S   `}     , B( "`@` GMessage Publisher R , B "`   <Sink   , B\ G&3"`   QPersistent Message Channel R  , BP "` P 0  >Source    , B! G3"`  j&Publisher Agent: Store, deliver, retry(' R , H' "`  <Sink   , <+ "`   GLocal Message Log  dB , <D>  dB , <D> ` dB ,@ <D> P b , 6/ "`0 `   WXindice b , 6(1 "`0 p  UMySQL f2 , 0"` P l2 , 6-"` w l2 , 6;"`   , <9 "`@ zDMessage Listener  Pull or  Push # # , Bp: G3"`P0  h$Listener Agent: Pull, maintain token(% R , HZB "`0P@ <Sink  dB , <D>H , 0޽h ? fff̙___PPT10i.uf+D='  = @B +} /0 0$(  0r 0 S P  `}   r 0 S (  `   H 0 0޽h ? fff̙___PPT10i.uxj+D='  = @B +} /0 4$(  4r 4 S H  `}    r 4 S I  `   H 4 0޽h ? fff̙___PPT10i.u@pL+D='  = @B +} /0 8$(  8r 8 S O  `}    r 8 S O  `   H 8 0޽h ? fff̙___PPT10i.u8'+D='  = @B +} /0 <$(  <r < S U  `}    r < S V  `   H < 0޽h ? fff̙___PPT10i.u߸+D='  = @B +@ /0 WO @(  @r @ S   @  POGSA (open grid services arch.) : messaging => notification; message => events ,/H  0!i ? 3380___PPT10.u` 0 TL(  ^  S '   @ F  c $h@  >  @  Security: authentication, authorization, privacy Information services: naming, resolving, discovery Data services: remote data access, metadata management, caching Monitoring: resources and servicesH  0!i ? 3380___PPT10.u@Umrh ]miqx{Aq:L?čIΒ3=¿ X1Oh+'0D hp    $,LXMessages: Building Reliable, Persistent Messaging Middleware for the Grid1@`@.VP@`/uG g  4  y--$xx--'ff--$2666622--'--$6266h6h262--'--$h2h662h2--'@Garamond-. 42 XMessages: Building Reliable,  ."System07-@Garamond-. '2 !%Persistent Messaging b.-@Garamond-. *2 -Middleware for the Grid .-@"Verdana-. !2 A/Yogesh L. Simmhane.-@"Verdana-. 32 KAleksander Slominski, Dennis .-@"Verdana-. .2 S#Gannon, Mathew Farrellee, .-@"Verdana-. 02 ["Albert Rossi, Octav Chiparas.-@"Verdana-. (2 c,Extreme! Computing Lab.-@"Verdana-. "2 k5Indiana University.-՜.+,0    On-screen Show\ Arial GaramondTimes New RomanVerdana Wingdings Trebuchet MSSimSunLevelKXMessages: Building Reliable, Persistent Messaging Middleware for the GridGridGrid Messaging & Notification0Messaging Requirements: Bandwidth vs. Latency Messaging Requirements (contd.)Existing Messaging SystemsXMessages: Key featuresXMessages ArchitectureXMessages APIXMessages API (contd.)XMessages Implementation"XMessages Implementation (contd.)Publishing MessagesRetrieving MessagesRetrieving Messages (contd.) Message handling in the Channel Performance Future work Questions  Fonts UsedDesign Template Slide Titles_0    !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstvwxyz{|~Root EntrydO)Pictures\Current UserSummaryInformation(uPowerPoint Document( DocumentSummaryInformation8}