cvs commit: ws-fx/sandesha/src/org/apache/sandesha/client ClientPropertyValidator.java RMSender.java

[jaliya]

jaliya      2005/01/18 22:50:26

  Modified:    sandesha/src/org/apache/sandesha/client
                        ClientPropertyValidator.java RMSender.java
  Log:
  Change the Sender thread's setDeamon(false)
  
  Revision  Changes    Path
  1.6       +1 -1      
ws-fx/sandesha/src/org/apache/sandesha/client/ClientPropertyValidator.java
  
  Index: ClientPropertyValidator.java
  ===================================================================
  RCS file: 
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/client/ClientPropertyValidator.java,v
  retrieving revision 1.5
  retrieving revision 1.6
  diff -u -r1.5 -r1.6
  --- ClientPropertyValidator.java      12 Jan 2005 12:19:31 -0000      1.5
  +++ ClientPropertyValidator.java      19 Jan 2005 06:50:25 -0000      1.6
  @@ -109,7 +109,7 @@
   
       private static boolean getSync(Call call) {
           Boolean synchronous = (Boolean) call.getProperty("sync");
  -       
  +
           if (synchronous != null) {
              return synchronous.booleanValue();
           } else
  
  
  
  1.19      +1 -0      
ws-fx/sandesha/src/org/apache/sandesha/client/RMSender.java
  
  Index: RMSender.java
  ===================================================================
  RCS file: 
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/client/RMSender.java,v
  retrieving revision 1.18
  retrieving revision 1.19
  diff -u -r1.18 -r1.19
  --- RMSender.java     12 Jan 2005 12:19:31 -0000      1.18
  +++ RMSender.java     19 Jan 2005 06:50:25 -0000      1.19
  @@ -109,6 +109,7 @@
               } else {
                   boolean gotAck = false;
                   while (!gotAck) {
  +                    System.out.println("");
                       gotAck = 
checkTheQueueForAck(requestMesssageContext.getSequenceID(),
                               requestMesssageContext.getMessageID());
                       
Thread.sleep(Constants.CLIENT_RESPONSE_CHECKING_INTERVAL);