svn commit: r426431 [7/14] - in /incubator/activemq/branches/activemq-4.0: activemq-core/src/gram/script/ activemq-core/src/main/java/org/apache/activemq/kaha/impl/ activemq-core/src/main/java/org/apache/activemq/openwire/v1/ activemq-core/src/test/jav...

[ch...@apache.org]

Propchange: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempDestination.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempDestination.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempDestination.hpp?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempDestination.hpp (original)
+++ incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempDestination.hpp Fri Jul 28 01:22:48 2006
@@ -1,50 +1,50 @@
-/*
- * 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_ActiveMQTempDestination_hpp_
-#define ActiveMQ_ActiveMQTempDestination_hpp_
-
-#include "activemq/command/ActiveMQDestination.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace command
-    {
-
-/*
- * 
- */
-class ActiveMQTempDestination : public ActiveMQDestination
-{
-public:
-    const static unsigned char TYPE = 0 ;
-
-public:
-    ActiveMQTempDestination() ;
-    ActiveMQTempDestination(const char* name) ;
-    virtual ~ActiveMQTempDestination() ;
-
-    virtual unsigned char getDataStructureType() ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_ActiveMQTempDestination_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_ActiveMQTempDestination_hpp_
+#define ActiveMQ_ActiveMQTempDestination_hpp_
+
+#include "activemq/command/ActiveMQDestination.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+
+/*
+ * 
+ */
+class ActiveMQTempDestination : public ActiveMQDestination
+{
+public:
+    const static unsigned char TYPE = 0 ;
+
+public:
+    ActiveMQTempDestination() ;
+    ActiveMQTempDestination(const char* name) ;
+    virtual ~ActiveMQTempDestination() ;
+
+    virtual unsigned char getDataStructureType() ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ActiveMQTempDestination_hpp_*/

Propchange: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempDestination.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempQueue.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempQueue.cpp?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempQueue.cpp (original)
+++ incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempQueue.cpp Fri Jul 28 01:22:48 2006
@@ -1,75 +1,75 @@
-/*
- * 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.
- */
-#include "activemq/command/ActiveMQTempQueue.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- * 
- */
-ActiveMQTempQueue::ActiveMQTempQueue()
-   : ActiveMQTempDestination()
-{
-}
-
-/*
- * 
- */
-ActiveMQTempQueue::ActiveMQTempQueue(const char* name)
-   : ActiveMQTempDestination(name)
-{
-}
-
-/*
- * 
- */
-ActiveMQTempQueue::~ActiveMQTempQueue()
-{
-}
-
-/*
- * 
- */
-unsigned char ActiveMQTempQueue::getDataStructureType()
-{
-    return ActiveMQTempQueue::TYPE ; 
-}
-
-/*
- * 
- */
-p<string> ActiveMQTempQueue::getQueueName()
-{
-    return this->getPhysicalName() ;
-}
-
-/*
- * 
- */
-int ActiveMQTempQueue::getDestinationType()
-{
-    return ActiveMQDestination::ACTIVEMQ_QUEUE ;
-}
-
-/*
- * 
- */
-p<ActiveMQDestination> ActiveMQTempQueue::createDestination(const char* name)
-{
-    p<ActiveMQTempQueue> tempQueue = new ActiveMQTempQueue(name) ;
-    return tempQueue ;
-}
+/*
+ * 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.
+ */
+#include "activemq/command/ActiveMQTempQueue.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ * 
+ */
+ActiveMQTempQueue::ActiveMQTempQueue()
+   : ActiveMQTempDestination()
+{
+}
+
+/*
+ * 
+ */
+ActiveMQTempQueue::ActiveMQTempQueue(const char* name)
+   : ActiveMQTempDestination(name)
+{
+}
+
+/*
+ * 
+ */
+ActiveMQTempQueue::~ActiveMQTempQueue()
+{
+}
+
+/*
+ * 
+ */
+unsigned char ActiveMQTempQueue::getDataStructureType()
+{
+    return ActiveMQTempQueue::TYPE ; 
+}
+
+/*
+ * 
+ */
+p<string> ActiveMQTempQueue::getQueueName()
+{
+    return this->getPhysicalName() ;
+}
+
+/*
+ * 
+ */
+int ActiveMQTempQueue::getDestinationType()
+{
+    return ActiveMQDestination::ACTIVEMQ_QUEUE ;
+}
+
+/*
+ * 
+ */
+p<ActiveMQDestination> ActiveMQTempQueue::createDestination(const char* name)
+{
+    p<ActiveMQTempQueue> tempQueue = new ActiveMQTempQueue(name) ;
+    return tempQueue ;
+}

Propchange: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempQueue.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempQueue.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempQueue.hpp?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempQueue.hpp (original)
+++ incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempQueue.hpp Fri Jul 28 01:22:48 2006
@@ -1,55 +1,55 @@
-/*
- * 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_ActiveMQTempQueue_hpp_
-#define ActiveMQ_ActiveMQTempQueue_hpp_
-
-#include "cms/ITemporaryQueue.hpp"
-#include "activemq/command/ActiveMQTempDestination.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace command
-    {
-        using namespace apache::cms;
-
-/*
- * 
- */
-class ActiveMQTempQueue : public ActiveMQTempDestination, public ITemporaryQueue
-{
-public:
-    const static unsigned char TYPE = 102 ;
-
-public:
-    ActiveMQTempQueue() ;
-    ActiveMQTempQueue(const char* name) ;
-    virtual ~ActiveMQTempQueue() ;
-
-    virtual unsigned char getDataStructureType() ;
-    virtual p<string> getQueueName() ;
-    virtual int getDestinationType() ;
-    virtual p<ActiveMQDestination> createDestination(const char* name) ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_ActiveMQTempQueue_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_ActiveMQTempQueue_hpp_
+#define ActiveMQ_ActiveMQTempQueue_hpp_
+
+#include "cms/ITemporaryQueue.hpp"
+#include "activemq/command/ActiveMQTempDestination.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+        using namespace apache::cms;
+
+/*
+ * 
+ */
+class ActiveMQTempQueue : public ActiveMQTempDestination, public ITemporaryQueue
+{
+public:
+    const static unsigned char TYPE = 102 ;
+
+public:
+    ActiveMQTempQueue() ;
+    ActiveMQTempQueue(const char* name) ;
+    virtual ~ActiveMQTempQueue() ;
+
+    virtual unsigned char getDataStructureType() ;
+    virtual p<string> getQueueName() ;
+    virtual int getDestinationType() ;
+    virtual p<ActiveMQDestination> createDestination(const char* name) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ActiveMQTempQueue_hpp_*/

Propchange: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempQueue.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempTopic.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempTopic.cpp?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempTopic.cpp (original)
+++ incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempTopic.cpp Fri Jul 28 01:22:48 2006
@@ -1,75 +1,75 @@
-/*
- * 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.
- */
-#include "activemq/command/ActiveMQTempTopic.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- * 
- */
-ActiveMQTempTopic::ActiveMQTempTopic()
-   : ActiveMQTempDestination()
-{
-}
-
-/*
- * 
- */
-ActiveMQTempTopic::ActiveMQTempTopic(const char* name)
-   : ActiveMQTempDestination(name)
-{
-}
-
-/*
- * 
- */
-ActiveMQTempTopic::~ActiveMQTempTopic()
-{
-}
-
-/*
- * 
- */
-unsigned char ActiveMQTempTopic::getDataStructureType()
-{
-    return ActiveMQTempTopic::TYPE ; 
-}
-
-/*
- * 
- */
-p<string> ActiveMQTempTopic::getTopicName()
-{
-    return this->getPhysicalName() ;
-}
-
-/*
- * 
- */
-int ActiveMQTempTopic::getDestinationType()
-{
-    return ActiveMQDestination::ACTIVEMQ_TOPIC ;
-}
-
-/*
- * 
- */
-p<ActiveMQDestination> ActiveMQTempTopic::createDestination(const char* name)
-{
-    p<ActiveMQTempTopic> tempTopic = new ActiveMQTempTopic(name) ;
-    return tempTopic ;
-}
+/*
+ * 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.
+ */
+#include "activemq/command/ActiveMQTempTopic.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ * 
+ */
+ActiveMQTempTopic::ActiveMQTempTopic()
+   : ActiveMQTempDestination()
+{
+}
+
+/*
+ * 
+ */
+ActiveMQTempTopic::ActiveMQTempTopic(const char* name)
+   : ActiveMQTempDestination(name)
+{
+}
+
+/*
+ * 
+ */
+ActiveMQTempTopic::~ActiveMQTempTopic()
+{
+}
+
+/*
+ * 
+ */
+unsigned char ActiveMQTempTopic::getDataStructureType()
+{
+    return ActiveMQTempTopic::TYPE ; 
+}
+
+/*
+ * 
+ */
+p<string> ActiveMQTempTopic::getTopicName()
+{
+    return this->getPhysicalName() ;
+}
+
+/*
+ * 
+ */
+int ActiveMQTempTopic::getDestinationType()
+{
+    return ActiveMQDestination::ACTIVEMQ_TOPIC ;
+}
+
+/*
+ * 
+ */
+p<ActiveMQDestination> ActiveMQTempTopic::createDestination(const char* name)
+{
+    p<ActiveMQTempTopic> tempTopic = new ActiveMQTempTopic(name) ;
+    return tempTopic ;
+}

Propchange: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempTopic.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempTopic.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempTopic.hpp?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempTopic.hpp (original)
+++ incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempTopic.hpp Fri Jul 28 01:22:48 2006
@@ -1,55 +1,55 @@
-/*
- * 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_ActiveMQTempTopic_hpp_
-#define ActiveMQ_ActiveMQTempTopic_hpp_
-
-#include "cms/ITemporaryTopic.hpp"
-#include "activemq/command/ActiveMQTempDestination.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace command
-    {
-        using namespace apache::cms;
-
-/*
- * 
- */
-class ActiveMQTempTopic : public ActiveMQTempDestination, public ITemporaryTopic
-{
-public:
-    const static unsigned char TYPE = 103 ;
-
-public:
-    ActiveMQTempTopic() ;
-    ActiveMQTempTopic(const char* name) ;
-    virtual ~ActiveMQTempTopic() ;
-
-    virtual unsigned char getDataStructureType() ;
-    virtual p<string> getTopicName() ;
-    virtual int getDestinationType() ;
-    virtual p<ActiveMQDestination> createDestination(const char* name) ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_ActiveMQTempTopic_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_ActiveMQTempTopic_hpp_
+#define ActiveMQ_ActiveMQTempTopic_hpp_
+
+#include "cms/ITemporaryTopic.hpp"
+#include "activemq/command/ActiveMQTempDestination.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+        using namespace apache::cms;
+
+/*
+ * 
+ */
+class ActiveMQTempTopic : public ActiveMQTempDestination, public ITemporaryTopic
+{
+public:
+    const static unsigned char TYPE = 103 ;
+
+public:
+    ActiveMQTempTopic() ;
+    ActiveMQTempTopic(const char* name) ;
+    virtual ~ActiveMQTempTopic() ;
+
+    virtual unsigned char getDataStructureType() ;
+    virtual p<string> getTopicName() ;
+    virtual int getDestinationType() ;
+    virtual p<ActiveMQDestination> createDestination(const char* name) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ActiveMQTempTopic_hpp_*/

Propchange: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempTopic.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTextMessage.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTextMessage.cpp?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTextMessage.cpp (original)
+++ incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTextMessage.cpp Fri Jul 28 01:22:48 2006
@@ -1,98 +1,98 @@
-/*
- * 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.
- */
-#include "activemq/command/ActiveMQTextMessage.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- * 
- */
-ActiveMQTextMessage::ActiveMQTextMessage()
-{
-    setText(NULL) ;
-}
-
-/*
- * 
- */
-ActiveMQTextMessage::ActiveMQTextMessage(const char* text)
-{
-    setText(text) ;
-}
-
-/*
- * 
- */
-ActiveMQTextMessage::~ActiveMQTextMessage()
-{
-}
-
-/*
- * 
- */
-unsigned char ActiveMQTextMessage::getDataStructureType()
-{
-    return ActiveMQTextMessage::TYPE ;
-}
-
-/*
- * 
- */
-p<string> ActiveMQTextMessage::getText()
-{
-    // Extract text from message content
-    if( this->content.size() > 0 )
-    {
-        int utflen = 0 ;
-        char* buffer = this->content.c_array() ;
-
-        // TODO: assuming that the text is ASCII
-        utflen |= (char) ((buffer[0] << 24) & 0xFF) ;
-        utflen |= (char) ((buffer[1] >> 16) & 0xFF);
-        utflen |= (char) ((buffer[2] >> 8) & 0xFF);
-        utflen |= (char) ((buffer[3] >> 0) & 0xFF);
-
-        p<string> text = new string( buffer + 4, this->content.size() - 4 ) ;
-        return text ;
-    }
-    return NULL ;
-}
-
-/*
- * 
- */
-void ActiveMQTextMessage::setText(const char* text)
-{
-    if( text != NULL )
-    {
-        int length = (int)strlen(text) ;
-        int utflen = length ;
-
-        // TODO: assuming that the text is ASCII
-        this->content = array<char> (length + 4) ;
-
-        this->content[0] = (char) ((utflen >> 24) & 0xFF) ;
-        this->content[1] = (char) ((utflen >> 16) & 0xFF);
-        this->content[2] = (char) ((utflen >> 8) & 0xFF);
-        this->content[3] = (char) ((utflen >> 0) & 0xFF);
-
-        for( int i = 0 ; i < length ; i++ )
-            this->content[4+i] = text[i] ;
-    }
-    else
-        this->content = NULL ;
-}
+/*
+ * 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.
+ */
+#include "activemq/command/ActiveMQTextMessage.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ * 
+ */
+ActiveMQTextMessage::ActiveMQTextMessage()
+{
+    setText(NULL) ;
+}
+
+/*
+ * 
+ */
+ActiveMQTextMessage::ActiveMQTextMessage(const char* text)
+{
+    setText(text) ;
+}
+
+/*
+ * 
+ */
+ActiveMQTextMessage::~ActiveMQTextMessage()
+{
+}
+
+/*
+ * 
+ */
+unsigned char ActiveMQTextMessage::getDataStructureType()
+{
+    return ActiveMQTextMessage::TYPE ;
+}
+
+/*
+ * 
+ */
+p<string> ActiveMQTextMessage::getText()
+{
+    // Extract text from message content
+    if( this->content.size() > 0 )
+    {
+        int utflen = 0 ;
+        char* buffer = this->content.c_array() ;
+
+        // TODO: assuming that the text is ASCII
+        utflen |= (char) ((buffer[0] << 24) & 0xFF) ;
+        utflen |= (char) ((buffer[1] >> 16) & 0xFF);
+        utflen |= (char) ((buffer[2] >> 8) & 0xFF);
+        utflen |= (char) ((buffer[3] >> 0) & 0xFF);
+
+        p<string> text = new string( buffer + 4, this->content.size() - 4 ) ;
+        return text ;
+    }
+    return NULL ;
+}
+
+/*
+ * 
+ */
+void ActiveMQTextMessage::setText(const char* text)
+{
+    if( text != NULL )
+    {
+        int length = (int)strlen(text) ;
+        int utflen = length ;
+
+        // TODO: assuming that the text is ASCII
+        this->content = array<char> (length + 4) ;
+
+        this->content[0] = (char) ((utflen >> 24) & 0xFF) ;
+        this->content[1] = (char) ((utflen >> 16) & 0xFF);
+        this->content[2] = (char) ((utflen >> 8) & 0xFF);
+        this->content[3] = (char) ((utflen >> 0) & 0xFF);
+
+        for( int i = 0 ; i < length ; i++ )
+            this->content[4+i] = text[i] ;
+    }
+    else
+        this->content = NULL ;
+}

Propchange: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTextMessage.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTextMessage.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTextMessage.hpp?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTextMessage.hpp (original)
+++ incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTextMessage.hpp Fri Jul 28 01:22:48 2006
@@ -1,135 +1,135 @@
-/*
- * 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_ActiveMQTextMessage_hpp_
-#define ActiveMQ_ActiveMQTextMessage_hpp_
-
-#include <string>
-#include "cms/ITextMessage.hpp"
-#include "activemq/command/ActiveMQMessage.hpp"
-#include "ppr/util/MapItemHolder.hpp"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace command
-    {
-      using namespace ifr;
-      using namespace apache::cms;
-      using namespace apache::ppr::util;
-
-/*
- * 
- */
-class ActiveMQTextMessage : public ActiveMQMessage, public ITextMessage
-{
-public:
-    const static unsigned char TYPE = 28 ;
-
-public:
-    ActiveMQTextMessage() ;
-    ActiveMQTextMessage(const char* text) ;
-    virtual ~ActiveMQTextMessage() ;
-
-    virtual unsigned char getDataStructureType() ;
-    virtual p<string> getText() ;
-    virtual void setText(const char* text) ;
-
-    //
-    // The methods below are needed to resolve the multiple
-    // inheritance of IMessage.
-    virtual void acknowledge() {
-        ActiveMQMessage::acknowledge() ;
-    } ;
-    virtual p<PropertyMap> getProperties() {
-        return ActiveMQMessage::getProperties() ;
-    } ;
-    virtual p<string> getJMSCorrelationID() {
-        return ActiveMQMessage::getJMSCorrelationID() ;
-    } ;
-    virtual void setJMSCorrelationID(const char* correlationId) {
-        return ActiveMQMessage::setJMSCorrelationID(correlationId) ;
-    } ;
-    virtual p<IDestination> getJMSDestination() {
-        return ActiveMQMessage::getJMSDestination() ;
-    } ;
-    virtual long long getJMSExpiration() {
-        return ActiveMQMessage::getJMSExpiration() ;
-    } ;
-    virtual void setJMSExpiration(long long time) {
-        return ActiveMQMessage::setJMSExpiration(time) ;
-    } ;
-    virtual p<string> getJMSMessageID() {
-        return ActiveMQMessage::getJMSMessageID() ;
-    } ;
-    virtual bool getJMSPersistent() {
-        return ActiveMQMessage::getJMSPersistent() ;
-    } ;
-    virtual void setJMSPersistent(bool persistent) {
-        return ActiveMQMessage::setJMSPersistent(persistent) ;
-    } ;
-    virtual unsigned char getJMSPriority() {
-        return ActiveMQMessage::getJMSPriority() ;
-    } ;
-    virtual void setJMSPriority(unsigned char priority) {
-        return ActiveMQMessage::setJMSPriority(priority) ;
-    } ;
-    virtual bool getJMSRedelivered() {
-        return ActiveMQMessage::getJMSRedelivered() ;
-    } ;
-    virtual p<IDestination> getJMSReplyTo() {
-        return ActiveMQMessage::getJMSReplyTo() ;
-    } ;
-    virtual void setJMSReplyTo(p<IDestination> destination) {
-        return ActiveMQMessage::setJMSReplyTo(destination) ;
-    } ;
-    virtual long long getJMSTimestamp() {
-        return ActiveMQMessage::getJMSTimestamp() ;
-    } ;
-    virtual p<string> getJMSType() {
-        return ActiveMQMessage::getJMSType() ;
-    } ;
-    virtual void setJMSType(const char* type) {
-        return ActiveMQMessage::setJMSType(type) ;
-    } ;
-    virtual int getJMSXDeliveryCount() {
-        return ActiveMQMessage::getJMSXDeliveryCount() ;
-    } ;
-    virtual p<string> getJMSXGroupID() {
-        return ActiveMQMessage::getJMSXGroupID() ;
-    } ;
-    virtual void setJMSXGroupID(const char* groupId) {
-        return ActiveMQMessage::setJMSXGroupID(groupId) ;
-    } ;
-    virtual int getJMSXGroupSeq() {
-        return ActiveMQMessage::getJMSXGroupSeq() ;
-    } ;
-    virtual void setJMSXGroupSeq(int sequence) {
-        return ActiveMQMessage::setJMSXGroupSeq(sequence) ;
-    } ;
-    virtual p<string> getJMSXProducerTxID() {
-        return ActiveMQMessage::getJMSXProducerTxID() ;
-    } ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_ActiveMQTextMessage_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_ActiveMQTextMessage_hpp_
+#define ActiveMQ_ActiveMQTextMessage_hpp_
+
+#include <string>
+#include "cms/ITextMessage.hpp"
+#include "activemq/command/ActiveMQMessage.hpp"
+#include "ppr/util/MapItemHolder.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr;
+      using namespace apache::cms;
+      using namespace apache::ppr::util;
+
+/*
+ * 
+ */
+class ActiveMQTextMessage : public ActiveMQMessage, public ITextMessage
+{
+public:
+    const static unsigned char TYPE = 28 ;
+
+public:
+    ActiveMQTextMessage() ;
+    ActiveMQTextMessage(const char* text) ;
+    virtual ~ActiveMQTextMessage() ;
+
+    virtual unsigned char getDataStructureType() ;
+    virtual p<string> getText() ;
+    virtual void setText(const char* text) ;
+
+    //
+    // The methods below are needed to resolve the multiple
+    // inheritance of IMessage.
+    virtual void acknowledge() {
+        ActiveMQMessage::acknowledge() ;
+    } ;
+    virtual p<PropertyMap> getProperties() {
+        return ActiveMQMessage::getProperties() ;
+    } ;
+    virtual p<string> getJMSCorrelationID() {
+        return ActiveMQMessage::getJMSCorrelationID() ;
+    } ;
+    virtual void setJMSCorrelationID(const char* correlationId) {
+        return ActiveMQMessage::setJMSCorrelationID(correlationId) ;
+    } ;
+    virtual p<IDestination> getJMSDestination() {
+        return ActiveMQMessage::getJMSDestination() ;
+    } ;
+    virtual long long getJMSExpiration() {
+        return ActiveMQMessage::getJMSExpiration() ;
+    } ;
+    virtual void setJMSExpiration(long long time) {
+        return ActiveMQMessage::setJMSExpiration(time) ;
+    } ;
+    virtual p<string> getJMSMessageID() {
+        return ActiveMQMessage::getJMSMessageID() ;
+    } ;
+    virtual bool getJMSPersistent() {
+        return ActiveMQMessage::getJMSPersistent() ;
+    } ;
+    virtual void setJMSPersistent(bool persistent) {
+        return ActiveMQMessage::setJMSPersistent(persistent) ;
+    } ;
+    virtual unsigned char getJMSPriority() {
+        return ActiveMQMessage::getJMSPriority() ;
+    } ;
+    virtual void setJMSPriority(unsigned char priority) {
+        return ActiveMQMessage::setJMSPriority(priority) ;
+    } ;
+    virtual bool getJMSRedelivered() {
+        return ActiveMQMessage::getJMSRedelivered() ;
+    } ;
+    virtual p<IDestination> getJMSReplyTo() {
+        return ActiveMQMessage::getJMSReplyTo() ;
+    } ;
+    virtual void setJMSReplyTo(p<IDestination> destination) {
+        return ActiveMQMessage::setJMSReplyTo(destination) ;
+    } ;
+    virtual long long getJMSTimestamp() {
+        return ActiveMQMessage::getJMSTimestamp() ;
+    } ;
+    virtual p<string> getJMSType() {
+        return ActiveMQMessage::getJMSType() ;
+    } ;
+    virtual void setJMSType(const char* type) {
+        return ActiveMQMessage::setJMSType(type) ;
+    } ;
+    virtual int getJMSXDeliveryCount() {
+        return ActiveMQMessage::getJMSXDeliveryCount() ;
+    } ;
+    virtual p<string> getJMSXGroupID() {
+        return ActiveMQMessage::getJMSXGroupID() ;
+    } ;
+    virtual void setJMSXGroupID(const char* groupId) {
+        return ActiveMQMessage::setJMSXGroupID(groupId) ;
+    } ;
+    virtual int getJMSXGroupSeq() {
+        return ActiveMQMessage::getJMSXGroupSeq() ;
+    } ;
+    virtual void setJMSXGroupSeq(int sequence) {
+        return ActiveMQMessage::setJMSXGroupSeq(sequence) ;
+    } ;
+    virtual p<string> getJMSXProducerTxID() {
+        return ActiveMQMessage::getJMSXProducerTxID() ;
+    } ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ActiveMQTextMessage_hpp_*/

Propchange: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTextMessage.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTopic.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTopic.cpp?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTopic.cpp (original)
+++ incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTopic.cpp Fri Jul 28 01:22:48 2006
@@ -1,75 +1,75 @@
-/*
- * 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.
- */
-#include "activemq/command/ActiveMQTopic.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- * 
- */
-ActiveMQTopic::ActiveMQTopic()
-   : ActiveMQDestination()
-{
-}
-
-/*
- * 
- */
-ActiveMQTopic::ActiveMQTopic(const char* name)
-   : ActiveMQDestination(name)
-{
-}
-
-/*
- * 
- */
-ActiveMQTopic::~ActiveMQTopic()
-{
-}
-
-/*
- * 
- */
-unsigned char ActiveMQTopic::getDataStructureType()
-{
-    return ActiveMQTopic::TYPE ; 
-}
-
-/*
- * 
- */
-p<string> ActiveMQTopic::getTopicName()
-{
-    return this->getPhysicalName() ;
-}
-
-/*
- * 
- */
-int ActiveMQTopic::getDestinationType()
-{
-    return ActiveMQDestination::ACTIVEMQ_TOPIC ;
-}
-
-/*
- * 
- */
-p<ActiveMQDestination> ActiveMQTopic::createDestination(const char* name)
-{
-    p<ActiveMQTopic> topic = new ActiveMQTopic(name) ;
-    return topic ;
-}
+/*
+ * 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.
+ */
+#include "activemq/command/ActiveMQTopic.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ * 
+ */
+ActiveMQTopic::ActiveMQTopic()
+   : ActiveMQDestination()
+{
+}
+
+/*
+ * 
+ */
+ActiveMQTopic::ActiveMQTopic(const char* name)
+   : ActiveMQDestination(name)
+{
+}
+
+/*
+ * 
+ */
+ActiveMQTopic::~ActiveMQTopic()
+{
+}
+
+/*
+ * 
+ */
+unsigned char ActiveMQTopic::getDataStructureType()
+{
+    return ActiveMQTopic::TYPE ; 
+}
+
+/*
+ * 
+ */
+p<string> ActiveMQTopic::getTopicName()
+{
+    return this->getPhysicalName() ;
+}
+
+/*
+ * 
+ */
+int ActiveMQTopic::getDestinationType()
+{
+    return ActiveMQDestination::ACTIVEMQ_TOPIC ;
+}
+
+/*
+ * 
+ */
+p<ActiveMQDestination> ActiveMQTopic::createDestination(const char* name)
+{
+    p<ActiveMQTopic> topic = new ActiveMQTopic(name) ;
+    return topic ;
+}

Propchange: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTopic.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTopic.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTopic.hpp?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTopic.hpp (original)
+++ incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTopic.hpp Fri Jul 28 01:22:48 2006
@@ -1,55 +1,55 @@
-/*
- * 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_ActiveMQTopic_hpp_
-#define ActiveMQ_ActiveMQTopic_hpp_
-
-#include "cms/ITopic.hpp"
-#include "activemq/command/ActiveMQDestination.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace command
-    {
-      using namespace apache::cms;
-
-/*
- * 
- */
-class ActiveMQTopic : public ActiveMQDestination, public ITopic
-{
-public:
-    const static unsigned char TYPE = 101 ;
-
-public:
-    ActiveMQTopic() ;
-    ActiveMQTopic(const char* name) ;
-    virtual ~ActiveMQTopic() ;
-
-    virtual unsigned char getDataStructureType() ;
-    virtual p<string> getTopicName() ;
-    virtual int getDestinationType() ;
-    virtual p<ActiveMQDestination> createDestination(const char* name) ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_ActiveMQTopic_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_ActiveMQTopic_hpp_
+#define ActiveMQ_ActiveMQTopic_hpp_
+
+#include "cms/ITopic.hpp"
+#include "activemq/command/ActiveMQDestination.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace apache::cms;
+
+/*
+ * 
+ */
+class ActiveMQTopic : public ActiveMQDestination, public ITopic
+{
+public:
+    const static unsigned char TYPE = 101 ;
+
+public:
+    ActiveMQTopic() ;
+    ActiveMQTopic(const char* name) ;
+    virtual ~ActiveMQTopic() ;
+
+    virtual unsigned char getDataStructureType() ;
+    virtual p<string> getTopicName() ;
+    virtual int getDestinationType() ;
+    virtual p<ActiveMQDestination> createDestination(const char* name) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ActiveMQTopic_hpp_*/

Propchange: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTopic.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BaseCommand.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BaseCommand.cpp?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BaseCommand.cpp (original)
+++ incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BaseCommand.cpp Fri Jul 28 01:22:48 2006
@@ -1,57 +1,57 @@
-/*
- * 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.
- */
-#include "activemq/command/BaseCommand.hpp"
-
-using namespace apache::activemq::command;
-
-
-// Attribute methods ------------------------------------------------
-
-int BaseCommand::getHashCode()
-{
-    return ( commandId * 38 ) + getDataStructureType() ;
-}
-
-
-// Operation methods ------------------------------------------------
-
-bool BaseCommand::operator== (BaseCommand& that)
-{
-    if( this->getDataStructureType() == that.getDataStructureType() &&
-        this->commandId == that.commandId )
-    {
-        return true ;
-    }
-    return false ;
-}
-
-p<string> BaseCommand::toString()
-{
-    p<string> str = new string() ;
-    char      buffer[10] ;
-    
-    str->assign( getDataStructureTypeAsString( getDataStructureType() )->c_str() ) ;
-
-    if( str->length() == 0 )
-        str->assign("") ;
-
-    str->append(": id = ") ;
-	sprintf(buffer, "%d", commandId) ;
-    str->append( buffer ) ;
-
-    return str ;
-}
+/*
+ * 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.
+ */
+#include "activemq/command/BaseCommand.hpp"
+
+using namespace apache::activemq::command;
+
+
+// Attribute methods ------------------------------------------------
+
+int BaseCommand::getHashCode()
+{
+    return ( commandId * 38 ) + getDataStructureType() ;
+}
+
+
+// Operation methods ------------------------------------------------
+
+bool BaseCommand::operator== (BaseCommand& that)
+{
+    if( this->getDataStructureType() == that.getDataStructureType() &&
+        this->commandId == that.commandId )
+    {
+        return true ;
+    }
+    return false ;
+}
+
+p<string> BaseCommand::toString()
+{
+    p<string> str = new string() ;
+    char      buffer[10] ;
+    
+    str->assign( getDataStructureTypeAsString( getDataStructureType() )->c_str() ) ;
+
+    if( str->length() == 0 )
+        str->assign("") ;
+
+    str->append(": id = ") ;
+	sprintf(buffer, "%d", commandId) ;
+    str->append( buffer ) ;
+
+    return str ;
+}

Propchange: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BaseCommand.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BaseCommand.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BaseCommand.hpp?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BaseCommand.hpp (original)
+++ incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BaseCommand.hpp Fri Jul 28 01:22:48 2006
@@ -1,51 +1,51 @@
-/*
- * 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_BaseCommand_hpp_
-#define ActiveMQ_BaseCommand_hpp_
-
-#include <string>
-#include "activemq/command/AbstractCommand.hpp"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace command
-    {
-      using namespace ifr;
-      using namespace std;
-
-/*
- * 
- */
-class BaseCommand : public AbstractCommand
-{
-public:
-    // Equals operator
-    bool operator== (BaseCommand& other) ;
-
-    virtual int getHashCode() ;
-    virtual p<string> toString() ;
-};
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_BaseCommand_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_BaseCommand_hpp_
+#define ActiveMQ_BaseCommand_hpp_
+
+#include <string>
+#include "activemq/command/AbstractCommand.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr;
+      using namespace std;
+
+/*
+ * 
+ */
+class BaseCommand : public AbstractCommand
+{
+public:
+    // Equals operator
+    bool operator== (BaseCommand& other) ;
+
+    virtual int getHashCode() ;
+    virtual p<string> toString() ;
+};
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_BaseCommand_hpp_*/

Propchange: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BaseCommand.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BooleanExpression.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BooleanExpression.hpp?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BooleanExpression.hpp (original)
+++ incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BooleanExpression.hpp Fri Jul 28 01:22:48 2006
@@ -1,45 +1,45 @@
-/*
- * 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_BooleanExpression_hpp_
-#define ActiveMQ_BooleanExpression_hpp_
-
-#include "activemq/command/BaseCommand.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace command
-    {
-
-/*
- * 
- */
-class BooleanExpression : public BaseCommand
-{
-protected:
-
-protected:
-    BooleanExpression() {}
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_BooleanExpression_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_BooleanExpression_hpp_
+#define ActiveMQ_BooleanExpression_hpp_
+
+#include "activemq/command/BaseCommand.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+
+/*
+ * 
+ */
+class BooleanExpression : public BaseCommand
+{
+protected:
+
+protected:
+    BooleanExpression() {}
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_BooleanExpression_hpp_*/

Propchange: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BooleanExpression.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BrokerError.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BrokerError.cpp?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BrokerError.cpp (original)
+++ incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BrokerError.cpp Fri Jul 28 01:22:48 2006
@@ -1,126 +1,126 @@
-/*
- * 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.
- */
-#include "activemq/command/BrokerError.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- * 
- */
-BrokerError::BrokerError()
-{
-    message            = new string() ;
-    exceptionClass     = new string() ;
-    stackTraceElements = NULL ;
-    cause              = NULL ;
-}
-
-/*
- * 
- */
-p<string> BrokerError::getMessage()
-{
-    return message ;
-}
-
-/*
- * 
- */
-void BrokerError::setMessage(const char* msg)
-{
-    this->message->assign(msg) ;
-}
-
-/*
- * 
- */
-p<string> BrokerError::getExceptionClass()
-{
-    return exceptionClass ;
-}
-
-/*
- * 
- */
-void BrokerError::setExceptionClass(const char* exClass)
-{
-    this->exceptionClass->assign(exClass) ;
-}
-
-/*
- * 
- */
-array<StackTraceElement> BrokerError::getStackTraceElements()
-{
-    return stackTraceElements ;
-}
-
-/*
- * 
- */
-void BrokerError::setStackTraceElements(array<StackTraceElement> elements)
-{
-    this->stackTraceElements = elements ;
-}
-
-/*
- * 
- */
-p<BrokerError> BrokerError::getCause()
-{
-    return cause ;
-}
-
-/*
- * 
- */
-void BrokerError::setCause(p<BrokerError> cause)
-{
-    this->cause = cause ;
-}
-
-/*
- * 
- */
-p<string> BrokerError::getStackTrace()
-{
-    ostringstream sstream ;
-    p<string> trace ;
-    printStackTrace(sstream) ;
-    trace = new string (sstream.str());
-    return trace ;
-}
-
-/*
- * 
- */
-void BrokerError::printStackTrace(ostream& out)
-{
-    out << getptr(exceptionClass) << ": " << getptr(message) << endl ;
-
-    for( size_t i = 0; i < sizeof(stackTraceElements)/sizeof(stackTraceElements[0]); i++ )
-    {
-        p<StackTraceElement> element = stackTraceElements[i] ;
-        out << "    at " << getptr(element->className) << "." << getptr(element->methodName) << "(" << getptr(element->fileName) << ":" << element->lineNumber << ")" << endl ;
-    }
-    // Dump any nested exceptions
-    if( cause != NULL )
-    {
-        out << "Nested Exception:" << endl ;
-        cause->printStackTrace(out) ;
-    }
-}
+/*
+ * 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.
+ */
+#include "activemq/command/BrokerError.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ * 
+ */
+BrokerError::BrokerError()
+{
+    message            = new string() ;
+    exceptionClass     = new string() ;
+    stackTraceElements = NULL ;
+    cause              = NULL ;
+}
+
+/*
+ * 
+ */
+p<string> BrokerError::getMessage()
+{
+    return message ;
+}
+
+/*
+ * 
+ */
+void BrokerError::setMessage(const char* msg)
+{
+    this->message->assign(msg) ;
+}
+
+/*
+ * 
+ */
+p<string> BrokerError::getExceptionClass()
+{
+    return exceptionClass ;
+}
+
+/*
+ * 
+ */
+void BrokerError::setExceptionClass(const char* exClass)
+{
+    this->exceptionClass->assign(exClass) ;
+}
+
+/*
+ * 
+ */
+array<StackTraceElement> BrokerError::getStackTraceElements()
+{
+    return stackTraceElements ;
+}
+
+/*
+ * 
+ */
+void BrokerError::setStackTraceElements(array<StackTraceElement> elements)
+{
+    this->stackTraceElements = elements ;
+}
+
+/*
+ * 
+ */
+p<BrokerError> BrokerError::getCause()
+{
+    return cause ;
+}
+
+/*
+ * 
+ */
+void BrokerError::setCause(p<BrokerError> cause)
+{
+    this->cause = cause ;
+}
+
+/*
+ * 
+ */
+p<string> BrokerError::getStackTrace()
+{
+    ostringstream sstream ;
+    p<string> trace ;
+    printStackTrace(sstream) ;
+    trace = new string (sstream.str());
+    return trace ;
+}
+
+/*
+ * 
+ */
+void BrokerError::printStackTrace(ostream& out)
+{
+    out << getptr(exceptionClass) << ": " << getptr(message) << endl ;
+
+    for( size_t i = 0; i < sizeof(stackTraceElements)/sizeof(stackTraceElements[0]); i++ )
+    {
+        p<StackTraceElement> element = stackTraceElements[i] ;
+        out << "    at " << getptr(element->className) << "." << getptr(element->methodName) << "(" << getptr(element->fileName) << ":" << element->lineNumber << ")" << endl ;
+    }
+    // Dump any nested exceptions
+    if( cause != NULL )
+    {
+        out << "Nested Exception:" << endl ;
+        cause->printStackTrace(out) ;
+    }
+}

Propchange: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BrokerError.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BrokerError.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BrokerError.hpp?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BrokerError.hpp (original)
+++ incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BrokerError.hpp Fri Jul 28 01:22:48 2006
@@ -1,78 +1,78 @@
-/*
- * 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_BrokerError_hpp_
-#define ActiveMQ_BrokerError_hpp_
-
-#include <string>
-#include <ostream>
-#include <sstream>
-#include "activemq/command/AbstractCommand.hpp"
-#include "ppr/util/ifr/array"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace command
-    {
-      using namespace ifr ;
-      using namespace std ;
-
-/*
- * 
- */
-struct StackTraceElement
-{
-    p<string> className ;
-    p<string> fileName ;
-    p<string> methodName ;
-    int lineNumber ;
-} ;
-
-/*
- * Represents an exception on the broker.
- */
-class BrokerError : public AbstractCommand
-{
-private:
-    p<string>             message ;
-    p<string>             exceptionClass ;
-    array<StackTraceElement> stackTraceElements ;
-    p<BrokerError>        cause ;
-
-public:
-    BrokerError() ;
-
-    virtual p<string> getMessage() ;
-    virtual void setMessage(const char* msg) ;
-    virtual p<string> getExceptionClass() ;
-    virtual void setExceptionClass(const char* exClass) ;
-    virtual array<StackTraceElement> getStackTraceElements() ;
-    virtual void setStackTraceElements(array<StackTraceElement> elements) ;
-    virtual p<BrokerError> getCause() ;
-    virtual void setCause(p<BrokerError> cause) ;
-    virtual p<string> getStackTrace() ;
-    virtual void printStackTrace(ostream& out) ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_BrokerError_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_BrokerError_hpp_
+#define ActiveMQ_BrokerError_hpp_
+
+#include <string>
+#include <ostream>
+#include <sstream>
+#include "activemq/command/AbstractCommand.hpp"
+#include "ppr/util/ifr/array"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace command
+    {
+      using namespace ifr ;
+      using namespace std ;
+
+/*
+ * 
+ */
+struct StackTraceElement
+{
+    p<string> className ;
+    p<string> fileName ;
+    p<string> methodName ;
+    int lineNumber ;
+} ;
+
+/*
+ * Represents an exception on the broker.
+ */
+class BrokerError : public AbstractCommand
+{
+private:
+    p<string>             message ;
+    p<string>             exceptionClass ;
+    array<StackTraceElement> stackTraceElements ;
+    p<BrokerError>        cause ;
+
+public:
+    BrokerError() ;
+
+    virtual p<string> getMessage() ;
+    virtual void setMessage(const char* msg) ;
+    virtual p<string> getExceptionClass() ;
+    virtual void setExceptionClass(const char* exClass) ;
+    virtual array<StackTraceElement> getStackTraceElements() ;
+    virtual void setStackTraceElements(array<StackTraceElement> elements) ;
+    virtual p<BrokerError> getCause() ;
+    virtual void setCause(p<BrokerError> cause) ;
+    virtual p<string> getStackTrace() ;
+    virtual void printStackTrace(ostream& out) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_BrokerError_hpp_*/

Propchange: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BrokerError.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/WireFormatInfo.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/WireFormatInfo.cpp?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/WireFormatInfo.cpp (original)
+++ incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/WireFormatInfo.cpp Fri Jul 28 01:22:48 2006
@@ -1,165 +1,165 @@
-/*
-* 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.
-*/
-#include "activemq/command/WireFormatInfo.hpp"
-
-using namespace apache::activemq::command;
-
-/*
- *
- *  Marshalling code for Open Wire Format for WireFormatInfo
- *
- *
- *  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
- *
- */
-WireFormatInfo::WireFormatInfo()
-{    
-    this->magic         = array<char> (8) ;
-    this->version       = 0 ;
-    this->propsByteSize = 0 ;
-    this->properties    = new PropertyMap() ;
-}
-
-unsigned char WireFormatInfo::getDataStructureType()
-{
-    return WireFormatInfo::TYPE ; 
-}
-
-        
-array<char> WireFormatInfo::getMagic()
-{
-    return magic ;
-}
-
-void WireFormatInfo::setMagic(array<char> magic)
-{
-    this->magic = magic ;
-}
-
-        
-int WireFormatInfo::getVersion()
-{
-    return version ;
-}
-
-void WireFormatInfo::setVersion(int version)
-{
-    this->version = version ;
-}
-
-        
-bool WireFormatInfo::getCacheEnabled()
-{
-    return (*properties)["CacheEnabled"].getBoolean() ;
-}
-
-void WireFormatInfo::setCacheEnabled(bool cacheEnabled)
-{
-    (*properties)["CacheEnabled"] = MapItemHolder(cacheEnabled) ;
-}
-
-        
-bool WireFormatInfo::getStackTraceEnabled()
-{
-    return (*properties)["StackTraceEnabled"].getBoolean() ;
-}
-
-void WireFormatInfo::setStackTraceEnabled(bool stackTraceEnabled)
-{
-    (*properties)["StackTraceEnabled"] = MapItemHolder(stackTraceEnabled) ;
-}
-
-        
-bool WireFormatInfo::getTcpNoDelayEnabled()
-{
-    return (*properties)["TcpNoDelayedEnabled"].getBoolean() ;
-}
-
-void WireFormatInfo::setTcpNoDelayEnabled(bool tcpNoDelayEnabled)
-{
-    (*properties)["TcpNoDelayedEnabled"] = MapItemHolder(tcpNoDelayEnabled) ;
-}
-
-
-bool WireFormatInfo::getSizePrefixDisabled()
-{
-    return (*properties)["SizePrefixDisabled"].getBoolean() ;
-}
-
-void WireFormatInfo::setSizePrefixDisabled(bool sizePrefixDisabled)
-{
-    (*properties)["SizePrefixDisabled"] = MapItemHolder(sizePrefixDisabled) ;
-}
-
-        
-bool WireFormatInfo::getTightEncodingEnabled()
-{
-    return (*properties)["TightEncodingEnabled"].getBoolean() ;
-}
-
-void WireFormatInfo::setTightEncodingEnabled(bool tightEncodingEnabled)
-{
-    (*properties)["TightEncodingEnabled"] = MapItemHolder(tightEncodingEnabled) ;
-}
-
-int WireFormatInfo::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> writer) throw (IOException)
-{
-    int size = 0 ;
-
-    // BUG: Should write array size
-    //size += marshaller->marshalByteArray(magic, mode, writer) ; 
-    size += (int)magic.size() ;
-    
-    if( mode == IMarshaller::MARSHAL_WRITE )
-        writer->write(magic.c_array(), 0, size) ;
-
-    size += marshaller->marshalInt(version, mode, writer) ; 
-    size += marshaller->marshalBoolean( properties != NULL, mode, writer) ;
-
-    if( mode == IMarshaller::MARSHAL_SIZE )
-    {
-        //propsByteSize = sizeof(int) ;
-        propsByteSize += marshaller->marshalMap(properties, mode, writer) ;
-        size += propsByteSize ;
-    }
-    else
-    {
-        size += marshaller->marshalInt(propsByteSize, mode, writer) ; 
-        size += marshaller->marshalMap(properties, mode, writer) ; 
-    }
-    return size ;
-}
-
-void WireFormatInfo::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
-{
-    bool isNonNullProps ;
-
-    // BUG: Should read array size
-    //magic = marshaller->unmarshalByteArray(mode, reader) ; 
-    reader->read(magic.c_array(), 0, 8) ;
-    version = marshaller->unmarshalInt(mode, reader) ; 
-    isNonNullProps = marshaller->unmarshalBoolean(mode, reader) ;
-    if( isNonNullProps )
-    {
-        propsByteSize = marshaller->unmarshalInt(mode, reader) ;
-        properties = marshaller->unmarshalMap(mode, reader) ; 
-    }
-    else
-        properties = NULL ;
-}
+/*
+* 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.
+*/
+#include "activemq/command/WireFormatInfo.hpp"
+
+using namespace apache::activemq::command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for WireFormatInfo
+ *
+ *
+ *  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
+ *
+ */
+WireFormatInfo::WireFormatInfo()
+{    
+    this->magic         = array<char> (8) ;
+    this->version       = 0 ;
+    this->propsByteSize = 0 ;
+    this->properties    = new PropertyMap() ;
+}
+
+unsigned char WireFormatInfo::getDataStructureType()
+{
+    return WireFormatInfo::TYPE ; 
+}
+
+        
+array<char> WireFormatInfo::getMagic()
+{
+    return magic ;
+}
+
+void WireFormatInfo::setMagic(array<char> magic)
+{
+    this->magic = magic ;
+}
+
+        
+int WireFormatInfo::getVersion()
+{
+    return version ;
+}
+
+void WireFormatInfo::setVersion(int version)
+{
+    this->version = version ;
+}
+
+        
+bool WireFormatInfo::getCacheEnabled()
+{
+    return (*properties)["CacheEnabled"].getBoolean() ;
+}
+
+void WireFormatInfo::setCacheEnabled(bool cacheEnabled)
+{
+    (*properties)["CacheEnabled"] = MapItemHolder(cacheEnabled) ;
+}
+
+        
+bool WireFormatInfo::getStackTraceEnabled()
+{
+    return (*properties)["StackTraceEnabled"].getBoolean() ;
+}
+
+void WireFormatInfo::setStackTraceEnabled(bool stackTraceEnabled)
+{
+    (*properties)["StackTraceEnabled"] = MapItemHolder(stackTraceEnabled) ;
+}
+
+        
+bool WireFormatInfo::getTcpNoDelayEnabled()
+{
+    return (*properties)["TcpNoDelayedEnabled"].getBoolean() ;
+}
+
+void WireFormatInfo::setTcpNoDelayEnabled(bool tcpNoDelayEnabled)
+{
+    (*properties)["TcpNoDelayedEnabled"] = MapItemHolder(tcpNoDelayEnabled) ;
+}
+
+
+bool WireFormatInfo::getSizePrefixDisabled()
+{
+    return (*properties)["SizePrefixDisabled"].getBoolean() ;
+}
+
+void WireFormatInfo::setSizePrefixDisabled(bool sizePrefixDisabled)
+{
+    (*properties)["SizePrefixDisabled"] = MapItemHolder(sizePrefixDisabled) ;
+}
+
+        
+bool WireFormatInfo::getTightEncodingEnabled()
+{
+    return (*properties)["TightEncodingEnabled"].getBoolean() ;
+}
+
+void WireFormatInfo::setTightEncodingEnabled(bool tightEncodingEnabled)
+{
+    (*properties)["TightEncodingEnabled"] = MapItemHolder(tightEncodingEnabled) ;
+}
+
+int WireFormatInfo::marshal(p<IMarshaller> marshaller, int mode, p<IOutputStream> writer) throw (IOException)
+{
+    int size = 0 ;
+
+    // BUG: Should write array size
+    //size += marshaller->marshalByteArray(magic, mode, writer) ; 
+    size += (int)magic.size() ;
+    
+    if( mode == IMarshaller::MARSHAL_WRITE )
+        writer->write(magic.c_array(), 0, size) ;
+
+    size += marshaller->marshalInt(version, mode, writer) ; 
+    size += marshaller->marshalBoolean( properties != NULL, mode, writer) ;
+
+    if( mode == IMarshaller::MARSHAL_SIZE )
+    {
+        //propsByteSize = sizeof(int) ;
+        propsByteSize += marshaller->marshalMap(properties, mode, writer) ;
+        size += propsByteSize ;
+    }
+    else
+    {
+        size += marshaller->marshalInt(propsByteSize, mode, writer) ; 
+        size += marshaller->marshalMap(properties, mode, writer) ; 
+    }
+    return size ;
+}
+
+void WireFormatInfo::unmarshal(p<IMarshaller> marshaller, int mode, p<IInputStream> reader) throw (IOException)
+{
+    bool isNonNullProps ;
+
+    // BUG: Should read array size
+    //magic = marshaller->unmarshalByteArray(mode, reader) ; 
+    reader->read(magic.c_array(), 0, 8) ;
+    version = marshaller->unmarshalInt(mode, reader) ; 
+    isNonNullProps = marshaller->unmarshalBoolean(mode, reader) ;
+    if( isNonNullProps )
+    {
+        propsByteSize = marshaller->unmarshalInt(mode, reader) ;
+        properties = marshaller->unmarshalMap(mode, reader) ; 
+    }
+    else
+        properties = NULL ;
+}

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

Modified: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/protocol/IMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/protocol/IMarshaller.hpp?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/protocol/IMarshaller.hpp (original)
+++ incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/protocol/IMarshaller.hpp Fri Jul 28 01:22:48 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> writer) throw(IOException) = 0 ;
-    virtual int marshalByte(char value, int mode, p<IOutputStream> writer) throw(IOException) = 0  ;
-    virtual int marshalShort(short value, int mode, p<IOutputStream> writer) throw(IOException) = 0  ;
-    virtual int marshalInt(int value, int mode, p<IOutputStream> writer) throw(IOException) = 0 ;
-    virtual int marshalLong(long long value, int mode, p<IOutputStream> writer) throw(IOException) = 0 ;
-    virtual int marshalFloat(float value, int mode, p<IOutputStream> writer) throw(IOException) = 0 ;
-    virtual int marshalDouble(double value, int mode, p<IOutputStream> writer) throw(IOException) = 0 ;
-    virtual int marshalString(p<string> value, int mode, p<IOutputStream> writer) throw(IOException) = 0 ;
-    virtual int marshalObject(p<IDataStructure> object, int mode, p<IOutputStream> writer) throw(IOException) = 0 ;
-    virtual int marshalObjectArray(array<IDataStructure> object, int mode, p<IOutputStream> writer) throw(IOException) = 0 ;
-    virtual int marshalByteArray(array<char> value, int mode, p<IOutputStream> writer) throw(IOException) = 0 ;
-    virtual int marshalMap(p<PropertyMap> value, int mode, p<IOutputStream> writer) throw(IOException) = 0 ;
-
-    virtual bool unmarshalBoolean(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
-    virtual char unmarshalByte(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
-    virtual short unmarshalShort(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
-    virtual int unmarshalInt(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
-    virtual long long unmarshalLong(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
-    virtual float unmarshalFloat(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
-    virtual double unmarshalDouble(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
-    virtual p<string> unmarshalString(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
-    virtual p<IDataStructure> unmarshalObject(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
-    virtual array<IDataStructure> unmarshalObjectArray(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
-    virtual array<char> unmarshalByteArray(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
-    virtual p<PropertyMap> unmarshalMap(int mode, p<IInputStream> reader) 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> writer) throw(IOException) = 0 ;
+    virtual int marshalByte(char value, int mode, p<IOutputStream> writer) throw(IOException) = 0  ;
+    virtual int marshalShort(short value, int mode, p<IOutputStream> writer) throw(IOException) = 0  ;
+    virtual int marshalInt(int value, int mode, p<IOutputStream> writer) throw(IOException) = 0 ;
+    virtual int marshalLong(long long value, int mode, p<IOutputStream> writer) throw(IOException) = 0 ;
+    virtual int marshalFloat(float value, int mode, p<IOutputStream> writer) throw(IOException) = 0 ;
+    virtual int marshalDouble(double value, int mode, p<IOutputStream> writer) throw(IOException) = 0 ;
+    virtual int marshalString(p<string> value, int mode, p<IOutputStream> writer) throw(IOException) = 0 ;
+    virtual int marshalObject(p<IDataStructure> object, int mode, p<IOutputStream> writer) throw(IOException) = 0 ;
+    virtual int marshalObjectArray(array<IDataStructure> object, int mode, p<IOutputStream> writer) throw(IOException) = 0 ;
+    virtual int marshalByteArray(array<char> value, int mode, p<IOutputStream> writer) throw(IOException) = 0 ;
+    virtual int marshalMap(p<PropertyMap> value, int mode, p<IOutputStream> writer) throw(IOException) = 0 ;
+
+    virtual bool unmarshalBoolean(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
+    virtual char unmarshalByte(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
+    virtual short unmarshalShort(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
+    virtual int unmarshalInt(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
+    virtual long long unmarshalLong(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
+    virtual float unmarshalFloat(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
+    virtual double unmarshalDouble(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
+    virtual p<string> unmarshalString(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
+    virtual p<IDataStructure> unmarshalObject(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
+    virtual array<IDataStructure> unmarshalObjectArray(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
+    virtual array<char> unmarshalByteArray(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
+    virtual p<PropertyMap> unmarshalMap(int mode, p<IInputStream> reader) throw(IOException) = 0 ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_IMarshaller_hpp_*/

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

Modified: incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/protocol/IProtocol.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/protocol/IProtocol.hpp?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/protocol/IProtocol.hpp (original)
+++ incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/protocol/IProtocol.hpp Fri Jul 28 01:22:48 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> writer) throw(IOException) = 0 ;
-	virtual p<IDataStructure> unmarshal(p<IInputStream> reader) 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> writer) throw(IOException) = 0 ;
+	virtual p<IDataStructure> unmarshal(p<IInputStream> reader) throw(IOException) = 0 ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_IProtocol_hpp_*/

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