activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r383296 [1/5] - in /incubator/activemq/trunk: activemq-core/ activemq-core/src/gram/java/org/apache/activemq/openwire/tool/ activemq-core/src/gram/script/ activemq-core/src/main/java/org/apache/activemq/openwire/v1/ activemq-core/src/test/j...
Date Sun, 05 Mar 2006 08:49:19 GMT
Author: chirino
Date: Sun Mar  5 00:49:13 2006
New Revision: 383296

URL: http://svn.apache.org/viewcvs?rev=383296&view=rev
Log:
Updated openwire generation scripts so that they produce file with consistent newlines even on windows.
Updated dotnet generator due to refactor

Added:
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/BrokerException.cs
Modified:
    incubator/activemq/trunk/activemq-core/project.xml
    incubator/activemq/trunk/activemq-core/src/gram/java/org/apache/activemq/openwire/tool/OpenWireCSharpClassesScript.java
    incubator/activemq/trunk/activemq-core/src/gram/java/org/apache/activemq/openwire/tool/OpenWireCSharpMarshallingScript.java
    incubator/activemq/trunk/activemq-core/src/gram/java/org/apache/activemq/openwire/tool/OpenWireClassesScript.java
    incubator/activemq/trunk/activemq-core/src/gram/script/GenerateCSharpClasses.groovy
    incubator/activemq/trunk/activemq-core/src/gram/script/GenerateCSharpMarshalling.groovy
    incubator/activemq/trunk/activemq-core/src/gram/script/GenerateJavaTests.groovy
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConsumerInfoMarshaller.java
    incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConsumerInfoTest.java
    incubator/activemq/trunk/etc/project.properties
    incubator/activemq/trunk/openwire-c/src/libopenwire/ow_commands_v1.c
    incubator/activemq/trunk/openwire-c/src/libopenwire/ow_commands_v1.h
    incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQObjectMessage.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/ConnectionError.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/ConsumerInfo.cpp
    incubator/activemq/trunk/openwire-cpp/src/command/ConsumerInfo.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/ControlCommand.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/DataArrayResponse.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/DataResponse.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/DestinationInfo.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/DiscoveryEvent.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/FlushCommand.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/IntegerResponse.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/JournalQueueAck.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/JournalTopicAck.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/JournalTrace.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/JournalTransaction.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/KeepAliveInfo.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/LocalTransactionId.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/MessageDispatch.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/MessageDispatchNotification.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/MessageId.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/RemoveSubscriptionInfo.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/ShutdownInfo.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/SubscriptionInfo.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/TransactionId.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/TransactionInfo.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/WireFormatInfo.hpp
    incubator/activemq/trunk/openwire-cpp/src/command/XATransactionId.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQBytesMessageMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQDestinationMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQMapMessageMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQMessageMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQObjectMessageMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQQueueMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQStreamMessageMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempDestinationMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempQueueMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTempTopicMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTextMessageMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ActiveMQTopicMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/BaseCommandMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionErrorMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionIdMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ConnectionInfoMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerIdMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerInfoMarshaller.cpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ConsumerInfoMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ControlCommandMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/DataArrayResponseMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/DataResponseMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/DestinationInfoMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/DiscoveryEventMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ExceptionResponseMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/FlushCommandMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/IntegerResponseMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/JournalQueueAckMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerInfoMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveInfoMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveSubscriptionInfoMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ResponseMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/SessionIdMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/SessionInfoMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionInfoMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/WireFormatInfoMarshaller.hpp
    incubator/activemq/trunk/openwire-cpp/src/marshal/XATransactionIdMarshaller.hpp

Modified: incubator/activemq/trunk/activemq-core/project.xml
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/project.xml?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/project.xml (original)
+++ incubator/activemq/trunk/activemq-core/project.xml Sun Mar  5 00:49:13 2006
@@ -261,6 +261,11 @@
             <artifactId>annogen</artifactId>
             <version>0.1.0</version>
         </dependency>
+        <dependency>
+            <groupId>ant</groupId>
+            <artifactId>ant</artifactId>
+            <version>${ant_version}</version>
+        </dependency>
         
         <!-- Axion SQL DB used for testing JDBC message store -->
         <dependency>

Modified: incubator/activemq/trunk/activemq-core/src/gram/java/org/apache/activemq/openwire/tool/OpenWireCSharpClassesScript.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/gram/java/org/apache/activemq/openwire/tool/OpenWireCSharpClassesScript.java?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/gram/java/org/apache/activemq/openwire/tool/OpenWireCSharpClassesScript.java (original)
+++ incubator/activemq/trunk/activemq-core/src/gram/java/org/apache/activemq/openwire/tool/OpenWireCSharpClassesScript.java Sun Mar  5 00:49:13 2006
@@ -31,7 +31,7 @@
     public Object run() {
         filePostFix = ".cs";
         if (destDir == null) {
-            destDir = new File("../openwire-dotnet/src/OpenWire.Client/Commands");
+            destDir = new File("../openwire-dotnet/src/ActiveMQ/Commands");
         }
         
         return super.run();

Modified: incubator/activemq/trunk/activemq-core/src/gram/java/org/apache/activemq/openwire/tool/OpenWireCSharpMarshallingScript.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/gram/java/org/apache/activemq/openwire/tool/OpenWireCSharpMarshallingScript.java?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/gram/java/org/apache/activemq/openwire/tool/OpenWireCSharpMarshallingScript.java (original)
+++ incubator/activemq/trunk/activemq-core/src/gram/java/org/apache/activemq/openwire/tool/OpenWireCSharpMarshallingScript.java Sun Mar  5 00:49:13 2006
@@ -33,7 +33,7 @@
     public Object run() {
         filePostFix = ".cs";
         if (destDir == null) {
-            destDir = new File("../openwire-dotnet/src/OpenWire.Client/IO");
+            destDir = new File("../openwire-dotnet/src/ActiveMQ/OpenWire/V"+getOpenwireVersion());
         }
         
         return super.run();

Modified: incubator/activemq/trunk/activemq-core/src/gram/java/org/apache/activemq/openwire/tool/OpenWireClassesScript.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/gram/java/org/apache/activemq/openwire/tool/OpenWireClassesScript.java?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/gram/java/org/apache/activemq/openwire/tool/OpenWireClassesScript.java (original)
+++ incubator/activemq/trunk/activemq-core/src/gram/java/org/apache/activemq/openwire/tool/OpenWireClassesScript.java Sun Mar  5 00:49:13 2006
@@ -16,14 +16,19 @@
  */
 package org.apache.activemq.openwire.tool;
 
-import org.codehaus.jam.JClass;
-import org.codehaus.jam.JProperty;
-import org.codehaus.jam.JamClassIterator;
-
 import java.io.File;
 import java.io.FileWriter;
 import java.io.PrintWriter;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Set;
+
+import org.apache.tools.ant.Project;
+import org.apache.tools.ant.taskdefs.FixCRLF;
+import org.codehaus.jam.JClass;
+import org.codehaus.jam.JProperty;
+import org.codehaus.jam.JamClassIterator;
 
 /**
  * 
@@ -110,6 +115,16 @@
                 out.close();
             }
         }
+        
+        // Use the FixCRLF Ant Task to make sure the file has consistent newlines
+        // so that SVN does not complain on checkin.
+        Project project = new Project();
+        project.init();
+        FixCRLF fixCRLF = new FixCRLF();
+        fixCRLF.setProject(project);
+        fixCRLF.setSrcdir(destFile.getParentFile());
+        fixCRLF.setIncludes(destFile.getName());
+        fixCRLF.execute();
     }
 
     protected abstract void generateFile(PrintWriter out);

Modified: incubator/activemq/trunk/activemq-core/src/gram/script/GenerateCSharpClasses.groovy
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/gram/script/GenerateCSharpClasses.groovy?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/gram/script/GenerateCSharpClasses.groovy (original)
+++ incubator/activemq/trunk/activemq-core/src/gram/script/GenerateCSharpClasses.groovy Sun Mar  5 00:49:13 2006
@@ -44,10 +44,10 @@
 using System;
 using System.Collections;
 
-using OpenWire.Client;
-using OpenWire.Client.Core;
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
 
-namespace OpenWire.Client.Commands
+namespace ActiveMQ.Commands
 {
     //
     //  Marshalling code for Open Wire Format for ${jclass.simpleName}

Modified: incubator/activemq/trunk/activemq-core/src/gram/script/GenerateCSharpMarshalling.groovy
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/gram/script/GenerateCSharpMarshalling.groovy?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/gram/script/GenerateCSharpMarshalling.groovy (original)
+++ incubator/activemq/trunk/activemq-core/src/gram/script/GenerateCSharpMarshalling.groovy Sun Mar  5 00:49:13 2006
@@ -45,12 +45,11 @@
 using System.Collections;
 using System.IO;
 
-using OpenWire.Client;
-using OpenWire.Client.Commands;
-using OpenWire.Client.Core;
-using OpenWire.Client.IO;
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.V${openwireVersion};
 
-namespace OpenWire.Client.IO
+namespace ActiveMQ.OpenWire.V${openwireVersion}
 {
   //
   //  Marshalling code for Open Wire Format for ${jclass.simpleName}
@@ -182,12 +181,11 @@
 using System.Collections;
 using System.IO;
 
-using OpenWire.Client;
-using OpenWire.Client.Commands;
-using OpenWire.Client.Core;
-using OpenWire.Client.IO;
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.V${openwireVersion};
 
-namespace OpenWire.Client.IO
+namespace ActiveMQ.OpenWire.V${openwireVersion}
 {
     public class MarshallerFactory
     {

Modified: incubator/activemq/trunk/activemq-core/src/gram/script/GenerateJavaTests.groovy
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/gram/script/GenerateJavaTests.groovy?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/gram/script/GenerateJavaTests.groovy (original)
+++ incubator/activemq/trunk/activemq-core/src/gram/script/GenerateJavaTests.groovy Sun Mar  5 00:49:13 2006
@@ -16,6 +16,8 @@
  */
 import org.apache.activemq.openwire.tool.OpenWireScript
 import org.apache.activemq.openwire.tool.TestDataGenerator
+import org.apache.tools.ant.Project;
+import org.apache.tools.ant.taskdefs.FixCRLF;
 
 /**
  * Generates the Java test code for the Open Wire Format
@@ -205,6 +207,16 @@
         }
 """
 }
+        // Use the FixCRLF Ant Task to make sure the file has consistent newlines
+        // so that SVN does not complain on checkin.
+        Project project = new Project();
+        project.init();
+        FixCRLF fixCRLF = new FixCRLF();
+        fixCRLF.setProject(project);
+        fixCRLF.setSrcdir(file.getParentFile());
+        fixCRLF.setIncludes(file.getName());
+        fixCRLF.execute();
+
 		}
     }
 }

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConsumerInfoMarshaller.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConsumerInfoMarshaller.java?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConsumerInfoMarshaller.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConsumerInfoMarshaller.java Sun Mar  5 00:49:13 2006
@@ -68,6 +68,7 @@
         info.setBrowser(bs.readBoolean());
         info.setDestination((ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
         info.setPrefetchSize(dataIn.readInt());
+        info.setMaximumPendingMessageLimit(dataIn.readInt());
         info.setDispatchAsync(bs.readBoolean());
         info.setSelector(tightUnmarshalString(dataIn, bs));
         info.setSubcriptionName(tightUnmarshalString(dataIn, bs));
@@ -103,7 +104,7 @@
     rc += tightMarshalCachedObject1(wireFormat, info.getConsumerId(), bs);
     bs.writeBoolean(info.isBrowser());
     rc += tightMarshalCachedObject1(wireFormat, info.getDestination(), bs);
-        bs.writeBoolean(info.isDispatchAsync());
+            bs.writeBoolean(info.isDispatchAsync());
     rc += tightMarshalString1(info.getSelector(), bs);
     rc += tightMarshalString1(info.getSubcriptionName(), bs);
     bs.writeBoolean(info.isNoLocal());
@@ -112,7 +113,7 @@
         rc += tightMarshalObjectArray1(wireFormat, info.getBrokerPath(), bs);
     bs.writeBoolean(info.isNetworkSubscription());
 
-        return rc + 5;
+        return rc + 9;
     }
 
     /**
@@ -130,6 +131,7 @@
     bs.readBoolean();
     tightMarshalCachedObject2(wireFormat, info.getDestination(), dataOut, bs);
     dataOut.writeInt(info.getPrefetchSize());
+    dataOut.writeInt(info.getMaximumPendingMessageLimit());
     bs.readBoolean();
     tightMarshalString2(info.getSelector(), dataOut, bs);
     tightMarshalString2(info.getSubcriptionName(), dataOut, bs);
@@ -157,6 +159,7 @@
         info.setBrowser(dataIn.readBoolean());
         info.setDestination((ActiveMQDestination) looseUnmarsalCachedObject(wireFormat, dataIn));
         info.setPrefetchSize(dataIn.readInt());
+        info.setMaximumPendingMessageLimit(dataIn.readInt());
         info.setDispatchAsync(dataIn.readBoolean());
         info.setSelector(looseUnmarshalString(dataIn));
         info.setSubcriptionName(looseUnmarshalString(dataIn));
@@ -193,6 +196,7 @@
     dataOut.writeBoolean(info.isBrowser());
     looseMarshalCachedObject(wireFormat, info.getDestination(), dataOut);
     dataOut.writeInt(info.getPrefetchSize());
+    dataOut.writeInt(info.getMaximumPendingMessageLimit());
     dataOut.writeBoolean(info.isDispatchAsync());
     looseMarshalString(info.getSelector(), dataOut);
     looseMarshalString(info.getSubcriptionName(), dataOut);

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConsumerInfoTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConsumerInfoTest.java?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConsumerInfoTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConsumerInfoTest.java Sun Mar  5 00:49:13 2006
@@ -54,6 +54,7 @@
         info.setBrowser(true);
         info.setDestination(createActiveMQDestination("Destination:2"));
         info.setPrefetchSize(1);
+        info.setMaximumPendingMessageLimit(2);
         info.setDispatchAsync(false);
         info.setSelector("Selector:3");
         info.setSubcriptionName("SubcriptionName:4");

Modified: incubator/activemq/trunk/etc/project.properties
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/etc/project.properties?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/etc/project.properties (original)
+++ incubator/activemq/trunk/etc/project.properties Sun Mar  5 00:49:13 2006
@@ -66,6 +66,7 @@
 #maven.jar.override=on
 
 <!-- used by all modules -->
+ant_version=1.6
 geronimo_spec_j2ee_version=1.4-rc4
 concurrent_version=1.3.4
 commons_logging_version=1.0.3

Modified: incubator/activemq/trunk/openwire-c/src/libopenwire/ow_commands_v1.c
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-c/src/libopenwire/ow_commands_v1.c?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-c/src/libopenwire/ow_commands_v1.c (original)
+++ incubator/activemq/trunk/openwire-c/src/libopenwire/ow_commands_v1.c Sun Mar  5 00:49:13 2006
@@ -957,6 +957,7 @@
    ow_bit_buffer_append(buffer, object->browser);
    SUCCESS_CHECK(ow_marshal1_cached_object(buffer, (ow_DataStructure*)object->destination));
    
+   
    ow_bit_buffer_append(buffer, object->dispatchAsync);
    ow_marshal1_string(buffer, object->selector);
    ow_marshal1_string(buffer, object->subcriptionName);
@@ -976,6 +977,7 @@
    ow_bit_buffer_read(bitbuffer);
    SUCCESS_CHECK(ow_marshal2_cached_object(buffer, bitbuffer, (ow_DataStructure*)object->destination));
    SUCCESS_CHECK(ow_byte_buffer_append_int(buffer, object->prefetchSize));
+   SUCCESS_CHECK(ow_byte_buffer_append_int(buffer, object->maximumPendingMessageLimit));
    ow_bit_buffer_read(bitbuffer);
    SUCCESS_CHECK(ow_marshal2_string(buffer, bitbuffer, object->selector));
    SUCCESS_CHECK(ow_marshal2_string(buffer, bitbuffer, object->subcriptionName));
@@ -996,6 +998,7 @@
    object->browser = ow_bit_buffer_read(bitbuffer);
    SUCCESS_CHECK(ow_unmarshal_cached_object(buffer, bitbuffer, (ow_DataStructure**)&object->destination, pool));
    SUCCESS_CHECK(ow_byte_array_read_int(buffer, &object->prefetchSize));
+   SUCCESS_CHECK(ow_byte_array_read_int(buffer, &object->maximumPendingMessageLimit));
    object->dispatchAsync = ow_bit_buffer_read(bitbuffer);
    SUCCESS_CHECK(ow_unmarshal_string(buffer, bitbuffer, &object->selector, pool));
    SUCCESS_CHECK(ow_unmarshal_string(buffer, bitbuffer, &object->subcriptionName, pool));

Modified: incubator/activemq/trunk/openwire-c/src/libopenwire/ow_commands_v1.h
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-c/src/libopenwire/ow_commands_v1.h?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-c/src/libopenwire/ow_commands_v1.h (original)
+++ incubator/activemq/trunk/openwire-c/src/libopenwire/ow_commands_v1.h Sun Mar  5 00:49:13 2006
@@ -312,6 +312,7 @@
    ow_boolean browser;
    struct ow_ActiveMQDestination *destination;
    ow_int prefetchSize;
+   ow_int maximumPendingMessageLimit;
    ow_boolean dispatchAsync;
    ow_string *selector;
    ow_string *subcriptionName;

Modified: incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQObjectMessage.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQObjectMessage.hpp?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQObjectMessage.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ActiveMQObjectMessage.hpp Sun Mar  5 00:49:13 2006
@@ -1,71 +1,71 @@
-/*
-* 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 ActiveMQObjectMessage_hpp_
-#define ActiveMQObjectMessage_hpp_
-
-#include <string>
-#include "command/ActiveMQMessage.hpp"
-    
-
-#include "util/ifr/ap.hpp"
-#include "util/ifr/p.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      namespace command
-      {
-        using namespace ifr;
-        using namespace std;
-        using namespace apache::activemq::client;
-
-/*
- *
- *  Marshalling code for Open Wire Format for ActiveMQObjectMessage
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class ActiveMQObjectMessage : public ActiveMQMessage
-{
-private:
-
-public:
-    const static int TYPE = 26;
-
-public:
-    ActiveMQObjectMessage() ;
-    virtual ~ActiveMQObjectMessage() ;
-
-    virtual int getCommandType() ;
-
-
-} ;
-
-/* namespace */
-      }
-    }
-  }
-}
-
-#endif /*ActiveMQObjectMessage_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 ActiveMQObjectMessage_hpp_
+#define ActiveMQObjectMessage_hpp_
+
+#include <string>
+#include "command/ActiveMQMessage.hpp"
+    
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+        using namespace apache::activemq::client;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for ActiveMQObjectMessage
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class ActiveMQObjectMessage : public ActiveMQMessage
+{
+private:
+
+public:
+    const static int TYPE = 26;
+
+public:
+    ActiveMQObjectMessage() ;
+    virtual ~ActiveMQObjectMessage() ;
+
+    virtual int getCommandType() ;
+
+
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*ActiveMQObjectMessage_hpp_*/

Modified: incubator/activemq/trunk/openwire-cpp/src/command/ConnectionError.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ConnectionError.hpp?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ConnectionError.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ConnectionError.hpp Sun Mar  5 00:49:13 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 ConnectionError_hpp_
-#define ConnectionError_hpp_
-
-#include <string>
-#include "command/BaseCommand.hpp"
-    
-#include "BrokerError.hpp"
-#include "command/ConnectionId.hpp"
-
-#include "util/ifr/ap.hpp"
-#include "util/ifr/p.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      namespace command
-      {
-        using namespace ifr;
-        using namespace std;
-        using namespace apache::activemq::client;
-
-/*
- *
- *  Marshalling code for Open Wire Format for ConnectionError
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class ConnectionError : public BaseCommand
-{
-private:
-    p<BrokerError> exception ;
-    p<ConnectionId> connectionId ;
-
-public:
-    const static int TYPE = 16;
-
-public:
-    ConnectionError() ;
-    virtual ~ConnectionError() ;
-
-    virtual int getCommandType() ;
-
-    virtual p<BrokerError> getException() ;
-    virtual void setException(p<BrokerError> exception) ;
-
-    virtual p<ConnectionId> getConnectionId() ;
-    virtual void setConnectionId(p<ConnectionId> connectionId) ;
-
-
-} ;
-
-/* namespace */
-      }
-    }
-  }
-}
-
-#endif /*ConnectionError_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 ConnectionError_hpp_
+#define ConnectionError_hpp_
+
+#include <string>
+#include "command/BaseCommand.hpp"
+    
+#include "BrokerError.hpp"
+#include "command/ConnectionId.hpp"
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+        using namespace apache::activemq::client;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for ConnectionError
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class ConnectionError : public BaseCommand
+{
+private:
+    p<BrokerError> exception ;
+    p<ConnectionId> connectionId ;
+
+public:
+    const static int TYPE = 16;
+
+public:
+    ConnectionError() ;
+    virtual ~ConnectionError() ;
+
+    virtual int getCommandType() ;
+
+    virtual p<BrokerError> getException() ;
+    virtual void setException(p<BrokerError> exception) ;
+
+    virtual p<ConnectionId> getConnectionId() ;
+    virtual void setConnectionId(p<ConnectionId> connectionId) ;
+
+
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*ConnectionError_hpp_*/

Modified: incubator/activemq/trunk/openwire-cpp/src/command/ConsumerInfo.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ConsumerInfo.cpp?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ConsumerInfo.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ConsumerInfo.cpp Sun Mar  5 00:49:13 2006
@@ -34,6 +34,7 @@
     this->browser = 0 ;
     this->destination = 0 ;
     this->prefetchSize = 0 ;
+    this->maximumPendingMessageLimit = 0 ;
     this->dispatchAsync = 0 ;
     this->selector = 0 ;
     this->subcriptionName = 0 ;
@@ -91,6 +92,17 @@
 void ConsumerInfo::setPrefetchSize(int prefetchSize)
 {
     this->prefetchSize = prefetchSize ;
+}
+
+        
+int ConsumerInfo::getMaximumPendingMessageLimit()
+{
+    return maximumPendingMessageLimit ;
+}
+
+void ConsumerInfo::setMaximumPendingMessageLimit(int maximumPendingMessageLimit)
+{
+    this->maximumPendingMessageLimit = maximumPendingMessageLimit ;
 }
 
         

Modified: incubator/activemq/trunk/openwire-cpp/src/command/ConsumerInfo.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ConsumerInfo.hpp?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ConsumerInfo.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ConsumerInfo.hpp Sun Mar  5 00:49:13 2006
@@ -56,6 +56,7 @@
     bool browser ;
     p<ActiveMQDestination> destination ;
     int prefetchSize ;
+    int maximumPendingMessageLimit ;
     bool dispatchAsync ;
     p<string> selector ;
     p<string> subcriptionName ;
@@ -86,6 +87,9 @@
 
     virtual int getPrefetchSize() ;
     virtual void setPrefetchSize(int prefetchSize) ;
+
+    virtual int getMaximumPendingMessageLimit() ;
+    virtual void setMaximumPendingMessageLimit(int maximumPendingMessageLimit) ;
 
     virtual bool getDispatchAsync() ;
     virtual void setDispatchAsync(bool dispatchAsync) ;

Modified: incubator/activemq/trunk/openwire-cpp/src/command/ControlCommand.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ControlCommand.hpp?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ControlCommand.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ControlCommand.hpp Sun Mar  5 00:49:13 2006
@@ -1,75 +1,75 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*     http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#ifndef ControlCommand_hpp_
-#define ControlCommand_hpp_
-
-#include <string>
-#include "command/BaseCommand.hpp"
-    
-
-#include "util/ifr/ap.hpp"
-#include "util/ifr/p.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      namespace command
-      {
-        using namespace ifr;
-        using namespace std;
-        using namespace apache::activemq::client;
-
-/*
- *
- *  Marshalling code for Open Wire Format for ControlCommand
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class ControlCommand : public BaseCommand
-{
-private:
-    p<string> command ;
-
-public:
-    const static int TYPE = 14;
-
-public:
-    ControlCommand() ;
-    virtual ~ControlCommand() ;
-
-    virtual int getCommandType() ;
-
-    virtual p<string> getCommand() ;
-    virtual void setCommand(p<string> command) ;
-
-
-} ;
-
-/* namespace */
-      }
-    }
-  }
-}
-
-#endif /*ControlCommand_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 ControlCommand_hpp_
+#define ControlCommand_hpp_
+
+#include <string>
+#include "command/BaseCommand.hpp"
+    
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+        using namespace apache::activemq::client;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for ControlCommand
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class ControlCommand : public BaseCommand
+{
+private:
+    p<string> command ;
+
+public:
+    const static int TYPE = 14;
+
+public:
+    ControlCommand() ;
+    virtual ~ControlCommand() ;
+
+    virtual int getCommandType() ;
+
+    virtual p<string> getCommand() ;
+    virtual void setCommand(p<string> command) ;
+
+
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*ControlCommand_hpp_*/

Modified: incubator/activemq/trunk/openwire-cpp/src/command/DataArrayResponse.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/DataArrayResponse.hpp?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/DataArrayResponse.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/DataArrayResponse.hpp Sun Mar  5 00:49:13 2006
@@ -1,76 +1,76 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*     http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#ifndef DataArrayResponse_hpp_
-#define DataArrayResponse_hpp_
-
-#include <string>
-#include "command/Response.hpp"
-    
-#include "command/IDataStructure.hpp"
-
-#include "util/ifr/ap.hpp"
-#include "util/ifr/p.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      namespace command
-      {
-        using namespace ifr;
-        using namespace std;
-        using namespace apache::activemq::client;
-
-/*
- *
- *  Marshalling code for Open Wire Format for DataArrayResponse
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class DataArrayResponse : public Response
-{
-private:
-    ap<IDataStructure> data ;
-
-public:
-    const static int TYPE = 33;
-
-public:
-    DataArrayResponse() ;
-    virtual ~DataArrayResponse() ;
-
-    virtual int getCommandType() ;
-
-    virtual ap<IDataStructure> getData() ;
-    virtual void setData(ap<IDataStructure> data) ;
-
-
-} ;
-
-/* namespace */
-      }
-    }
-  }
-}
-
-#endif /*DataArrayResponse_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 DataArrayResponse_hpp_
+#define DataArrayResponse_hpp_
+
+#include <string>
+#include "command/Response.hpp"
+    
+#include "command/IDataStructure.hpp"
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+        using namespace apache::activemq::client;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for DataArrayResponse
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class DataArrayResponse : public Response
+{
+private:
+    ap<IDataStructure> data ;
+
+public:
+    const static int TYPE = 33;
+
+public:
+    DataArrayResponse() ;
+    virtual ~DataArrayResponse() ;
+
+    virtual int getCommandType() ;
+
+    virtual ap<IDataStructure> getData() ;
+    virtual void setData(ap<IDataStructure> data) ;
+
+
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*DataArrayResponse_hpp_*/

Modified: incubator/activemq/trunk/openwire-cpp/src/command/DataResponse.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/DataResponse.hpp?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/DataResponse.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/DataResponse.hpp Sun Mar  5 00:49:13 2006
@@ -1,76 +1,76 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*     http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#ifndef DataResponse_hpp_
-#define DataResponse_hpp_
-
-#include <string>
-#include "command/Response.hpp"
-    
-#include "command/IDataStructure.hpp"
-
-#include "util/ifr/ap.hpp"
-#include "util/ifr/p.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      namespace command
-      {
-        using namespace ifr;
-        using namespace std;
-        using namespace apache::activemq::client;
-
-/*
- *
- *  Marshalling code for Open Wire Format for DataResponse
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class DataResponse : public Response
-{
-private:
-    p<IDataStructure> data ;
-
-public:
-    const static int TYPE = 32;
-
-public:
-    DataResponse() ;
-    virtual ~DataResponse() ;
-
-    virtual int getCommandType() ;
-
-    virtual p<IDataStructure> getData() ;
-    virtual void setData(p<IDataStructure> data) ;
-
-
-} ;
-
-/* namespace */
-      }
-    }
-  }
-}
-
-#endif /*DataResponse_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 DataResponse_hpp_
+#define DataResponse_hpp_
+
+#include <string>
+#include "command/Response.hpp"
+    
+#include "command/IDataStructure.hpp"
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+        using namespace apache::activemq::client;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for DataResponse
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class DataResponse : public Response
+{
+private:
+    p<IDataStructure> data ;
+
+public:
+    const static int TYPE = 32;
+
+public:
+    DataResponse() ;
+    virtual ~DataResponse() ;
+
+    virtual int getCommandType() ;
+
+    virtual p<IDataStructure> getData() ;
+    virtual void setData(p<IDataStructure> data) ;
+
+
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*DataResponse_hpp_*/

Modified: incubator/activemq/trunk/openwire-cpp/src/command/DestinationInfo.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/DestinationInfo.hpp?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/DestinationInfo.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/DestinationInfo.hpp Sun Mar  5 00:49:13 2006
@@ -1,94 +1,94 @@
-/*
-* 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 DestinationInfo_hpp_
-#define DestinationInfo_hpp_
-
-#include <string>
-#include "command/BaseCommand.hpp"
-    
-#include "command/ConnectionId.hpp"
-#include "command/ActiveMQDestination.hpp"
-#include "command/BrokerId.hpp"
-
-#include "util/ifr/ap.hpp"
-#include "util/ifr/p.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      namespace command
-      {
-        using namespace ifr;
-        using namespace std;
-        using namespace apache::activemq::client;
-
-/*
- *
- *  Marshalling code for Open Wire Format for DestinationInfo
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class DestinationInfo : public BaseCommand
-{
-private:
-    p<ConnectionId> connectionId ;
-    p<ActiveMQDestination> destination ;
-    char operationType ;
-    long long timeout ;
-    ap<BrokerId> brokerPath ;
-
-public:
-    const static int TYPE = 8;
-
-public:
-    DestinationInfo() ;
-    virtual ~DestinationInfo() ;
-
-    virtual int getCommandType() ;
-
-    virtual p<ConnectionId> getConnectionId() ;
-    virtual void setConnectionId(p<ConnectionId> connectionId) ;
-
-    virtual p<ActiveMQDestination> getDestination() ;
-    virtual void setDestination(p<ActiveMQDestination> destination) ;
-
-    virtual char getOperationType() ;
-    virtual void setOperationType(char operationType) ;
-
-    virtual long long getTimeout() ;
-    virtual void setTimeout(long long timeout) ;
-
-    virtual ap<BrokerId> getBrokerPath() ;
-    virtual void setBrokerPath(ap<BrokerId> brokerPath) ;
-
-
-} ;
-
-/* namespace */
-      }
-    }
-  }
-}
-
-#endif /*DestinationInfo_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 DestinationInfo_hpp_
+#define DestinationInfo_hpp_
+
+#include <string>
+#include "command/BaseCommand.hpp"
+    
+#include "command/ConnectionId.hpp"
+#include "command/ActiveMQDestination.hpp"
+#include "command/BrokerId.hpp"
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+        using namespace apache::activemq::client;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for DestinationInfo
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class DestinationInfo : public BaseCommand
+{
+private:
+    p<ConnectionId> connectionId ;
+    p<ActiveMQDestination> destination ;
+    char operationType ;
+    long long timeout ;
+    ap<BrokerId> brokerPath ;
+
+public:
+    const static int TYPE = 8;
+
+public:
+    DestinationInfo() ;
+    virtual ~DestinationInfo() ;
+
+    virtual int getCommandType() ;
+
+    virtual p<ConnectionId> getConnectionId() ;
+    virtual void setConnectionId(p<ConnectionId> connectionId) ;
+
+    virtual p<ActiveMQDestination> getDestination() ;
+    virtual void setDestination(p<ActiveMQDestination> destination) ;
+
+    virtual char getOperationType() ;
+    virtual void setOperationType(char operationType) ;
+
+    virtual long long getTimeout() ;
+    virtual void setTimeout(long long timeout) ;
+
+    virtual ap<BrokerId> getBrokerPath() ;
+    virtual void setBrokerPath(ap<BrokerId> brokerPath) ;
+
+
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*DestinationInfo_hpp_*/

Modified: incubator/activemq/trunk/openwire-cpp/src/command/DiscoveryEvent.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/DiscoveryEvent.hpp?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/DiscoveryEvent.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/DiscoveryEvent.hpp Sun Mar  5 00:49:13 2006
@@ -1,79 +1,79 @@
-/*
-* 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 DiscoveryEvent_hpp_
-#define DiscoveryEvent_hpp_
-
-#include <string>
-#include "command/AbstractCommand.hpp"
-    
-
-#include "util/ifr/ap.hpp"
-#include "util/ifr/p.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      namespace command
-      {
-        using namespace ifr;
-        using namespace std;
-        using namespace apache::activemq::client;
-
-/*
- *
- *  Marshalling code for Open Wire Format for DiscoveryEvent
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class DiscoveryEvent : public AbstractCommand
-{
-private:
-    p<string> serviceName ;
-    p<string> brokerName ;
-
-public:
-    const static int TYPE = 40;
-
-public:
-    DiscoveryEvent() ;
-    virtual ~DiscoveryEvent() ;
-
-    virtual int getCommandType() ;
-
-    virtual p<string> getServiceName() ;
-    virtual void setServiceName(p<string> serviceName) ;
-
-    virtual p<string> getBrokerName() ;
-    virtual void setBrokerName(p<string> brokerName) ;
-
-
-} ;
-
-/* namespace */
-      }
-    }
-  }
-}
-
-#endif /*DiscoveryEvent_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 DiscoveryEvent_hpp_
+#define DiscoveryEvent_hpp_
+
+#include <string>
+#include "command/AbstractCommand.hpp"
+    
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+        using namespace apache::activemq::client;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for DiscoveryEvent
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class DiscoveryEvent : public AbstractCommand
+{
+private:
+    p<string> serviceName ;
+    p<string> brokerName ;
+
+public:
+    const static int TYPE = 40;
+
+public:
+    DiscoveryEvent() ;
+    virtual ~DiscoveryEvent() ;
+
+    virtual int getCommandType() ;
+
+    virtual p<string> getServiceName() ;
+    virtual void setServiceName(p<string> serviceName) ;
+
+    virtual p<string> getBrokerName() ;
+    virtual void setBrokerName(p<string> brokerName) ;
+
+
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*DiscoveryEvent_hpp_*/

Modified: incubator/activemq/trunk/openwire-cpp/src/command/FlushCommand.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/FlushCommand.hpp?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/FlushCommand.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/FlushCommand.hpp Sun Mar  5 00:49:13 2006
@@ -1,71 +1,71 @@
-/*
-* 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 FlushCommand_hpp_
-#define FlushCommand_hpp_
-
-#include <string>
-#include "command/BaseCommand.hpp"
-    
-
-#include "util/ifr/ap.hpp"
-#include "util/ifr/p.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      namespace command
-      {
-        using namespace ifr;
-        using namespace std;
-        using namespace apache::activemq::client;
-
-/*
- *
- *  Marshalling code for Open Wire Format for FlushCommand
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class FlushCommand : public BaseCommand
-{
-private:
-
-public:
-    const static int TYPE = 15;
-
-public:
-    FlushCommand() ;
-    virtual ~FlushCommand() ;
-
-    virtual int getCommandType() ;
-
-
-} ;
-
-/* namespace */
-      }
-    }
-  }
-}
-
-#endif /*FlushCommand_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 FlushCommand_hpp_
+#define FlushCommand_hpp_
+
+#include <string>
+#include "command/BaseCommand.hpp"
+    
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+        using namespace apache::activemq::client;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for FlushCommand
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class FlushCommand : public BaseCommand
+{
+private:
+
+public:
+    const static int TYPE = 15;
+
+public:
+    FlushCommand() ;
+    virtual ~FlushCommand() ;
+
+    virtual int getCommandType() ;
+
+
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*FlushCommand_hpp_*/

Modified: incubator/activemq/trunk/openwire-cpp/src/command/IntegerResponse.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/IntegerResponse.hpp?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/IntegerResponse.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/IntegerResponse.hpp Sun Mar  5 00:49:13 2006
@@ -1,75 +1,75 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*     http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#ifndef IntegerResponse_hpp_
-#define IntegerResponse_hpp_
-
-#include <string>
-#include "command/Response.hpp"
-    
-
-#include "util/ifr/ap.hpp"
-#include "util/ifr/p.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      namespace command
-      {
-        using namespace ifr;
-        using namespace std;
-        using namespace apache::activemq::client;
-
-/*
- *
- *  Marshalling code for Open Wire Format for IntegerResponse
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class IntegerResponse : public Response
-{
-private:
-    int result ;
-
-public:
-    const static int TYPE = 34;
-
-public:
-    IntegerResponse() ;
-    virtual ~IntegerResponse() ;
-
-    virtual int getCommandType() ;
-
-    virtual int getResult() ;
-    virtual void setResult(int result) ;
-
-
-} ;
-
-/* namespace */
-      }
-    }
-  }
-}
-
-#endif /*IntegerResponse_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 IntegerResponse_hpp_
+#define IntegerResponse_hpp_
+
+#include <string>
+#include "command/Response.hpp"
+    
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+        using namespace apache::activemq::client;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for IntegerResponse
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class IntegerResponse : public Response
+{
+private:
+    int result ;
+
+public:
+    const static int TYPE = 34;
+
+public:
+    IntegerResponse() ;
+    virtual ~IntegerResponse() ;
+
+    virtual int getCommandType() ;
+
+    virtual int getResult() ;
+    virtual void setResult(int result) ;
+
+
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*IntegerResponse_hpp_*/

Modified: incubator/activemq/trunk/openwire-cpp/src/command/JournalQueueAck.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/JournalQueueAck.hpp?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/JournalQueueAck.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/JournalQueueAck.hpp Sun Mar  5 00:49:13 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 JournalQueueAck_hpp_
-#define JournalQueueAck_hpp_
-
-#include <string>
-#include "command/AbstractCommand.hpp"
-    
-#include "command/ActiveMQDestination.hpp"
-#include "command/MessageAck.hpp"
-
-#include "util/ifr/ap.hpp"
-#include "util/ifr/p.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      namespace command
-      {
-        using namespace ifr;
-        using namespace std;
-        using namespace apache::activemq::client;
-
-/*
- *
- *  Marshalling code for Open Wire Format for JournalQueueAck
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class JournalQueueAck : public AbstractCommand
-{
-private:
-    p<ActiveMQDestination> destination ;
-    p<MessageAck> messageAck ;
-
-public:
-    const static int TYPE = 52;
-
-public:
-    JournalQueueAck() ;
-    virtual ~JournalQueueAck() ;
-
-    virtual int getCommandType() ;
-
-    virtual p<ActiveMQDestination> getDestination() ;
-    virtual void setDestination(p<ActiveMQDestination> destination) ;
-
-    virtual p<MessageAck> getMessageAck() ;
-    virtual void setMessageAck(p<MessageAck> messageAck) ;
-
-
-} ;
-
-/* namespace */
-      }
-    }
-  }
-}
-
-#endif /*JournalQueueAck_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 JournalQueueAck_hpp_
+#define JournalQueueAck_hpp_
+
+#include <string>
+#include "command/AbstractCommand.hpp"
+    
+#include "command/ActiveMQDestination.hpp"
+#include "command/MessageAck.hpp"
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+        using namespace apache::activemq::client;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for JournalQueueAck
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class JournalQueueAck : public AbstractCommand
+{
+private:
+    p<ActiveMQDestination> destination ;
+    p<MessageAck> messageAck ;
+
+public:
+    const static int TYPE = 52;
+
+public:
+    JournalQueueAck() ;
+    virtual ~JournalQueueAck() ;
+
+    virtual int getCommandType() ;
+
+    virtual p<ActiveMQDestination> getDestination() ;
+    virtual void setDestination(p<ActiveMQDestination> destination) ;
+
+    virtual p<MessageAck> getMessageAck() ;
+    virtual void setMessageAck(p<MessageAck> messageAck) ;
+
+
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*JournalQueueAck_hpp_*/

Modified: incubator/activemq/trunk/openwire-cpp/src/command/JournalTopicAck.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/JournalTopicAck.hpp?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/JournalTopicAck.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/JournalTopicAck.hpp Sun Mar  5 00:49:13 2006
@@ -1,98 +1,98 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*     http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#ifndef JournalTopicAck_hpp_
-#define JournalTopicAck_hpp_
-
-#include <string>
-#include "command/AbstractCommand.hpp"
-    
-#include "command/ActiveMQDestination.hpp"
-#include "command/MessageId.hpp"
-#include "command/TransactionId.hpp"
-
-#include "util/ifr/ap.hpp"
-#include "util/ifr/p.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      namespace command
-      {
-        using namespace ifr;
-        using namespace std;
-        using namespace apache::activemq::client;
-
-/*
- *
- *  Marshalling code for Open Wire Format for JournalTopicAck
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class JournalTopicAck : public AbstractCommand
-{
-private:
-    p<ActiveMQDestination> destination ;
-    p<MessageId> messageId ;
-    long long messageSequenceId ;
-    p<string> subscritionName ;
-    p<string> clientId ;
-    p<TransactionId> transactionId ;
-
-public:
-    const static int TYPE = 50;
-
-public:
-    JournalTopicAck() ;
-    virtual ~JournalTopicAck() ;
-
-    virtual int getCommandType() ;
-
-    virtual p<ActiveMQDestination> getDestination() ;
-    virtual void setDestination(p<ActiveMQDestination> destination) ;
-
-    virtual p<MessageId> getMessageId() ;
-    virtual void setMessageId(p<MessageId> messageId) ;
-
-    virtual long long getMessageSequenceId() ;
-    virtual void setMessageSequenceId(long long messageSequenceId) ;
-
-    virtual p<string> getSubscritionName() ;
-    virtual void setSubscritionName(p<string> subscritionName) ;
-
-    virtual p<string> getClientId() ;
-    virtual void setClientId(p<string> clientId) ;
-
-    virtual p<TransactionId> getTransactionId() ;
-    virtual void setTransactionId(p<TransactionId> transactionId) ;
-
-
-} ;
-
-/* namespace */
-      }
-    }
-  }
-}
-
-#endif /*JournalTopicAck_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 JournalTopicAck_hpp_
+#define JournalTopicAck_hpp_
+
+#include <string>
+#include "command/AbstractCommand.hpp"
+    
+#include "command/ActiveMQDestination.hpp"
+#include "command/MessageId.hpp"
+#include "command/TransactionId.hpp"
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+        using namespace apache::activemq::client;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for JournalTopicAck
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class JournalTopicAck : public AbstractCommand
+{
+private:
+    p<ActiveMQDestination> destination ;
+    p<MessageId> messageId ;
+    long long messageSequenceId ;
+    p<string> subscritionName ;
+    p<string> clientId ;
+    p<TransactionId> transactionId ;
+
+public:
+    const static int TYPE = 50;
+
+public:
+    JournalTopicAck() ;
+    virtual ~JournalTopicAck() ;
+
+    virtual int getCommandType() ;
+
+    virtual p<ActiveMQDestination> getDestination() ;
+    virtual void setDestination(p<ActiveMQDestination> destination) ;
+
+    virtual p<MessageId> getMessageId() ;
+    virtual void setMessageId(p<MessageId> messageId) ;
+
+    virtual long long getMessageSequenceId() ;
+    virtual void setMessageSequenceId(long long messageSequenceId) ;
+
+    virtual p<string> getSubscritionName() ;
+    virtual void setSubscritionName(p<string> subscritionName) ;
+
+    virtual p<string> getClientId() ;
+    virtual void setClientId(p<string> clientId) ;
+
+    virtual p<TransactionId> getTransactionId() ;
+    virtual void setTransactionId(p<TransactionId> transactionId) ;
+
+
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*JournalTopicAck_hpp_*/

Modified: incubator/activemq/trunk/openwire-cpp/src/command/JournalTrace.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/JournalTrace.hpp?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/JournalTrace.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/JournalTrace.hpp Sun Mar  5 00:49:13 2006
@@ -1,75 +1,75 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*     http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#ifndef JournalTrace_hpp_
-#define JournalTrace_hpp_
-
-#include <string>
-#include "command/AbstractCommand.hpp"
-    
-
-#include "util/ifr/ap.hpp"
-#include "util/ifr/p.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      namespace command
-      {
-        using namespace ifr;
-        using namespace std;
-        using namespace apache::activemq::client;
-
-/*
- *
- *  Marshalling code for Open Wire Format for JournalTrace
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class JournalTrace : public AbstractCommand
-{
-private:
-    p<string> message ;
-
-public:
-    const static int TYPE = 53;
-
-public:
-    JournalTrace() ;
-    virtual ~JournalTrace() ;
-
-    virtual int getCommandType() ;
-
-    virtual p<string> getMessage() ;
-    virtual void setMessage(p<string> message) ;
-
-
-} ;
-
-/* namespace */
-      }
-    }
-  }
-}
-
-#endif /*JournalTrace_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 JournalTrace_hpp_
+#define JournalTrace_hpp_
+
+#include <string>
+#include "command/AbstractCommand.hpp"
+    
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+        using namespace apache::activemq::client;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for JournalTrace
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class JournalTrace : public AbstractCommand
+{
+private:
+    p<string> message ;
+
+public:
+    const static int TYPE = 53;
+
+public:
+    JournalTrace() ;
+    virtual ~JournalTrace() ;
+
+    virtual int getCommandType() ;
+
+    virtual p<string> getMessage() ;
+    virtual void setMessage(p<string> message) ;
+
+
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*JournalTrace_hpp_*/

Modified: incubator/activemq/trunk/openwire-cpp/src/command/JournalTransaction.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/JournalTransaction.hpp?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/JournalTransaction.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/JournalTransaction.hpp Sun Mar  5 00:49:13 2006
@@ -1,84 +1,84 @@
-/*
-* Copyright 2006 The Apache Software Foundation or its licensors, as
-* applicable.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-*     http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*/
-#ifndef JournalTransaction_hpp_
-#define JournalTransaction_hpp_
-
-#include <string>
-#include "command/AbstractCommand.hpp"
-    
-#include "command/TransactionId.hpp"
-
-#include "util/ifr/ap.hpp"
-#include "util/ifr/p.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      namespace command
-      {
-        using namespace ifr;
-        using namespace std;
-        using namespace apache::activemq::client;
-
-/*
- *
- *  Marshalling code for Open Wire Format for JournalTransaction
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class JournalTransaction : public AbstractCommand
-{
-private:
-    p<TransactionId> transactionId ;
-    char type ;
-    bool wasPrepared ;
-
-public:
-    const static int TYPE = 54;
-
-public:
-    JournalTransaction() ;
-    virtual ~JournalTransaction() ;
-
-    virtual int getCommandType() ;
-
-    virtual p<TransactionId> getTransactionId() ;
-    virtual void setTransactionId(p<TransactionId> transactionId) ;
-
-    virtual char getType() ;
-    virtual void setType(char type) ;
-
-    virtual bool getWasPrepared() ;
-    virtual void setWasPrepared(bool wasPrepared) ;
-
-
-} ;
-
-/* namespace */
-      }
-    }
-  }
-}
-
-#endif /*JournalTransaction_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 JournalTransaction_hpp_
+#define JournalTransaction_hpp_
+
+#include <string>
+#include "command/AbstractCommand.hpp"
+    
+#include "command/TransactionId.hpp"
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+        using namespace apache::activemq::client;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for JournalTransaction
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class JournalTransaction : public AbstractCommand
+{
+private:
+    p<TransactionId> transactionId ;
+    char type ;
+    bool wasPrepared ;
+
+public:
+    const static int TYPE = 54;
+
+public:
+    JournalTransaction() ;
+    virtual ~JournalTransaction() ;
+
+    virtual int getCommandType() ;
+
+    virtual p<TransactionId> getTransactionId() ;
+    virtual void setTransactionId(p<TransactionId> transactionId) ;
+
+    virtual char getType() ;
+    virtual void setType(char type) ;
+
+    virtual bool getWasPrepared() ;
+    virtual void setWasPrepared(bool wasPrepared) ;
+
+
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*JournalTransaction_hpp_*/

Modified: incubator/activemq/trunk/openwire-cpp/src/command/KeepAliveInfo.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/KeepAliveInfo.hpp?rev=383296&r1=383295&r2=383296&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/KeepAliveInfo.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/KeepAliveInfo.hpp Sun Mar  5 00:49:13 2006
@@ -1,71 +1,71 @@
-/*
-* 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 KeepAliveInfo_hpp_
-#define KeepAliveInfo_hpp_
-
-#include <string>
-#include "command/AbstractCommand.hpp"
-    
-
-#include "util/ifr/ap.hpp"
-#include "util/ifr/p.hpp"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      namespace command
-      {
-        using namespace ifr;
-        using namespace std;
-        using namespace apache::activemq::client;
-
-/*
- *
- *  Marshalling code for Open Wire Format for KeepAliveInfo
- *
- *
- *  NOTE!: This file is autogenerated - do not modify!
- *         if you need to make a change, please see the Groovy scripts in the
- *         activemq-core module
- *
- */
-class KeepAliveInfo : public AbstractCommand
-{
-private:
-
-public:
-    const static int TYPE = 10;
-
-public:
-    KeepAliveInfo() ;
-    virtual ~KeepAliveInfo() ;
-
-    virtual int getCommandType() ;
-
-
-} ;
-
-/* namespace */
-      }
-    }
-  }
-}
-
-#endif /*KeepAliveInfo_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 KeepAliveInfo_hpp_
+#define KeepAliveInfo_hpp_
+
+#include <string>
+#include "command/AbstractCommand.hpp"
+    
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace command
+      {
+        using namespace ifr;
+        using namespace std;
+        using namespace apache::activemq::client;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for KeepAliveInfo
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+class KeepAliveInfo : public AbstractCommand
+{
+private:
+
+public:
+    const static int TYPE = 10;
+
+public:
+    KeepAliveInfo() ;
+    virtual ~KeepAliveInfo() ;
+
+    virtual int getCommandType() ;
+
+
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*KeepAliveInfo_hpp_*/



Mime
View raw message