beepcore-java-commits

[Huston F. <hu...@us...>]

Update of /cvsroot/beepcore-java/beepcore-java/src/org/beepcore/beep/profile/echo
In directory sc8-pr-cvs1:/tmp/cvs-serv21972/src/org/beepcore/beep/profile/echo

Modified Files:
	EchoProfile.java 
Log Message:
More interface cleanup, added RequestHandler to replace MessageListener.

Index: EchoProfile.java
===================================================================
RCS file: /cvsroot/beepcore-java/beepcore-java/src/org/beepcore/beep/profile/echo/EchoProfile.java,v
retrieving revision 1.16
retrieving revision 1.17
diff -C2 -r1.16 -r1.17
*** EchoProfile.java	23 Apr 2003 15:23:07 -0000	1.16
--- EchoProfile.java	10 Jun 2003 18:59:21 -0000	1.17
***************
*** 3,7 ****
   *
   * Copyright (c) 2001 Invisible Worlds, Inc.  All rights reserved.
!  * Copyright (c) 2002 Huston Franklin.  All rights reserved.
   *
   * The contents of this file are subject to the Blocks Public License (the
--- 3,7 ----
   *
   * Copyright (c) 2001 Invisible Worlds, Inc.  All rights reserved.
!  * Copyright (c) 2002,2003 Huston Franklin.  All rights reserved.
   *
   * The contents of this file are subject to the Blocks Public License (the
***************
*** 37,41 ****
   */
  public class EchoProfile
!     implements Profile, StartChannelListener, MessageListener
  {
  
--- 37,41 ----
   */
  public class EchoProfile
!     implements Profile, StartChannelListener, RequestHandler
  {
  
***************
*** 55,59 ****
      {
          log.debug("EchoCCL StartChannel Callback");
!         channel.setMessageListener(this);
      }
  
--- 55,59 ----
      {
          log.debug("EchoCCL StartChannel Callback");
!         channel.setRequestHandler(this);
      }
  
***************
*** 61,65 ****
      {
          log.debug("EchoCCL CloseChannel Callback");
!         channel.setMessageListener(null);
      }
  
--- 61,65 ----
      {
          log.debug("EchoCCL CloseChannel Callback");
!         channel.setRequestHandler(null);
      }
  
***************
*** 69,73 ****
      }
  
!     public void receiveMSG(Message message) throws BEEPError
      {
          new ReplyThread(message).start();
--- 69,73 ----
      }
  
!     public void receiveMSG(MessageMSG message)
      {
          new ReplyThread(message).start();
***************
*** 75,81 ****
  
      private class ReplyThread extends Thread {
!         private Message message;
  
!         ReplyThread(Message message) {
              this.message = message;
          }
--- 75,81 ----
  
      private class ReplyThread extends Thread {
!         private MessageMSG message;
  
!         ReplyThread(MessageMSG message) {
              this.message = message;
          }