<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<meta http-equiv="Content-Type" content="text/html;charset=UTF-8">
<head>
<style>.content {
padding: 20px;
height: 100%;
width: 944px;
margin-left: auto;
margin-right: auto;
}
.fold {
width: 20px;
float: left;
-webkit-touch-callout: none;
-webkit-user-select: none;
-khtml-user-select: none;
-moz-user-select: none;
-ms-user-select: none;
user-select: none;
}
.number {
width: 45px;
float: left;
margin-right: 10px;
text-align: right;
-webkit-touch-callout: none;
-webkit-user-select: none;
-khtml-user-select: none;
-moz-user-select: none;
-ms-user-select: none;
user-select: none;
}
.line {
}
.content {
font-family: "Monospace";
font-size: 1em;
background: #3f3f3f;
color: White;
width: 944px;
padding: 20px;
height: 100%;
margin-left: auto;
margin-right: auto;
}
font.Alert {
color: Yellow;
font-weight: bold;
}
font.Annotation {
color: Yellow;
font-style: italic;
}
font.Attribute {
color: LightPink;
}
font.BaseN {
color: Gold;
}
font.BuiltIn {
color: Coral;
}
font.Char {
color: Cyan;
}
font.Comment {
color: Beige;
font-style: italic;
}
font.CommentVar {
color: LightBlue;
font-style: italic;
}
font.Constant {
color: White;
font-weight: bold;
}
font.ControlFlow {
color: DeepPink;
}
font.DataType {
color: CadetBlue;
}
font.DecVal {
color: MediumPurple;
font-weight: bold;
}
font.Documentation {
color: Gold;
font-style: italic;
}
font.Error {
color: Red;
font-weight: bold;
}
font.Extension {
color: DarkGray;
font-weight: bold;
}
font.Float {
color: DarkViolet;
font-weight: bold;
}
font.Function {
color: RosyBrown;
}
font.Import {
color: PaleVioletRed;
}
font.Information {
color: LightGreen;
font-style: italic;
}
font.Keyword {
color: LightGreen;
font-weight: bold;
}
font.Normal {
color: White;
}
font.Operator {
color: Magenta;
}
font.Others {
color: GreenYellow;
}
font.Preprocessor {
color: DarkSeaGreen ;
font-weight: bold;
}
font.RegionMarker {
color: Plum;
}
font.SpecialChar {
color: Plum;
font-weight: bold;
}
font.SpecialString {
color: LightBlue;
}
font.String {
color: MediumAquaMarine;
}
font.Variable {
color: Turquoise;
font-weight: bold;
}
font.VerbatimString {
color: LightSkyBlue;
}
font.Warning {
color: Brown;
font-weight: bold;
}
</style>
<title>Kamelon output</title>
</head>
<body>
<div class="content">
<div id="1" class="line"><font class="Comment">/*</font></br></div>
<div id="2" class="line"><font class="Comment"> * Copyright (c) 2006 Sun Microsystems, Inc. All rights reserved. U.S.</font></br></div>
<div id="3" class="line"><font class="Comment"> * Government Rights - Commercial software. Government users are subject</font></br></div>
<div id="4" class="line"><font class="Comment"> * to the Sun Microsystems, Inc. standard license agreement and</font></br></div>
<div id="5" class="line"><font class="Comment"> * applicable provisions of the FAR and its supplements. Use is subject</font></br></div>
<div id="6" class="line"><font class="Comment"> * to license terms.</font></br></div>
<div id="7" class="line"><font class="Comment"> *</font></br></div>
<div id="8" class="line"><font class="Comment"> * This distribution may include materials developed by third parties.</font></br></div>
<div id="9" class="line"><font class="Comment"> * Sun, Sun Microsystems, the Sun logo, Java and J2EE are trademarks</font></br></div>
<div id="10" class="line"><font class="Comment"> * or registered trademarks of Sun Microsystems, Inc. in the U.S. and</font></br></div>
<div id="11" class="line"><font class="Comment"> * other countries.</font></br></div>
<div id="12" class="line"><font class="Comment"> *</font></br></div>
<div id="13" class="line"><font class="Comment"> * Copyright (c) 2006 Sun Microsystems, Inc. Tous droits reserves.</font></br></div>
<div id="14" class="line"><font class="Comment"> *</font></br></div>
<div id="15" class="line"><font class="Comment"> * Droits du gouvernement americain, utilisateurs gouvernementaux - logiciel</font></br></div>
<div id="16" class="line"><font class="Comment"> * commercial. Les utilisateurs gouvernementaux sont soumis au contrat de</font></br></div>
<div id="17" class="line"><font class="Comment"> * licence standard de Sun Microsystems, Inc., ainsi qu'aux dispositions</font></br></div>
<div id="18" class="line"><font class="Comment"> * en vigueur de la FAR (Federal Acquisition Regulations) et des</font></br></div>
<div id="19" class="line"><font class="Comment"> * supplements a celles-ci. Distribue par des licences qui en</font></br></div>
<div id="20" class="line"><font class="Comment"> * restreignent l'utilisation.</font></br></div>
<div id="21" class="line"><font class="Comment"> *</font></br></div>
<div id="22" class="line"><font class="Comment"> * Cette distribution peut comprendre des composants developpes par des</font></br></div>
<div id="23" class="line"><font class="Comment"> * tierces parties. Sun, Sun Microsystems, le logo Sun, Java et J2EE</font></br></div>
<div id="24" class="line"><font class="Comment"> * sont des marques de fabrique ou des marques deposees de Sun</font></br></div>
<div id="25" class="line"><font class="Comment"> * Microsystems, Inc. aux Etats-Unis et dans d'autres pays.</font></br></div>
<div id="26" class="line"><font class="Comment"> */</font></br></div>
<div id="27" class="line"></br></div>
<div id="28" class="line"></br></div>
<div id="29" class="line"><font class="Keyword">import</font><font class="Import"> javax.jms.ConnectionFactory;</font></br></div>
<div id="30" class="line"><font class="Keyword">import</font><font class="Import"> javax.jms.Queue;</font></br></div>
<div id="31" class="line"><font class="Keyword">import</font><font class="Import"> javax.jms.Topic;</font></br></div>
<div id="32" class="line"><font class="Keyword">import</font><font class="Import"> javax.jms.Connection;</font></br></div>
<div id="33" class="line"><font class="Keyword">import</font><font class="Import"> javax.jms.Session;</font></br></div>
<div id="34" class="line"><font class="Keyword">import</font><font class="Import"> javax.jms.MessageProducer;</font></br></div>
<div id="35" class="line"><font class="Keyword">import</font><font class="Import"> javax.jms.MessageConsumer;</font></br></div>
<div id="36" class="line"><font class="Keyword">import</font><font class="Import"> javax.jms.TextMessage;</font></br></div>
<div id="37" class="line"><font class="Keyword">import</font><font class="Import"> javax.jms.JMSException;</font></br></div>
<div id="38" class="line"></br></div>
<div id="39" class="line"></br></div>
<div id="40" class="line"><font class="Keyword">public</font><font class="Normal"> </font><font class="Keyword">class</font><font class="Normal"> SampleUtilities {</font></br></div>
<div id="41" class="line"><font class="Normal"> </font><font class="Documentation">/**</font></br></div>
<div id="42" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> Waits for </font><font class="Documentation">'count'</font><font class="Normal"> messages on controlQueue before</font></br></div>
<div id="43" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> continuing</font><font class="Documentation">. </font><font class="Normal"> Called by a publisher to make sure that</font></br></div>
<div id="44" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> subscribers have started before it begins publishing</font></br></div>
<div id="45" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> messages</font><font class="Comment">.</font></br></div>
<div id="46" class="line"><font class="Normal"> </font><font class="Documentation">*</font></br></div>
<div id="47" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> If controlQueue does not exist</font><font class="Comment">,</font><font class="Normal"> the method throws an</font></br></div>
<div id="48" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> exception</font><font class="Comment">.</font></br></div>
<div id="49" class="line"><font class="Normal"> </font><font class="Documentation">*</font></br></div>
<div id="50" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> </font><font class="Char">@param </font><font class="Keyword">prefix </font><font class="Normal"> prefix </font><font class="Comment">(</font><font class="Normal">publisher or subscriber</font><font class="Comment">)</font><font class="Normal"> to be</font></br></div>
<div id="51" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> displayed</font></br></div>
<div id="52" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> </font><font class="Char">@param </font><font class="Keyword">controlQueue </font><font class="Normal"> control queue</font></br></div>
<div id="53" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> </font><font class="Char">@param </font><font class="Keyword">count </font><font class="Normal"> number of messages to receive</font></br></div>
<div id="54" class="line"><font class="Normal"> </font><font class="Documentation">*/</font></br></div>
<div id="55" class="line"><font class="Normal"> </font><font class="Keyword">public</font><font class="Normal"> </font><font class="DataType">static</font><font class="Normal"> </font><font class="DataType">void</font><font class="Normal"> </font><font class="Function">receiveSynchronizeMessages</font><font class="Normal">(</font><font class="BuiltIn">String</font><font class="Normal"> prefix,</font></br></div>
<div id="56" class="line"><font class="Normal"> ConnectionFactory connectionFactory, </font><font class="BuiltIn">Queue</font><font class="Normal"> controlQueue, </font><font class="DataType">int</font><font class="Normal"> count)</font></br></div>
<div id="57" class="line"><font class="Normal"> </font><font class="Keyword">throws</font><font class="Normal"> </font><font class="BuiltIn">Exception</font><font class="Normal"> {</font></br></div>
<div id="58" class="line"><font class="Normal"> </font><font class="BuiltIn">Connection</font><font class="Normal"> connection = </font><font class="Keyword">null</font><font class="Normal">;</font></br></div>
<div id="59" class="line"><font class="Normal"> Session session = </font><font class="Keyword">null</font><font class="Normal">;</font></br></div>
<div id="60" class="line"><font class="Normal"> MessageConsumer receiver = </font><font class="Keyword">null</font><font class="Normal">;</font></br></div>
<div id="61" class="line"></br></div>
<div id="62" class="line"><font class="Normal"> </font><font class="Keyword">try</font><font class="Normal"> {</font></br></div>
<div id="63" class="line"><font class="Normal"> connection = connectionFactory.</font><font class="Function">createConnection</font><font class="Normal">();</font></br></div>
<div id="64" class="line"><font class="Normal"> session = connection.</font><font class="Function">createSession</font><font class="Normal">(</font><font class="Keyword">false</font><font class="Normal">, Session.</font><font class="Function">AUTO_ACKNOWLEDGE</font><font class="Normal">);</font></br></div>
<div id="65" class="line"><font class="Normal"> connection.</font><font class="Function">start</font><font class="Normal">();</font></br></div>
<div id="66" class="line"><font class="Normal"> } </font><font class="Keyword">catch</font><font class="Normal"> (</font><font class="BuiltIn">Exception</font><font class="Normal"> e) {</font></br></div>
<div id="67" class="line"><font class="Normal"> </font><font class="BuiltIn">System</font><font class="Normal">.</font><font class="Function">err</font><font class="Normal">.</font><font class="Function">println</font><font class="Normal">(</font></br></div>
<div id="68" class="line"><font class="Normal"> </font><font class="String">"receiveSynchronizeMessages connection problem: "</font><font class="Normal"> +</font></br></div>
<div id="69" class="line"><font class="Normal"> e.</font><font class="Function">toString</font><font class="Normal">());</font></br></div>
<div id="70" class="line"><font class="Normal"> e.</font><font class="Function">printStackTrace</font><font class="Normal">();</font></br></div>
<div id="71" class="line"></br></div>
<div id="72" class="line"><font class="Normal"> </font><font class="Keyword">if</font><font class="Normal"> (connection != </font><font class="Keyword">null</font><font class="Normal">) {</font></br></div>
<div id="73" class="line"><font class="Normal"> </font><font class="Keyword">try</font><font class="Normal"> {</font></br></div>
<div id="74" class="line"><font class="Normal"> connection.</font><font class="Function">close</font><font class="Normal">();</font></br></div>
<div id="75" class="line"><font class="Normal"> } </font><font class="Keyword">catch</font><font class="Normal"> (JMSException ee) {</font></br></div>
<div id="76" class="line"><font class="Normal"> }</font></br></div>
<div id="77" class="line"><font class="Normal"> }</font></br></div>
<div id="78" class="line"></br></div>
<div id="79" class="line"><font class="Normal"> </font><font class="Keyword">throw</font><font class="Normal"> e;</font></br></div>
<div id="80" class="line"><font class="Normal"> }</font></br></div>
<div id="81" class="line"></br></div>
<div id="82" class="line"><font class="Normal"> </font><font class="Keyword">try</font><font class="Normal"> {</font></br></div>
<div id="83" class="line"><font class="Normal"> </font><font class="BuiltIn">System</font><font class="Normal">.</font><font class="Function">out</font><font class="Normal">.</font><font class="Function">println</font><font class="Normal">(prefix + </font><font class="String">"Receiving synchronize messages from "</font><font class="Normal"> +</font></br></div>
<div id="84" class="line"><font class="Normal"> </font><font class="String">"control queue; count = "</font><font class="Normal"> + count);</font></br></div>
<div id="85" class="line"><font class="Normal"> receiver = session.</font><font class="Function">createConsumer</font><font class="Normal">(controlQueue);</font></br></div>
<div id="86" class="line"></br></div>
<div id="87" class="line"><font class="Normal"> </font><font class="Keyword">while</font><font class="Normal"> (count > </font><font class="Float">0</font><font class="Normal">) {</font></br></div>
<div id="88" class="line"><font class="Normal"> receiver.</font><font class="Function">receive</font><font class="Normal">();</font></br></div>
<div id="89" class="line"><font class="Normal"> count--;</font></br></div>
<div id="90" class="line"><font class="Normal"> </font><font class="BuiltIn">System</font><font class="Normal">.</font><font class="Function">out</font><font class="Normal">.</font><font class="Function">println</font><font class="Normal">(prefix + </font><font class="String">"Received synchronize message; "</font><font class="Normal"> +</font></br></div>
<div id="91" class="line"><font class="Normal"> </font><font class="String">" expect "</font><font class="Normal"> + count + </font><font class="String">" more"</font><font class="Normal">);</font></br></div>
<div id="92" class="line"><font class="Normal"> }</font></br></div>
<div id="93" class="line"><font class="Normal"> } </font><font class="Keyword">catch</font><font class="Normal"> (JMSException e) {</font></br></div>
<div id="94" class="line"><font class="Normal"> </font><font class="BuiltIn">System</font><font class="Normal">.</font><font class="Function">err</font><font class="Normal">.</font><font class="Function">println</font><font class="Normal">(</font><font class="String">"Exception occurred: "</font><font class="Normal"> + e.</font><font class="Function">toString</font><font class="Normal">());</font></br></div>
<div id="95" class="line"><font class="Normal"> </font><font class="Keyword">throw</font><font class="Normal"> e;</font></br></div>
<div id="96" class="line"><font class="Normal"> } </font><font class="Keyword">finally</font><font class="Normal"> {</font></br></div>
<div id="97" class="line"><font class="Normal"> </font><font class="Keyword">if</font><font class="Normal"> (connection != </font><font class="Keyword">null</font><font class="Normal">) {</font></br></div>
<div id="98" class="line"><font class="Normal"> </font><font class="Keyword">try</font><font class="Normal"> {</font></br></div>
<div id="99" class="line"><font class="Normal"> connection.</font><font class="Function">close</font><font class="Normal">();</font></br></div>
<div id="100" class="line"><font class="Normal"> } </font><font class="Keyword">catch</font><font class="Normal"> (JMSException e) {</font></br></div>
<div id="101" class="line"><font class="Normal"> }</font></br></div>
<div id="102" class="line"><font class="Normal"> }</font></br></div>
<div id="103" class="line"><font class="Normal"> }</font></br></div>
<div id="104" class="line"><font class="Normal"> }</font></br></div>
<div id="105" class="line"></br></div>
<div id="106" class="line"><font class="Normal"> </font><font class="Documentation">/**</font></br></div>
<div id="107" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> Sends a message to controlQueue</font><font class="Documentation">. </font><font class="Normal"> Called by a subscriber</font></br></div>
<div id="108" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> to notify a publisher that it is ready to receive</font></br></div>
<div id="109" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> messages</font><font class="Comment">.</font></br></div>
<div id="110" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> </font><font class="Keyword"><p></font></br></div>
<div id="111" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> If controlQueue doesn</font><font class="Comment">'t</font><font class="Normal"> exist</font><font class="Comment">,</font><font class="Normal"> the method throws an</font></br></div>
<div id="112" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> exception</font><font class="Comment">.</font></br></div>
<div id="113" class="line"><font class="Normal"> </font><font class="Documentation">*</font></br></div>
<div id="114" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> </font><font class="Char">@param </font><font class="Keyword">prefix </font><font class="Normal"> prefix </font><font class="Comment">(</font><font class="Normal">publisher or subscriber</font><font class="Comment">)</font><font class="Normal"> to be</font></br></div>
<div id="115" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> displayed</font></br></div>
<div id="116" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> </font><font class="Char">@param </font><font class="Keyword">controlQueue </font><font class="Normal"> control queue</font></br></div>
<div id="117" class="line"><font class="Normal"> </font><font class="Documentation">*/</font></br></div>
<div id="118" class="line"><font class="Normal"> </font><font class="Keyword">public</font><font class="Normal"> </font><font class="DataType">static</font><font class="Normal"> </font><font class="DataType">void</font><font class="Normal"> </font><font class="Function">sendSynchronizeMessage</font><font class="Normal">(</font><font class="BuiltIn">String</font><font class="Normal"> prefix,</font></br></div>
<div id="119" class="line"><font class="Normal"> ConnectionFactory connectionFactory, </font><font class="BuiltIn">Queue</font><font class="Normal"> controlQueue)</font></br></div>
<div id="120" class="line"><font class="Normal"> </font><font class="Keyword">throws</font><font class="Normal"> </font><font class="BuiltIn">Exception</font><font class="Normal"> {</font></br></div>
<div id="121" class="line"><font class="Normal"> </font><font class="BuiltIn">Connection</font><font class="Normal"> connection = </font><font class="Keyword">null</font><font class="Normal">;</font></br></div>
<div id="122" class="line"><font class="Normal"> Session session = </font><font class="Keyword">null</font><font class="Normal">;</font></br></div>
<div id="123" class="line"><font class="Normal"> MessageProducer producer = </font><font class="Keyword">null</font><font class="Normal">;</font></br></div>
<div id="124" class="line"><font class="Normal"> TextMessage message = </font><font class="Keyword">null</font><font class="Normal">;</font></br></div>
<div id="125" class="line"></br></div>
<div id="126" class="line"><font class="Normal"> </font><font class="Keyword">try</font><font class="Normal"> {</font></br></div>
<div id="127" class="line"><font class="Normal"> connection = connectionFactory.</font><font class="Function">createConnection</font><font class="Normal">();</font></br></div>
<div id="128" class="line"><font class="Normal"> session = connection.</font><font class="Function">createSession</font><font class="Normal">(</font><font class="Keyword">false</font><font class="Normal">, Session.</font><font class="Function">AUTO_ACKNOWLEDGE</font><font class="Normal">);</font></br></div>
<div id="129" class="line"><font class="Normal"> } </font><font class="Keyword">catch</font><font class="Normal"> (</font><font class="BuiltIn">Exception</font><font class="Normal"> e) {</font></br></div>
<div id="130" class="line"><font class="Normal"> </font><font class="BuiltIn">System</font><font class="Normal">.</font><font class="Function">err</font><font class="Normal">.</font><font class="Function">println</font><font class="Normal">(</font><font class="String">"sendSynchronizeMessage connection problem: "</font><font class="Normal"> +</font></br></div>
<div id="131" class="line"><font class="Normal"> e.</font><font class="Function">toString</font><font class="Normal">());</font></br></div>
<div id="132" class="line"><font class="Normal"> e.</font><font class="Function">printStackTrace</font><font class="Normal">();</font></br></div>
<div id="133" class="line"></br></div>
<div id="134" class="line"><font class="Normal"> </font><font class="Keyword">if</font><font class="Normal"> (connection != </font><font class="Keyword">null</font><font class="Normal">) {</font></br></div>
<div id="135" class="line"><font class="Normal"> </font><font class="Keyword">try</font><font class="Normal"> {</font></br></div>
<div id="136" class="line"><font class="Normal"> connection.</font><font class="Function">close</font><font class="Normal">();</font></br></div>
<div id="137" class="line"><font class="Normal"> } </font><font class="Keyword">catch</font><font class="Normal"> (JMSException ee) {</font></br></div>
<div id="138" class="line"><font class="Normal"> }</font></br></div>
<div id="139" class="line"><font class="Normal"> }</font></br></div>
<div id="140" class="line"></br></div>
<div id="141" class="line"><font class="Normal"> </font><font class="Keyword">throw</font><font class="Normal"> e;</font></br></div>
<div id="142" class="line"><font class="Normal"> }</font></br></div>
<div id="143" class="line"></br></div>
<div id="144" class="line"><font class="Normal"> </font><font class="Keyword">try</font><font class="Normal"> {</font></br></div>
<div id="145" class="line"><font class="Normal"> producer = session.</font><font class="Function">createProducer</font><font class="Normal">(controlQueue);</font></br></div>
<div id="146" class="line"><font class="Normal"> message = session.</font><font class="Function">createTextMessage</font><font class="Normal">();</font></br></div>
<div id="147" class="line"><font class="Normal"> message.</font><font class="Function">setText</font><font class="Normal">(</font><font class="String">"synchronize"</font><font class="Normal">);</font></br></div>
<div id="148" class="line"><font class="Normal"> </font><font class="BuiltIn">System</font><font class="Normal">.</font><font class="Function">out</font><font class="Normal">.</font><font class="Function">println</font><font class="Normal">(prefix + </font><font class="String">"Sending synchronize message to "</font><font class="Normal"> +</font></br></div>
<div id="149" class="line"><font class="Normal"> </font><font class="String">"control queue"</font><font class="Normal">);</font></br></div>
<div id="150" class="line"><font class="Normal"> producer.</font><font class="Function">send</font><font class="Normal">(message);</font></br></div>
<div id="151" class="line"><font class="Normal"> } </font><font class="Keyword">catch</font><font class="Normal"> (JMSException e) {</font></br></div>
<div id="152" class="line"><font class="Normal"> </font><font class="BuiltIn">System</font><font class="Normal">.</font><font class="Function">err</font><font class="Normal">.</font><font class="Function">println</font><font class="Normal">(</font><font class="String">"Exception occurred: "</font><font class="Normal"> + e.</font><font class="Function">toString</font><font class="Normal">());</font></br></div>
<div id="153" class="line"><font class="Normal"> </font><font class="Keyword">throw</font><font class="Normal"> e;</font></br></div>
<div id="154" class="line"><font class="Normal"> } </font><font class="Keyword">finally</font><font class="Normal"> {</font></br></div>
<div id="155" class="line"><font class="Normal"> </font><font class="Keyword">if</font><font class="Normal"> (connection != </font><font class="Keyword">null</font><font class="Normal">) {</font></br></div>
<div id="156" class="line"><font class="Normal"> </font><font class="Keyword">try</font><font class="Normal"> {</font></br></div>
<div id="157" class="line"><font class="Normal"> connection.</font><font class="Function">close</font><font class="Normal">();</font></br></div>
<div id="158" class="line"><font class="Normal"> } </font><font class="Keyword">catch</font><font class="Normal"> (JMSException e) {</font></br></div>
<div id="159" class="line"><font class="Normal"> }</font></br></div>
<div id="160" class="line"><font class="Normal"> }</font></br></div>
<div id="161" class="line"><font class="Normal"> }</font></br></div>
<div id="162" class="line"><font class="Normal"> }</font></br></div>
<div id="163" class="line"></br></div>
<div id="164" class="line"><font class="Normal"> </font><font class="Documentation">/**</font></br></div>
<div id="165" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> Monitor class for asynchronous examples</font><font class="Documentation">. </font><font class="Normal"> Producer signals</font></br></div>
<div id="166" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> end of message stream</font><font class="Comment">;</font><font class="Normal"> listener calls allDone</font><font class="Comment">()</font><font class="Normal"> to notify</font></br></div>
<div id="167" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> consumer that the signal has arrived</font><font class="Comment">,</font><font class="Normal"> while consumer calls</font></br></div>
<div id="168" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> waitTillDone</font><font class="Comment">()</font><font class="Normal"> to wait for this notification</font><font class="Comment">.</font></br></div>
<div id="169" class="line"><font class="Normal"> </font><font class="Documentation">*/</font></br></div>
<div id="170" class="line"><font class="Normal"> </font><font class="DataType">static</font><font class="Normal"> </font><font class="Keyword">public</font><font class="Normal"> </font><font class="Keyword">class</font><font class="Normal"> DoneLatch {</font></br></div>
<div id="171" class="line"><font class="Normal"> </font><font class="DataType">boolean</font><font class="Normal"> done = </font><font class="Keyword">false</font><font class="Normal">;</font></br></div>
<div id="172" class="line"></br></div>
<div id="173" class="line"><font class="Normal"> </font><font class="Documentation">/**</font></br></div>
<div id="174" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> Waits until done is set to true</font><font class="Documentation">.</font></br></div>
<div id="175" class="line"><font class="Normal"> </font><font class="Documentation">*/</font></br></div>
<div id="176" class="line"><font class="Normal"> </font><font class="Keyword">public</font><font class="Normal"> </font><font class="DataType">void</font><font class="Normal"> </font><font class="Function">waitTillDone</font><font class="Normal">() {</font></br></div>
<div id="177" class="line"><font class="Normal"> </font><font class="Keyword">synchronized</font><font class="Normal"> (</font><font class="Keyword">this</font><font class="Normal">) {</font></br></div>
<div id="178" class="line"><font class="Normal"> </font><font class="Keyword">while</font><font class="Normal"> (!done) {</font></br></div>
<div id="179" class="line"><font class="Normal"> </font><font class="Keyword">try</font><font class="Normal"> {</font></br></div>
<div id="180" class="line"><font class="Normal"> </font><font class="Keyword">this</font><font class="Normal">.</font><font class="Function">wait</font><font class="Normal">();</font></br></div>
<div id="181" class="line"><font class="Normal"> } </font><font class="Keyword">catch</font><font class="Normal"> (</font><font class="BuiltIn">InterruptedException</font><font class="Normal"> ie) {</font></br></div>
<div id="182" class="line"><font class="Normal"> }</font></br></div>
<div id="183" class="line"><font class="Normal"> }</font></br></div>
<div id="184" class="line"><font class="Normal"> }</font></br></div>
<div id="185" class="line"><font class="Normal"> }</font></br></div>
<div id="186" class="line"></br></div>
<div id="187" class="line"><font class="Normal"> </font><font class="Documentation">/**</font></br></div>
<div id="188" class="line"><font class="Normal"> </font><font class="Documentation">*</font><font class="Normal"> Sets done to true</font><font class="Documentation">.</font></br></div>
<div id="189" class="line"><font class="Normal"> </font><font class="Documentation">*/</font></br></div>
<div id="190" class="line"><font class="Normal"> </font><font class="Keyword">public</font><font class="Normal"> </font><font class="DataType">void</font><font class="Normal"> </font><font class="Function">allDone</font><font class="Normal">() {</font></br></div>
<div id="191" class="line"><font class="Normal"> </font><font class="Keyword">synchronized</font><font class="Normal"> (</font><font class="Keyword">this</font><font class="Normal">) {</font></br></div>
<div id="192" class="line"><font class="Normal"> done = </font><font class="Keyword">true</font><font class="Normal">;</font></br></div>
<div id="193" class="line"><font class="Normal"> </font><font class="Keyword">this</font><font class="Normal">.</font><font class="Function">notify</font><font class="Normal">();</font></br></div>
<div id="194" class="line"><font class="Normal"> }</font></br></div>
<div id="195" class="line"><font class="Normal"> }</font></br></div>
<div id="196" class="line"><font class="Normal"> }</font></br></div>
<div id="197" class="line"><font class="Normal">}</font></br></div>
</div>
</body>
</html>