activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r920034 - in /activemq/activemq-cpp/trunk/activemq-cpp-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/commands: MessageHeaderGenerator.java MessageSourceGenerator.java
Date Sun, 07 Mar 2010 16:59:29 GMT
Author: tabish
Date: Sun Mar  7 16:59:29 2010
New Revision: 920034

URL: http://svn.apache.org/viewvc?rev=920034&view=rev
Log:
http://issues.apache.org/activemq/browse/AMQCPP-287

Move pointer to the ActiveMQConnection down to the Message class in Commands.

Modified:
    activemq/activemq-cpp/trunk/activemq-cpp-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/commands/MessageHeaderGenerator.java
    activemq/activemq-cpp/trunk/activemq-cpp-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/commands/MessageSourceGenerator.java

Modified: activemq/activemq-cpp/trunk/activemq-cpp-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/commands/MessageHeaderGenerator.java
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/commands/MessageHeaderGenerator.java?rev=920034&r1=920033&r2=920034&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/commands/MessageHeaderGenerator.java
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/commands/MessageHeaderGenerator.java
Sun Mar  7 16:59:29 2010
@@ -34,6 +34,7 @@
         out.println("namespace activemq{");
         out.println("namespace core{");
         out.println("    class ActiveMQAckHandler;");
+        out.println("    class ActiveMQConnection;");
         out.println("}");
         out.println("namespace commands{");
         out.println("");
@@ -59,6 +60,8 @@
         out.println("");
         out.println("    protected:");
         out.println("");
+        out.println("        core::ActiveMQConnection* connection;");
+        out.println("");
         out.println("        static const unsigned int DEFAULT_MESSAGE_SIZE = 1024;");
         out.println("");
 
@@ -114,6 +117,24 @@
         out.println("        }");
         out.println("");
         out.println("        /**");
+        out.println("         * Sets the ActiveMQConnection instance that this Command was
created from");
+        out.println("         * when the session create methods are called to create a Message..");
+        out.println("         * @param handler ActiveMQConnection parent for this message");
+        out.println("         */");
+        out.println("        void setConnection( core::ActiveMQConnection* connection ) {");
+        out.println("            this->connection = connection;");
+        out.println("        }");
+        out.println("");
+        out.println("        /**");
+        out.println("         * Gets the ActiveMQConnection instance that this Command was
created from");
+        out.println("         * when the session create methods are called to create a Message..");
+        out.println("         * @returns the ActiveMQConnection parent for this Message or
NULL if not set.");
+        out.println("         */");
+        out.println("        core::ActiveMQConnection* getConnection() const {");
+        out.println("            return this->connection;");
+        out.println("        }");
+        out.println("");
+        out.println("        /**");
         out.println("         * Returns the Size of this message in Bytes.");
         out.println("         * @returns number of bytes this message equates to.");
         out.println("         */");

Modified: activemq/activemq-cpp/trunk/activemq-cpp-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/commands/MessageSourceGenerator.java
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/commands/MessageSourceGenerator.java?rev=920034&r1=920033&r2=920034&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/commands/MessageSourceGenerator.java
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp-openwire-generator/src/main/java/org/apache/activemq/openwire/tool/commands/MessageSourceGenerator.java
Sun Mar  7 16:59:29 2010
@@ -26,6 +26,8 @@
         Set<String> includes = getIncludeFiles();
         includes.add("<activemq/wireformat/openwire/marshal/BaseDataStreamMarshaller.h>");
         includes.add("<activemq/wireformat/openwire/marshal/PrimitiveTypesMarshaller.h>");
+        includes.add("<activemq/core/ActiveMQAckHandler.h>");
+        includes.add("<activemq/core/ActiveMQConnection.h>");
         includes.add("<decaf/lang/System.h>");
     }
 
@@ -33,6 +35,7 @@
 
         out.println("    this->readOnlyBody = false;");
         out.println("    this->readOnlyProperties = false;");
+        out.println("    this->connection = NULL;");
 
         super.generateDefaultConstructorBody(out);
     }
@@ -44,6 +47,7 @@
         out.println("    this->setAckHandler( srcPtr->getAckHandler() );");
         out.println("    this->setReadOnlyBody( srcPtr->isReadOnlyBody() );");
         out.println("    this->setReadOnlyProperties( srcPtr->isReadOnlyProperties()
);");
+        out.println("    this->setConnection( srcPtr->getConnection() );");
     }
 
     protected void generateToStringBody( PrintWriter out ) {



Mime
View raw message