svn commit: r379623 [12/18] - in /incubator/activemq/trunk: ./ activecluster/ activecluster/src/java/org/apache/activecluster/ activecluster/src/java/org/apache/activecluster/group/ activecluster/src/java/org/apache/activecluster/impl/ activeio/ active...

[ch...@apache.org]

Modified: incubator/activemq/trunk/openwire-cpp/src/DestinationFilter.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/DestinationFilter.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/DestinationFilter.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/DestinationFilter.hpp Tue Feb 21 15:28:33 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 DestinationFilter_hpp_
-#define DestinationFilter_hpp_
-
-#include "command/ActiveMQMessage.hpp"
-#include "command/ActiveMQDestination.hpp"
-#include "util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      using namespace ifr;
-      using namespace apache::activemq::client::command;
-
-/*
- * 
- */
-class DestinationFilter
-{
-public:
-    const static char* ANY_DESCENDENT ;
-    const static char* ANY_CHILD ;
-
-public:
-    DestinationFilter() ;
-    virtual ~DestinationFilter() ;
-
-    virtual bool matches(p<ActiveMQMessage> message) ;
-    virtual bool matches(p<ActiveMQDestination> destination) = 0 ;
-};
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*DestinationFilter_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 DestinationFilter_hpp_
+#define DestinationFilter_hpp_
+
+#include "command/ActiveMQMessage.hpp"
+#include "command/ActiveMQDestination.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      using namespace ifr;
+      using namespace apache::activemq::client::command;
+
+/*
+ * 
+ */
+class DestinationFilter
+{
+public:
+    const static char* ANY_DESCENDENT ;
+    const static char* ANY_CHILD ;
+
+public:
+    DestinationFilter() ;
+    virtual ~DestinationFilter() ;
+
+    virtual bool matches(p<ActiveMQMessage> message) ;
+    virtual bool matches(p<ActiveMQDestination> destination) = 0 ;
+};
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*DestinationFilter_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/FutureResponse.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/FutureResponse.cpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/FutureResponse.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/FutureResponse.cpp Tue Feb 21 15:28:33 2006
@@ -1,47 +1,47 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#include "FutureResponse.hpp"
-
-using namespace apache::activemq::client;
-
-/*
- * 
- */
-FutureResponse::FutureResponse()
-{
-    complete = false ;
-    response = NULL ;
-}
-
-FutureResponse::~FutureResponse()
-{
-}
-
-p<Response> FutureResponse::getResponse()
-{
-    return response ;
-}
-
-void FutureResponse::setResponse(p<Response> response)
-{
-    response = response ;
-}
-
-bool FutureResponse::isCompleted()
-{
-    return complete ;
-}
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "FutureResponse.hpp"
+
+using namespace apache::activemq::client;
+
+/*
+ * 
+ */
+FutureResponse::FutureResponse()
+{
+    complete = false ;
+    response = NULL ;
+}
+
+FutureResponse::~FutureResponse()
+{
+}
+
+p<Response> FutureResponse::getResponse()
+{
+    return response ;
+}
+
+void FutureResponse::setResponse(p<Response> response)
+{
+    response = response ;
+}
+
+bool FutureResponse::isCompleted()
+{
+    return complete ;
+}

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

Modified: incubator/activemq/trunk/openwire-cpp/src/FutureResponse.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/FutureResponse.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/FutureResponse.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/FutureResponse.hpp Tue Feb 21 15:28:33 2006
@@ -1,58 +1,58 @@
-/*
- * 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 FutureResponse_hpp_
-#define FutureResponse_hpp_
-
-#include <string>
-#include "command/Response.hpp"
-#include "util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      using namespace ifr;
-      using namespace apache::activemq::client::command;
-
-/*
- * Interface for commands.
- */
-class FutureResponse
-{
-private:
-    p<Response> response ;
-    bool        complete ;
-
-public:
-    FutureResponse() ;
-    virtual ~FutureResponse() ;
-
-    virtual p<Response> getResponse() ;
-    virtual void setResponse(p<Response> response) ;
-    virtual bool isCompleted() ;
-
-    // TODO: add notify/wait
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*FutureResponse_hpp_*/
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef FutureResponse_hpp_
+#define FutureResponse_hpp_
+
+#include <string>
+#include "command/Response.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      using namespace ifr;
+      using namespace apache::activemq::client::command;
+
+/*
+ * Interface for commands.
+ */
+class FutureResponse
+{
+private:
+    p<Response> response ;
+    bool        complete ;
+
+public:
+    FutureResponse() ;
+    virtual ~FutureResponse() ;
+
+    virtual p<Response> getResponse() ;
+    virtual void setResponse(p<Response> response) ;
+    virtual bool isCompleted() ;
+
+    // TODO: add notify/wait
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*FutureResponse_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/IConnection.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/IConnection.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/IConnection.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/IConnection.hpp Tue Feb 21 15:28:33 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 IConnection_hpp_
-#define IConnection_hpp_
-
-#include "ISession.hpp"
-#include "OpenWireException.hpp"
-#include "util/ifr/p"
-
-// Turn off warning message for ignored exception specification
-#ifdef _MSC_VER
-#pragma warning( disable : 4290 )
-#endif
-
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-        using namespace ifr;
-
-enum AcknowledgementMode {
-    UnknownMode, AutoMode, ClientMode, TransactionalMode 
-} ;
-
-/*
- * 
- */
-struct IConnection
-{
-    virtual p<ISession> createSession() throw(OpenWireException) = 0 ;
-    virtual p<ISession> createSession(bool transacted, AcknowledgementMode ackMode) throw(OpenWireException) = 0 ;
-    virtual bool getTransacted() = 0 ;
-    virtual void setTransacted(bool tx) = 0 ;
-    virtual AcknowledgementMode getAcknowledgementMode() = 0 ;
-    virtual void setAcknowledgementMode(AcknowledgementMode mode) = 0 ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
+/*
+ * 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 IConnection_hpp_
+#define IConnection_hpp_
+
+#include "ISession.hpp"
+#include "OpenWireException.hpp"
+#include "util/ifr/p"
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+        using namespace ifr;
+
+enum AcknowledgementMode {
+    UnknownMode, AutoMode, ClientMode, TransactionalMode 
+} ;
+
+/*
+ * 
+ */
+struct IConnection
+{
+    virtual p<ISession> createSession() throw(OpenWireException) = 0 ;
+    virtual p<ISession> createSession(bool transacted, AcknowledgementMode ackMode) throw(OpenWireException) = 0 ;
+    virtual bool getTransacted() = 0 ;
+    virtual void setTransacted(bool tx) = 0 ;
+    virtual AcknowledgementMode getAcknowledgementMode() = 0 ;
+    virtual void setAcknowledgementMode(AcknowledgementMode mode) = 0 ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
 #endif /*IConnection_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/IConnectionFactory.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/IConnectionFactory.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/IConnectionFactory.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/IConnectionFactory.hpp Tue Feb 21 15:28:33 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 IConnectionFactory_hpp_
-#define IConnectionFactory_hpp_
-
-#include <string>
-#include "IConnection.hpp"
-#include "util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      using namespace ifr;
-
-/*
- * 
- */
-struct IConnectionFactory
-{
-    virtual p<IConnection> createConnection() = 0 ;
-    virtual p<IConnection> createConnection(const char* username, const char* password) = 0 ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*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 IConnectionFactory_hpp_
+#define IConnectionFactory_hpp_
+
+#include <string>
+#include "IConnection.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      using namespace ifr;
+
+/*
+ * 
+ */
+struct IConnectionFactory
+{
+    virtual p<IConnection> createConnection() = 0 ;
+    virtual p<IConnection> createConnection(const char* username, const char* password) = 0 ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*IConnectionFactory_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/IDestination.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/IDestination.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/IDestination.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/IDestination.hpp Tue Feb 21 15:28:33 2006
@@ -1,43 +1,43 @@
-/*
- * 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 IDestination_hpp_
-#define IDestination_hpp_
-
-#include "command/ICommand.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-        using namespace apache::activemq::client::command;
-
-/*
- * 
- */
-struct IDestination
-{
-    // Empty marker interface
-} ;
-
-/* namespace */
-    }
-  }
-}
-
+/*
+ * 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 IDestination_hpp_
+#define IDestination_hpp_
+
+#include "command/ICommand.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+        using namespace apache::activemq::client::command;
+
+/*
+ * 
+ */
+struct IDestination
+{
+    // Empty marker interface
+} ;
+
+/* namespace */
+    }
+  }
+}
+
 #endif /*IDestination_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/IMessage.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/IMessage.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/IMessage.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/IMessage.hpp Tue Feb 21 15:28:33 2006
@@ -1,45 +1,45 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#ifndef IMessage_hpp_
-#define IMessage_hpp_
-
-#include "IDestination.hpp"
-#include "util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      using namespace ifr;
-
-/*
- * 
- */
-struct IMessage
-{
-    virtual p<IDestination> getFromDestination() = 0 ;
-    virtual void setFromDestination(p<IDestination> destination) = 0 ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
+/*
+ * 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 IMessage_hpp_
+#define IMessage_hpp_
+
+#include "IDestination.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      using namespace ifr;
+
+/*
+ * 
+ */
+struct IMessage
+{
+    virtual p<IDestination> getFromDestination() = 0 ;
+    virtual void setFromDestination(p<IDestination> destination) = 0 ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
 #endif /*IMessage_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/IMessageConsumer.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/IMessageConsumer.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/IMessageConsumer.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/IMessageConsumer.hpp Tue Feb 21 15:28:33 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 IMessageConsumer_hpp_
-#define IMessageConsumer_hpp_
-
-#include <string>
-#include "IMessage.hpp"
-#include "util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      using namespace ifr;
-
-/*
- * 
- */
-struct IMessageConsumer
-{
-    virtual p<IMessage> receive() = 0 ;
-    virtual p<IMessage> receiveNoWait() = 0 ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
+/*
+ * 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 IMessageConsumer_hpp_
+#define IMessageConsumer_hpp_
+
+#include <string>
+#include "IMessage.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      using namespace ifr;
+
+/*
+ * 
+ */
+struct IMessageConsumer
+{
+    virtual p<IMessage> receive() = 0 ;
+    virtual p<IMessage> receiveNoWait() = 0 ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
 #endif /*IMessageConsumer_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/IMessageProducer.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/IMessageProducer.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/IMessageProducer.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/IMessageProducer.hpp Tue Feb 21 15:28:33 2006
@@ -1,47 +1,47 @@
-/*
- * 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 IMessageProducer_hpp_
-#define IMessageProducer_hpp_
-
-#include <string>
-#include "IDestination.hpp"
-#include "IMessage.hpp"
-#include "util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      using namespace ifr;
-
-/*
- * 
- */
-struct IMessageProducer
-{
-    virtual void send(p<IMessage> message) = 0 ;
-    virtual void send(p<IDestination> destination, p<IMessage> message) = 0 ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
+/*
+ * 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 IMessageProducer_hpp_
+#define IMessageProducer_hpp_
+
+#include <string>
+#include "IDestination.hpp"
+#include "IMessage.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      using namespace ifr;
+
+/*
+ * 
+ */
+struct IMessageProducer
+{
+    virtual void send(p<IMessage> message) = 0 ;
+    virtual void send(p<IDestination> destination, p<IMessage> message) = 0 ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
 #endif /*IMessageProducer_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/IQueue.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/IQueue.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/IQueue.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/IQueue.hpp Tue Feb 21 15:28:33 2006
@@ -1,47 +1,47 @@
-/*
- * 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 IQueue_hpp_
-#define IQueue_hpp_
-
-#include <string>
-#include "IDestination.hpp"
-#include "util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      using namespace ifr;
-      using namespace std;
-
-/*
- * 
- */
-struct IQueue : IDestination
-{
-    virtual p<string> getQueueName() = 0 ;
-    virtual void setQueueName(const char* name) = 0 ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
+/*
+ * 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 IQueue_hpp_
+#define IQueue_hpp_
+
+#include <string>
+#include "IDestination.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      using namespace ifr;
+      using namespace std;
+
+/*
+ * 
+ */
+struct IQueue : IDestination
+{
+    virtual p<string> getQueueName() = 0 ;
+    virtual void setQueueName(const char* name) = 0 ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
 #endif /*IQueue_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/ISession.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/ISession.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/ISession.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/ISession.hpp Tue Feb 21 15:28:33 2006
@@ -1,58 +1,58 @@
-/*
- * 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 ISession_hpp_
-#define ISession_hpp_
-
-#include <string>
-#include "IDestination.hpp"
-#include "IMessageProducer.hpp"
-#include "IMessageConsumer.hpp"
-#include "IQueue.hpp"
-#include "ITopic.hpp"
-#include "ITextMessage.hpp"
-#include "util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      using namespace ifr;
-
-/*
- * 
- */
-struct ISession
-{
-    virtual p<IMessageProducer> createProducer() = 0 ;
-    virtual p<IMessageProducer> createProducer(p<IDestination> destination) = 0 ;
-    virtual p<IMessageConsumer> createConsumer(p<IDestination> destination) = 0 ;
-    virtual p<IMessageConsumer> createConsumer(p<IDestination> destination, const char* selector) = 0 ;
-    virtual p<IQueue> getQueue(const char* name) = 0 ;
-    virtual p<ITopic> getTopic(const char* name) = 0 ;
-    virtual p<IMessage> createMessage() = 0 ;
-    virtual p<ITextMessage> createTextMessage() = 0 ;
-    virtual p<ITextMessage> createTextMessage(const char* text) = 0 ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
+/*
+ * 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 ISession_hpp_
+#define ISession_hpp_
+
+#include <string>
+#include "IDestination.hpp"
+#include "IMessageProducer.hpp"
+#include "IMessageConsumer.hpp"
+#include "IQueue.hpp"
+#include "ITopic.hpp"
+#include "ITextMessage.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      using namespace ifr;
+
+/*
+ * 
+ */
+struct ISession
+{
+    virtual p<IMessageProducer> createProducer() = 0 ;
+    virtual p<IMessageProducer> createProducer(p<IDestination> destination) = 0 ;
+    virtual p<IMessageConsumer> createConsumer(p<IDestination> destination) = 0 ;
+    virtual p<IMessageConsumer> createConsumer(p<IDestination> destination, const char* selector) = 0 ;
+    virtual p<IQueue> getQueue(const char* name) = 0 ;
+    virtual p<ITopic> getTopic(const char* name) = 0 ;
+    virtual p<IMessage> createMessage() = 0 ;
+    virtual p<ITextMessage> createTextMessage() = 0 ;
+    virtual p<ITextMessage> createTextMessage(const char* text) = 0 ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
 #endif /*ISession_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/ITemporaryQueue.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/ITemporaryQueue.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/ITemporaryQueue.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/ITemporaryQueue.hpp Tue Feb 21 15:28:33 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 ITemporaryQueue_hpp_
-#define ITemporaryQueue_hpp_
-
-#include <string>
-#include "IDestination.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-
-/*
- * 
- */
-struct ITemporaryQueue : IDestination
-{
-} ;
-
-/* namespace */
-    }
-  }
-}
-
+/*
+ * 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 ITemporaryQueue_hpp_
+#define ITemporaryQueue_hpp_
+
+#include <string>
+#include "IDestination.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+
+/*
+ * 
+ */
+struct ITemporaryQueue : IDestination
+{
+} ;
+
+/* namespace */
+    }
+  }
+}
+
 #endif /*ITemporaryQueue_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/ITemporaryTopic.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/ITemporaryTopic.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/ITemporaryTopic.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/ITemporaryTopic.hpp Tue Feb 21 15:28:33 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 ITemporaryTopic_hpp_
-#define ITemporaryTopic_hpp_
-
-#include <string>
-#include "IDestination.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-
-/*
- * 
- */
-struct ITemporaryTopic : IDestination
-{
-} ;
-
-/* namespace */
-    }
-  }
-}
-
+/*
+ * 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 ITemporaryTopic_hpp_
+#define ITemporaryTopic_hpp_
+
+#include <string>
+#include "IDestination.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+
+/*
+ * 
+ */
+struct ITemporaryTopic : IDestination
+{
+} ;
+
+/* namespace */
+    }
+  }
+}
+
 #endif /*ITemporaryTopic_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/ITextMessage.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/ITextMessage.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/ITextMessage.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/ITextMessage.hpp Tue Feb 21 15:28:33 2006
@@ -1,45 +1,45 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#ifndef ITextMessage_hpp_
-#define ITextMessage_hpp_
-
-#include <string>
-#include "IMessage.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-        using namespace std;
-
-/*
- * 
- */
-struct ITextMessage : IMessage
-{
-    virtual string* getText() = 0 ;
-    virtual void setText(string* txt) = 0 ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
+/*
+ * 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 ITextMessage_hpp_
+#define ITextMessage_hpp_
+
+#include <string>
+#include "IMessage.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+        using namespace std;
+
+/*
+ * 
+ */
+struct ITextMessage : IMessage
+{
+    virtual string* getText() = 0 ;
+    virtual void setText(string* txt) = 0 ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
 #endif /*ITextMessage_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/ITopic.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/ITopic.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/ITopic.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/ITopic.hpp Tue Feb 21 15:28:33 2006
@@ -1,47 +1,47 @@
-/*
- * 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 ITopic_hpp_
-#define ITopic_hpp_
-
-#include <string>
-#include "IDestination.hpp"
-#include "util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      using namespace ifr;
-      using namespace std;
-
-/*
- * 
- */
-struct ITopic : IDestination
-{
-    virtual p<string> getTopicName() = 0 ;
-    virtual void setTopicName(const char* name) = 0 ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
+/*
+ * 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 ITopic_hpp_
+#define ITopic_hpp_
+
+#include <string>
+#include "IDestination.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      using namespace ifr;
+      using namespace std;
+
+/*
+ * 
+ */
+struct ITopic : IDestination
+{
+    virtual p<string> getTopicName() = 0 ;
+    virtual void setTopicName(const char* name) = 0 ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
 #endif /*ITopic_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/MessageConsumer.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/MessageConsumer.cpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/MessageConsumer.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/MessageConsumer.cpp Tue Feb 21 15:28:33 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.
- */
-#include "MessageConsumer.hpp"
-
-using namespace apache::activemq::client;
-
-/*
- * 
- */
-MessageConsumer::MessageConsumer(p<Session> session, p<ConsumerInfo> producerInfo)
-{
-    this->session      = session ;
-    this->consumerInfo = consumerInfo ;
-    this->closed       = false ;
-}
-
-MessageConsumer::~MessageConsumer()
-{
-    session->disposeOf( consumerInfo->getConsumerId() ) ;
-}
-
-p<IMessage> MessageConsumer::receive()
-{
-    checkClosed() ;
-    // TODO
-    return NULL ;
-}
-
-p<IMessage> MessageConsumer::receiveNoWait()
-{
-    checkClosed() ;
-    // TODO
-    return NULL ;
-}
-
-// Implementation methods ------------------------------------------------
-
-void MessageConsumer::checkClosed() throw(OpenWireException) 
-{
-    if( closed )
-        throw new ConnectionClosedException("Oops! Connection already closed") ;
-}
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "MessageConsumer.hpp"
+
+using namespace apache::activemq::client;
+
+/*
+ * 
+ */
+MessageConsumer::MessageConsumer(p<Session> session, p<ConsumerInfo> producerInfo)
+{
+    this->session      = session ;
+    this->consumerInfo = consumerInfo ;
+    this->closed       = false ;
+}
+
+MessageConsumer::~MessageConsumer()
+{
+    session->disposeOf( consumerInfo->getConsumerId() ) ;
+}
+
+p<IMessage> MessageConsumer::receive()
+{
+    checkClosed() ;
+    // TODO
+    return NULL ;
+}
+
+p<IMessage> MessageConsumer::receiveNoWait()
+{
+    checkClosed() ;
+    // TODO
+    return NULL ;
+}
+
+// Implementation methods ------------------------------------------------
+
+void MessageConsumer::checkClosed() throw(OpenWireException) 
+{
+    if( closed )
+        throw new ConnectionClosedException("Oops! Connection already closed") ;
+}

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

Modified: incubator/activemq/trunk/openwire-cpp/src/MessageConsumer.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/MessageConsumer.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/MessageConsumer.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/MessageConsumer.hpp Tue Feb 21 15:28:33 2006
@@ -1,74 +1,74 @@
-/*
- * 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 MessageConsumer_hpp_
-#define MessageConsume_hpp_
-
-#include <string>
-#include "IDestination.hpp"
-#include "IMessage.hpp"
-#include "IMessageConsumer.hpp"
-#include "Session.hpp"
-#include "OpenWireException.hpp"
-#include "ConnectionClosedException.hpp"
-#include "command/ConsumerInfo.hpp"
-#include "util/ifr/p"
-
-// Turn off warning message for ignored exception specification
-#ifdef _MSC_VER
-#pragma warning( disable : 4290 )
-#endif
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      using namespace ifr;
-
-/*
- * 
- */
-class MessageConsumer : public IMessageConsumer
-{
-private:
-    p<Session>      session ;
-    p<ConsumerInfo> consumerInfo ;
-    bool            closed ;
-
-public:
-    MessageConsumer(p<Session> session, p<ConsumerInfo> consumerInfo) ;
-    ~MessageConsumer() ;
-
-    /* TODO
-    virtual void setMessageListener(p<IMessageListener> listener) ;
-    virtual p<IMessageListener> getMessageListener() ;
-    */
-
-    virtual p<IMessage> receive() ;
-    virtual p<IMessage> receiveNoWait() ;
-
-protected:
-    void checkClosed() throw(OpenWireException) ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
+/*
+ * 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 MessageConsumer_hpp_
+#define MessageConsume_hpp_
+
+#include <string>
+#include "IDestination.hpp"
+#include "IMessage.hpp"
+#include "IMessageConsumer.hpp"
+#include "Session.hpp"
+#include "OpenWireException.hpp"
+#include "ConnectionClosedException.hpp"
+#include "command/ConsumerInfo.hpp"
+#include "util/ifr/p"
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      using namespace ifr;
+
+/*
+ * 
+ */
+class MessageConsumer : public IMessageConsumer
+{
+private:
+    p<Session>      session ;
+    p<ConsumerInfo> consumerInfo ;
+    bool            closed ;
+
+public:
+    MessageConsumer(p<Session> session, p<ConsumerInfo> consumerInfo) ;
+    ~MessageConsumer() ;
+
+    /* TODO
+    virtual void setMessageListener(p<IMessageListener> listener) ;
+    virtual p<IMessageListener> getMessageListener() ;
+    */
+
+    virtual p<IMessage> receive() ;
+    virtual p<IMessage> receiveNoWait() ;
+
+protected:
+    void checkClosed() throw(OpenWireException) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
 #endif /*IMessageConsumer_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/MessageProducer.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/MessageProducer.cpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/MessageProducer.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/MessageProducer.cpp Tue Feb 21 15:28:33 2006
@@ -1,43 +1,43 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#include "MessageProducer.hpp"
-
-using namespace apache::activemq::client;
-
-/*
- * 
- */
-MessageProducer::MessageProducer(p<Session> session, p<ProducerInfo> producerInfo)
-{
-    this->session      = session ;
-    this->producerInfo = producerInfo ;
-}
-
-MessageProducer::~MessageProducer()
-{
-    session->disposeOf( producerInfo->getProducerId() ) ;
-}
-
-void MessageProducer::send(p<IMessage> message)
-{
-    send(producerInfo->getDestination(), message) ;
-}
-
-void MessageProducer::send(p<IDestination> destination, p<IMessage> message)
-{
-    session->doSend(destination, message) ;
-}
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "MessageProducer.hpp"
+
+using namespace apache::activemq::client;
+
+/*
+ * 
+ */
+MessageProducer::MessageProducer(p<Session> session, p<ProducerInfo> producerInfo)
+{
+    this->session      = session ;
+    this->producerInfo = producerInfo ;
+}
+
+MessageProducer::~MessageProducer()
+{
+    session->disposeOf( producerInfo->getProducerId() ) ;
+}
+
+void MessageProducer::send(p<IMessage> message)
+{
+    send(producerInfo->getDestination(), message) ;
+}
+
+void MessageProducer::send(p<IDestination> destination, p<IMessage> message)
+{
+    session->doSend(destination, message) ;
+}

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

Modified: incubator/activemq/trunk/openwire-cpp/src/MessageProducer.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/MessageProducer.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/MessageProducer.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/MessageProducer.hpp Tue Feb 21 15:28:33 2006
@@ -1,58 +1,58 @@
-/*
- * 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 MessageProducer_hpp_
-#define MessageProducer_hpp_
-
-#include <string>
-#include "IDestination.hpp"
-#include "IMessage.hpp"
-#include "IMessageProducer.hpp"
-#include "Session.hpp"
-#include "command/ProducerInfo.hpp"
-#include "util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      using namespace ifr;
-
-/*
- * 
- */
-class MessageProducer : public IMessageProducer
-{
-private:
-    p<Session>      session ;
-    p<ProducerInfo> producerInfo ;
-
-public:
-    MessageProducer(p<Session> session, p<ProducerInfo> producerInfo) ;
-    ~MessageProducer() ;
-
-    virtual void send(p<IMessage> message) ;
-    virtual void send(p<IDestination> destination, p<IMessage> message) ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
+/*
+ * 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 MessageProducer_hpp_
+#define MessageProducer_hpp_
+
+#include <string>
+#include "IDestination.hpp"
+#include "IMessage.hpp"
+#include "IMessageProducer.hpp"
+#include "Session.hpp"
+#include "command/ProducerInfo.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      using namespace ifr;
+
+/*
+ * 
+ */
+class MessageProducer : public IMessageProducer
+{
+private:
+    p<Session>      session ;
+    p<ProducerInfo> producerInfo ;
+
+public:
+    MessageProducer(p<Session> session, p<ProducerInfo> producerInfo) ;
+    ~MessageProducer() ;
+
+    virtual void send(p<IMessage> message) ;
+    virtual void send(p<IDestination> destination, p<IMessage> message) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
 #endif /*IMessageProducer_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/OpenWireException.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/OpenWireException.cpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/OpenWireException.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/OpenWireException.cpp Tue Feb 21 15:28:33 2006
@@ -1,33 +1,33 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#include "OpenWireException.hpp"
-
-using namespace apache::activemq::client;
-
-/*
- * 
- */
-OpenWireException::OpenWireException(const char* message)
-    : exception(message) 
-{
-    // no-op
-}
-
-OpenWireException::~OpenWireException()
-{
-    // no-op
-}
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "OpenWireException.hpp"
+
+using namespace apache::activemq::client;
+
+/*
+ * 
+ */
+OpenWireException::OpenWireException(const char* message)
+    : exception(message) 
+{
+    // no-op
+}
+
+OpenWireException::~OpenWireException()
+{
+    // no-op
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/OpenWireException.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/OpenWireException.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/OpenWireException.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/OpenWireException.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/OpenWireException.hpp Tue Feb 21 15:28:33 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 OpenWireException_hpp_
-#define OpenWireException_hpp_
-
-#include <exception>
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-
-/*
- * 
- */
-class OpenWireException : public exception
-{
-public:
-    OpenWireException(const char* message) ;
-    ~OpenWireException() ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
+/*
+ * 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 OpenWireException_hpp_
+#define OpenWireException_hpp_
+
+#include <exception>
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+
+/*
+ * 
+ */
+class OpenWireException : public exception
+{
+public:
+    OpenWireException(const char* message) ;
+    ~OpenWireException() ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
 #endif /*OpenWireException_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/Session.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/Session.cpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/Session.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/Session.cpp Tue Feb 21 15:28:33 2006
@@ -1,150 +1,150 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#include "Session.hpp"
-#include "command/ActiveMQQueue.hpp"
-#include "command/ActiveMQTopic.hpp"
-#include "command/ActiveMQMessage.hpp"
-#include "command/ActiveMQTextMessage.hpp"
-#include "command/ProducerInfo.hpp"
-#include "command/ConsumerInfo.hpp"
-#include "command/MessageAck.hpp"
-#include "MessageConsumer.hpp"
-#include "MessageProducer.hpp"
-#include "Connection.hpp"
-
-using namespace apache::activemq::client;
-
-/*
- * 
- */
-Session::Session(p<Connection> connection, p<SessionInfo> info)
-{
-    this->connection  = connection ;
-    this->sessionInfo = info ;
-}
-
-Session::~Session()
-{
-    // De-activate session
-    disposeOf(sessionInfo->getSessionId()) ;  //(IDataStructure*)
-}
-
-p<IMessageProducer> Session::createProducer()
-{
-    return createProducer(NULL) ; 
-}
-
-p<IMessageProducer> Session::createProducer(p<IDestination> destination)
-{
-    p<ProducerInfo> command = createProducerInfo(destination) ;
-    connection->syncRequest(command) ;  //(ICommand*)
-    p<IMessageProducer> messageProducer = new MessageProducer(this, command) ;
-    return messageProducer ;
-}
-
-void Session::acknowledge(p<IMessage> message)
-{
-    if( ackMode == ClientMode )
-    {
-        p<MessageAck> msgAck = new MessageAck() ;
-        // TODO complete packet
-        connection->syncRequest(msgAck) ;  //(ICommand*)
-    } 
-}
-
-p<IMessageConsumer> Session::createConsumer(p<IDestination> destination)
-{
-    return createConsumer(destination, NULL) ; 
-}
-
-p<IMessageConsumer> Session::createConsumer(p<IDestination> destination, const char* selector)
-{
-    p<ConsumerInfo> command = createConsumerInfo(destination, selector) ;
-    connection->syncRequest(command) ;  //(ICommand*)
-    p<IMessageConsumer> messageConsumer = new MessageConsumer(this, command) ; 
-    return messageConsumer ;
-}
-
-p<IQueue> Session::getQueue(const char* name)
-{
-    p<IQueue> queue = (IQueue*)new ActiveMQQueue(name) ;
-    return queue ;
-}
-
-p<ITopic> Session::getTopic(const char* name)
-{
-    p<ITopic> topic = (ITopic*)new ActiveMQTopic(name) ;
-    return topic ;
-}
-
-p<IMessage> Session::createMessage()
-{
-    p<IMessage> message = (IMessage*)new ActiveMQMessage() ;
-    return message ;
-}
-
-p<ITextMessage> Session::createTextMessage()
-{
-    p<ITextMessage> message = (ITextMessage*)new ActiveMQTextMessage() ;
-    return message ;
-}
-
-p<ITextMessage> Session::createTextMessage(const char* text)
-{
-    p<ITextMessage> message = (ITextMessage*)new ActiveMQTextMessage(text) ;
-    return message ;
-}
-
-void Session::doSend(p<IDestination> destination, p<IMessage> message)
-{
-    p<ActiveMQMessage> command = ActiveMQMessage::transform(message) ;
-    // TODO complete packet
-    connection->syncRequest(command) ; //(ICommand*)
-}
-
-void Session::disposeOf(p<IDataStructure> objectId)
-{
-    p<RemoveInfo> command = new RemoveInfo() ;
-    command->setObjectId( objectId ) ;
-
-    connection->syncRequest(command) ;  //(ICommand*)
-}
-
-// Implementation methods ------------------------------------------
-
-p<ConsumerInfo> Session::createConsumerInfo(p<IDestination> destination, const char* selector)
-{
-    p<ConsumerInfo> consumerInfo = new ConsumerInfo() ;
-    p<ConsumerId> consumerId = new ConsumerId() ;
-    consumerId->setSessionId( sessionInfo->getSessionId()->getValue() ) ;
-
-    mutex.lock() ;
-    consumerId->setValue( ++consumerCounter ) ;
-    mutex.unlock() ;
-
-    // TODO complete packet
-    consumerInfo->setConsumerId( consumerId ) ;
-
-    return consumerInfo ;
-}
-
-p<ProducerInfo> Session::createProducerInfo(p<IDestination> destination)
-{
-    p<ProducerInfo> producerInfo = new ProducerInfo() ;
-    // TODO complete packet
-    return producerInfo ;
-} 
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "Session.hpp"
+#include "command/ActiveMQQueue.hpp"
+#include "command/ActiveMQTopic.hpp"
+#include "command/ActiveMQMessage.hpp"
+#include "command/ActiveMQTextMessage.hpp"
+#include "command/ProducerInfo.hpp"
+#include "command/ConsumerInfo.hpp"
+#include "command/MessageAck.hpp"
+#include "MessageConsumer.hpp"
+#include "MessageProducer.hpp"
+#include "Connection.hpp"
+
+using namespace apache::activemq::client;
+
+/*
+ * 
+ */
+Session::Session(p<Connection> connection, p<SessionInfo> info)
+{
+    this->connection  = connection ;
+    this->sessionInfo = info ;
+}
+
+Session::~Session()
+{
+    // De-activate session
+    disposeOf(sessionInfo->getSessionId()) ;  //(IDataStructure*)
+}
+
+p<IMessageProducer> Session::createProducer()
+{
+    return createProducer(NULL) ; 
+}
+
+p<IMessageProducer> Session::createProducer(p<IDestination> destination)
+{
+    p<ProducerInfo> command = createProducerInfo(destination) ;
+    connection->syncRequest(command) ;  //(ICommand*)
+    p<IMessageProducer> messageProducer = new MessageProducer(this, command) ;
+    return messageProducer ;
+}
+
+void Session::acknowledge(p<IMessage> message)
+{
+    if( ackMode == ClientMode )
+    {
+        p<MessageAck> msgAck = new MessageAck() ;
+        // TODO complete packet
+        connection->syncRequest(msgAck) ;  //(ICommand*)
+    } 
+}
+
+p<IMessageConsumer> Session::createConsumer(p<IDestination> destination)
+{
+    return createConsumer(destination, NULL) ; 
+}
+
+p<IMessageConsumer> Session::createConsumer(p<IDestination> destination, const char* selector)
+{
+    p<ConsumerInfo> command = createConsumerInfo(destination, selector) ;
+    connection->syncRequest(command) ;  //(ICommand*)
+    p<IMessageConsumer> messageConsumer = new MessageConsumer(this, command) ; 
+    return messageConsumer ;
+}
+
+p<IQueue> Session::getQueue(const char* name)
+{
+    p<IQueue> queue = (IQueue*)new ActiveMQQueue(name) ;
+    return queue ;
+}
+
+p<ITopic> Session::getTopic(const char* name)
+{
+    p<ITopic> topic = (ITopic*)new ActiveMQTopic(name) ;
+    return topic ;
+}
+
+p<IMessage> Session::createMessage()
+{
+    p<IMessage> message = (IMessage*)new ActiveMQMessage() ;
+    return message ;
+}
+
+p<ITextMessage> Session::createTextMessage()
+{
+    p<ITextMessage> message = (ITextMessage*)new ActiveMQTextMessage() ;
+    return message ;
+}
+
+p<ITextMessage> Session::createTextMessage(const char* text)
+{
+    p<ITextMessage> message = (ITextMessage*)new ActiveMQTextMessage(text) ;
+    return message ;
+}
+
+void Session::doSend(p<IDestination> destination, p<IMessage> message)
+{
+    p<ActiveMQMessage> command = ActiveMQMessage::transform(message) ;
+    // TODO complete packet
+    connection->syncRequest(command) ; //(ICommand*)
+}
+
+void Session::disposeOf(p<IDataStructure> objectId)
+{
+    p<RemoveInfo> command = new RemoveInfo() ;
+    command->setObjectId( objectId ) ;
+
+    connection->syncRequest(command) ;  //(ICommand*)
+}
+
+// Implementation methods ------------------------------------------
+
+p<ConsumerInfo> Session::createConsumerInfo(p<IDestination> destination, const char* selector)
+{
+    p<ConsumerInfo> consumerInfo = new ConsumerInfo() ;
+    p<ConsumerId> consumerId = new ConsumerId() ;
+    consumerId->setSessionId( sessionInfo->getSessionId()->getValue() ) ;
+
+    mutex.lock() ;
+    consumerId->setValue( ++consumerCounter ) ;
+    mutex.unlock() ;
+
+    // TODO complete packet
+    consumerInfo->setConsumerId( consumerId ) ;
+
+    return consumerInfo ;
+}
+
+p<ProducerInfo> Session::createProducerInfo(p<IDestination> destination)
+{
+    p<ProducerInfo> producerInfo = new ProducerInfo() ;
+    // TODO complete packet
+    return producerInfo ;
+} 

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

Modified: incubator/activemq/trunk/openwire-cpp/src/Session.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/Session.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/Session.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/Session.hpp Tue Feb 21 15:28:33 2006
@@ -1,81 +1,81 @@
-/*
- * 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 Session_hpp_
-#define Session_hpp_
-
-#include <string>
-#include "IMessage.hpp"
-#include "ISession.hpp"
-#include "command/IDataStructure.hpp"
-#include "command/ConsumerInfo.hpp"
-#include "command/ProducerInfo.hpp"
-#include "command/RemoveInfo.hpp"
-#include "command/SessionInfo.hpp"
-#include "util/SimpleMutex.hpp"
-#include "util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-        using namespace ifr;
-        using namespace apache::activemq::client::util;
-        class Connection;
-        enum  AcknowledgementMode;
-
-/*
- * 
- */
-class Session : public ISession
-{
-private:
-    p<Connection>       connection ;
-    p<SessionInfo>      sessionInfo ;
-    AcknowledgementMode ackMode ;
-    long                consumerCounter ;
-    SimpleMutex         mutex ;
-
-public:
-    Session(p<Connection> connection, p<SessionInfo> sessionInfo) ;
-    ~Session() ;
-    
-    virtual p<IMessageProducer> createProducer() ;
-    virtual p<IMessageProducer> createProducer(p<IDestination> destination) ;
-    virtual p<IMessageConsumer> createConsumer(p<IDestination> destination) ;
-    virtual p<IMessageConsumer> createConsumer(p<IDestination> destination, const char* selector) ;
-    virtual p<IQueue> getQueue(const char* name) ;
-    virtual p<ITopic> getTopic(const char* name) ;
-    virtual p<IMessage> createMessage() ;
-    virtual p<ITextMessage> createTextMessage() ;
-    virtual p<ITextMessage> createTextMessage(const char* text) ;
-    virtual void acknowledge(p<IMessage> message) ;
-    virtual void doSend(p<IDestination> destination, p<IMessage> message) ;
-    virtual void disposeOf(p<IDataStructure> objectId) ;
-
-protected:
-    p<ConsumerInfo> createConsumerInfo(p<IDestination> destination, const char* selector) ;
-    p<ProducerInfo> createProducerInfo(p<IDestination> destination) ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
-#endif /*Session_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 Session_hpp_
+#define Session_hpp_
+
+#include <string>
+#include "IMessage.hpp"
+#include "ISession.hpp"
+#include "command/IDataStructure.hpp"
+#include "command/ConsumerInfo.hpp"
+#include "command/ProducerInfo.hpp"
+#include "command/RemoveInfo.hpp"
+#include "command/SessionInfo.hpp"
+#include "util/SimpleMutex.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+        using namespace ifr;
+        using namespace apache::activemq::client::util;
+        class Connection;
+        enum  AcknowledgementMode;
+
+/*
+ * 
+ */
+class Session : public ISession
+{
+private:
+    p<Connection>       connection ;
+    p<SessionInfo>      sessionInfo ;
+    AcknowledgementMode ackMode ;
+    long                consumerCounter ;
+    SimpleMutex         mutex ;
+
+public:
+    Session(p<Connection> connection, p<SessionInfo> sessionInfo) ;
+    ~Session() ;
+    
+    virtual p<IMessageProducer> createProducer() ;
+    virtual p<IMessageProducer> createProducer(p<IDestination> destination) ;
+    virtual p<IMessageConsumer> createConsumer(p<IDestination> destination) ;
+    virtual p<IMessageConsumer> createConsumer(p<IDestination> destination, const char* selector) ;
+    virtual p<IQueue> getQueue(const char* name) ;
+    virtual p<ITopic> getTopic(const char* name) ;
+    virtual p<IMessage> createMessage() ;
+    virtual p<ITextMessage> createTextMessage() ;
+    virtual p<ITextMessage> createTextMessage(const char* text) ;
+    virtual void acknowledge(p<IMessage> message) ;
+    virtual void doSend(p<IDestination> destination, p<IMessage> message) ;
+    virtual void disposeOf(p<IDataStructure> objectId) ;
+
+protected:
+    p<ConsumerInfo> createConsumerInfo(p<IDestination> destination, const char* selector) ;
+    p<ProducerInfo> createProducerInfo(p<IDestination> destination) ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
+#endif /*Session_hpp_*/

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

Modified: incubator/activemq/trunk/openwire-cpp/src/TraceException.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/TraceException.cpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/TraceException.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/TraceException.cpp Tue Feb 21 15:28:33 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.
- */
-#include "TraceException.hpp"
-
-using namespace apache::activemq::client;
-
-/*
- * 
- */
-TraceException::TraceException()
-   : exception()
-{
-    // no-op
-} ;
-
-/*
- * 
- */
-TraceException::TraceException(const char* msg)
-   : exception(msg)
-{
-    // no-op
-} ;
-
-/*
- * 
- */
-TraceException::TraceException(const char* fileName, int lineNo, const char* message)
-    : exception(message)
-{
-    char buf[10] ;
-
-    trace = new string() ;
-    trace->append(fileName) ;
-    trace->append(" at ") ;
-    trace->append( itoa(lineNo, buf, 10) ) ;
-}
-
-TraceException::~TraceException()
-{
-    // no-op
-}
-
-p<string> TraceException::where()
-{
-    return trace ;
-}
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "TraceException.hpp"
+
+using namespace apache::activemq::client;
+
+/*
+ * 
+ */
+TraceException::TraceException()
+   : exception()
+{
+    // no-op
+} ;
+
+/*
+ * 
+ */
+TraceException::TraceException(const char* msg)
+   : exception(msg)
+{
+    // no-op
+} ;
+
+/*
+ * 
+ */
+TraceException::TraceException(const char* fileName, int lineNo, const char* message)
+    : exception(message)
+{
+    char buf[10] ;
+
+    trace = new string() ;
+    trace->append(fileName) ;
+    trace->append(" at ") ;
+    trace->append( itoa(lineNo, buf, 10) ) ;
+}
+
+TraceException::~TraceException()
+{
+    // no-op
+}
+
+p<string> TraceException::where()
+{
+    return trace ;
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/TraceException.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/TraceException.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/TraceException.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/TraceException.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/TraceException.hpp Tue Feb 21 15:28:33 2006
@@ -1,54 +1,54 @@
-/*
- * 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 TraceException_hpp_
-#define TraceException_hpp_
-
-#include <exception>
-#include <string>
-#include "util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      using namespace std ;
-      using namespace ifr ;
-
-/*
- * Base class for all exceptions containing trace information.
- */
-class TraceException : public exception
-{
-    p<string> trace ;
-
-public:
-    TraceException() ;
-    TraceException(const char* msg) ;
-    TraceException(const char* fileName, int lineNo, const char* msg) ;
-    virtual ~TraceException() ;
-
-    p<string> where() ;
-} ;
-
-/* namespace */
-    }
-  }
-}
-
+/*
+ * 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 TraceException_hpp_
+#define TraceException_hpp_
+
+#include <exception>
+#include <string>
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      using namespace std ;
+      using namespace ifr ;
+
+/*
+ * Base class for all exceptions containing trace information.
+ */
+class TraceException : public exception
+{
+    p<string> trace ;
+
+public:
+    TraceException() ;
+    TraceException(const char* msg) ;
+    TraceException(const char* fileName, int lineNo, const char* msg) ;
+    virtual ~TraceException() ;
+
+    p<string> where() ;
+} ;
+
+/* namespace */
+    }
+  }
+}
+
 #endif /*TraceException_hpp_*/

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