00001
00044 #ifndef ABA_MESSAGE_H
00045 #define ABA_MESSAGE_H
00046 #include "abacus/messagebase.h"
00047 #include <ace/SOCK_Stream.h>
00048 class ABA_MESSAGE : public ABA_MESSAGEBASE {
00049 public:
00050
00057 ABA_MESSAGE();
00058
00060 ~ABA_MESSAGE();
00061 ACE_SOCK_Stream& stream();
00062
00063 protected:
00064
00069 static int readit(ABA_MESSAGE *msg, char *buf, int len);
00070 static int writeit(ABA_MESSAGE *msg, const char *buf, int len);
00072 ACE_SOCK_Stream stream_;
00073 };
00074
00075 inline ACE_SOCK_Stream& ABA_MESSAGE::stream()
00076 {
00077 return stream_;
00078 }
00079
00080
00081 #endif // ABA_MESSAGE_H
00082
