activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r504740 - in /activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire: OpenWireCommandReader.cpp OpenWireCommandReader.h OpenwireCommandWriter.cpp OpenwireCommandWriter.h
Date Wed, 07 Feb 2007 23:42:25 GMT
Author: tabish
Date: Wed Feb  7 15:42:24 2007
New Revision: 504740

URL: http://svn.apache.org/viewvc?view=rev&rev=504740
Log:
http://issues.apache.org/activemq/browse/AMQCPP-30

Removed:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireCommandWriter.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireCommandWriter.h
Modified:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireCommandReader.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireCommandReader.h

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireCommandReader.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireCommandReader.cpp?view=diff&rev=504740&r1=504739&r2=504740
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireCommandReader.cpp
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireCommandReader.cpp
Wed Feb  7 15:42:24 2007
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-#include "OpenwireCommandReader.h"
+#include "OpenWireCommandReader.h"
 
 #include <activemq/concurrent/Thread.h>
 
@@ -29,7 +29,7 @@
 using namespace activemq::exceptions;
 
 ////////////////////////////////////////////////////////////////////////////////
-OpenwireCommandReader::OpenwireCommandReader(void)
+OpenWireCommandReader::OpenWireCommandReader(void)
 {
     this->inputStream = NULL;
     this->openWireFormat = NULL;
@@ -37,7 +37,7 @@
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-OpenwireCommandReader::OpenwireCommandReader( InputStream* inputStream,
+OpenWireCommandReader::OpenWireCommandReader( InputStream* inputStream,
                                               OpenWireFormat* openWireFormat )
 {
     this->setInputStream( inputStream );
@@ -45,7 +45,7 @@
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Command* OpenwireCommandReader::readCommand(void)
+Command* OpenWireCommandReader::readCommand(void)
     throw ( CommandIOException )
 {
     try
@@ -67,7 +67,7 @@
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-size_t OpenwireCommandReader::read( unsigned char* buffer, size_t count )
+size_t OpenWireCommandReader::read( unsigned char* buffer, size_t count )
    throw( io::IOException )
 {
     try
@@ -79,7 +79,7 @@
                 "OpenwireCommandReader::read(char*,int) - input stream is NULL" );
         }
 
-        return inputStream->read( &buffer[head], count );
+        return inputStream->read( &buffer[0], count );
     }
     AMQ_CATCH_RETHROW( IOException )
     AMQ_CATCH_EXCEPTION_CONVERT( ActiveMQException, IOException )
@@ -87,7 +87,7 @@
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-unsigned char OpenwireCommandReader::readByte(void) throw( io::IOException )
+unsigned char OpenWireCommandReader::readByte(void) throw( io::IOException )
 {
     try
     {

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireCommandReader.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireCommandReader.h?view=diff&rev=504740&r1=504739&r2=504740
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireCommandReader.h
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireCommandReader.h
Wed Feb  7 15:42:24 2007
@@ -29,7 +29,7 @@
 namespace connector{
 namespace openwire{
 
-    class OpenwireCommandReader : public transport::CommandReader
+    class OpenWireCommandReader : public transport::CommandReader
     {
     private:
 
@@ -54,17 +54,17 @@
         /**
          * Constructor.
          */
-        OpenwireCommandReader();
+        OpenWireCommandReader();
 
         /**
          * Constructor.
          * @param inputStream the target input stream.
          * @param owFormat the OpenWireFormat object that handles unmarshaling
          */
-        OpenwireCommandReader( io::InputStream* inputStream,
+        OpenWireCommandReader( io::InputStream* inputStream,
                                OpenWireFormat* openWireFormat );
 
-        virtual ~OpenwireCommandReader() {}
+        virtual ~OpenWireCommandReader() {}
 
         /**
          * Reads a command from the given input stream.
@@ -81,7 +81,7 @@
         virtual void setInputStream( io::InputStream* inputStream ){
             this->inputStream = inputStream;
             delete dataInputStream;
-            dataInputStream = new io::DataInputStram( inputStream );
+            dataInputStream = new io::DataInputStream( inputStream );
         }
 
         /**
@@ -104,7 +104,7 @@
          * Gets the target input stream.
          * @return Target Input Stream
          */
-        virtual io::InputStream* getOpenWireFormat(void){
+        virtual OpenWireFormat* getOpenWireFormat(void){
             return this->openWireFormat;
         }
 



Mime
View raw message