---

RoutedMessageEvent.h

/*
 * Copyright 2003 Michael A. Marsh, Cornell University. All rights reserved.
 * This software is released under the modified BSD license.
 * See the file LICENSE in the top-level directory for details.
 */
//
// $Id: RoutedMessageEvent.h,v 1.3 2004/05/19 15:56:25 mmarsh Exp $
//
// $Log: RoutedMessageEvent.h,v $
// Revision 1.3  2004/05/19 15:56:25  mmarsh
// Added copyright and license statements.
//
// Revision 1.2  2003/11/04 22:31:46  mmarsh
// *** empty log message ***
//
//

#ifndef __CODEX_APSS_ROUTEDMESSAGEEVENT_H__
#define __CODEX_APSS_ROUTEDMESSAGEEVENT_H__

//#include "MessageEvent.h"
#include "CODEX_Events/Event.h"
#include "CODEX_Server/RoutingInfo.h"

namespace CODEX_APSS
{
   class RoutedMessageHandler;

   class RoutedMessageEventBase : public CODEX_Events::EventBase,
                                  public CODEX_Server::RoutingInfo
   {
      public :
         RoutedMessageEventBase( CODEX_Events::Activity* source,
                                 unsigned char* server,
                                 unsigned char* seqNum ) :
            CODEX_Events::EventBase( source ),
            CODEX_Server::RoutingInfo( server, seqNum )
         {}

         virtual ~RoutedMessageEventBase() {}

         virtual bool unmarshal( unsigned char ** pp, long length ) = 0;
   };

   template< class MT >
   class RoutedMessageEvent : public RoutedMessageEventBase
   {
      public :
         RoutedMessageEvent( CODEX_Events::Activity* source,
                             RoutedMessageHandler* destination,
                             unsigned char* server,
                             unsigned char* seqNum ) :
            RoutedMessageEventBase( source, server, seqNum ),
            m_destination( destination ),
            m_failed( false )
         {}

         virtual ~RoutedMessageEvent() {}

         bool handle() { return m_destination->handler( *this ); }

         void reRoute( RoutedMessageHandler* newDestination )
         {
            m_destination = newDestination;
         }

         const MT& message() const { return m_message; }

         bool failed() const { return m_failed; }

         void setFailed() { m_failed = true; }

         bool unmarshal( unsigned char ** pp, long length )
         {
            return ( 0 != m_message.unmarshal( 0, pp, length ) );
         }

      private :
         RoutedMessageHandler*  m_destination;
         MT                     m_message;
         bool                   m_failed;
   };

}

#endif /* __CODEX_APSS_ROUTEDMESSAGEEVENT_H__ */

---