activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r419371 [6/10] - in /incubator/activemq/trunk/openwire-cpp/src/main/cpp: activemq/ activemq/command/ activemq/protocol/ activemq/protocol/openwire/ activemq/transport/ activemq/transport/tcp/ cms/ ppr/ ppr/io/ ppr/io/encoding/ ppr/net/ ppr/...
Date Wed, 05 Jul 2006 22:36:42 GMT
Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ReplayCommand.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ReplayCommand.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ReplayCommand.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ReplayCommand.hpp Wed Jul  5 15:36:36 2006
@@ -1,87 +1,87 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*     http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#ifndef ActiveMQ_ReplayCommand_hpp_
-#define ActiveMQ_ReplayCommand_hpp_
-
-// Turn off warning message for ignored exception specification
-#ifdef _MSC_VER
-#pragma warning( disable : 4290 )
-#endif
-
-#include <string>
-#include "activemq/command/BaseCommand.hpp"
-
-#include "activemq/protocol/IMarshaller.hpp"
-#include "ppr/io/IOutputStream.hpp"
-#include "ppr/io/IInputStream.hpp"
-#include "ppr/io/IOException.hpp"
-#include "ppr/util/ifr/array"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace command
-    {
-      using namespace ifr;
-      using namespace std;
-      using namespace apache::activemq;
-      using namespace apache::activemq::protocol;
-      using namespace apache::ppr::io;
-
-/*
- *
- *  Command and marshalling code for OpenWire format for ReplayCommand
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class ReplayCommand : public BaseCommand
-{
-protected:
-    int firstNakNumber ;
-    int lastNakNumber ;
-
-public:
-    const static unsigned char TYPE = 65;
-
-public:
-    ReplayCommand() ;
-    virtual ~ReplayCommand() ;
-
-    virtual unsigned char getDataStructureType() ;
-
-    virtual int getFirstNakNumber() ;
-    virtual void setFirstNakNumber(int firstNakNumber) ;
-
-    virtual int getLastNakNumber() ;
-    virtual void setLastNakNumber(int lastNakNumber) ;
-
-    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
-    virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_ReplayCommand_hpp_*/
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*     http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef ActiveMQ_ReplayCommand_hpp_
+#define ActiveMQ_ReplayCommand_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/BaseCommand.hpp"
+
+#include "activemq/protocol/IMarshaller.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr;
+      using namespace std;
+      using namespace apache::activemq;
+      using namespace apache::activemq::protocol;
+      using namespace apache::ppr::io;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for ReplayCommand
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class ReplayCommand : public BaseCommand
+{
+protected:
+    int firstNakNumber ;
+    int lastNakNumber ;
+
+public:
+    const static unsigned char TYPE = 65;
+
+public:
+    ReplayCommand() ;
+    virtual ~ReplayCommand() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual int getFirstNakNumber() ;
+    virtual void setFirstNakNumber(int firstNakNumber) ;
+
+    virtual int getLastNakNumber() ;
+    virtual void setLastNakNumber(int lastNakNumber) ;
+
+    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
+    virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ReplayCommand_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ReplayCommand.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Response.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Response.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Response.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Response.hpp Wed Jul  5 15:36:36 2006
@@ -1,83 +1,83 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*     http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#ifndef ActiveMQ_Response_hpp_
-#define ActiveMQ_Response_hpp_
-
-// Turn off warning message for ignored exception specification
-#ifdef _MSC_VER
-#pragma warning( disable : 4290 )
-#endif
-
-#include <string>
-#include "activemq/command/BaseCommand.hpp"
-
-#include "activemq/protocol/IMarshaller.hpp"
-#include "ppr/io/IOutputStream.hpp"
-#include "ppr/io/IInputStream.hpp"
-#include "ppr/io/IOException.hpp"
-#include "ppr/util/ifr/array"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace command
-    {
-      using namespace ifr;
-      using namespace std;
-      using namespace apache::activemq;
-      using namespace apache::activemq::protocol;
-      using namespace apache::ppr::io;
-
-/*
- *
- *  Command and marshalling code for OpenWire format for Response
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class Response : public BaseCommand
-{
-protected:
-    int correlationId ;
-
-public:
-    const static unsigned char TYPE = 30;
-
-public:
-    Response() ;
-    virtual ~Response() ;
-
-    virtual unsigned char getDataStructureType() ;
-
-    virtual int getCorrelationId() ;
-    virtual void setCorrelationId(int correlationId) ;
-
-    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
-    virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_Response_hpp_*/
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*     http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef ActiveMQ_Response_hpp_
+#define ActiveMQ_Response_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/BaseCommand.hpp"
+
+#include "activemq/protocol/IMarshaller.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr;
+      using namespace std;
+      using namespace apache::activemq;
+      using namespace apache::activemq::protocol;
+      using namespace apache::ppr::io;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for Response
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class Response : public BaseCommand
+{
+protected:
+    int correlationId ;
+
+public:
+    const static unsigned char TYPE = 30;
+
+public:
+    Response() ;
+    virtual ~Response() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual int getCorrelationId() ;
+    virtual void setCorrelationId(int correlationId) ;
+
+    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
+    virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_Response_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/Response.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/SessionId.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/SessionId.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/SessionId.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/SessionId.hpp Wed Jul  5 15:36:36 2006
@@ -1,87 +1,87 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*     http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#ifndef ActiveMQ_SessionId_hpp_
-#define ActiveMQ_SessionId_hpp_
-
-// Turn off warning message for ignored exception specification
-#ifdef _MSC_VER
-#pragma warning( disable : 4290 )
-#endif
-
-#include <string>
-#include "activemq/command/BaseDataStructure.hpp"
-
-#include "activemq/protocol/IMarshaller.hpp"
-#include "ppr/io/IOutputStream.hpp"
-#include "ppr/io/IInputStream.hpp"
-#include "ppr/io/IOException.hpp"
-#include "ppr/util/ifr/array"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace command
-    {
-      using namespace ifr;
-      using namespace std;
-      using namespace apache::activemq;
-      using namespace apache::activemq::protocol;
-      using namespace apache::ppr::io;
-
-/*
- *
- *  Command and marshalling code for OpenWire format for SessionId
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class SessionId : public BaseDataStructure
-{
-protected:
-    p<string> connectionId ;
-    long long value ;
-
-public:
-    const static unsigned char TYPE = 121;
-
-public:
-    SessionId() ;
-    virtual ~SessionId() ;
-
-    virtual unsigned char getDataStructureType() ;
-
-    virtual p<string> getConnectionId() ;
-    virtual void setConnectionId(p<string> connectionId) ;
-
-    virtual long long getValue() ;
-    virtual void setValue(long long value) ;
-
-    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
-    virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_SessionId_hpp_*/
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*     http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef ActiveMQ_SessionId_hpp_
+#define ActiveMQ_SessionId_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/BaseDataStructure.hpp"
+
+#include "activemq/protocol/IMarshaller.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr;
+      using namespace std;
+      using namespace apache::activemq;
+      using namespace apache::activemq::protocol;
+      using namespace apache::ppr::io;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for SessionId
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class SessionId : public BaseDataStructure
+{
+protected:
+    p<string> connectionId ;
+    long long value ;
+
+public:
+    const static unsigned char TYPE = 121;
+
+public:
+    SessionId() ;
+    virtual ~SessionId() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual p<string> getConnectionId() ;
+    virtual void setConnectionId(p<string> connectionId) ;
+
+    virtual long long getValue() ;
+    virtual void setValue(long long value) ;
+
+    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
+    virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_SessionId_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/SessionId.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/SessionInfo.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/SessionInfo.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/SessionInfo.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/SessionInfo.hpp Wed Jul  5 15:36:36 2006
@@ -1,84 +1,84 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*     http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#ifndef ActiveMQ_SessionInfo_hpp_
-#define ActiveMQ_SessionInfo_hpp_
-
-// Turn off warning message for ignored exception specification
-#ifdef _MSC_VER
-#pragma warning( disable : 4290 )
-#endif
-
-#include <string>
-#include "activemq/command/BaseCommand.hpp"
-#include "activemq/command/SessionId.hpp"
-
-#include "activemq/protocol/IMarshaller.hpp"
-#include "ppr/io/IOutputStream.hpp"
-#include "ppr/io/IInputStream.hpp"
-#include "ppr/io/IOException.hpp"
-#include "ppr/util/ifr/array"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace command
-    {
-      using namespace ifr;
-      using namespace std;
-      using namespace apache::activemq;
-      using namespace apache::activemq::protocol;
-      using namespace apache::ppr::io;
-
-/*
- *
- *  Command and marshalling code for OpenWire format for SessionInfo
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class SessionInfo : public BaseCommand
-{
-protected:
-    p<SessionId> sessionId ;
-
-public:
-    const static unsigned char TYPE = 4;
-
-public:
-    SessionInfo() ;
-    virtual ~SessionInfo() ;
-
-    virtual unsigned char getDataStructureType() ;
-
-    virtual p<SessionId> getSessionId() ;
-    virtual void setSessionId(p<SessionId> sessionId) ;
-
-    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
-    virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_SessionInfo_hpp_*/
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*     http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef ActiveMQ_SessionInfo_hpp_
+#define ActiveMQ_SessionInfo_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/BaseCommand.hpp"
+#include "activemq/command/SessionId.hpp"
+
+#include "activemq/protocol/IMarshaller.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr;
+      using namespace std;
+      using namespace apache::activemq;
+      using namespace apache::activemq::protocol;
+      using namespace apache::ppr::io;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for SessionInfo
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class SessionInfo : public BaseCommand
+{
+protected:
+    p<SessionId> sessionId ;
+
+public:
+    const static unsigned char TYPE = 4;
+
+public:
+    SessionInfo() ;
+    virtual ~SessionInfo() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual p<SessionId> getSessionId() ;
+    virtual void setSessionId(p<SessionId> sessionId) ;
+
+    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
+    virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_SessionInfo_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/SessionInfo.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ShutdownInfo.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ShutdownInfo.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ShutdownInfo.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ShutdownInfo.hpp Wed Jul  5 15:36:36 2006
@@ -1,79 +1,79 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*     http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#ifndef ActiveMQ_ShutdownInfo_hpp_
-#define ActiveMQ_ShutdownInfo_hpp_
-
-// Turn off warning message for ignored exception specification
-#ifdef _MSC_VER
-#pragma warning( disable : 4290 )
-#endif
-
-#include <string>
-#include "activemq/command/BaseCommand.hpp"
-
-#include "activemq/protocol/IMarshaller.hpp"
-#include "ppr/io/IOutputStream.hpp"
-#include "ppr/io/IInputStream.hpp"
-#include "ppr/io/IOException.hpp"
-#include "ppr/util/ifr/array"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace command
-    {
-      using namespace ifr;
-      using namespace std;
-      using namespace apache::activemq;
-      using namespace apache::activemq::protocol;
-      using namespace apache::ppr::io;
-
-/*
- *
- *  Command and marshalling code for OpenWire format for ShutdownInfo
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class ShutdownInfo : public BaseCommand
-{
-protected:
-
-public:
-    const static unsigned char TYPE = 11;
-
-public:
-    ShutdownInfo() ;
-    virtual ~ShutdownInfo() ;
-
-    virtual unsigned char getDataStructureType() ;
-
-    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
-    virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_ShutdownInfo_hpp_*/
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*     http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef ActiveMQ_ShutdownInfo_hpp_
+#define ActiveMQ_ShutdownInfo_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/BaseCommand.hpp"
+
+#include "activemq/protocol/IMarshaller.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr;
+      using namespace std;
+      using namespace apache::activemq;
+      using namespace apache::activemq::protocol;
+      using namespace apache::ppr::io;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for ShutdownInfo
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class ShutdownInfo : public BaseCommand
+{
+protected:
+
+public:
+    const static unsigned char TYPE = 11;
+
+public:
+    ShutdownInfo() ;
+    virtual ~ShutdownInfo() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
+    virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ShutdownInfo_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/ShutdownInfo.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/SubscriptionInfo.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/SubscriptionInfo.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/SubscriptionInfo.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/SubscriptionInfo.hpp Wed Jul  5 15:36:36 2006
@@ -1,96 +1,96 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*     http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#ifndef ActiveMQ_SubscriptionInfo_hpp_
-#define ActiveMQ_SubscriptionInfo_hpp_
-
-// Turn off warning message for ignored exception specification
-#ifdef _MSC_VER
-#pragma warning( disable : 4290 )
-#endif
-
-#include <string>
-#include "activemq/command/BaseDataStructure.hpp"
-#include "activemq/command/ActiveMQDestination.hpp"
-
-#include "activemq/protocol/IMarshaller.hpp"
-#include "ppr/io/IOutputStream.hpp"
-#include "ppr/io/IInputStream.hpp"
-#include "ppr/io/IOException.hpp"
-#include "ppr/util/ifr/array"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace command
-    {
-      using namespace ifr;
-      using namespace std;
-      using namespace apache::activemq;
-      using namespace apache::activemq::protocol;
-      using namespace apache::ppr::io;
-
-/*
- *
- *  Command and marshalling code for OpenWire format for SubscriptionInfo
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class SubscriptionInfo : public BaseDataStructure
-{
-protected:
-    p<string> clientId ;
-    p<ActiveMQDestination> destination ;
-    p<string> selector ;
-    p<string> subcriptionName ;
-
-public:
-    const static unsigned char TYPE = 55;
-
-public:
-    SubscriptionInfo() ;
-    virtual ~SubscriptionInfo() ;
-
-    virtual unsigned char getDataStructureType() ;
-
-    virtual p<string> getClientId() ;
-    virtual void setClientId(p<string> clientId) ;
-
-    virtual p<ActiveMQDestination> getDestination() ;
-    virtual void setDestination(p<ActiveMQDestination> destination) ;
-
-    virtual p<string> getSelector() ;
-    virtual void setSelector(p<string> selector) ;
-
-    virtual p<string> getSubcriptionName() ;
-    virtual void setSubcriptionName(p<string> subcriptionName) ;
-
-    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
-    virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_SubscriptionInfo_hpp_*/
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*     http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef ActiveMQ_SubscriptionInfo_hpp_
+#define ActiveMQ_SubscriptionInfo_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/BaseDataStructure.hpp"
+#include "activemq/command/ActiveMQDestination.hpp"
+
+#include "activemq/protocol/IMarshaller.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr;
+      using namespace std;
+      using namespace apache::activemq;
+      using namespace apache::activemq::protocol;
+      using namespace apache::ppr::io;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for SubscriptionInfo
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class SubscriptionInfo : public BaseDataStructure
+{
+protected:
+    p<string> clientId ;
+    p<ActiveMQDestination> destination ;
+    p<string> selector ;
+    p<string> subcriptionName ;
+
+public:
+    const static unsigned char TYPE = 55;
+
+public:
+    SubscriptionInfo() ;
+    virtual ~SubscriptionInfo() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual p<string> getClientId() ;
+    virtual void setClientId(p<string> clientId) ;
+
+    virtual p<ActiveMQDestination> getDestination() ;
+    virtual void setDestination(p<ActiveMQDestination> destination) ;
+
+    virtual p<string> getSelector() ;
+    virtual void setSelector(p<string> selector) ;
+
+    virtual p<string> getSubcriptionName() ;
+    virtual void setSubcriptionName(p<string> subcriptionName) ;
+
+    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
+    virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_SubscriptionInfo_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/SubscriptionInfo.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/TransactionId.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/TransactionId.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/TransactionId.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/TransactionId.hpp Wed Jul  5 15:36:36 2006
@@ -1,79 +1,79 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*     http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#ifndef ActiveMQ_TransactionId_hpp_
-#define ActiveMQ_TransactionId_hpp_
-
-// Turn off warning message for ignored exception specification
-#ifdef _MSC_VER
-#pragma warning( disable : 4290 )
-#endif
-
-#include <string>
-#include "activemq/command/BaseDataStructure.hpp"
-
-#include "activemq/protocol/IMarshaller.hpp"
-#include "ppr/io/IOutputStream.hpp"
-#include "ppr/io/IInputStream.hpp"
-#include "ppr/io/IOException.hpp"
-#include "ppr/util/ifr/array"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace command
-    {
-      using namespace ifr;
-      using namespace std;
-      using namespace apache::activemq;
-      using namespace apache::activemq::protocol;
-      using namespace apache::ppr::io;
-
-/*
- *
- *  Command and marshalling code for OpenWire format for TransactionId
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class TransactionId : public BaseDataStructure
-{
-protected:
-
-public:
-    const static unsigned char TYPE = 0;
-
-public:
-    TransactionId() ;
-    virtual ~TransactionId() ;
-
-    virtual unsigned char getDataStructureType() ;
-
-    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
-    virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_TransactionId_hpp_*/
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*     http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef ActiveMQ_TransactionId_hpp_
+#define ActiveMQ_TransactionId_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/BaseDataStructure.hpp"
+
+#include "activemq/protocol/IMarshaller.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr;
+      using namespace std;
+      using namespace apache::activemq;
+      using namespace apache::activemq::protocol;
+      using namespace apache::ppr::io;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for TransactionId
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class TransactionId : public BaseDataStructure
+{
+protected:
+
+public:
+    const static unsigned char TYPE = 0;
+
+public:
+    TransactionId() ;
+    virtual ~TransactionId() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
+    virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_TransactionId_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/TransactionId.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/TransactionInfo.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/TransactionInfo.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/TransactionInfo.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/TransactionInfo.hpp Wed Jul  5 15:36:36 2006
@@ -1,93 +1,93 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*     http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#ifndef ActiveMQ_TransactionInfo_hpp_
-#define ActiveMQ_TransactionInfo_hpp_
-
-// Turn off warning message for ignored exception specification
-#ifdef _MSC_VER
-#pragma warning( disable : 4290 )
-#endif
-
-#include <string>
-#include "activemq/command/BaseCommand.hpp"
-#include "activemq/command/ConnectionId.hpp"
-#include "activemq/command/TransactionId.hpp"
-
-#include "activemq/protocol/IMarshaller.hpp"
-#include "ppr/io/IOutputStream.hpp"
-#include "ppr/io/IInputStream.hpp"
-#include "ppr/io/IOException.hpp"
-#include "ppr/util/ifr/array"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace command
-    {
-      using namespace ifr;
-      using namespace std;
-      using namespace apache::activemq;
-      using namespace apache::activemq::protocol;
-      using namespace apache::ppr::io;
-
-/*
- *
- *  Command and marshalling code for OpenWire format for TransactionInfo
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class TransactionInfo : public BaseCommand
-{
-protected:
-    p<ConnectionId> connectionId ;
-    p<TransactionId> transactionId ;
-    char type ;
-
-public:
-    const static unsigned char TYPE = 7;
-
-public:
-    TransactionInfo() ;
-    virtual ~TransactionInfo() ;
-
-    virtual unsigned char getDataStructureType() ;
-
-    virtual p<ConnectionId> getConnectionId() ;
-    virtual void setConnectionId(p<ConnectionId> connectionId) ;
-
-    virtual p<TransactionId> getTransactionId() ;
-    virtual void setTransactionId(p<TransactionId> transactionId) ;
-
-    virtual char getType() ;
-    virtual void setType(char type) ;
-
-    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
-    virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_TransactionInfo_hpp_*/
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*     http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef ActiveMQ_TransactionInfo_hpp_
+#define ActiveMQ_TransactionInfo_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/BaseCommand.hpp"
+#include "activemq/command/ConnectionId.hpp"
+#include "activemq/command/TransactionId.hpp"
+
+#include "activemq/protocol/IMarshaller.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr;
+      using namespace std;
+      using namespace apache::activemq;
+      using namespace apache::activemq::protocol;
+      using namespace apache::ppr::io;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for TransactionInfo
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class TransactionInfo : public BaseCommand
+{
+protected:
+    p<ConnectionId> connectionId ;
+    p<TransactionId> transactionId ;
+    char type ;
+
+public:
+    const static unsigned char TYPE = 7;
+
+public:
+    TransactionInfo() ;
+    virtual ~TransactionInfo() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual p<ConnectionId> getConnectionId() ;
+    virtual void setConnectionId(p<ConnectionId> connectionId) ;
+
+    virtual p<TransactionId> getTransactionId() ;
+    virtual void setTransactionId(p<TransactionId> transactionId) ;
+
+    virtual char getType() ;
+    virtual void setType(char type) ;
+
+    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
+    virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_TransactionInfo_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/TransactionInfo.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/WireFormatInfo.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/XATransactionId.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/XATransactionId.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/XATransactionId.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/XATransactionId.hpp Wed Jul  5 15:36:36 2006
@@ -1,91 +1,91 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*     http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#ifndef ActiveMQ_XATransactionId_hpp_
-#define ActiveMQ_XATransactionId_hpp_
-
-// Turn off warning message for ignored exception specification
-#ifdef _MSC_VER
-#pragma warning( disable : 4290 )
-#endif
-
-#include <string>
-#include "activemq/command/TransactionId.hpp"
-
-#include "activemq/protocol/IMarshaller.hpp"
-#include "ppr/io/IOutputStream.hpp"
-#include "ppr/io/IInputStream.hpp"
-#include "ppr/io/IOException.hpp"
-#include "ppr/util/ifr/array"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace command
-    {
-      using namespace ifr;
-      using namespace std;
-      using namespace apache::activemq;
-      using namespace apache::activemq::protocol;
-      using namespace apache::ppr::io;
-
-/*
- *
- *  Command and marshalling code for OpenWire format for XATransactionId
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class XATransactionId : public TransactionId
-{
-protected:
-    int formatId ;
-    array<char> globalTransactionId ;
-    array<char> branchQualifier ;
-
-public:
-    const static unsigned char TYPE = 112;
-
-public:
-    XATransactionId() ;
-    virtual ~XATransactionId() ;
-
-    virtual unsigned char getDataStructureType() ;
-
-    virtual int getFormatId() ;
-    virtual void setFormatId(int formatId) ;
-
-    virtual array<char> getGlobalTransactionId() ;
-    virtual void setGlobalTransactionId(array<char> globalTransactionId) ;
-
-    virtual array<char> getBranchQualifier() ;
-    virtual void setBranchQualifier(array<char> branchQualifier) ;
-
-    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
-    virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_XATransactionId_hpp_*/
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*     http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef ActiveMQ_XATransactionId_hpp_
+#define ActiveMQ_XATransactionId_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/command/TransactionId.hpp"
+
+#include "activemq/protocol/IMarshaller.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr;
+      using namespace std;
+      using namespace apache::activemq;
+      using namespace apache::activemq::protocol;
+      using namespace apache::ppr::io;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for XATransactionId
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class XATransactionId : public TransactionId
+{
+protected:
+    int formatId ;
+    array<char> globalTransactionId ;
+    array<char> branchQualifier ;
+
+public:
+    const static unsigned char TYPE = 112;
+
+public:
+    XATransactionId() ;
+    virtual ~XATransactionId() ;
+
+    virtual unsigned char getDataStructureType() ;
+
+    virtual int getFormatId() ;
+    virtual void setFormatId(int formatId) ;
+
+    virtual array<char> getGlobalTransactionId() ;
+    virtual void setGlobalTransactionId(array<char> globalTransactionId) ;
+
+    virtual array<char> getBranchQualifier() ;
+    virtual void setBranchQualifier(array<char> branchQualifier) ;
+
+    virtual int marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> ostream) throw (IOException) ;
+    virtual void unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> istream) throw (IOException) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_XATransactionId_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/command/XATransactionId.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/protocol/IMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/protocol/IMarshaller.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/protocol/IMarshaller.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/protocol/IMarshaller.hpp Wed Jul  5 15:36:36 2006
@@ -1,84 +1,84 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#ifndef ActiveMQ_IMarshaller_hpp_
-#define ActiveMQ_IMarshaller_hpp_
-
-#include <string>
-#include <map>
-#include "activemq/IDataStructure.hpp"
-#include "ppr/io/IOutputStream.hpp"
-#include "ppr/io/IInputStream.hpp"
-#include "ppr/io/IOException.hpp"
-#include "ppr/util/MapItemHolder.hpp"
-#include "ppr/util/ifr/array"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace protocol
-    {
-      using namespace ifr ;
-      using namespace std ;
-      using namespace apache::activemq;
-      using namespace apache::ppr::io;
-      using namespace apache::ppr::util;
-
-/*
- * Represents a wire protocol marshaller.
- */
-struct IMarshaller : Interface
-{
-    // Marshal modes
-    const static int MARSHAL_SIZE  = 1 ;
-    const static int MARSHAL_WRITE = 2 ;
-    const static int MARSHAL_READ  = 3 ;
-
-    virtual int marshalBoolean(bool value, int mode, p<IOutputStream> ostream) throw(IOException) = 0 ;
-    virtual int marshalByte(char value, int mode, p<IOutputStream> ostream) throw(IOException) = 0  ;
-    virtual int marshalShort(short value, int mode, p<IOutputStream> ostream) throw(IOException) = 0  ;
-    virtual int marshalInt(int value, int mode, p<IOutputStream> ostream) throw(IOException) = 0 ;
-    virtual int marshalLong(long long value, int mode, p<IOutputStream> ostream) throw(IOException) = 0 ;
-    virtual int marshalFloat(float value, int mode, p<IOutputStream> ostream) throw(IOException) = 0 ;
-    virtual int marshalDouble(double value, int mode, p<IOutputStream> ostream) throw(IOException) = 0 ;
-    virtual int marshalString(p<string> value, int mode, p<IOutputStream> ostream) throw(IOException) = 0 ;
-    virtual int marshalObject(p<IDataStructure> object, int mode, p<IOutputStream> ostream) throw(IOException) = 0 ;
-    virtual int marshalObjectArray(array<IDataStructure> object, int mode, p<IOutputStream> ostream) throw(IOException) = 0 ;
-    virtual int marshalByteArray(array<char> value, int mode, p<IOutputStream> ostream) throw(IOException) = 0 ;
-    virtual int marshalMap(p<PropertyMap> value, int mode, p<IOutputStream> ostream) throw(IOException) = 0 ;
-
-    virtual bool unmarshalBoolean(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
-    virtual char unmarshalByte(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
-    virtual short unmarshalShort(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
-    virtual int unmarshalInt(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
-    virtual long long unmarshalLong(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
-    virtual float unmarshalFloat(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
-    virtual double unmarshalDouble(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
-    virtual p<string> unmarshalString(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
-    virtual p<IDataStructure> unmarshalObject(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
-    virtual array<IDataStructure> unmarshalObjectArray(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
-    virtual array<char> unmarshalByteArray(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
-    virtual p<PropertyMap> unmarshalMap(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_IMarshaller_hpp_*/
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef ActiveMQ_IMarshaller_hpp_
+#define ActiveMQ_IMarshaller_hpp_
+
+#include <string>
+#include <map>
+#include "activemq/IDataStructure.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/MapItemHolder.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace protocol
+    {
+      using namespace ifr ;
+      using namespace std ;
+      using namespace apache::activemq;
+      using namespace apache::ppr::io;
+      using namespace apache::ppr::util;
+
+/*
+ * Represents a wire protocol marshaller.
+ */
+struct IMarshaller : Interface
+{
+    // Marshal modes
+    const static int MARSHAL_SIZE  = 1 ;
+    const static int MARSHAL_WRITE = 2 ;
+    const static int MARSHAL_READ  = 3 ;
+
+    virtual int marshalBoolean(bool value, int mode, p<IOutputStream> ostream) throw(IOException) = 0 ;
+    virtual int marshalByte(char value, int mode, p<IOutputStream> ostream) throw(IOException) = 0  ;
+    virtual int marshalShort(short value, int mode, p<IOutputStream> ostream) throw(IOException) = 0  ;
+    virtual int marshalInt(int value, int mode, p<IOutputStream> ostream) throw(IOException) = 0 ;
+    virtual int marshalLong(long long value, int mode, p<IOutputStream> ostream) throw(IOException) = 0 ;
+    virtual int marshalFloat(float value, int mode, p<IOutputStream> ostream) throw(IOException) = 0 ;
+    virtual int marshalDouble(double value, int mode, p<IOutputStream> ostream) throw(IOException) = 0 ;
+    virtual int marshalString(p<string> value, int mode, p<IOutputStream> ostream) throw(IOException) = 0 ;
+    virtual int marshalObject(p<IDataStructure> object, int mode, p<IOutputStream> ostream) throw(IOException) = 0 ;
+    virtual int marshalObjectArray(array<IDataStructure> object, int mode, p<IOutputStream> ostream) throw(IOException) = 0 ;
+    virtual int marshalByteArray(array<char> value, int mode, p<IOutputStream> ostream) throw(IOException) = 0 ;
+    virtual int marshalMap(p<PropertyMap> value, int mode, p<IOutputStream> ostream) throw(IOException) = 0 ;
+
+    virtual bool unmarshalBoolean(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
+    virtual char unmarshalByte(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
+    virtual short unmarshalShort(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
+    virtual int unmarshalInt(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
+    virtual long long unmarshalLong(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
+    virtual float unmarshalFloat(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
+    virtual double unmarshalDouble(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
+    virtual p<string> unmarshalString(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
+    virtual p<IDataStructure> unmarshalObject(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
+    virtual array<IDataStructure> unmarshalObjectArray(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
+    virtual array<char> unmarshalByteArray(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
+    virtual p<PropertyMap> unmarshalMap(int mode, p<IInputStream> istream) throw(IOException) = 0 ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_IMarshaller_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/protocol/IMarshaller.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/protocol/IProtocol.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/protocol/IProtocol.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/protocol/IProtocol.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/protocol/IProtocol.hpp Wed Jul  5 15:36:36 2006
@@ -1,53 +1,53 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#ifndef ActiveMQ_IProtocol_hpp_
-#define ActiveMQ_IProtocol_hpp_
-
-#include "activemq/IDataStructure.hpp"
-#include "activemq/transport/ITransport.hpp"
-#include "ppr/io/IOutputStream.hpp"
-#include "ppr/io/IInputStream.hpp"
-#include "ppr/io/IOException.hpp"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace protocol
-    {
-      using namespace ifr ;
-      using namespace apache::activemq;
-      using namespace apache::activemq::transport;
-      using namespace apache::ppr::io;
-
-/*
- * Represents the logical protocol layer.
- */
-struct IProtocol : Interface
-{
-    virtual void handshake(p<ITransport> transport) = 0 ;
-	virtual void marshal(p<IDataStructure> object, p<IOutputStream> ostream) throw(IOException) = 0 ;
-	virtual p<IDataStructure> unmarshal(p<IInputStream> istream) throw(IOException) = 0 ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_IProtocol_hpp_*/
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef ActiveMQ_IProtocol_hpp_
+#define ActiveMQ_IProtocol_hpp_
+
+#include "activemq/IDataStructure.hpp"
+#include "activemq/transport/ITransport.hpp"
+#include "ppr/io/IOutputStream.hpp"
+#include "ppr/io/IInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace protocol
+    {
+      using namespace ifr ;
+      using namespace apache::activemq;
+      using namespace apache::activemq::transport;
+      using namespace apache::ppr::io;
+
+/*
+ * Represents the logical protocol layer.
+ */
+struct IProtocol : Interface
+{
+    virtual void handshake(p<ITransport> transport) = 0 ;
+	virtual void marshal(p<IDataStructure> object, p<IOutputStream> ostream) throw(IOException) = 0 ;
+	virtual p<IDataStructure> unmarshal(p<IInputStream> istream) throw(IOException) = 0 ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_IProtocol_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/protocol/IProtocol.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/protocol/openwire/OpenWireMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/protocol/openwire/OpenWireMarshaller.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/protocol/openwire/OpenWireMarshaller.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/protocol/openwire/OpenWireMarshaller.hpp Wed Jul  5 15:36:36 2006
@@ -1,121 +1,121 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#ifndef ActiveMQ_OpenWireMarshaller_hpp_
-#define ActiveMQ_OpenWireMarshaller_hpp_
-
-// Turn off warning message for ignored exception specification
-#ifdef _MSC_VER
-#pragma warning( disable : 4290 )
-#endif
-
-#include <string>
-#include <map>
-#include "activemq/IDataStructure.hpp"
-#include "activemq/command/BaseDataStructure.hpp"
-#include "activemq/command/WireFormatInfo.hpp"
-#include "activemq/protocol/IMarshaller.hpp"
-#include "activemq/protocol/openwire/OpenWireProtocol.hpp"
-#include "ppr/io/DataOutputStream.hpp"
-#include "ppr/io/DataInputStream.hpp"
-#include "ppr/io/IOException.hpp"
-#include "ppr/io/encoding/CharsetEncoderRegistry.hpp"
-#include "ppr/io/encoding/ICharsetEncoder.hpp"
-#include "ppr/util/MapItemHolder.hpp"
-#include "ppr/util/ifr/array"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace protocol
-    {
-      namespace openwire
-      {
-        using namespace ifr ;
-        using namespace apache::activemq;
-        using namespace apache::activemq::command;
-        using namespace apache::activemq::protocol;
-        using namespace apache::ppr::io;
-        using namespace apache::ppr::io::encoding;
-        using namespace apache::ppr::util;
-
-/*
- * A helper class with marshalling methods for the OpenWire protocol.
- */
-class OpenWireMarshaller : public IMarshaller
-{
-private:
-    p<WireFormatInfo>  formatInfo ;
-    p<ICharsetEncoder> encoder ;
-    bool               useTightEncoding ;
-
-public:
-    // Primitive types
-    static const unsigned char TYPE_NULL      = 0 ;
-    static const unsigned char TYPE_BOOLEAN   = 1 ;
-    static const unsigned char TYPE_BYTE      = 2 ;
-    static const unsigned char TYPE_CHAR      = 3 ;
-    static const unsigned char TYPE_SHORT     = 4 ;
-    static const unsigned char TYPE_INTEGER   = 5 ;
-    static const unsigned char TYPE_LONG      = 6 ;
-    static const unsigned char TYPE_DOUBLE    = 7 ;
-    static const unsigned char TYPE_FLOAT     = 8 ;
-    static const unsigned char TYPE_STRING    = 9 ;
-    static const unsigned char TYPE_BYTEARRAY = 10 ;
-
-public:
-    OpenWireMarshaller(p<WireFormatInfo> formatInfo) ;
-
-    virtual int marshalBoolean(bool value, int mode, p<IOutputStream> ostream) throw(IOException) ;
-    virtual int marshalByte(char value, int mode, p<IOutputStream> ostream) throw(IOException) ;
-    virtual int marshalShort(short value, int mode, p<IOutputStream> ostream) throw(IOException) ;
-    virtual int marshalInt(int value, int mode, p<IOutputStream> ostream) throw(IOException) ;
-    virtual int marshalLong(long long value, int mode, p<IOutputStream> ostream) throw(IOException) ;
-    virtual int marshalFloat(float value, int mode, p<IOutputStream> ostream) throw(IOException) ;
-    virtual int marshalDouble(double value, int mode, p<IOutputStream> ostream) throw(IOException) ;
-    virtual int marshalString(p<string> value, int mode, p<IOutputStream> ostream) throw(IOException) ;
-    virtual int marshalObject(p<IDataStructure> object, int mode, p<IOutputStream> ostream) throw(IOException) ;
-    virtual int marshalObjectArray(array<IDataStructure> object, int mode, p<IOutputStream> ostream) throw(IOException) ;
-    virtual int marshalByteArray(array<char> value, int mode, p<IOutputStream> ostream) throw(IOException) ;
-    virtual int marshalMap(p<PropertyMap> value, int mode, p<IOutputStream> ostream) throw(IOException) ;
-
-    virtual bool unmarshalBoolean(int mode, p<IInputStream> istream) throw(IOException) ;
-    virtual char unmarshalByte(int mode, p<IInputStream> istream) throw(IOException) ;
-    virtual short unmarshalShort(int mode, p<IInputStream> istream) throw(IOException) ;
-    virtual int unmarshalInt(int mode, p<IInputStream> istream) throw(IOException) ;
-    virtual long long unmarshalLong(int mode, p<IInputStream> istream) throw(IOException) ;
-    virtual float unmarshalFloat(int mode, p<IInputStream> istream) throw(IOException) ;
-    virtual double unmarshalDouble(int mode, p<IInputStream> istream) throw(IOException) ;
-    virtual p<string> unmarshalString(int mode, p<IInputStream> istream) throw(IOException) ;
-    virtual p<IDataStructure> unmarshalObject(int mode, p<IInputStream> istream) throw(IOException) ;
-    virtual array<IDataStructure> unmarshalObjectArray(int mode, p<IInputStream> istream) throw(IOException) ;
-    virtual array<char> unmarshalByteArray(int mode, p<IInputStream> istream) throw(IOException) ;
-    virtual p<PropertyMap> unmarshalMap(int mode, p<IInputStream> istream) throw(IOException) ;
-
-protected:
-    p<DataOutputStream> checkOutputStream(p<IOutputStream> ostream) throw (IOException) ;
-    p<DataInputStream> checkInputStream(p<IInputStream> istream) throw (IOException) ;
-} ;
-
-/* namespace */
-      }
-    }
-  }
-}
-
-#endif /*ActiveMQ_OpenWireMarshaller_hpp_*/
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef ActiveMQ_OpenWireMarshaller_hpp_
+#define ActiveMQ_OpenWireMarshaller_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include <map>
+#include "activemq/IDataStructure.hpp"
+#include "activemq/command/BaseDataStructure.hpp"
+#include "activemq/command/WireFormatInfo.hpp"
+#include "activemq/protocol/IMarshaller.hpp"
+#include "activemq/protocol/openwire/OpenWireProtocol.hpp"
+#include "ppr/io/DataOutputStream.hpp"
+#include "ppr/io/DataInputStream.hpp"
+#include "ppr/io/IOException.hpp"
+#include "ppr/io/encoding/CharsetEncoderRegistry.hpp"
+#include "ppr/io/encoding/ICharsetEncoder.hpp"
+#include "ppr/util/MapItemHolder.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace protocol
+    {
+      namespace openwire
+      {
+        using namespace ifr ;
+        using namespace apache::activemq;
+        using namespace apache::activemq::command;
+        using namespace apache::activemq::protocol;
+        using namespace apache::ppr::io;
+        using namespace apache::ppr::io::encoding;
+        using namespace apache::ppr::util;
+
+/*
+ * A helper class with marshalling methods for the OpenWire protocol.
+ */
+class OpenWireMarshaller : public IMarshaller
+{
+private:
+    p<WireFormatInfo>  formatInfo ;
+    p<ICharsetEncoder> encoder ;
+    bool               useTightEncoding ;
+
+public:
+    // Primitive types
+    static const unsigned char TYPE_NULL      = 0 ;
+    static const unsigned char TYPE_BOOLEAN   = 1 ;
+    static const unsigned char TYPE_BYTE      = 2 ;
+    static const unsigned char TYPE_CHAR      = 3 ;
+    static const unsigned char TYPE_SHORT     = 4 ;
+    static const unsigned char TYPE_INTEGER   = 5 ;
+    static const unsigned char TYPE_LONG      = 6 ;
+    static const unsigned char TYPE_DOUBLE    = 7 ;
+    static const unsigned char TYPE_FLOAT     = 8 ;
+    static const unsigned char TYPE_STRING    = 9 ;
+    static const unsigned char TYPE_BYTEARRAY = 10 ;
+
+public:
+    OpenWireMarshaller(p<WireFormatInfo> formatInfo) ;
+
+    virtual int marshalBoolean(bool value, int mode, p<IOutputStream> ostream) throw(IOException) ;
+    virtual int marshalByte(char value, int mode, p<IOutputStream> ostream) throw(IOException) ;
+    virtual int marshalShort(short value, int mode, p<IOutputStream> ostream) throw(IOException) ;
+    virtual int marshalInt(int value, int mode, p<IOutputStream> ostream) throw(IOException) ;
+    virtual int marshalLong(long long value, int mode, p<IOutputStream> ostream) throw(IOException) ;
+    virtual int marshalFloat(float value, int mode, p<IOutputStream> ostream) throw(IOException) ;
+    virtual int marshalDouble(double value, int mode, p<IOutputStream> ostream) throw(IOException) ;
+    virtual int marshalString(p<string> value, int mode, p<IOutputStream> ostream) throw(IOException) ;
+    virtual int marshalObject(p<IDataStructure> object, int mode, p<IOutputStream> ostream) throw(IOException) ;
+    virtual int marshalObjectArray(array<IDataStructure> object, int mode, p<IOutputStream> ostream) throw(IOException) ;
+    virtual int marshalByteArray(array<char> value, int mode, p<IOutputStream> ostream) throw(IOException) ;
+    virtual int marshalMap(p<PropertyMap> value, int mode, p<IOutputStream> ostream) throw(IOException) ;
+
+    virtual bool unmarshalBoolean(int mode, p<IInputStream> istream) throw(IOException) ;
+    virtual char unmarshalByte(int mode, p<IInputStream> istream) throw(IOException) ;
+    virtual short unmarshalShort(int mode, p<IInputStream> istream) throw(IOException) ;
+    virtual int unmarshalInt(int mode, p<IInputStream> istream) throw(IOException) ;
+    virtual long long unmarshalLong(int mode, p<IInputStream> istream) throw(IOException) ;
+    virtual float unmarshalFloat(int mode, p<IInputStream> istream) throw(IOException) ;
+    virtual double unmarshalDouble(int mode, p<IInputStream> istream) throw(IOException) ;
+    virtual p<string> unmarshalString(int mode, p<IInputStream> istream) throw(IOException) ;
+    virtual p<IDataStructure> unmarshalObject(int mode, p<IInputStream> istream) throw(IOException) ;
+    virtual array<IDataStructure> unmarshalObjectArray(int mode, p<IInputStream> istream) throw(IOException) ;
+    virtual array<char> unmarshalByteArray(int mode, p<IInputStream> istream) throw(IOException) ;
+    virtual p<PropertyMap> unmarshalMap(int mode, p<IInputStream> istream) throw(IOException) ;
+
+protected:
+    p<DataOutputStream> checkOutputStream(p<IOutputStream> ostream) throw (IOException) ;
+    p<DataInputStream> checkInputStream(p<IInputStream> istream) throw (IOException) ;
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*ActiveMQ_OpenWireMarshaller_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/protocol/openwire/OpenWireMarshaller.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/protocol/openwire/OpenWireProtocol.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/protocol/openwire/OpenWireProtocol.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/protocol/openwire/OpenWireProtocol.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/protocol/openwire/OpenWireProtocol.hpp Wed Jul  5 15:36:36 2006
@@ -74,9 +74,9 @@
 	virtual void marshal(p<IDataStructure> object, p<IOutputStream> ostream) throw(IOException) ;
 	virtual p<IDataStructure> unmarshal(p<IInputStream> istream) throw(IOException) ;
 
-protected:
-    p<DataOutputStream> checkOutputStream(p<IOutputStream> ostream) throw (IOException) ;
-    p<DataInputStream> checkInputStream(p<IInputStream> istream) throw (IOException) ;
+protected:
+    p<DataOutputStream> checkOutputStream(p<IOutputStream> ostream) throw (IOException) ;
+    p<DataInputStream> checkInputStream(p<IInputStream> istream) throw (IOException) ;
 } ;
 
 /* namespace */

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/protocol/openwire/OpenWireProtocol.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/CorrelatorFilter.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/CorrelatorFilter.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/CorrelatorFilter.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/CorrelatorFilter.hpp Wed Jul  5 15:36:36 2006
@@ -1,66 +1,66 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#ifndef ActiveMQ_CorrelatorFilter_hpp_
-#define ActiveMQ_CorrelatorFilter_hpp_
-
-#include <iostream>
-#include "activemq/BrokerException.hpp"
-#include "activemq/command/Response.hpp"
-#include "activemq/command/ExceptionResponse.hpp"
-#include "activemq/transport/TransportFilter.hpp"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace transport
-    {
-      using namespace ifr;
-      using namespace apache::activemq;
-      using namespace apache::activemq::command;
-
-/*
- * Interface for commands.
- */
-class CorrelatorFilter : public TransportFilter
-{
-protected:
-    SimpleMutex                  mutex ;
-    map<int, p<FutureResponse> > requestMap ;
-    int                          nextCommandId ;
-
-public:
-    CorrelatorFilter(p<ITransport> next) ;
-    virtual ~CorrelatorFilter() {}
-
-	virtual void oneway(p<BaseCommand> command) ;
-	virtual p<FutureResponse> asyncRequest(p<BaseCommand> command) ;
-	virtual p<Response> request(p<BaseCommand> command) ;
-
-    virtual void onCommand(p<ITransport> transport, p<BaseCommand> command) ;
-
-protected:
-    virtual int getNextCommandId() ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_CorrelatorFilter_hpp_*/
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef ActiveMQ_CorrelatorFilter_hpp_
+#define ActiveMQ_CorrelatorFilter_hpp_
+
+#include <iostream>
+#include "activemq/BrokerException.hpp"
+#include "activemq/command/Response.hpp"
+#include "activemq/command/ExceptionResponse.hpp"
+#include "activemq/transport/TransportFilter.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace transport
+    {
+      using namespace ifr;
+      using namespace apache::activemq;
+      using namespace apache::activemq::command;
+
+/*
+ * Interface for commands.
+ */
+class CorrelatorFilter : public TransportFilter
+{
+protected:
+    SimpleMutex                  mutex ;
+    map<int, p<FutureResponse> > requestMap ;
+    int                          nextCommandId ;
+
+public:
+    CorrelatorFilter(p<ITransport> next) ;
+    virtual ~CorrelatorFilter() {}
+
+	virtual void oneway(p<BaseCommand> command) ;
+	virtual p<FutureResponse> asyncRequest(p<BaseCommand> command) ;
+	virtual p<Response> request(p<BaseCommand> command) ;
+
+    virtual void onCommand(p<ITransport> transport, p<BaseCommand> command) ;
+
+protected:
+    virtual int getNextCommandId() ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_CorrelatorFilter_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/CorrelatorFilter.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/FutureResponse.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/FutureResponse.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/FutureResponse.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/FutureResponse.hpp Wed Jul  5 15:36:36 2006
@@ -1,66 +1,66 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#ifndef ActiveMQ_FutureResponse_hpp_
-#define ActiveMQ_FutureResponse_hpp_
-
-#include <string>
-#include "activemq/command/Response.hpp"
-#include "ppr/thread/SimpleMutex.hpp"
-#include "ppr/thread/Semaphore.hpp"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace transport
-    {
-      using namespace ifr;
-      using namespace apache::activemq::command;
-      using namespace apache::ppr::thread;
-
-/*
- * Interface for commands.
- */
-class FutureResponse
-{
-private:
-    p<Response>    response ;
-    p<SimpleMutex> mutex ;
-    p<Semaphore>   semaphore ;
-    int            maxWait ;
-    bool           complete ;
-
-public:
-    FutureResponse() ;
-    virtual ~FutureResponse() {}
-
-    virtual p<Response> getResponse() ;
-    virtual void setResponse(p<Response> response) ;
-    virtual p<Response> getAsyncState() ;
-    virtual void setAsyncState(p<Response> response) ;
-    virtual p<SimpleMutex> getAsyncWaitHandle() ; // BUG: Shouldn't we return the semaphore here? What is it needed for? SHouldn't we require to use getResponse() instead? //dafah
-    virtual bool isCompleted() ;
-    virtual bool getCompletedSynchronously() ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_FutureResponse_hpp_*/
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef ActiveMQ_FutureResponse_hpp_
+#define ActiveMQ_FutureResponse_hpp_
+
+#include <string>
+#include "activemq/command/Response.hpp"
+#include "ppr/thread/SimpleMutex.hpp"
+#include "ppr/thread/Semaphore.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace transport
+    {
+      using namespace ifr;
+      using namespace apache::activemq::command;
+      using namespace apache::ppr::thread;
+
+/*
+ * Interface for commands.
+ */
+class FutureResponse
+{
+private:
+    p<Response>    response ;
+    p<SimpleMutex> mutex ;
+    p<Semaphore>   semaphore ;
+    int            maxWait ;
+    bool           complete ;
+
+public:
+    FutureResponse() ;
+    virtual ~FutureResponse() {}
+
+    virtual p<Response> getResponse() ;
+    virtual void setResponse(p<Response> response) ;
+    virtual p<Response> getAsyncState() ;
+    virtual void setAsyncState(p<Response> response) ;
+    virtual p<SimpleMutex> getAsyncWaitHandle() ; // BUG: Shouldn't we return the semaphore here? What is it needed for? SHouldn't we require to use getResponse() instead? //dafah
+    virtual bool isCompleted() ;
+    virtual bool getCompletedSynchronously() ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_FutureResponse_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/FutureResponse.hpp
------------------------------------------------------------------------------
    svn:eol-style = native



Mime
View raw message