activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r419371 [7/10] - in /incubator/activemq/trunk/openwire-cpp/src/main/cpp: activemq/ activemq/command/ activemq/protocol/ activemq/protocol/openwire/ activemq/transport/ activemq/transport/tcp/ cms/ ppr/ ppr/io/ ppr/io/encoding/ ppr/net/ ppr/...
Date Wed, 05 Jul 2006 22:36:42 GMT
Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/ICommandListener.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/ICommandListener.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/ICommandListener.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/ICommandListener.hpp Wed Jul  5 15:36:36 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_ICommandListener_hpp_
-#define ActiveMQ_ICommandListener_hpp_
-
-#include <exception>
-#include "activemq/command/BaseCommand.hpp"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace transport
-    {
-      using namespace ifr;
-      using namespace std;
-      using namespace apache::activemq::command;
-      using namespace apache::cms;
-      struct ITransport;
-
-/*
- * 
- */
-struct ICommandListener : Interface
-{
-    virtual void onCommand(p<ITransport> transport, p<BaseCommand> command) = 0 ;
-    virtual void onError(p<ITransport> transport, exception& error) = 0 ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_ICommandListener_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_ICommandListener_hpp_
+#define ActiveMQ_ICommandListener_hpp_
+
+#include <exception>
+#include "activemq/command/BaseCommand.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace transport
+    {
+      using namespace ifr;
+      using namespace std;
+      using namespace apache::activemq::command;
+      using namespace apache::cms;
+      struct ITransport;
+
+/*
+ * 
+ */
+struct ICommandListener : Interface
+{
+    virtual void onCommand(p<ITransport> transport, p<BaseCommand> command) = 0 ;
+    virtual void onError(p<ITransport> transport, exception& error) = 0 ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ICommandListener_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/ITransport.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/ITransport.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/ITransport.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/ITransport.hpp Wed Jul  5 15:36:36 2006
@@ -1,56 +1,56 @@
-/*
- * 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_ITransport_hpp_
-#define ActiveMQ_ITransport_hpp_
-
-#include "cms/IStartable.hpp"
-#include "activemq/command/BaseCommand.hpp"
-#include "activemq/command/Response.hpp"
-#include "activemq/transport/FutureResponse.hpp"
-#include "activemq/transport/ICommandListener.hpp"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace transport
-    {
-      using namespace ifr ;
-      using namespace apache::cms;
-      using namespace apache::activemq;
-      using namespace apache::activemq::command;
-
-/*
- * Represents the logical networking transport layer.
- */
-struct ITransport : IStartable
-{
-    virtual void setCommandListener(p<ICommandListener> listener) = 0 ;
-    virtual p<ICommandListener> getCommandListener() = 0 ;
-
-    virtual void oneway(p<BaseCommand> command) = 0 ;
-	virtual p<FutureResponse> asyncRequest(p<BaseCommand> command) = 0 ;
-	virtual p<Response> request(p<BaseCommand> command) = 0 ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_ITransport_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_ITransport_hpp_
+#define ActiveMQ_ITransport_hpp_
+
+#include "cms/IStartable.hpp"
+#include "activemq/command/BaseCommand.hpp"
+#include "activemq/command/Response.hpp"
+#include "activemq/transport/FutureResponse.hpp"
+#include "activemq/transport/ICommandListener.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace transport
+    {
+      using namespace ifr ;
+      using namespace apache::cms;
+      using namespace apache::activemq;
+      using namespace apache::activemq::command;
+
+/*
+ * Represents the logical networking transport layer.
+ */
+struct ITransport : IStartable
+{
+    virtual void setCommandListener(p<ICommandListener> listener) = 0 ;
+    virtual p<ICommandListener> getCommandListener() = 0 ;
+
+    virtual void oneway(p<BaseCommand> command) = 0 ;
+	virtual p<FutureResponse> asyncRequest(p<BaseCommand> command) = 0 ;
+	virtual p<Response> request(p<BaseCommand> command) = 0 ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ITransport_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/ITransportFactory.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/ITransportFactory.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/ITransportFactory.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/ITransportFactory.hpp Wed Jul  5 15:36:36 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 ActiveMQ_ITransportFactory_hpp_
-#define ActiveMQ_ITransportFactory_hpp_
-
-#include "activemq/transport/ITransport.hpp"
-#include "ppr/IllegalArgumentException.hpp"
-#include "ppr/net/SocketException.hpp"
-#include "ppr/net/Uri.hpp"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace transport
-    {
-      using namespace ifr ;
-      using namespace apache::ppr;
-      using namespace apache::ppr::net;
-
-/*
- * 
- */
-struct ITransportFactory : Interface
-{
-	virtual p<ITransport> createTransport(p<Uri> location) throw (SocketException, IllegalArgumentException) = 0 ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_ITransportFactory_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_ITransportFactory_hpp_
+#define ActiveMQ_ITransportFactory_hpp_
+
+#include "activemq/transport/ITransport.hpp"
+#include "ppr/IllegalArgumentException.hpp"
+#include "ppr/net/SocketException.hpp"
+#include "ppr/net/Uri.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace transport
+    {
+      using namespace ifr ;
+      using namespace apache::ppr;
+      using namespace apache::ppr::net;
+
+/*
+ * 
+ */
+struct ITransportFactory : Interface
+{
+	virtual p<ITransport> createTransport(p<Uri> location) throw (SocketException, IllegalArgumentException) = 0 ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_ITransportFactory_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/LoggingFilter.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/LoggingFilter.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/LoggingFilter.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/LoggingFilter.hpp Wed Jul  5 15:36:36 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.
- */
-#ifndef ActiveMQ_LoggingFilter_hpp_
-#define ActiveMQ_LoggingFilter_hpp_
-
-#include <iostream>
-#include <exception>
-#include "activemq/transport/TransportFilter.hpp"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace transport
-    {
-      using namespace ifr;
-      using namespace std;
-
-/*
- * 
- */
-class LoggingFilter : public TransportFilter
-{
-protected:
-    p<ITransport> next ;
-
-public:
-    LoggingFilter(p<ITransport> next) ;
-    virtual ~LoggingFilter() {}
-
-	virtual void oneway(p<BaseCommand> command) ;
-
-    virtual void onCommand(p<ITransport> transport, p<BaseCommand> command) ;
-    virtual void onError(p<ITransport> transport, exception& error) ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_LoggingFilter_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_LoggingFilter_hpp_
+#define ActiveMQ_LoggingFilter_hpp_
+
+#include <iostream>
+#include <exception>
+#include "activemq/transport/TransportFilter.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace transport
+    {
+      using namespace ifr;
+      using namespace std;
+
+/*
+ * 
+ */
+class LoggingFilter : public TransportFilter
+{
+protected:
+    p<ITransport> next ;
+
+public:
+    LoggingFilter(p<ITransport> next) ;
+    virtual ~LoggingFilter() {}
+
+	virtual void oneway(p<BaseCommand> command) ;
+
+    virtual void onCommand(p<ITransport> transport, p<BaseCommand> command) ;
+    virtual void onError(p<ITransport> transport, exception& error) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_LoggingFilter_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/MutexFilter.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/MutexFilter.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/MutexFilter.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/MutexFilter.hpp Wed Jul  5 15:36:36 2006
@@ -1,56 +1,56 @@
-/*
- * 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_MutexFilter_hpp_
-#define ActiveMQ_MutexFilter_hpp_
-
-#include "activemq/transport/TransportFilter.hpp"
-#include "ppr/thread/SimpleMutex.hpp"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace transport
-    {
-      using namespace ifr;
-      using namespace apache::ppr::thread;
-
-/*
- * A filter transport which gaurds access to the next transport
- * using a mutex.
- */
-class MutexFilter : public TransportFilter
-{
-protected:
-    SimpleMutex mutex ;
-
-public:
-    MutexFilter(p<ITransport> next) ;
-    virtual ~MutexFilter() ;
-
-	virtual void oneway(p<BaseCommand> command) ;
-	virtual p<FutureResponse> asyncRequest(p<BaseCommand> command) ;
-	virtual p<Response> request(p<BaseCommand> command) ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_MutexFilter_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_MutexFilter_hpp_
+#define ActiveMQ_MutexFilter_hpp_
+
+#include "activemq/transport/TransportFilter.hpp"
+#include "ppr/thread/SimpleMutex.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace transport
+    {
+      using namespace ifr;
+      using namespace apache::ppr::thread;
+
+/*
+ * A filter transport which gaurds access to the next transport
+ * using a mutex.
+ */
+class MutexFilter : public TransportFilter
+{
+protected:
+    SimpleMutex mutex ;
+
+public:
+    MutexFilter(p<ITransport> next) ;
+    virtual ~MutexFilter() ;
+
+	virtual void oneway(p<BaseCommand> command) ;
+	virtual p<FutureResponse> asyncRequest(p<BaseCommand> command) ;
+	virtual p<Response> request(p<BaseCommand> command) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_MutexFilter_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/TransportFactory.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/TransportFactory.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/TransportFactory.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/TransportFactory.hpp Wed Jul  5 15:36:36 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 ActiveMQ_TransportFactory_hpp_
-#define ActiveMQ_TransportFactory_hpp_
-
-// Turn off warning message for ignored exception specification
-#ifdef _MSC_VER
-#pragma warning( disable : 4290 )
-#endif
-
-#include <string>
-#include "activemq/protocol/IProtocol.hpp"
-#include "activemq/protocol/openwire/OpenWireProtocol.hpp"
-#include "activemq/transport/ITransport.hpp"
-#include "activemq/transport/ITransportFactory.hpp"
-#include "activemq/transport/LoggingFilter.hpp"
-#include "activemq/transport/MutexFilter.hpp"
-#include "activemq/transport/CorrelatorFilter.hpp"
-#include "activemq/transport/tcp/TcpTransport.hpp"
-#include "ppr/IllegalArgumentException.hpp"
-#include "ppr/io/encoding/CharsetEncoderRegistry.hpp"
-#include "ppr/io/encoding/AsciiToUTF8Encoder.hpp"
-#include "ppr/net/ISocket.hpp"
-#include "ppr/net/Socket.hpp"
-#include "ppr/net/SocketException.hpp"
-#include "ppr/net/ISocketFactory.hpp"
-#include "ppr/net/SocketFactory.hpp"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace transport
-    {
-      using namespace ifr ;
-      using namespace std;
-      using namespace apache::activemq::protocol;
-      using namespace apache::activemq::protocol::openwire;
-      using namespace apache::activemq::transport::tcp;
-      using namespace apache::ppr::io::encoding;
-      using namespace apache::ppr::net;
-
-/*
- * An implementation of ITransport that uses sockets to communicate with
- * the broker.
- */
-class TransportFactory : public ITransportFactory
-{
-private:
-    p<ISocketFactory> socketFactory ;
-
-public:
-    TransportFactory() ;
-    virtual ~TransportFactory() {}
-
-	virtual p<ITransport> createTransport(p<Uri> location) throw (SocketException, IllegalArgumentException) ;
-
-protected:
-    virtual p<ISocket> connect(const char* host, int port) throw (SocketException) ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_TransportFactory_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_TransportFactory_hpp_
+#define ActiveMQ_TransportFactory_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "activemq/protocol/IProtocol.hpp"
+#include "activemq/protocol/openwire/OpenWireProtocol.hpp"
+#include "activemq/transport/ITransport.hpp"
+#include "activemq/transport/ITransportFactory.hpp"
+#include "activemq/transport/LoggingFilter.hpp"
+#include "activemq/transport/MutexFilter.hpp"
+#include "activemq/transport/CorrelatorFilter.hpp"
+#include "activemq/transport/tcp/TcpTransport.hpp"
+#include "ppr/IllegalArgumentException.hpp"
+#include "ppr/io/encoding/CharsetEncoderRegistry.hpp"
+#include "ppr/io/encoding/AsciiToUTF8Encoder.hpp"
+#include "ppr/net/ISocket.hpp"
+#include "ppr/net/Socket.hpp"
+#include "ppr/net/SocketException.hpp"
+#include "ppr/net/ISocketFactory.hpp"
+#include "ppr/net/SocketFactory.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace transport
+    {
+      using namespace ifr ;
+      using namespace std;
+      using namespace apache::activemq::protocol;
+      using namespace apache::activemq::protocol::openwire;
+      using namespace apache::activemq::transport::tcp;
+      using namespace apache::ppr::io::encoding;
+      using namespace apache::ppr::net;
+
+/*
+ * An implementation of ITransport that uses sockets to communicate with
+ * the broker.
+ */
+class TransportFactory : public ITransportFactory
+{
+private:
+    p<ISocketFactory> socketFactory ;
+
+public:
+    TransportFactory() ;
+    virtual ~TransportFactory() {}
+
+	virtual p<ITransport> createTransport(p<Uri> location) throw (SocketException, IllegalArgumentException) ;
+
+protected:
+    virtual p<ISocket> connect(const char* host, int port) throw (SocketException) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_TransportFactory_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/TransportFilter.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/TransportFilter.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/TransportFilter.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/TransportFilter.hpp Wed Jul  5 15:36:36 2006
@@ -1,67 +1,67 @@
-/*
- * 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_TransportFilter_hpp_
-#define ActiveMQ_TransportFilter_hpp_
-
-#include <string>
-#include "activemq/command/BaseCommand.hpp"
-#include "activemq/command/Response.hpp"
-#include "activemq/transport/ITransport.hpp"
-#include "ppr/InvalidOperationException.hpp"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace transport
-    {
-      using namespace ifr;
-      using namespace apache::activemq::command;
-      using namespace apache::ppr;
-
-/*
- * 
- */
-class TransportFilter : public ITransport, public ICommandListener
-{
-protected:
-    p<ITransport>       next ;
-    p<ICommandListener> listener ;
-
-public:
-    TransportFilter(p<ITransport> next) ;
-    virtual ~TransportFilter() {}
-
-    virtual void setCommandListener(p<ICommandListener> listener) ;
-    virtual p<ICommandListener> getCommandListener() ;
-
-	virtual void start() ;
-	virtual void oneway(p<BaseCommand> command) ;
-	virtual p<FutureResponse> asyncRequest(p<BaseCommand> command) ;
-	virtual p<Response> request(p<BaseCommand> command) ;
-
-    virtual void onCommand(p<ITransport> transport, p<BaseCommand> command) ;
-    virtual void onError(p<ITransport> transport, exception& error) ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*ActiveMQ_TransportFilter_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_TransportFilter_hpp_
+#define ActiveMQ_TransportFilter_hpp_
+
+#include <string>
+#include "activemq/command/BaseCommand.hpp"
+#include "activemq/command/Response.hpp"
+#include "activemq/transport/ITransport.hpp"
+#include "ppr/InvalidOperationException.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace transport
+    {
+      using namespace ifr;
+      using namespace apache::activemq::command;
+      using namespace apache::ppr;
+
+/*
+ * 
+ */
+class TransportFilter : public ITransport, public ICommandListener
+{
+protected:
+    p<ITransport>       next ;
+    p<ICommandListener> listener ;
+
+public:
+    TransportFilter(p<ITransport> next) ;
+    virtual ~TransportFilter() {}
+
+    virtual void setCommandListener(p<ICommandListener> listener) ;
+    virtual p<ICommandListener> getCommandListener() ;
+
+	virtual void start() ;
+	virtual void oneway(p<BaseCommand> command) ;
+	virtual p<FutureResponse> asyncRequest(p<BaseCommand> command) ;
+	virtual p<Response> request(p<BaseCommand> command) ;
+
+    virtual void onCommand(p<ITransport> transport, p<BaseCommand> command) ;
+    virtual void onError(p<ITransport> transport, exception& error) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*ActiveMQ_TransportFilter_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/tcp/TcpTransport.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/tcp/TcpTransport.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/tcp/TcpTransport.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/activemq/transport/tcp/TcpTransport.hpp Wed Jul  5 15:36:36 2006
@@ -1,131 +1,131 @@
-/*
- * 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_TcpTransport_hpp_
-#define ActiveMQ_TcpTransport_hpp_
-
-// Turn off warning message for ignored exception specification
-#ifdef _MSC_VER
-#pragma warning( disable : 4290 )
-#endif
-
-#include <iostream>
-#include <map>
-#include "cms/CmsException.hpp"
-#include "activemq/BrokerException.hpp"
-#include "activemq/command/BaseCommand.hpp"
-#include "activemq/command/Response.hpp"
-#include "activemq/command/ExceptionResponse.hpp"
-#include "activemq/protocol/IProtocol.hpp"
-#include "activemq/transport/FutureResponse.hpp"
-#include "activemq/transport/ITransport.hpp"
-#include "activemq/transport/ICommandListener.hpp"
-#include "ppr/InvalidOperationException.hpp"
-#include "ppr/io/DataInputStream.hpp"
-#include "ppr/io/DataOutputStream.hpp"
-#include "ppr/io/BufferedInputStream.hpp"
-#include "ppr/io/BufferedOutputStream.hpp"
-#include "ppr/io/SocketInputStream.hpp"
-#include "ppr/io/SocketOutputStream.hpp"
-#include "ppr/net/ISocket.hpp"
-#include "ppr/net/Socket.hpp"
-#include "ppr/net/SocketException.hpp"
-#include "ppr/net/ISocketFactory.hpp"
-#include "ppr/net/SocketFactory.hpp"
-#include "ppr/thread/SimpleMutex.hpp"
-#include "ppr/thread/Thread.hpp"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace transport
-    {
-      namespace tcp
-      {
-        using namespace ifr ;
-        using namespace std;
-        using namespace apache::activemq;
-        using namespace apache::activemq::command;
-        using namespace apache::activemq::protocol;
-        using namespace apache::ppr;
-        using namespace apache::ppr::io;
-        using namespace apache::ppr::net;
-        using namespace apache::ppr::thread;
-        using namespace apache::ppr::util;
-        class ReadThread ;
-
-/*
- * An implementation of ITransport that uses TCP to communicate with
- * the broker.
- */
-class TcpTransport : public ITransport
-{
-private:
-    p<IProtocol>        protocol ;
-    p<DataInputStream>  istream ;
-    p<DataOutputStream> ostream ;
-    p<ICommandListener> listener ;
-    p<ReadThread>       readThread ;
-    p<ISocket>          socket ;
-    bool                closed,
-                        started ;
-
-public:
-    TcpTransport(p<ISocket> socket, p<IProtocol> wireProtocol) ;
-    virtual ~TcpTransport() ;
-
-    virtual void setCommandListener(p<ICommandListener> listener) ;
-    virtual p<ICommandListener> getCommandListener() ;
-
-    virtual void start() ;
-    virtual void oneway(p<BaseCommand> command) ;
-    virtual p<FutureResponse> asyncRequest(p<BaseCommand> command) ;
-    virtual p<Response> request(p<BaseCommand> command) ;
-
-public:
-    void readLoop() ;
-} ;
-
-/*
- * 
- */
-class ReadThread : public Thread
-{
-private:
-    TcpTransport* transport ;
-
-public:
-    ReadThread(TcpTransport* transport)
-    {
-        this->transport = transport ;
-    }
-
-protected:
-    virtual void run() throw(p<exception>)
-    {
-        transport->readLoop() ;
-    }
-} ;
-
-/* namespace */
-      }
-    }
-  }
-}
-
-#endif /*ActiveMQ_TcpTransport_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_TcpTransport_hpp_
+#define ActiveMQ_TcpTransport_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <iostream>
+#include <map>
+#include "cms/CmsException.hpp"
+#include "activemq/BrokerException.hpp"
+#include "activemq/command/BaseCommand.hpp"
+#include "activemq/command/Response.hpp"
+#include "activemq/command/ExceptionResponse.hpp"
+#include "activemq/protocol/IProtocol.hpp"
+#include "activemq/transport/FutureResponse.hpp"
+#include "activemq/transport/ITransport.hpp"
+#include "activemq/transport/ICommandListener.hpp"
+#include "ppr/InvalidOperationException.hpp"
+#include "ppr/io/DataInputStream.hpp"
+#include "ppr/io/DataOutputStream.hpp"
+#include "ppr/io/BufferedInputStream.hpp"
+#include "ppr/io/BufferedOutputStream.hpp"
+#include "ppr/io/SocketInputStream.hpp"
+#include "ppr/io/SocketOutputStream.hpp"
+#include "ppr/net/ISocket.hpp"
+#include "ppr/net/Socket.hpp"
+#include "ppr/net/SocketException.hpp"
+#include "ppr/net/ISocketFactory.hpp"
+#include "ppr/net/SocketFactory.hpp"
+#include "ppr/thread/SimpleMutex.hpp"
+#include "ppr/thread/Thread.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace transport
+    {
+      namespace tcp
+      {
+        using namespace ifr ;
+        using namespace std;
+        using namespace apache::activemq;
+        using namespace apache::activemq::command;
+        using namespace apache::activemq::protocol;
+        using namespace apache::ppr;
+        using namespace apache::ppr::io;
+        using namespace apache::ppr::net;
+        using namespace apache::ppr::thread;
+        using namespace apache::ppr::util;
+        class ReadThread ;
+
+/*
+ * An implementation of ITransport that uses TCP to communicate with
+ * the broker.
+ */
+class TcpTransport : public ITransport
+{
+private:
+    p<IProtocol>        protocol ;
+    p<DataInputStream>  istream ;
+    p<DataOutputStream> ostream ;
+    p<ICommandListener> listener ;
+    p<ReadThread>       readThread ;
+    p<ISocket>          socket ;
+    bool                closed,
+                        started ;
+
+public:
+    TcpTransport(p<ISocket> socket, p<IProtocol> wireProtocol) ;
+    virtual ~TcpTransport() ;
+
+    virtual void setCommandListener(p<ICommandListener> listener) ;
+    virtual p<ICommandListener> getCommandListener() ;
+
+    virtual void start() ;
+    virtual void oneway(p<BaseCommand> command) ;
+    virtual p<FutureResponse> asyncRequest(p<BaseCommand> command) ;
+    virtual p<Response> request(p<BaseCommand> command) ;
+
+public:
+    void readLoop() ;
+} ;
+
+/*
+ * 
+ */
+class ReadThread : public Thread
+{
+private:
+    TcpTransport* transport ;
+
+public:
+    ReadThread(TcpTransport* transport)
+    {
+        this->transport = transport ;
+    }
+
+protected:
+    virtual void run() throw(p<exception>)
+    {
+        transport->readLoop() ;
+    }
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*ActiveMQ_TcpTransport_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/CmsException.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/CmsException.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/CmsException.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/CmsException.hpp Wed Jul  5 15:36:36 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 Cms_CmsException_hpp_
-#define Cms_CmsException_hpp_
-
-#include <exception>
-#include <string>
-
-namespace apache
-{
-  namespace cms
-  {
-    using namespace std;
-
-/*
- * 
- */
-class CmsException : public exception
-{
-protected:
-    string msg;
-
-public:
-    CmsException() ;
-    CmsException(const char* message) ;
-    virtual ~CmsException() throw();
-
-    virtual const char* what() const throw () {
-      return msg.c_str();
-    }
-} ;
-
-/* namespace */
-  }
-}
-
-#endif /*Cms_CmsException_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 Cms_CmsException_hpp_
+#define Cms_CmsException_hpp_
+
+#include <exception>
+#include <string>
+
+namespace apache
+{
+  namespace cms
+  {
+    using namespace std;
+
+/*
+ * 
+ */
+class CmsException : public exception
+{
+protected:
+    string msg;
+
+public:
+    CmsException() ;
+    CmsException(const char* message) ;
+    virtual ~CmsException() throw();
+
+    virtual const char* what() const throw () {
+      return msg.c_str();
+    }
+} ;
+
+/* namespace */
+  }
+}
+
+#endif /*Cms_CmsException_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IBytesMessage.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IBytesMessage.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IBytesMessage.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IBytesMessage.hpp Wed Jul  5 15:36:36 2006
@@ -1,70 +1,70 @@
-/*
- * 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_IBytesMessage_hpp_
-#define Cms_IBytesMessage_hpp_
-
-// Turn off warning message for ignored exception specification
-#ifdef _MSC_VER
-#pragma warning( disable : 4290 )
-#endif
-
-#include <string>
-#include "cms/IMessage.hpp"
-#include "cms/MessageEOFException.hpp"
-#include "cms/MessageNotReadableException.hpp"
-#include "cms/MessageNotWritableException.hpp"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace cms
-  {
-    using namespace std;
-    using namespace ifr;
-
-/*
- * 
- */
-struct IBytesMessage : IMessage
-{
-    //virtual int getBodyLength() = 0;
-    virtual void reset() = 0 ;
-    virtual char readByte() throw (MessageNotReadableException, MessageEOFException) = 0 ;
-    virtual int readBytes(char* buffer, int index, int length) throw (MessageNotReadableException, MessageEOFException) = 0 ;
-    virtual bool readBoolean() throw (MessageNotReadableException, MessageEOFException) = 0 ;
-    virtual double readDouble() throw (MessageNotReadableException, MessageEOFException) = 0 ;
-    virtual float readFloat() throw (MessageNotReadableException, MessageEOFException) = 0 ;
-    virtual int readInt() throw (MessageNotReadableException, MessageEOFException) = 0 ;
-    virtual long long readLong() throw (MessageNotReadableException, MessageEOFException) = 0 ;
-    virtual short readShort() throw (MessageNotReadableException, MessageEOFException) = 0 ;
-    virtual p<string> readString() throw (MessageNotReadableException, MessageEOFException) = 0 ;
-    virtual void writeBoolean(bool value) throw (MessageNotWritableException) = 0 ;
-    virtual void writeByte(char value) throw (MessageNotWritableException) = 0 ;
-    virtual void writeBytes(char* value, int index, int length) throw (MessageNotWritableException) = 0 ;
-    virtual void writeDouble(double value) throw (MessageNotWritableException) = 0 ;
-    virtual void writeFloat(float value) throw (MessageNotWritableException) = 0 ;
-    virtual void writeInt(int value) throw (MessageNotWritableException) = 0 ;
-    virtual void writeLong(long long value) throw (MessageNotWritableException) = 0 ;
-    virtual void writeShort(short value) throw (MessageNotWritableException) = 0 ;
-    virtual void writeString(const char* value) throw (MessageNotWritableException) = 0 ;
-} ;
-
-/* namespace */
-  }
-}
-
-#endif /*Cms_IBytesMessage_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 Cms_IBytesMessage_hpp_
+#define Cms_IBytesMessage_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <string>
+#include "cms/IMessage.hpp"
+#include "cms/MessageEOFException.hpp"
+#include "cms/MessageNotReadableException.hpp"
+#include "cms/MessageNotWritableException.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace cms
+  {
+    using namespace std;
+    using namespace ifr;
+
+/*
+ * 
+ */
+struct IBytesMessage : IMessage
+{
+    //virtual int getBodyLength() = 0;
+    virtual void reset() = 0 ;
+    virtual char readByte() throw (MessageNotReadableException, MessageEOFException) = 0 ;
+    virtual int readBytes(char* buffer, int index, int length) throw (MessageNotReadableException, MessageEOFException) = 0 ;
+    virtual bool readBoolean() throw (MessageNotReadableException, MessageEOFException) = 0 ;
+    virtual double readDouble() throw (MessageNotReadableException, MessageEOFException) = 0 ;
+    virtual float readFloat() throw (MessageNotReadableException, MessageEOFException) = 0 ;
+    virtual int readInt() throw (MessageNotReadableException, MessageEOFException) = 0 ;
+    virtual long long readLong() throw (MessageNotReadableException, MessageEOFException) = 0 ;
+    virtual short readShort() throw (MessageNotReadableException, MessageEOFException) = 0 ;
+    virtual p<string> readString() throw (MessageNotReadableException, MessageEOFException) = 0 ;
+    virtual void writeBoolean(bool value) throw (MessageNotWritableException) = 0 ;
+    virtual void writeByte(char value) throw (MessageNotWritableException) = 0 ;
+    virtual void writeBytes(char* value, int index, int length) throw (MessageNotWritableException) = 0 ;
+    virtual void writeDouble(double value) throw (MessageNotWritableException) = 0 ;
+    virtual void writeFloat(float value) throw (MessageNotWritableException) = 0 ;
+    virtual void writeInt(int value) throw (MessageNotWritableException) = 0 ;
+    virtual void writeLong(long long value) throw (MessageNotWritableException) = 0 ;
+    virtual void writeShort(short value) throw (MessageNotWritableException) = 0 ;
+    virtual void writeString(const char* value) throw (MessageNotWritableException) = 0 ;
+} ;
+
+/* namespace */
+  }
+}
+
+#endif /*Cms_IBytesMessage_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IConnection.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IConnection.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IConnection.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IConnection.hpp Wed Jul  5 15:36:36 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 Cms_IConnection_hpp_
-#define Cms_IConnection_hpp_
-
-#include "cms/ISession.hpp"
-#include "cms/CmsException.hpp"
-#include "activemq/AcknowledgementMode.hpp"
-#include "ppr/util/ifr/p"
-
-// Turn off warning message for ignored exception specification
-#ifdef _MSC_VER
-#pragma warning( disable : 4290 )
-#endif
-
-namespace apache
-{
-  namespace cms
-  {
-    using namespace ifr;
-    using namespace apache::activemq;
-
-/*
- * 
- */
-struct IConnection : Interface
-{
-    virtual p<ISession> createSession() throw(CmsException) = 0 ;
-    virtual p<ISession> createSession(AcknowledgementMode ackMode) throw(CmsException) = 0 ;
-    virtual p<string> getClientId() = 0 ;
-    virtual void setClientId(const char* value) throw (CmsException) = 0 ;
-    virtual AcknowledgementMode getAcknowledgementMode() = 0 ;
-    virtual void setAcknowledgementMode(AcknowledgementMode mode) = 0 ;
-    virtual void close() = 0 ;
-} ;
-
-/* namespace */
-  }
-}
-
-#endif /*Cms_IConnection_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 Cms_IConnection_hpp_
+#define Cms_IConnection_hpp_
+
+#include "cms/ISession.hpp"
+#include "cms/CmsException.hpp"
+#include "activemq/AcknowledgementMode.hpp"
+#include "ppr/util/ifr/p"
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+namespace apache
+{
+  namespace cms
+  {
+    using namespace ifr;
+    using namespace apache::activemq;
+
+/*
+ * 
+ */
+struct IConnection : Interface
+{
+    virtual p<ISession> createSession() throw(CmsException) = 0 ;
+    virtual p<ISession> createSession(AcknowledgementMode ackMode) throw(CmsException) = 0 ;
+    virtual p<string> getClientId() = 0 ;
+    virtual void setClientId(const char* value) throw (CmsException) = 0 ;
+    virtual AcknowledgementMode getAcknowledgementMode() = 0 ;
+    virtual void setAcknowledgementMode(AcknowledgementMode mode) = 0 ;
+    virtual void close() = 0 ;
+} ;
+
+/* namespace */
+  }
+}
+
+#endif /*Cms_IConnection_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IConnectionFactory.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IConnectionFactory.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IConnectionFactory.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IConnectionFactory.hpp Wed Jul  5 15:36:36 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_IConnectionFactory_hpp_
-#define Cms_IConnectionFactory_hpp_
-
-#include <string>
-#include "cms/IConnection.hpp"
-#include "activemq/ConnectionException.hpp"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace cms
-  {
-    using namespace ifr;
-
-/*
- * 
- */
-struct IConnectionFactory : Interface
-{
-    virtual p<IConnection> createConnection() throw (ConnectionException) = 0 ;
-    virtual p<IConnection> createConnection(const char* username, const char* password) throw (ConnectionException) = 0 ;
-} ;
-
-/* namespace */
-  }
-}
-
-#endif /*Cms_IConnectionFactory_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 Cms_IConnectionFactory_hpp_
+#define Cms_IConnectionFactory_hpp_
+
+#include <string>
+#include "cms/IConnection.hpp"
+#include "activemq/ConnectionException.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace cms
+  {
+    using namespace ifr;
+
+/*
+ * 
+ */
+struct IConnectionFactory : Interface
+{
+    virtual p<IConnection> createConnection() throw (ConnectionException) = 0 ;
+    virtual p<IConnection> createConnection(const char* username, const char* password) throw (ConnectionException) = 0 ;
+} ;
+
+/* namespace */
+  }
+}
+
+#endif /*Cms_IConnectionFactory_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IDestination.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IDestination.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IDestination.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IDestination.hpp Wed Jul  5 15:36:36 2006
@@ -1,39 +1,39 @@
-/*
- * 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_IDestination_hpp_
-#define Cms_IDestination_hpp_
-
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace cms
-  {
-    using namespace ifr;
-
-/*
- * Top interface for all message destinations.
- */
-struct IDestination : Interface
-{
-} ;
-
-/* namespace */
-  }
-}
-
-#endif /*Cms_IDestination_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 Cms_IDestination_hpp_
+#define Cms_IDestination_hpp_
+
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace cms
+  {
+    using namespace ifr;
+
+/*
+ * Top interface for all message destinations.
+ */
+struct IDestination : Interface
+{
+} ;
+
+/* namespace */
+  }
+}
+
+#endif /*Cms_IDestination_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IExceptionListener.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IExceptionListener.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IExceptionListener.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IExceptionListener.hpp Wed Jul  5 15:36:36 2006
@@ -1,42 +1,42 @@
-/*
- * 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_IExceptionListener_hpp_
-#define Cms_IExceptionListener_hpp_
-
-#include <exception>
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace cms
-  {
-    using namespace ifr;
-    using namespace std;
-
-/*
- * 
- */
-struct IExceptionListener : Interface
-{
-    virtual void onException(exception& error) = 0 ;
-} ;
-
-/* namespace */
-  }
-}
-
-#endif /*Cms_IExceptionListener_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 Cms_IExceptionListener_hpp_
+#define Cms_IExceptionListener_hpp_
+
+#include <exception>
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace cms
+  {
+    using namespace ifr;
+    using namespace std;
+
+/*
+ * 
+ */
+struct IExceptionListener : Interface
+{
+    virtual void onException(exception& error) = 0 ;
+} ;
+
+/* namespace */
+  }
+}
+
+#endif /*Cms_IExceptionListener_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IMapMessage.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IMapMessage.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IMapMessage.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IMapMessage.hpp Wed Jul  5 15:36:36 2006
@@ -1,69 +1,69 @@
-/*
- * 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_IMapMessage_hpp_
-#define Cms_IMapMessage_hpp_
-
-// Turn off warning message for ignored exception specification
-#ifdef _MSC_VER
-#pragma warning( disable : 4290 )
-#endif
-
-#include "cms/IMessage.hpp"
-#include "cms/MessageFormatException.hpp"
-#include "ppr/IllegalArgumentException.hpp"
-#include "ppr/util/MapItemHolder.hpp"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace cms
-  {
-    using namespace apache::ppr;
-    using namespace apache::ppr::util;
-    using namespace ifr;
-
-/*
- * 
- */
-struct IMapMessage : IMessage
-{
-    virtual p<PropertyMap> getBody() = 0 ;
-    virtual bool getBoolean(const char* name) throw (MessageFormatException, IllegalArgumentException) = 0 ;
-    virtual void setBoolean(const char* name, bool value) throw (IllegalArgumentException) = 0 ;
-    virtual char getByte(const char* name) throw (MessageFormatException, IllegalArgumentException) = 0 ;
-    virtual void setByte(const char* name, char value) throw (IllegalArgumentException) = 0 ;
-    virtual array<char> getBytes(const char* name) throw (MessageFormatException, IllegalArgumentException) = 0 ;
-    virtual void setBytes(const char* name, array<char> value) throw (IllegalArgumentException) = 0 ;
-    virtual double getDouble(const char* name) throw (MessageFormatException, IllegalArgumentException) = 0 ;
-    virtual void setDouble(const char* name, double value) throw (IllegalArgumentException) = 0 ;
-    virtual float getFloat(const char* name) throw (MessageFormatException, IllegalArgumentException) = 0 ;
-    virtual void setFloat(const char* name, float value) throw (IllegalArgumentException) = 0 ;
-    virtual int getInt(const char* name) throw (MessageFormatException, IllegalArgumentException) = 0 ;
-    virtual void setInt(const char* name, int value) throw (IllegalArgumentException) = 0 ;
-    virtual long long getLong(const char* name) throw (MessageFormatException, IllegalArgumentException) = 0 ;
-    virtual void setLong(const char* name, long long value) throw (IllegalArgumentException) = 0 ;
-    virtual short getShort(const char* name) throw (MessageFormatException, IllegalArgumentException) = 0 ;
-    virtual void setShort(const char* name, short value) throw (IllegalArgumentException) = 0 ;
-    virtual p<string> getString(const char* name) throw (MessageFormatException, IllegalArgumentException) = 0 ;
-    virtual void setString(const char* name, const char* value) throw (IllegalArgumentException) = 0 ;
-} ;
-
-/* namespace */
-  }
-}
-
-#endif /*Cms_IMapMessage_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 Cms_IMapMessage_hpp_
+#define Cms_IMapMessage_hpp_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include "cms/IMessage.hpp"
+#include "cms/MessageFormatException.hpp"
+#include "ppr/IllegalArgumentException.hpp"
+#include "ppr/util/MapItemHolder.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace cms
+  {
+    using namespace apache::ppr;
+    using namespace apache::ppr::util;
+    using namespace ifr;
+
+/*
+ * 
+ */
+struct IMapMessage : IMessage
+{
+    virtual p<PropertyMap> getBody() = 0 ;
+    virtual bool getBoolean(const char* name) throw (MessageFormatException, IllegalArgumentException) = 0 ;
+    virtual void setBoolean(const char* name, bool value) throw (IllegalArgumentException) = 0 ;
+    virtual char getByte(const char* name) throw (MessageFormatException, IllegalArgumentException) = 0 ;
+    virtual void setByte(const char* name, char value) throw (IllegalArgumentException) = 0 ;
+    virtual array<char> getBytes(const char* name) throw (MessageFormatException, IllegalArgumentException) = 0 ;
+    virtual void setBytes(const char* name, array<char> value) throw (IllegalArgumentException) = 0 ;
+    virtual double getDouble(const char* name) throw (MessageFormatException, IllegalArgumentException) = 0 ;
+    virtual void setDouble(const char* name, double value) throw (IllegalArgumentException) = 0 ;
+    virtual float getFloat(const char* name) throw (MessageFormatException, IllegalArgumentException) = 0 ;
+    virtual void setFloat(const char* name, float value) throw (IllegalArgumentException) = 0 ;
+    virtual int getInt(const char* name) throw (MessageFormatException, IllegalArgumentException) = 0 ;
+    virtual void setInt(const char* name, int value) throw (IllegalArgumentException) = 0 ;
+    virtual long long getLong(const char* name) throw (MessageFormatException, IllegalArgumentException) = 0 ;
+    virtual void setLong(const char* name, long long value) throw (IllegalArgumentException) = 0 ;
+    virtual short getShort(const char* name) throw (MessageFormatException, IllegalArgumentException) = 0 ;
+    virtual void setShort(const char* name, short value) throw (IllegalArgumentException) = 0 ;
+    virtual p<string> getString(const char* name) throw (MessageFormatException, IllegalArgumentException) = 0 ;
+    virtual void setString(const char* name, const char* value) throw (IllegalArgumentException) = 0 ;
+} ;
+
+/* namespace */
+  }
+}
+
+#endif /*Cms_IMapMessage_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IMessage.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IMessage.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IMessage.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IMessage.hpp Wed Jul  5 15:36:36 2006
@@ -1,111 +1,111 @@
-/*
- * 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_IMessage_hpp_
-#define Cms_IMessage_hpp_
-
-#include <string>
-#include "cms/IDestination.hpp"
-#include "ppr/util/MapItemHolder.hpp"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace cms
-  {
-    using namespace apache::ppr::util;
-    using namespace ifr;
-    using namespace std;
-
-/*
- * Represents a message either to be sent to a message broker
- * or received from a message broker.
- */
-struct IMessage : Interface
-{
-    // If using client acknowledgement mode on the session then
-    // this method will acknowledge that the message has been
-    // processed correctly.
-    virtual void acknowledge() = 0 ;
-
-    // Provides access to the message properties (headers).
-    virtual p<PropertyMap> getProperties() = 0 ;
-
-    // The correlation ID used to correlate messages from
-    // conversations or long running business processes.
-    virtual p<string> getJMSCorrelationID() = 0 ;
-    virtual void setJMSCorrelationID(const char* correlationId) = 0 ;
-
-    // The destination of the message.
-    virtual p<IDestination> getJMSDestination() = 0 ;
-
-    // The time in milliseconds that this message should expire.
-    virtual long long getJMSExpiration() = 0 ;
-    virtual void setJMSExpiration(long long time) = 0 ;
-
-    // The message ID which is set by the provider.
-    virtual p<string> getJMSMessageID() = 0 ;
-
-    // Whether or not this message is persistent.
-    virtual bool getJMSPersistent() = 0 ;
-    virtual void setJMSPersistent(bool persistent) = 0 ;
-
-    // The priority on this message.
-    virtual unsigned char getJMSPriority() = 0 ;
-    virtual void setJMSPriority(unsigned char priority) = 0 ;
-
-    // Returns true if this message has been redelivered to this
-    // or another consumer before being acknowledged successfully.
-    virtual bool getJMSRedelivered() = 0 ;
-
-    // The destination that the consumer of this message should
-    // send replies to.
-    virtual p<IDestination> getJMSReplyTo() = 0 ;
-    virtual void setJMSReplyTo(p<IDestination> destination) = 0 ;
-
-    // The timestamp the broker added to the message.
-    virtual long long getJMSTimestamp() = 0 ;
-
-    // The type name of this message.
-    virtual p<string> getJMSType() = 0 ;
-    virtual void setJMSType(const char* type) = 0 ;
-
-    //
-    // JMS Extension Headers
-
-    // Returns the number of times this message has been redelivered
-    // to other consumers without being acknowledged successfully.
-    virtual int getJMSXDeliveryCount() = 0 ;
-
-    // The message group ID is used to group messages together to the
-    // same consumer for the same group ID value.
-    virtual p<string> getJMSXGroupID() = 0 ;
-    virtual void setJMSXGroupID(const char* groupId) = 0 ;
-
-    // The message group sequence counter to indicate the position
-    // in a group.
-    virtual int getJMSXGroupSeq() = 0 ;
-    virtual void setJMSXGroupSeq(int sequence) = 0 ;
-
-    // Returns the ID of the producers transaction.
-    virtual p<string> getJMSXProducerTxID() = 0 ;
-} ;
-
-/* namespace */
-  }
-}
-
-#endif /*Cms_IMessage_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 Cms_IMessage_hpp_
+#define Cms_IMessage_hpp_
+
+#include <string>
+#include "cms/IDestination.hpp"
+#include "ppr/util/MapItemHolder.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace cms
+  {
+    using namespace apache::ppr::util;
+    using namespace ifr;
+    using namespace std;
+
+/*
+ * Represents a message either to be sent to a message broker
+ * or received from a message broker.
+ */
+struct IMessage : Interface
+{
+    // If using client acknowledgement mode on the session then
+    // this method will acknowledge that the message has been
+    // processed correctly.
+    virtual void acknowledge() = 0 ;
+
+    // Provides access to the message properties (headers).
+    virtual p<PropertyMap> getProperties() = 0 ;
+
+    // The correlation ID used to correlate messages from
+    // conversations or long running business processes.
+    virtual p<string> getJMSCorrelationID() = 0 ;
+    virtual void setJMSCorrelationID(const char* correlationId) = 0 ;
+
+    // The destination of the message.
+    virtual p<IDestination> getJMSDestination() = 0 ;
+
+    // The time in milliseconds that this message should expire.
+    virtual long long getJMSExpiration() = 0 ;
+    virtual void setJMSExpiration(long long time) = 0 ;
+
+    // The message ID which is set by the provider.
+    virtual p<string> getJMSMessageID() = 0 ;
+
+    // Whether or not this message is persistent.
+    virtual bool getJMSPersistent() = 0 ;
+    virtual void setJMSPersistent(bool persistent) = 0 ;
+
+    // The priority on this message.
+    virtual unsigned char getJMSPriority() = 0 ;
+    virtual void setJMSPriority(unsigned char priority) = 0 ;
+
+    // Returns true if this message has been redelivered to this
+    // or another consumer before being acknowledged successfully.
+    virtual bool getJMSRedelivered() = 0 ;
+
+    // The destination that the consumer of this message should
+    // send replies to.
+    virtual p<IDestination> getJMSReplyTo() = 0 ;
+    virtual void setJMSReplyTo(p<IDestination> destination) = 0 ;
+
+    // The timestamp the broker added to the message.
+    virtual long long getJMSTimestamp() = 0 ;
+
+    // The type name of this message.
+    virtual p<string> getJMSType() = 0 ;
+    virtual void setJMSType(const char* type) = 0 ;
+
+    //
+    // JMS Extension Headers
+
+    // Returns the number of times this message has been redelivered
+    // to other consumers without being acknowledged successfully.
+    virtual int getJMSXDeliveryCount() = 0 ;
+
+    // The message group ID is used to group messages together to the
+    // same consumer for the same group ID value.
+    virtual p<string> getJMSXGroupID() = 0 ;
+    virtual void setJMSXGroupID(const char* groupId) = 0 ;
+
+    // The message group sequence counter to indicate the position
+    // in a group.
+    virtual int getJMSXGroupSeq() = 0 ;
+    virtual void setJMSXGroupSeq(int sequence) = 0 ;
+
+    // Returns the ID of the producers transaction.
+    virtual p<string> getJMSXProducerTxID() = 0 ;
+} ;
+
+/* namespace */
+  }
+}
+
+#endif /*Cms_IMessage_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IMessageConsumer.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IMessageConsumer.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IMessageConsumer.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IMessageConsumer.hpp Wed Jul  5 15:36:36 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_IMessageConsumer_hpp_
-#define Cms_IMessageConsumer_hpp_
-
-#include <string>
-#include "cms/IMessage.hpp"
-#include "cms/IMessageListener.hpp"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace cms
-  {
-    using namespace ifr;
-
-/*
- * 
- */
-struct IMessageConsumer : Interface
-{
-    virtual void setMessageListener(p<IMessageListener> listener) = 0 ;
-    virtual p<IMessageListener> getMessageListener() = 0 ;
-    virtual p<IMessage> receive() = 0 ;
-    virtual p<IMessage> receive(int timeout) = 0 ;
-    virtual p<IMessage> receiveNoWait() = 0 ;
-
-    virtual void close() = 0 ;
-} ;
-
-/* namespace */
-  }
-}
-
-#endif /*Cms_IMessageConsumer_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 Cms_IMessageConsumer_hpp_
+#define Cms_IMessageConsumer_hpp_
+
+#include <string>
+#include "cms/IMessage.hpp"
+#include "cms/IMessageListener.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace cms
+  {
+    using namespace ifr;
+
+/*
+ * 
+ */
+struct IMessageConsumer : Interface
+{
+    virtual void setMessageListener(p<IMessageListener> listener) = 0 ;
+    virtual p<IMessageListener> getMessageListener() = 0 ;
+    virtual p<IMessage> receive() = 0 ;
+    virtual p<IMessage> receive(int timeout) = 0 ;
+    virtual p<IMessage> receiveNoWait() = 0 ;
+
+    virtual void close() = 0 ;
+} ;
+
+/* namespace */
+  }
+}
+
+#endif /*Cms_IMessageConsumer_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IMessageListener.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IMessageListener.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IMessageListener.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IMessageListener.hpp Wed Jul  5 15:36:36 2006
@@ -1,41 +1,41 @@
-/*
- * 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_IMessageListener_hpp_
-#define Cms_IMessageListener_hpp_
-
-#include "cms/IMessage.hpp"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace cms
-  {
-    using namespace ifr;
-
-/*
- * 
- */
-struct IMessageListener : Interface
-{
-    virtual void onMessage(p<IMessage> message) = 0 ;
-} ;
-
-/* namespace */
-  }
-}
-
-#endif /*Cms_IMessageListener_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 Cms_IMessageListener_hpp_
+#define Cms_IMessageListener_hpp_
+
+#include "cms/IMessage.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace cms
+  {
+    using namespace ifr;
+
+/*
+ * 
+ */
+struct IMessageListener : Interface
+{
+    virtual void onMessage(p<IMessage> message) = 0 ;
+} ;
+
+/* namespace */
+  }
+}
+
+#endif /*Cms_IMessageListener_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IMessageProducer.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IMessageProducer.hpp?rev=419371&r1=419370&r2=419371&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IMessageProducer.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/main/cpp/cms/IMessageProducer.hpp Wed Jul  5 15:36:36 2006
@@ -1,60 +1,60 @@
-/*
- * 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_IMessageProducer_hpp_
-#define Cms_IMessageProducer_hpp_
-
-#include <string>
-#include "cms/IDestination.hpp"
-#include "cms/IMessage.hpp"
-#include "ppr/util/ifr/p"
-
-namespace apache
-{
-  namespace cms
-  {
-    using namespace ifr;
-
-/*
- * An object capable of sending messages to some destination.
- */
-struct IMessageProducer : Interface
-{
-    // Sends the message to the default destination for this producer.
-    virtual void send(p<IMessage> message) = 0 ;
-
-    // Sends the message to the given destination.
-    virtual void send(p<IDestination> destination, p<IMessage> message) = 0 ;
-
-    virtual void close() = 0 ;
-
-	virtual bool getPersistent() = 0 ;
-	virtual void setPersistent(bool persistent) = 0 ;
-    virtual long long getTimeToLive() = 0 ;
-    virtual void getTimeToLive(long long ttl) = 0 ;
-    virtual int getPriority() = 0 ;
-    virtual void getPriority(int priority) = 0 ;
-    virtual bool getDisableMessageID() = 0 ;
-    virtual void getDisableMessageID(bool disable) = 0 ;
-    virtual bool getDisableMessageTimestamp() = 0 ;
-    virtual void getDisableMessageTimestamp(bool disable) = 0 ;
-} ;
-
-/* namespace */
-  }
-}
-
-#endif /*Cms_IMessageProducer_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 Cms_IMessageProducer_hpp_
+#define Cms_IMessageProducer_hpp_
+
+#include <string>
+#include "cms/IDestination.hpp"
+#include "cms/IMessage.hpp"
+#include "ppr/util/ifr/p"
+
+namespace apache
+{
+  namespace cms
+  {
+    using namespace ifr;
+
+/*
+ * An object capable of sending messages to some destination.
+ */
+struct IMessageProducer : Interface
+{
+    // Sends the message to the default destination for this producer.
+    virtual void send(p<IMessage> message) = 0 ;
+
+    // Sends the message to the given destination.
+    virtual void send(p<IDestination> destination, p<IMessage> message) = 0 ;
+
+    virtual void close() = 0 ;
+
+	virtual bool getPersistent() = 0 ;
+	virtual void setPersistent(bool persistent) = 0 ;
+    virtual long long getTimeToLive() = 0 ;
+    virtual void getTimeToLive(long long ttl) = 0 ;
+    virtual int getPriority() = 0 ;
+    virtual void getPriority(int priority) = 0 ;
+    virtual bool getDisableMessageID() = 0 ;
+    virtual void getDisableMessageID(bool disable) = 0 ;
+    virtual bool getDisableMessageTimestamp() = 0 ;
+    virtual void getDisableMessageTimestamp(bool disable) = 0 ;
+} ;
+
+/* namespace */
+  }
+}
+
+#endif /*Cms_IMessageProducer_hpp_*/

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



Mime
View raw message