activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r419370 [1/2] - in /incubator/activemq/trunk/activemq-cpp/src: main/cms/ test-integration/integration/common/ test-integration/integration/durable/ test-integration/integration/simple/ test-integration/integration/transactional/
Date Wed, 05 Jul 2006 22:33:52 GMT
Author: chirino
Date: Wed Jul  5 15:33:50 2006
New Revision: 419370

URL: http://svn.apache.org/viewvc?rev=419370&view=rev
Log:
set the eol style to native

Modified:
    incubator/activemq/trunk/activemq-cpp/src/main/cms/BytesMessage.h   (contents, props changed)
    incubator/activemq/trunk/activemq-cpp/src/main/cms/CMSException.h   (props changed)
    incubator/activemq/trunk/activemq-cpp/src/main/cms/Closeable.h   (props changed)
    incubator/activemq/trunk/activemq-cpp/src/main/cms/Connection.h   (contents, props changed)
    incubator/activemq/trunk/activemq-cpp/src/main/cms/ConnectionFactory.h   (contents, props changed)
    incubator/activemq/trunk/activemq-cpp/src/main/cms/Destination.h   (contents, props changed)
    incubator/activemq/trunk/activemq-cpp/src/main/cms/ExceptionListener.h   (contents, props changed)
    incubator/activemq/trunk/activemq-cpp/src/main/cms/Message.h   (contents, props changed)
    incubator/activemq/trunk/activemq-cpp/src/main/cms/MessageConsumer.h   (contents, props changed)
    incubator/activemq/trunk/activemq-cpp/src/main/cms/MessageListener.h   (contents, props changed)
    incubator/activemq/trunk/activemq-cpp/src/main/cms/MessageProducer.h   (contents, props changed)
    incubator/activemq/trunk/activemq-cpp/src/main/cms/Queue.h   (contents, props changed)
    incubator/activemq/trunk/activemq-cpp/src/main/cms/Session.h   (contents, props changed)
    incubator/activemq/trunk/activemq-cpp/src/main/cms/Startable.h   (props changed)
    incubator/activemq/trunk/activemq-cpp/src/main/cms/Stoppable.h   (props changed)
    incubator/activemq/trunk/activemq-cpp/src/main/cms/TemporaryTopic.h   (contents, props changed)
    incubator/activemq/trunk/activemq-cpp/src/main/cms/TextMessage.h   (contents, props changed)
    incubator/activemq/trunk/activemq-cpp/src/main/cms/Topic.h   (contents, props changed)
    incubator/activemq/trunk/activemq-cpp/src/test-integration/integration/common/AbstractTester.h   (contents, props changed)
    incubator/activemq/trunk/activemq-cpp/src/test-integration/integration/common/IntegrationCommon.h   (contents, props changed)
    incubator/activemq/trunk/activemq-cpp/src/test-integration/integration/common/Tester.h   (contents, props changed)
    incubator/activemq/trunk/activemq-cpp/src/test-integration/integration/durable/DurableTester.h   (contents, props changed)
    incubator/activemq/trunk/activemq-cpp/src/test-integration/integration/simple/SimpleTester.h   (contents, props changed)
    incubator/activemq/trunk/activemq-cpp/src/test-integration/integration/transactional/TransactionTester.h   (contents, props changed)

Modified: incubator/activemq/trunk/activemq-cpp/src/main/cms/BytesMessage.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-cpp/src/main/cms/BytesMessage.h?rev=419370&r1=419369&r2=419370&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-cpp/src/main/cms/BytesMessage.h (original)
+++ incubator/activemq/trunk/activemq-cpp/src/main/cms/BytesMessage.h Wed Jul  5 15:33:50 2006
@@ -1,62 +1,62 @@
-/*
- * 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 _CMS_BYTESMESSAGE_H_
-#define _CMS_BYTESMESSAGE_H_
- 
-#include <cms/Message.h>
-
-namespace cms{
-   
-    class BytesMessage : public Message{
-      
-    public:
-   
-        /**
-         * Destructor
-         */
-        virtual ~BytesMessage(){}
-
-        /**
-         * sets the bytes given to the message body.  
-         * @param Byte Buffer to copy
-         * @param Number of bytes in Buffer to copy
-         * @throws CMSException
-         */
-        virtual void setBodyBytes( 
-            const unsigned char* buffer, const unsigned long numBytes ) 
-                throw( CMSException ) = 0;
-            
-        /**
-         * Gets the bytes that are contained in this message, user should
-         * copy this data into a user allocated buffer.  Call 
-         * <code>getBodyLength</code> to determine the number of bytes
-         * to expect.
-         * @return const pointer to a byte buffer
-         */
-        virtual const unsigned char* getBodyBytes(void) const = 0;
-      
-        /**
-         * Returns the number of bytes contained in the body of this message.
-         * @return number of bytes.
-         */
-        virtual unsigned long getBodyLength(void) const = 0;
-      
-   };
-}
-
-#endif /*_CMS_BYTESMESSAGE_H_*/
+/*
+ * 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 _CMS_BYTESMESSAGE_H_
+#define _CMS_BYTESMESSAGE_H_
+ 
+#include <cms/Message.h>
+
+namespace cms{
+   
+    class BytesMessage : public Message{
+      
+    public:
+   
+        /**
+         * Destructor
+         */
+        virtual ~BytesMessage(){}
+
+        /**
+         * sets the bytes given to the message body.  
+         * @param Byte Buffer to copy
+         * @param Number of bytes in Buffer to copy
+         * @throws CMSException
+         */
+        virtual void setBodyBytes( 
+            const unsigned char* buffer, const unsigned long numBytes ) 
+                throw( CMSException ) = 0;
+            
+        /**
+         * Gets the bytes that are contained in this message, user should
+         * copy this data into a user allocated buffer.  Call 
+         * <code>getBodyLength</code> to determine the number of bytes
+         * to expect.
+         * @return const pointer to a byte buffer
+         */
+        virtual const unsigned char* getBodyBytes(void) const = 0;
+      
+        /**
+         * Returns the number of bytes contained in the body of this message.
+         * @return number of bytes.
+         */
+        virtual unsigned long getBodyLength(void) const = 0;
+      
+   };
+}
+
+#endif /*_CMS_BYTESMESSAGE_H_*/

Propchange: incubator/activemq/trunk/activemq-cpp/src/main/cms/BytesMessage.h
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/activemq-cpp/src/main/cms/CMSException.h
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/activemq-cpp/src/main/cms/Closeable.h
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-cpp/src/main/cms/Connection.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-cpp/src/main/cms/Connection.h?rev=419370&r1=419369&r2=419370&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-cpp/src/main/cms/Connection.h (original)
+++ incubator/activemq/trunk/activemq-cpp/src/main/cms/Connection.h Wed Jul  5 15:33:50 2006
@@ -1,76 +1,76 @@
-/*
- * 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 _CMS_CONNECTION_H_
-#define _CMS_CONNECTION_H_
-
-#include <cms/Startable.h>
-#include <cms/Stoppable.h>
-#include <cms/Closeable.h>
-#include <cms/Session.h>
-
-namespace cms
-{
-    class ExceptionListener;
-   
-    class Connection :
-        public Startable,
-        public Stoppable,
-        public Closeable
-    {
-    public:
-
-        /**
-         * Destructor
-         */
-        virtual ~Connection(void) {}
-
-        /**
-         * Creates a new Session to work for this Connection
-         */
-        virtual Session* createSession(void) throw ( CMSException ) = 0;
-      
-        /**
-         * Creates a new Session to work for this Connection using the
-         * specified acknowledgment mode
-         * @param the Acknowledgement Mode to use.
-         */
-        virtual Session* createSession(Session::AcknowledgeMode ackMode) 
-            throw ( CMSException ) = 0;
-         
-        /**
-         * Get the Client Id for this session
-         */
-        virtual std::string getClientId(void) const = 0;      
-         
-        /**
-         * Gets the registered Exception Listener for this connection
-         * @return pointer to an exception listnener or NULL
-         */
-        virtual ExceptionListener* getExceptionListener(void) const = 0;
-      
-        /**
-         * Sets the registed Exception Listener for this connection
-         * @param pointer to and <code>ExceptionListener</code>
-         */
-        virtual void setExceptionListener(ExceptionListener* listener) = 0;
-      
-    };
-
-}
-
-#endif /*_CMS_CONNECTION_H_*/
+/*
+ * 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 _CMS_CONNECTION_H_
+#define _CMS_CONNECTION_H_
+
+#include <cms/Startable.h>
+#include <cms/Stoppable.h>
+#include <cms/Closeable.h>
+#include <cms/Session.h>
+
+namespace cms
+{
+    class ExceptionListener;
+   
+    class Connection :
+        public Startable,
+        public Stoppable,
+        public Closeable
+    {
+    public:
+
+        /**
+         * Destructor
+         */
+        virtual ~Connection(void) {}
+
+        /**
+         * Creates a new Session to work for this Connection
+         */
+        virtual Session* createSession(void) throw ( CMSException ) = 0;
+      
+        /**
+         * Creates a new Session to work for this Connection using the
+         * specified acknowledgment mode
+         * @param the Acknowledgement Mode to use.
+         */
+        virtual Session* createSession(Session::AcknowledgeMode ackMode) 
+            throw ( CMSException ) = 0;
+         
+        /**
+         * Get the Client Id for this session
+         */
+        virtual std::string getClientId(void) const = 0;      
+         
+        /**
+         * Gets the registered Exception Listener for this connection
+         * @return pointer to an exception listnener or NULL
+         */
+        virtual ExceptionListener* getExceptionListener(void) const = 0;
+      
+        /**
+         * Sets the registed Exception Listener for this connection
+         * @param pointer to and <code>ExceptionListener</code>
+         */
+        virtual void setExceptionListener(ExceptionListener* listener) = 0;
+      
+    };
+
+}
+
+#endif /*_CMS_CONNECTION_H_*/

Propchange: incubator/activemq/trunk/activemq-cpp/src/main/cms/Connection.h
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-cpp/src/main/cms/ConnectionFactory.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-cpp/src/main/cms/ConnectionFactory.h?rev=419370&r1=419369&r2=419370&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-cpp/src/main/cms/ConnectionFactory.h (original)
+++ incubator/activemq/trunk/activemq-cpp/src/main/cms/ConnectionFactory.h Wed Jul  5 15:33:50 2006
@@ -1,61 +1,61 @@
-/*
- * 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 _CMS_CONNECTIONFACTORY_H_
-#define _CMS_CONNECTIONFACTORY_H_
-
-#include <cms/Connection.h>
-#include <cms/CMSException.h>
-
-#include <string>
-
-namespace cms
-{
-
-   class ConnectionFactory
-   {
-   public:
-
-      /**
-       * Destructor
-       */
-   	virtual ~ConnectionFactory(void) {}
-
-      /**
-       * Creates a connection with the default user identity. The 
-       * connection is created in stopped mode. No messages will be 
-       * delivered until the Connection.start method is explicitly 
-       * called. 
-       * @throws CMSException
-       */
-      virtual Connection* createConnection(void) throw ( CMSException ) = 0;
-
-      /**
-       * Creates a connection with the specified user identity. The 
-       * connection is created in stopped mode. No messages will be 
-       * delivered until the Connection.start method is explicitly called.
-       * @throw CMSException.
-       */
-      virtual Connection* createConnection(const std::string& username,
-                                           const std::string& password,
-                                           const std::string& clientId) 
-                                              throw ( CMSException ) = 0;
-
-   };
-
-}
-
-#endif /*_CMS_CONNECTIONFACTORY_H_*/
+/*
+ * 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 _CMS_CONNECTIONFACTORY_H_
+#define _CMS_CONNECTIONFACTORY_H_
+
+#include <cms/Connection.h>
+#include <cms/CMSException.h>
+
+#include <string>
+
+namespace cms
+{
+
+   class ConnectionFactory
+   {
+   public:
+
+      /**
+       * Destructor
+       */
+   	virtual ~ConnectionFactory(void) {}
+
+      /**
+       * Creates a connection with the default user identity. The 
+       * connection is created in stopped mode. No messages will be 
+       * delivered until the Connection.start method is explicitly 
+       * called. 
+       * @throws CMSException
+       */
+      virtual Connection* createConnection(void) throw ( CMSException ) = 0;
+
+      /**
+       * Creates a connection with the specified user identity. The 
+       * connection is created in stopped mode. No messages will be 
+       * delivered until the Connection.start method is explicitly called.
+       * @throw CMSException.
+       */
+      virtual Connection* createConnection(const std::string& username,
+                                           const std::string& password,
+                                           const std::string& clientId) 
+                                              throw ( CMSException ) = 0;
+
+   };
+
+}
+
+#endif /*_CMS_CONNECTIONFACTORY_H_*/

Propchange: incubator/activemq/trunk/activemq-cpp/src/main/cms/ConnectionFactory.h
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-cpp/src/main/cms/Destination.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-cpp/src/main/cms/Destination.h?rev=419370&r1=419369&r2=419370&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-cpp/src/main/cms/Destination.h (original)
+++ incubator/activemq/trunk/activemq-cpp/src/main/cms/Destination.h Wed Jul  5 15:33:50 2006
@@ -1,82 +1,82 @@
-/*
- * 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 _CMS_DESTINATION_H_
-#define _CMS_DESTINATION_H_
-
-#include <string>
-
-namespace cms{
-	
-    /**
-     * A Destination object encapsulates a provider-specific address. 
-     */
-    class Destination{
-    public:
-   
-        enum DestinationType
-        {
-            TOPIC,
-            QUEUE,
-            TEMPORARY_TOPIC,
-            TEMPORARY_QUEUE
-        };
-		
-	public:
-
-        /**
-         * Destructor
-         */	
-        virtual ~Destination(void){}
-      
-        /**
-         * Retrieve the Destination Type for this Destination
-         * @return The Destination Type
-         */
-        virtual DestinationType getDestinationType(void) const = 0;
-        
-        /**
-         * Converts the Destination Name into a String 
-         * @return string name
-         */
-        virtual std::string toString(void) const = 0;
-
-        /**
-         * Converts the Destination to a String value representing the
-         * Provider specific name fot this destination, which is not
-         * necessarily equal to the User Supplied name of the Destination
-         * @return Provider specific Name
-         */
-        virtual std::string toProviderString(void) const = 0;
-        
-        /**
-         * Creates a new instance of this destination type that is a
-         * copy of this one, and returns it.
-         * @returns cloned copy of this object
-         */
-        virtual cms::Destination* clone(void) const = 0;
-      
+/*
+ * 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 _CMS_DESTINATION_H_
+#define _CMS_DESTINATION_H_
+
+#include <string>
+
+namespace cms{
+	
+    /**
+     * A Destination object encapsulates a provider-specific address. 
+     */
+    class Destination{
+    public:
+   
+        enum DestinationType
+        {
+            TOPIC,
+            QUEUE,
+            TEMPORARY_TOPIC,
+            TEMPORARY_QUEUE
+        };
+		
+	public:
+
+        /**
+         * Destructor
+         */	
+        virtual ~Destination(void){}
+      
+        /**
+         * Retrieve the Destination Type for this Destination
+         * @return The Destination Type
+         */
+        virtual DestinationType getDestinationType(void) const = 0;
+        
+        /**
+         * Converts the Destination Name into a String 
+         * @return string name
+         */
+        virtual std::string toString(void) const = 0;
+
+        /**
+         * Converts the Destination to a String value representing the
+         * Provider specific name fot this destination, which is not
+         * necessarily equal to the User Supplied name of the Destination
+         * @return Provider specific Name
+         */
+        virtual std::string toProviderString(void) const = 0;
+        
+        /**
+         * Creates a new instance of this destination type that is a
+         * copy of this one, and returns it.
+         * @returns cloned copy of this object
+         */
+        virtual cms::Destination* clone(void) const = 0;
+      
         /**
          * Copies the contents of the given Destinastion object to this one.
          * @param source The source Destination object.
          */
         virtual void copy( const cms::Destination& source ) = 0;
-
-    };
-}
-
-#endif /*_CMS_DESTINATION_H_*/
+
+    };
+}
+
+#endif /*_CMS_DESTINATION_H_*/

Propchange: incubator/activemq/trunk/activemq-cpp/src/main/cms/Destination.h
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-cpp/src/main/cms/ExceptionListener.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-cpp/src/main/cms/ExceptionListener.h?rev=419370&r1=419369&r2=419370&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-cpp/src/main/cms/ExceptionListener.h (original)
+++ incubator/activemq/trunk/activemq-cpp/src/main/cms/ExceptionListener.h Wed Jul  5 15:33:50 2006
@@ -1,44 +1,44 @@
-/*
- * 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 _CMS_EXCEPTIONLISTENER_H_
-#define _CMS_EXCEPTIONLISTENER_H_
-
-#include <cms/CMSException.h>
-
-namespace cms{
-
-   class ExceptionListener
-   {
-   public:
-   
-      /**
-       * Destructor
-       */
-      virtual ~ExceptionListener(void) {}
-   
-      /**
-       * Called when an exception occurs.
-       * @param Exception Object that occurred.
-       */
-      virtual void onException(const cms::CMSException& ex) = 0;
-      
-   };
-
-}
-
-#endif /*_CMS_EXCEPTIONLISTENER_H_*/
+/*
+ * 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 _CMS_EXCEPTIONLISTENER_H_
+#define _CMS_EXCEPTIONLISTENER_H_
+
+#include <cms/CMSException.h>
+
+namespace cms{
+
+   class ExceptionListener
+   {
+   public:
+   
+      /**
+       * Destructor
+       */
+      virtual ~ExceptionListener(void) {}
+   
+      /**
+       * Called when an exception occurs.
+       * @param Exception Object that occurred.
+       */
+      virtual void onException(const cms::CMSException& ex) = 0;
+      
+   };
+
+}
+
+#endif /*_CMS_EXCEPTIONLISTENER_H_*/

Propchange: incubator/activemq/trunk/activemq-cpp/src/main/cms/ExceptionListener.h
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-cpp/src/main/cms/Message.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-cpp/src/main/cms/Message.h?rev=419370&r1=419369&r2=419370&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-cpp/src/main/cms/Message.h (original)
+++ incubator/activemq/trunk/activemq-cpp/src/main/cms/Message.h Wed Jul  5 15:33:50 2006
@@ -1,190 +1,190 @@
-/*
- * 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 _CMS_MESSAGE_H_
-#define _CMS_MESSAGE_H_
-
-#include <activemq/util/Properties.h>
-
-#include <cms/Destination.h>
-#include <cms/CMSException.h>
-
-namespace cms{
-   
-    /**
-     * Root of all messages.
-     */
-    class Message{ 
-    public:
-
-        /**
-         * Enumeration value for Message Delivery Mode   
-         */
-        enum DeliveryMode
-        {
-            PERSISTANT,
-            NONPERSISTANT
-        };
-         
-    public:
-   
-        virtual ~Message(void){}
-      
-        /**
-         * Clonse this message exactly, returns a new instance that the
-         * caller is required to delete.
-         * @return new copy of this message
-         */
-        virtual Message* clone(void) const = 0;
-        
-        /**
-         * Acknowledges all consumed messages of the session 
-         * of this consumed message.
-         */
-        virtual void acknowledge(void) const throw( CMSException ) = 0;
-      
-        /**
-         * Retrieves a reference to the properties object owned
-         * by this message
-         * @return A Properties Object reference
-         */
-        virtual activemq::util::Properties& getProperties(void) = 0;
-        virtual const activemq::util::Properties& getProperties(void) const = 0;
-      
-        /**
-         * Get the Correlation Id for this message
-         * @return string representation of the correlation Id
-         */
-        virtual const char* getCMSCorrelationId(void) const = 0;
-
-        /**
-         * Sets the Correlation Id used by this message
-         * @param String representing the correlation id.
-         */
-        virtual void setCMSCorrelationId(const std::string& correlationId) = 0;
-
-        /**
-         * Sets the DeliveryMode for this message
-         * @return DeliveryMode enumerated value.
-         */
-        virtual DeliveryMode getCMSDeliveryMode(void) const = 0;
-
-        /**
-         * Sets the DeliveryMode for this message
-         * @param DeliveryMode enumerated value.
-         */
-        virtual void setCMSDeliveryMode(DeliveryMode mode) = 0;
-      
-        /**
-         * Gets the Destination for this Message, returns a
-         * @return Destination object
-         */
-        virtual const Destination& getCMSDestination(void) const = 0;
-      
-        /**
-         * Sets the Destination for this message
-         * @param Destination Object
-         */
-        virtual void setCMSDestination(const Destination& destination) = 0;
-      
-        /**
-         * Gets the Expiration Time for this Message
-         * @return time value
-         */
-        virtual long getCMSExpiration(void) const = 0;
-      
-        /**
-         * Sets the Expiration Time for this message
-         * @param time value
-         */
-        virtual void setCMSExpiration(long expireTime) = 0;
-      
-        /**
-         * Gets the CMS Message Id for this Message
-         * @return time value
-         */
-        virtual const char* getCMSMessageId(void) const = 0;
-      
-        /**
-         * Sets the CMS Message Id for this message
-         * @param time value
-         */
-        virtual void setCMSMessageId(const std::string& id) = 0;
-      
-        /**
-         * Gets the Priority Value for this Message
-         * @return priority value
-         */
-        virtual int getCMSPriority(void) const = 0;
-      
-        /**
-         * Sets the Priority Value for this message
-         * @param priority value
-         */
-        virtual void setCMSPriority(int priority) = 0;
-
-        /**
-         * Gets the Redelivered Flag for this Message
-         * @return redelivered value
-         */
-        virtual bool getCMSRedelivered(void) const = 0;
-      
-        /**
-         * Sets the Redelivered Flag for this message
-         * @param redelivered value
-         */
-        virtual void setCMSRedelivered(bool redelivered) = 0;
-
-        /**
-         * Gets the CMS Reply To Address for this Message
-         * @return Reply To Value
-         */
-        virtual const char* getCMSReplyTo(void) const = 0;
-      
-        /**
-         * Sets the CMS Reply To Address for this message
-         * @param Reply To value
-         */
-        virtual void setCMSReplyTo(const std::string& id) = 0;
-
-        /**
-         * Gets the Time Stamp for this Message
-         * @return time stamp value
-         */
-        virtual long getCMSTimeStamp(void) const = 0;
-      
-        /**
-         * Sets the Time Stamp for this message
-         * @param time stamp value
-         */
-        virtual void setCMSTimeStamp(long timeStamp) = 0;
-
-        /**
-         * Gets the CMS Message Type for this Message
-         * @return type value
-         */
-        virtual const char* getCMSMessageType(void) const = 0;
-      
-        /**
-         * Sets the CMS Message Type for this message
-         * @param type value
-         */
-        virtual void setCMSMessageType(const std::string& type) = 0;
-    };
-}
-
-#endif /*_CMS_MESSAGE_H_*/
+/*
+ * 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 _CMS_MESSAGE_H_
+#define _CMS_MESSAGE_H_
+
+#include <activemq/util/Properties.h>
+
+#include <cms/Destination.h>
+#include <cms/CMSException.h>
+
+namespace cms{
+   
+    /**
+     * Root of all messages.
+     */
+    class Message{ 
+    public:
+
+        /**
+         * Enumeration value for Message Delivery Mode   
+         */
+        enum DeliveryMode
+        {
+            PERSISTANT,
+            NONPERSISTANT
+        };
+         
+    public:
+   
+        virtual ~Message(void){}
+      
+        /**
+         * Clonse this message exactly, returns a new instance that the
+         * caller is required to delete.
+         * @return new copy of this message
+         */
+        virtual Message* clone(void) const = 0;
+        
+        /**
+         * Acknowledges all consumed messages of the session 
+         * of this consumed message.
+         */
+        virtual void acknowledge(void) const throw( CMSException ) = 0;
+      
+        /**
+         * Retrieves a reference to the properties object owned
+         * by this message
+         * @return A Properties Object reference
+         */
+        virtual activemq::util::Properties& getProperties(void) = 0;
+        virtual const activemq::util::Properties& getProperties(void) const = 0;
+      
+        /**
+         * Get the Correlation Id for this message
+         * @return string representation of the correlation Id
+         */
+        virtual const char* getCMSCorrelationId(void) const = 0;
+
+        /**
+         * Sets the Correlation Id used by this message
+         * @param String representing the correlation id.
+         */
+        virtual void setCMSCorrelationId(const std::string& correlationId) = 0;
+
+        /**
+         * Sets the DeliveryMode for this message
+         * @return DeliveryMode enumerated value.
+         */
+        virtual DeliveryMode getCMSDeliveryMode(void) const = 0;
+
+        /**
+         * Sets the DeliveryMode for this message
+         * @param DeliveryMode enumerated value.
+         */
+        virtual void setCMSDeliveryMode(DeliveryMode mode) = 0;
+      
+        /**
+         * Gets the Destination for this Message, returns a
+         * @return Destination object
+         */
+        virtual const Destination& getCMSDestination(void) const = 0;
+      
+        /**
+         * Sets the Destination for this message
+         * @param Destination Object
+         */
+        virtual void setCMSDestination(const Destination& destination) = 0;
+      
+        /**
+         * Gets the Expiration Time for this Message
+         * @return time value
+         */
+        virtual long getCMSExpiration(void) const = 0;
+      
+        /**
+         * Sets the Expiration Time for this message
+         * @param time value
+         */
+        virtual void setCMSExpiration(long expireTime) = 0;
+      
+        /**
+         * Gets the CMS Message Id for this Message
+         * @return time value
+         */
+        virtual const char* getCMSMessageId(void) const = 0;
+      
+        /**
+         * Sets the CMS Message Id for this message
+         * @param time value
+         */
+        virtual void setCMSMessageId(const std::string& id) = 0;
+      
+        /**
+         * Gets the Priority Value for this Message
+         * @return priority value
+         */
+        virtual int getCMSPriority(void) const = 0;
+      
+        /**
+         * Sets the Priority Value for this message
+         * @param priority value
+         */
+        virtual void setCMSPriority(int priority) = 0;
+
+        /**
+         * Gets the Redelivered Flag for this Message
+         * @return redelivered value
+         */
+        virtual bool getCMSRedelivered(void) const = 0;
+      
+        /**
+         * Sets the Redelivered Flag for this message
+         * @param redelivered value
+         */
+        virtual void setCMSRedelivered(bool redelivered) = 0;
+
+        /**
+         * Gets the CMS Reply To Address for this Message
+         * @return Reply To Value
+         */
+        virtual const char* getCMSReplyTo(void) const = 0;
+      
+        /**
+         * Sets the CMS Reply To Address for this message
+         * @param Reply To value
+         */
+        virtual void setCMSReplyTo(const std::string& id) = 0;
+
+        /**
+         * Gets the Time Stamp for this Message
+         * @return time stamp value
+         */
+        virtual long getCMSTimeStamp(void) const = 0;
+      
+        /**
+         * Sets the Time Stamp for this message
+         * @param time stamp value
+         */
+        virtual void setCMSTimeStamp(long timeStamp) = 0;
+
+        /**
+         * Gets the CMS Message Type for this Message
+         * @return type value
+         */
+        virtual const char* getCMSMessageType(void) const = 0;
+      
+        /**
+         * Sets the CMS Message Type for this message
+         * @param type value
+         */
+        virtual void setCMSMessageType(const std::string& type) = 0;
+    };
+}
+
+#endif /*_CMS_MESSAGE_H_*/

Propchange: incubator/activemq/trunk/activemq-cpp/src/main/cms/Message.h
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-cpp/src/main/cms/MessageConsumer.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-cpp/src/main/cms/MessageConsumer.h?rev=419370&r1=419369&r2=419370&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-cpp/src/main/cms/MessageConsumer.h (original)
+++ incubator/activemq/trunk/activemq-cpp/src/main/cms/MessageConsumer.h Wed Jul  5 15:33:50 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 _CMS_MESSAGECONSUMER_H_
-#define _CMS_MESSAGECONSUMER_H_
-
-#include <cms/MessageListener.h>
-#include <cms/Message.h>
-
-namespace cms
-{
-
-   class MessageConsumer
-   {
-   public:
-
-      /**
-       * Destructor
-       */
-      virtual ~MessageConsumer(void) {}
-      
-      /**
-       * Synchronously Receive a Message
-       * @return new message
-       * @throws CMSException
-       */
-      virtual Message* receive(void) throw ( CMSException ) = 0;
-
-      /**
-       * Synchronously Receive a Message, time out after defined interval.
-       * Returns null if nothing read.
-       * @return new message
-       * @throws CMSException
-       */
-      virtual Message* receive(int millisecs) throw ( CMSException ) = 0;
-
-      /**
-       * Receive a Message, does not wait if there isn't a new message
-       * to read, returns NULL if nothing read.
-       * @return new message
-       * @throws CMSException
-       */
-      virtual Message* receiveNoWait(void) throw ( CMSException ) = 0;
-
-      /**
-       * Sets the MessageListener that this class will send notifs on
-       * @param MessageListener interface pointer
-       */
-      virtual void setMessageListener(MessageListener* listener) = 0;
-      
-      /**
-       * Gets the MessageListener that this class will send notifs on
-       * @param MessageListener interface pointer
-       */
-      virtual MessageListener* getMessageListener(void) const = 0;
-      
-      /**
-       * Gets this message consumer's message selector expression.
-       * @return This Consumer's selector expression or "".
-       * @throws cms::CMSException
-       */
-      virtual std::string getMessageSelector(void) const 
-        throw ( cms::CMSException ) = 0;
-            
-   };
-
-}
-
-#endif /*_CMS_MESSAGECONSUMER_H_*/
+/*
+ * 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 _CMS_MESSAGECONSUMER_H_
+#define _CMS_MESSAGECONSUMER_H_
+
+#include <cms/MessageListener.h>
+#include <cms/Message.h>
+
+namespace cms
+{
+
+   class MessageConsumer
+   {
+   public:
+
+      /**
+       * Destructor
+       */
+      virtual ~MessageConsumer(void) {}
+      
+      /**
+       * Synchronously Receive a Message
+       * @return new message
+       * @throws CMSException
+       */
+      virtual Message* receive(void) throw ( CMSException ) = 0;
+
+      /**
+       * Synchronously Receive a Message, time out after defined interval.
+       * Returns null if nothing read.
+       * @return new message
+       * @throws CMSException
+       */
+      virtual Message* receive(int millisecs) throw ( CMSException ) = 0;
+
+      /**
+       * Receive a Message, does not wait if there isn't a new message
+       * to read, returns NULL if nothing read.
+       * @return new message
+       * @throws CMSException
+       */
+      virtual Message* receiveNoWait(void) throw ( CMSException ) = 0;
+
+      /**
+       * Sets the MessageListener that this class will send notifs on
+       * @param MessageListener interface pointer
+       */
+      virtual void setMessageListener(MessageListener* listener) = 0;
+      
+      /**
+       * Gets the MessageListener that this class will send notifs on
+       * @param MessageListener interface pointer
+       */
+      virtual MessageListener* getMessageListener(void) const = 0;
+      
+      /**
+       * Gets this message consumer's message selector expression.
+       * @return This Consumer's selector expression or "".
+       * @throws cms::CMSException
+       */
+      virtual std::string getMessageSelector(void) const 
+        throw ( cms::CMSException ) = 0;
+            
+   };
+
+}
+
+#endif /*_CMS_MESSAGECONSUMER_H_*/

Propchange: incubator/activemq/trunk/activemq-cpp/src/main/cms/MessageConsumer.h
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-cpp/src/main/cms/MessageListener.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-cpp/src/main/cms/MessageListener.h?rev=419370&r1=419369&r2=419370&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-cpp/src/main/cms/MessageListener.h (original)
+++ incubator/activemq/trunk/activemq-cpp/src/main/cms/MessageListener.h Wed Jul  5 15:33:50 2006
@@ -1,52 +1,52 @@
-/*
- * 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 _CMS_MESSAGELISTENER_H_
-#define _CMS_MESSAGELISTENER_H_
-
-//#include <cms/Message.h>
- 
-namespace cms{
-    
-    class Message;
-    
-    class MessageListener{
-    public:
-    
-        virtual ~MessageListener(void){}
-        
-        /**
-         * Called asynchronously when a new message is received, the message
-         * reference can be to any othe Message types. a dynamic cast is used
-         * to find out what type of message this is.  The lifetime of this
-         * object is only garunteed to be for life of the onMessage function
-         * after this returns the message may no longer exists.  User should
-         * copy the data or clone the message if they wish to keep something
-         * around about this message.
-         * 
-         * It is considered a programming error for this method to throw and
-         * exception.
-         * 
-         * @param Message object reference
-         */
-        virtual void onMessage( const Message& message ) = 0;
-
-    };
-    
-}
-
-#endif /*_CMS_MESSAGELISTENER_H_*/
+/*
+ * 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 _CMS_MESSAGELISTENER_H_
+#define _CMS_MESSAGELISTENER_H_
+
+//#include <cms/Message.h>
+ 
+namespace cms{
+    
+    class Message;
+    
+    class MessageListener{
+    public:
+    
+        virtual ~MessageListener(void){}
+        
+        /**
+         * Called asynchronously when a new message is received, the message
+         * reference can be to any othe Message types. a dynamic cast is used
+         * to find out what type of message this is.  The lifetime of this
+         * object is only garunteed to be for life of the onMessage function
+         * after this returns the message may no longer exists.  User should
+         * copy the data or clone the message if they wish to keep something
+         * around about this message.
+         * 
+         * It is considered a programming error for this method to throw and
+         * exception.
+         * 
+         * @param Message object reference
+         */
+        virtual void onMessage( const Message& message ) = 0;
+
+    };
+    
+}
+
+#endif /*_CMS_MESSAGELISTENER_H_*/

Propchange: incubator/activemq/trunk/activemq-cpp/src/main/cms/MessageListener.h
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-cpp/src/main/cms/MessageProducer.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-cpp/src/main/cms/MessageProducer.h?rev=419370&r1=419369&r2=419370&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-cpp/src/main/cms/MessageProducer.h (original)
+++ incubator/activemq/trunk/activemq-cpp/src/main/cms/MessageProducer.h Wed Jul  5 15:33:50 2006
@@ -1,120 +1,120 @@
-/*
- * 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 _CMS_MESSAGEPRODUCER_H_
-#define _CMS_MESSAGEPRODUCER_H_
-
-#include <cms/Message.h>
-#include <cms/Destination.h>
-#include <cms/CMSException.h>
-
-namespace cms
-{
-   /** 
-    * defines the <code>MEssageProducer</code> interface that is used
-    * by all MessageProducer derivations.  This class defines the JMS
-    * spec'd interface for a MessageProducer.
-    */
-   class MessageProducer
-   {
-   public:
-
-      /**
-       * Destructor
-       */
-      virtual ~MessageProducer(void) {}
-      
-      /**
-       * Sends the message to the default producer destination.
-       * @param a Message Object Pointer
-       * @throws CMSException
-       */
-      virtual void send(Message& message) throw ( CMSException ) = 0;
-      
-      /**
-       * Sends the message to the designated destination.
-       * @param a Message Object Pointer
-       * @throws CMSException
-       */
-      virtual void send(const Destination& destination,
-                        Message& message) throw ( CMSException ) = 0;
-
-      /** 
-       * Sets the delivery mode for this Producer
-       * @param The DeliveryMode
-       */
-      virtual void setDeliveryMode(Message::DeliveryMode mode) = 0;
-      
-      /** 
-       * Gets the delivery mode for this Producer
-       * @return The DeliveryMode
-       */
-      virtual Message::DeliveryMode getDeliveryMode(void) const = 0;
-      
-      /**
-       * Sets if Message Ids are disbled for this Producer
-       * @param boolean indicating enable / disable (true / false)
-       */
-      virtual void setDisableMessageId(bool value) = 0;
-      
-      /**
-       * Sets if Message Ids are disbled for this Producer
-       * @param boolean indicating enable / disable (true / false)
-       */
-      virtual bool getDisableMessageId(void) const = 0;
-
-      /**
-       * Sets if Message Time Stamps are disbled for this Producer
-       * @param boolean indicating enable / disable (true / false)
-       */
-      virtual void setDisableMessageTimeStamp(bool value) = 0;
-      
-      /**
-       * Sets if Message Time Stamps are disbled for this Producer
-       * @param boolean indicating enable / disable (true / false)
-       */
-      virtual bool getDisableMessageTimeStamp(void) const = 0;
-      
-      /**
-       * Sets the Priority that this Producers sends messages at
-       * @param int value for Priority level
-       */
-      virtual void setPriority(int priority) = 0;
-      
-      /**
-       * Gets the Priority level that this producer sends messages at
-       * @return int based priority level
-       */
-      virtual int getPriority(void) const = 0;
-      
-      /**
-       * Sets the Time to Live that this Producers sends messages with
-       * @param int value for time to live
-       */
-      virtual void setTimeToLive(int time) = 0;
-      
-      /**
-       * Gets the Time to Live that this producer sends messages with
-       * @return int based Time to Live
-       */
-      virtual int getTimeToLive(void) const = 0;
-      
-   };
-
-}
-
-#endif /*_CMS_MESSAGEPRODUCER_H_*/
+/*
+ * 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 _CMS_MESSAGEPRODUCER_H_
+#define _CMS_MESSAGEPRODUCER_H_
+
+#include <cms/Message.h>
+#include <cms/Destination.h>
+#include <cms/CMSException.h>
+
+namespace cms
+{
+   /** 
+    * defines the <code>MEssageProducer</code> interface that is used
+    * by all MessageProducer derivations.  This class defines the JMS
+    * spec'd interface for a MessageProducer.
+    */
+   class MessageProducer
+   {
+   public:
+
+      /**
+       * Destructor
+       */
+      virtual ~MessageProducer(void) {}
+      
+      /**
+       * Sends the message to the default producer destination.
+       * @param a Message Object Pointer
+       * @throws CMSException
+       */
+      virtual void send(Message& message) throw ( CMSException ) = 0;
+      
+      /**
+       * Sends the message to the designated destination.
+       * @param a Message Object Pointer
+       * @throws CMSException
+       */
+      virtual void send(const Destination& destination,
+                        Message& message) throw ( CMSException ) = 0;
+
+      /** 
+       * Sets the delivery mode for this Producer
+       * @param The DeliveryMode
+       */
+      virtual void setDeliveryMode(Message::DeliveryMode mode) = 0;
+      
+      /** 
+       * Gets the delivery mode for this Producer
+       * @return The DeliveryMode
+       */
+      virtual Message::DeliveryMode getDeliveryMode(void) const = 0;
+      
+      /**
+       * Sets if Message Ids are disbled for this Producer
+       * @param boolean indicating enable / disable (true / false)
+       */
+      virtual void setDisableMessageId(bool value) = 0;
+      
+      /**
+       * Sets if Message Ids are disbled for this Producer
+       * @param boolean indicating enable / disable (true / false)
+       */
+      virtual bool getDisableMessageId(void) const = 0;
+
+      /**
+       * Sets if Message Time Stamps are disbled for this Producer
+       * @param boolean indicating enable / disable (true / false)
+       */
+      virtual void setDisableMessageTimeStamp(bool value) = 0;
+      
+      /**
+       * Sets if Message Time Stamps are disbled for this Producer
+       * @param boolean indicating enable / disable (true / false)
+       */
+      virtual bool getDisableMessageTimeStamp(void) const = 0;
+      
+      /**
+       * Sets the Priority that this Producers sends messages at
+       * @param int value for Priority level
+       */
+      virtual void setPriority(int priority) = 0;
+      
+      /**
+       * Gets the Priority level that this producer sends messages at
+       * @return int based priority level
+       */
+      virtual int getPriority(void) const = 0;
+      
+      /**
+       * Sets the Time to Live that this Producers sends messages with
+       * @param int value for time to live
+       */
+      virtual void setTimeToLive(int time) = 0;
+      
+      /**
+       * Gets the Time to Live that this producer sends messages with
+       * @return int based Time to Live
+       */
+      virtual int getTimeToLive(void) const = 0;
+      
+   };
+
+}
+
+#endif /*_CMS_MESSAGEPRODUCER_H_*/

Propchange: incubator/activemq/trunk/activemq-cpp/src/main/cms/MessageProducer.h
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-cpp/src/main/cms/Queue.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-cpp/src/main/cms/Queue.h?rev=419370&r1=419369&r2=419370&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-cpp/src/main/cms/Queue.h (original)
+++ incubator/activemq/trunk/activemq-cpp/src/main/cms/Queue.h Wed Jul  5 15:33:50 2006
@@ -1,46 +1,46 @@
-/*
- * 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 _CMS_QUEUE_H_
-#define _CMS_QUEUE_H_
- 
-#include <cms/Destination.h>
-#include <cms/CMSException.h>
-
-namespace cms{
-	
-	/**
-	 * An interface encapsulating a provider-specific queue name.
-	 */
-	class Queue : public Destination{
-		
-	public:
-	
-		virtual ~Queue(void){}
-		
-		/**
-		 * Gets the name of this queue.
-		 * @return The queue name.
-		 */
-		virtual std::string getQueueName() const 
-            throw( CMSException ) = 0;
-
-	};
-
-}
-
-#endif /*_CMS_QUEUE_H_*/
+/*
+ * 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 _CMS_QUEUE_H_
+#define _CMS_QUEUE_H_
+ 
+#include <cms/Destination.h>
+#include <cms/CMSException.h>
+
+namespace cms{
+	
+	/**
+	 * An interface encapsulating a provider-specific queue name.
+	 */
+	class Queue : public Destination{
+		
+	public:
+	
+		virtual ~Queue(void){}
+		
+		/**
+		 * Gets the name of this queue.
+		 * @return The queue name.
+		 */
+		virtual std::string getQueueName() const 
+            throw( CMSException ) = 0;
+
+	};
+
+}
+
+#endif /*_CMS_QUEUE_H_*/

Propchange: incubator/activemq/trunk/activemq-cpp/src/main/cms/Queue.h
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-cpp/src/main/cms/Session.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-cpp/src/main/cms/Session.h?rev=419370&r1=419369&r2=419370&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-cpp/src/main/cms/Session.h (original)
+++ incubator/activemq/trunk/activemq-cpp/src/main/cms/Session.h Wed Jul  5 15:33:50 2006
@@ -1,232 +1,232 @@
-/*
-* 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 _CMS_SESSION_H_
-#define _CMS_SESSION_H_
-
-#include <cms/Closeable.h>
-#include <cms/Message.h>
-#include <cms/TextMessage.h>
-#include <cms/BytesMessage.h>
-#include <cms/MapMessage.h>
-#include <cms/MessageProducer.h>
-#include <cms/MessageConsumer.h>
-#include <cms/Topic.h>
-#include <cms/Queue.h>
-#include <cms/TemporaryTopic.h>
-#include <cms/TemporaryQueue.h>
-#include <cms/CMSException.h>
-
-namespace cms
-{
-
-    class Session : public Closeable
-    {
-    public:
-
-        enum AcknowledgeMode
-        {
-            /**
-            * With this acknowledgment mode, the session automatically
-            * acknowledges a client's receipt of a message either when
-            * the session has successfully returned from a call to receive
-            * or when the message listener the session has called to
-            * process the message successfully returns.
-            */
-            AutoAcknowledge,
-
-            /**
-            * With this acknowledgment mode, the session automatically
-            * acknowledges a client's receipt of a message either when
-            * the session has successfully returned from a call to receive
-            * or when the message listener the session has called to
-            * process the message successfully returns.  Acknowlegements
-            * may be delayed in this mode to increase performance at
-            * the cost of the message being redelivered this client fails.
-            */
-            DupsOkAcknowledge,
-
-            /**
-            * With this acknowledgment mode, the client acknowledges a
-            * consumed message by calling the message's acknowledge method.
-            */
-            ClientAcknowledge,
-
-            /**
-            * Messages will be consumed when the transaction commits.
-            */
-            Transactional         
-        };
-
-    public:
-
-        /**
-        * Destructor
-        */
-        virtual ~Session(void) {}
-
-        /**
-        * Commits all messages done in this transaction and releases any 
-        * locks currently held.
-        * @throws CMSException
-        */
-        virtual void commit(void) throw ( CMSException ) = 0;
-
-        /**
-        * Rollsback all messages done in this transaction and releases any 
-        * locks currently held.
-        * @throws CMSException
-        */
-        virtual void rollback(void) throw ( CMSException ) = 0;
-
-        /**
-        * Creates a MessageConsumer for the specified destination.
-        * @param the Destination that this consumer receiving messages for.
-        * @throws CMSException
-        */
-        virtual MessageConsumer* createConsumer(
-            Destination& destination )
-                throw ( CMSException ) = 0;
-
-        /**
-        * Creates a MessageConsumer for the specified destination, using a 
-        * message selector.
-        * @param the Destination that this consumer receiving messages for.
-        * @throws CMSException
-        */
-        virtual MessageConsumer* createConsumer( 
-            Destination& destination,
-            const std::string& selector )
-                throw ( CMSException ) = 0;
-
-        /**
-        * Creates a durable subscriber to the specified topic, using a 
-        * message selector
-        * @param the topic to subscribe to
-        * @param name used to identify the subscription
-        * @param only messages matching the selector are received
-        * @throws CMSException
-        */
-        virtual MessageConsumer* createDurableConsumer(
-            Topic& destination,
-            const std::string& name,
-            const std::string& selector,
-            bool noLocal = false )
-                throw ( CMSException ) = 0;
-
-        /**
-        * Creates a MessageProducer to send messages to the specified 
-        * destination.
-        * @param the Destination to publish on
-        * @throws CMSException
-        */
-        virtual MessageProducer* createProducer( Destination& destination )
-            throw ( CMSException ) = 0;
-
-        /**
-        * Creates a queue identity given a Queue name.
-        * @param the name of the new Queue
-        * @throws CMSException
-        */
-        virtual Queue* createQueue( const std::string& queueName )
-            throw ( CMSException ) = 0;
-
-        /**
-        * Creates a topic identity given a Queue name.
-        * @param the name of the new Topic
-        * @throws CMSException
-        */
-        virtual Topic* createTopic( const std::string& topicName )
-            throw ( CMSException ) = 0;
-
-        /**
-        * Creates a TemporaryQueue object.
-        * @throws CMSException
-        */
-        virtual TemporaryQueue* createTemporaryQueue(void)
-            throw ( CMSException ) = 0;
-
-        /**
-        * Creates a TemporaryTopic object.
-        * @throws CMSException
-        */
-        virtual TemporaryTopic* createTemporaryTopic(void)
-            throw ( CMSException ) = 0;
-
-        /**
-        * Creates a new Message
-        * @throws CMSException
-        */
-        virtual Message* createMessage(void) 
-            throw ( CMSException ) = 0;
-
-        /**
-        * Creates a BytesMessage
-        * @throws CMSException
-        */
-        virtual BytesMessage* createBytesMessage(void) 
-            throw ( CMSException) = 0;
-
-        /**
-        * Creates a BytesMessage and sets the paylod to the passed value
-        * @param an array of bytes to set in the message
-        * @param the size of the bytes array, or number of bytes to use
-        * @throws CMSException
-        */
-        virtual BytesMessage* createBytesMessage(
-            const unsigned char* bytes,
-            unsigned long bytesSize ) 
-                throw ( CMSException) = 0;
-
-        /**
-        * Creates a new TextMessage
-        * @throws CMSException
-        */
-        virtual TextMessage* createTextMessage(void) 
-            throw ( CMSException ) = 0;
-
-        /**
-        * Creates a new TextMessage and set the text to the value given
-        * @param the initial text for the message
-        * @throws CMSException
-        */
-        virtual TextMessage* createTextMessage( const std::string& text ) 
-            throw ( CMSException ) = 0;
-
-        /**
-        * Creates a new MapMessage
-        * @throws CMSException
-        */
-        virtual MapMessage* createMapMessage(void) 
-            throw ( CMSException ) = 0;
-
-        /**
-        * Returns the acknowledgement mode of the session.
-        * @return the Sessions Acknowledge Mode
-        */
-        virtual AcknowledgeMode getAcknowledgeMode(void) const = 0;
-
-        /**
-        * Gets if the Sessions is a Transacted Session
-        * @return transacted true - false.
-        */
-        virtual bool isTransacted(void) const = 0;
-
-    };
-
-}
-
-#endif /*_CMS_SESSION_H_*/
+/*
+* 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 _CMS_SESSION_H_
+#define _CMS_SESSION_H_
+
+#include <cms/Closeable.h>
+#include <cms/Message.h>
+#include <cms/TextMessage.h>
+#include <cms/BytesMessage.h>
+#include <cms/MapMessage.h>
+#include <cms/MessageProducer.h>
+#include <cms/MessageConsumer.h>
+#include <cms/Topic.h>
+#include <cms/Queue.h>
+#include <cms/TemporaryTopic.h>
+#include <cms/TemporaryQueue.h>
+#include <cms/CMSException.h>
+
+namespace cms
+{
+
+    class Session : public Closeable
+    {
+    public:
+
+        enum AcknowledgeMode
+        {
+            /**
+            * With this acknowledgment mode, the session automatically
+            * acknowledges a client's receipt of a message either when
+            * the session has successfully returned from a call to receive
+            * or when the message listener the session has called to
+            * process the message successfully returns.
+            */
+            AutoAcknowledge,
+
+            /**
+            * With this acknowledgment mode, the session automatically
+            * acknowledges a client's receipt of a message either when
+            * the session has successfully returned from a call to receive
+            * or when the message listener the session has called to
+            * process the message successfully returns.  Acknowlegements
+            * may be delayed in this mode to increase performance at
+            * the cost of the message being redelivered this client fails.
+            */
+            DupsOkAcknowledge,
+
+            /**
+            * With this acknowledgment mode, the client acknowledges a
+            * consumed message by calling the message's acknowledge method.
+            */
+            ClientAcknowledge,
+
+            /**
+            * Messages will be consumed when the transaction commits.
+            */
+            Transactional         
+        };
+
+    public:
+
+        /**
+        * Destructor
+        */
+        virtual ~Session(void) {}
+
+        /**
+        * Commits all messages done in this transaction and releases any 
+        * locks currently held.
+        * @throws CMSException
+        */
+        virtual void commit(void) throw ( CMSException ) = 0;
+
+        /**
+        * Rollsback all messages done in this transaction and releases any 
+        * locks currently held.
+        * @throws CMSException
+        */
+        virtual void rollback(void) throw ( CMSException ) = 0;
+
+        /**
+        * Creates a MessageConsumer for the specified destination.
+        * @param the Destination that this consumer receiving messages for.
+        * @throws CMSException
+        */
+        virtual MessageConsumer* createConsumer(
+            Destination& destination )
+                throw ( CMSException ) = 0;
+
+        /**
+        * Creates a MessageConsumer for the specified destination, using a 
+        * message selector.
+        * @param the Destination that this consumer receiving messages for.
+        * @throws CMSException
+        */
+        virtual MessageConsumer* createConsumer( 
+            Destination& destination,
+            const std::string& selector )
+                throw ( CMSException ) = 0;
+
+        /**
+        * Creates a durable subscriber to the specified topic, using a 
+        * message selector
+        * @param the topic to subscribe to
+        * @param name used to identify the subscription
+        * @param only messages matching the selector are received
+        * @throws CMSException
+        */
+        virtual MessageConsumer* createDurableConsumer(
+            Topic& destination,
+            const std::string& name,
+            const std::string& selector,
+            bool noLocal = false )
+                throw ( CMSException ) = 0;
+
+        /**
+        * Creates a MessageProducer to send messages to the specified 
+        * destination.
+        * @param the Destination to publish on
+        * @throws CMSException
+        */
+        virtual MessageProducer* createProducer( Destination& destination )
+            throw ( CMSException ) = 0;
+
+        /**
+        * Creates a queue identity given a Queue name.
+        * @param the name of the new Queue
+        * @throws CMSException
+        */
+        virtual Queue* createQueue( const std::string& queueName )
+            throw ( CMSException ) = 0;
+
+        /**
+        * Creates a topic identity given a Queue name.
+        * @param the name of the new Topic
+        * @throws CMSException
+        */
+        virtual Topic* createTopic( const std::string& topicName )
+            throw ( CMSException ) = 0;
+
+        /**
+        * Creates a TemporaryQueue object.
+        * @throws CMSException
+        */
+        virtual TemporaryQueue* createTemporaryQueue(void)
+            throw ( CMSException ) = 0;
+
+        /**
+        * Creates a TemporaryTopic object.
+        * @throws CMSException
+        */
+        virtual TemporaryTopic* createTemporaryTopic(void)
+            throw ( CMSException ) = 0;
+
+        /**
+        * Creates a new Message
+        * @throws CMSException
+        */
+        virtual Message* createMessage(void) 
+            throw ( CMSException ) = 0;
+
+        /**
+        * Creates a BytesMessage
+        * @throws CMSException
+        */
+        virtual BytesMessage* createBytesMessage(void) 
+            throw ( CMSException) = 0;
+
+        /**
+        * Creates a BytesMessage and sets the paylod to the passed value
+        * @param an array of bytes to set in the message
+        * @param the size of the bytes array, or number of bytes to use
+        * @throws CMSException
+        */
+        virtual BytesMessage* createBytesMessage(
+            const unsigned char* bytes,
+            unsigned long bytesSize ) 
+                throw ( CMSException) = 0;
+
+        /**
+        * Creates a new TextMessage
+        * @throws CMSException
+        */
+        virtual TextMessage* createTextMessage(void) 
+            throw ( CMSException ) = 0;
+
+        /**
+        * Creates a new TextMessage and set the text to the value given
+        * @param the initial text for the message
+        * @throws CMSException
+        */
+        virtual TextMessage* createTextMessage( const std::string& text ) 
+            throw ( CMSException ) = 0;
+
+        /**
+        * Creates a new MapMessage
+        * @throws CMSException
+        */
+        virtual MapMessage* createMapMessage(void) 
+            throw ( CMSException ) = 0;
+
+        /**
+        * Returns the acknowledgement mode of the session.
+        * @return the Sessions Acknowledge Mode
+        */
+        virtual AcknowledgeMode getAcknowledgeMode(void) const = 0;
+
+        /**
+        * Gets if the Sessions is a Transacted Session
+        * @return transacted true - false.
+        */
+        virtual bool isTransacted(void) const = 0;
+
+    };
+
+}
+
+#endif /*_CMS_SESSION_H_*/

Propchange: incubator/activemq/trunk/activemq-cpp/src/main/cms/Session.h
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/activemq-cpp/src/main/cms/Startable.h
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/activemq-cpp/src/main/cms/Stoppable.h
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-cpp/src/main/cms/TemporaryTopic.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-cpp/src/main/cms/TemporaryTopic.h?rev=419370&r1=419369&r2=419370&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-cpp/src/main/cms/TemporaryTopic.h (original)
+++ incubator/activemq/trunk/activemq-cpp/src/main/cms/TemporaryTopic.h Wed Jul  5 15:33:50 2006
@@ -1,46 +1,46 @@
-/*
- * 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 _CMS_TEMPORARYTOPIC_H_
-#define _CMS_TEMPORARYTOPIC_H_
-
-#include <cms/Destination.h>
-#include <cms/CMSException.h>
-
-namespace cms{
-
-    /**
-     * An interface encapsulating a provider-specific topic name.
-     */
-    class TemporaryTopic : public Destination
-    {
-    public:
-
-        virtual ~TemporaryTopic(void) {}
-
-        /**
-         * Gets the name of this topic.
-         * @return The topic name.
-         */
-        virtual const char* getTopicName(void) 
-            const throw( CMSException ) = 0;
-            
-   };
-
-}
-
-#endif /*_CMS_TEMPORARYTOPIC_H_*/
+/*
+ * 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 _CMS_TEMPORARYTOPIC_H_
+#define _CMS_TEMPORARYTOPIC_H_
+
+#include <cms/Destination.h>
+#include <cms/CMSException.h>
+
+namespace cms{
+
+    /**
+     * An interface encapsulating a provider-specific topic name.
+     */
+    class TemporaryTopic : public Destination
+    {
+    public:
+
+        virtual ~TemporaryTopic(void) {}
+
+        /**
+         * Gets the name of this topic.
+         * @return The topic name.
+         */
+        virtual const char* getTopicName(void) 
+            const throw( CMSException ) = 0;
+            
+   };
+
+}
+
+#endif /*_CMS_TEMPORARYTOPIC_H_*/

Propchange: incubator/activemq/trunk/activemq-cpp/src/main/cms/TemporaryTopic.h
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-cpp/src/main/cms/TextMessage.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-cpp/src/main/cms/TextMessage.h?rev=419370&r1=419369&r2=419370&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-cpp/src/main/cms/TextMessage.h (original)
+++ incubator/activemq/trunk/activemq-cpp/src/main/cms/TextMessage.h Wed Jul  5 15:33:50 2006
@@ -1,49 +1,49 @@
-/*
- * 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 _CMS_TEXTMESSAGE_H_
-#define _CMS_TEXTMESSAGE_H_
- 
-#include <cms/Message.h>
-#include <cms/CMSException.h>
-
-namespace cms{
-	
-	/**
-	 * Interface for a text message.
-	 */
-	class TextMessage : public Message{
-		
-	public:
-	
-		virtual ~TextMessage(){}
-		
-		/**
-		 * Gets the message character buffer.
-		 * @return The message character buffer.
-		 */
-		virtual const char* getText() const throw( CMSException ) = 0;
-		
-		/**
-		 * Sets the message contents.
-		 * @param msg The message buffer.
-		 */
-		virtual void setText( const char* msg ) throw( CMSException ) = 0;
-	};
-}
-
-#endif /*_CMS_TEXTMESSAGE_H_*/
+/*
+ * 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 _CMS_TEXTMESSAGE_H_
+#define _CMS_TEXTMESSAGE_H_
+ 
+#include <cms/Message.h>
+#include <cms/CMSException.h>
+
+namespace cms{
+	
+	/**
+	 * Interface for a text message.
+	 */
+	class TextMessage : public Message{
+		
+	public:
+	
+		virtual ~TextMessage(){}
+		
+		/**
+		 * Gets the message character buffer.
+		 * @return The message character buffer.
+		 */
+		virtual const char* getText() const throw( CMSException ) = 0;
+		
+		/**
+		 * Sets the message contents.
+		 * @param msg The message buffer.
+		 */
+		virtual void setText( const char* msg ) throw( CMSException ) = 0;
+	};
+}
+
+#endif /*_CMS_TEXTMESSAGE_H_*/

Propchange: incubator/activemq/trunk/activemq-cpp/src/main/cms/TextMessage.h
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-cpp/src/main/cms/Topic.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-cpp/src/main/cms/Topic.h?rev=419370&r1=419369&r2=419370&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-cpp/src/main/cms/Topic.h (original)
+++ incubator/activemq/trunk/activemq-cpp/src/main/cms/Topic.h Wed Jul  5 15:33:50 2006
@@ -1,46 +1,46 @@
-/*
- * 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 _CMS_TOPIC_
-#define _CMS_TOPIC_
- 
-#include <cms/Destination.h>
-#include <cms/CMSException.h>
-
-namespace cms{
-    
-    /**
-     * An interface encapsulating a provider-specific topic name.
-     */
-    class Topic : public Destination{
-        
-    public:
-    
-        virtual ~Topic(void) {}
-        
-        /**
-         * Gets the name of this topic.
-         * @return The topic name.
-         */
-        virtual std::string getTopicName(void) 
-            const throw( CMSException ) = 0;
-            
-    };
-
-}
-
-#endif /*_CMS_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.
+ */
+
+#ifndef _CMS_TOPIC_
+#define _CMS_TOPIC_
+ 
+#include <cms/Destination.h>
+#include <cms/CMSException.h>
+
+namespace cms{
+    
+    /**
+     * An interface encapsulating a provider-specific topic name.
+     */
+    class Topic : public Destination{
+        
+    public:
+    
+        virtual ~Topic(void) {}
+        
+        /**
+         * Gets the name of this topic.
+         * @return The topic name.
+         */
+        virtual std::string getTopicName(void) 
+            const throw( CMSException ) = 0;
+            
+    };
+
+}
+
+#endif /*_CMS_TOPIC_*/

Propchange: incubator/activemq/trunk/activemq-cpp/src/main/cms/Topic.h
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-cpp/src/test-integration/integration/common/AbstractTester.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-cpp/src/test-integration/integration/common/AbstractTester.h?rev=419370&r1=419369&r2=419370&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-cpp/src/test-integration/integration/common/AbstractTester.h (original)
+++ incubator/activemq/trunk/activemq-cpp/src/test-integration/integration/common/AbstractTester.h Wed Jul  5 15:33:50 2006
@@ -1,51 +1,51 @@
-#ifndef _INTEGRATION_COMMON_ABSTRACTTESTER_H_
-#define _INTEGRATION_COMMON_ABSTRACTTESTER_H_
-
-#include "Tester.h"
-
-#include <activemq/concurrent/Mutex.h>
-
-#include <cms/ConnectionFactory.h>
-#include <cms/Connection.h>
-#include <cms/Session.h>
-#include <cms/MessageProducer.h>
-
-namespace integration{
-namespace common{
-
-    class AbstractTester : public Tester
-    {
-    public:
-    
-    	AbstractTester( cms::Session::AcknowledgeMode ackMode = 
-                            cms::Session::AutoAcknowledge );
-    	virtual ~AbstractTester();
-    
-        virtual void doSleep(void);
-
-        virtual unsigned int produceTextMessages( 
-            cms::MessageProducer& producer,
-            unsigned int count );
-        virtual unsigned int produceBytesMessages( 
-            cms::MessageProducer& producer,
-            unsigned int count );
-
-        virtual void waitForMessages( unsigned int count );
-
-        virtual void onException( const cms::CMSException& error );
-        virtual void onMessage( const cms::Message& message );
-
-    public:
-        
-        cms::ConnectionFactory* connectionFactory;
-        cms::Connection* connection;
-        cms::Session* session;
-
-        unsigned int numReceived;
-        activemq::concurrent::Mutex mutex;
-
-    };
-
-}}
-
-#endif /*_INTEGRATION_COMMON_ABSTRACTTESTER_H_*/
+#ifndef _INTEGRATION_COMMON_ABSTRACTTESTER_H_
+#define _INTEGRATION_COMMON_ABSTRACTTESTER_H_
+
+#include "Tester.h"
+
+#include <activemq/concurrent/Mutex.h>
+
+#include <cms/ConnectionFactory.h>
+#include <cms/Connection.h>
+#include <cms/Session.h>
+#include <cms/MessageProducer.h>
+
+namespace integration{
+namespace common{
+
+    class AbstractTester : public Tester
+    {
+    public:
+    
+    	AbstractTester( cms::Session::AcknowledgeMode ackMode = 
+                            cms::Session::AutoAcknowledge );
+    	virtual ~AbstractTester();
+    
+        virtual void doSleep(void);
+
+        virtual unsigned int produceTextMessages( 
+            cms::MessageProducer& producer,
+            unsigned int count );
+        virtual unsigned int produceBytesMessages( 
+            cms::MessageProducer& producer,
+            unsigned int count );
+
+        virtual void waitForMessages( unsigned int count );
+
+        virtual void onException( const cms::CMSException& error );
+        virtual void onMessage( const cms::Message& message );
+
+    public:
+        
+        cms::ConnectionFactory* connectionFactory;
+        cms::Connection* connection;
+        cms::Session* session;
+
+        unsigned int numReceived;
+        activemq::concurrent::Mutex mutex;
+
+    };
+
+}}
+
+#endif /*_INTEGRATION_COMMON_ABSTRACTTESTER_H_*/

Propchange: incubator/activemq/trunk/activemq-cpp/src/test-integration/integration/common/AbstractTester.h
------------------------------------------------------------------------------
    svn:eol-style = native



Mime
View raw message