activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r384829 - in /incubator/activemq/trunk/openwire-c: openwire.xcodeproj/project.pbxproj src/libopenwire/ow_commands_v1.c src/libopenwire/ow_commands_v1.h
Date Fri, 10 Mar 2006 15:56:00 GMT
Author: jstrachan
Date: Fri Mar 10 07:55:58 2006
New Revision: 384829

URL: http://svn.apache.org/viewcvs?rev=384829&view=rev
Log:
Latest generated openwire

Modified:
    incubator/activemq/trunk/openwire-c/openwire.xcodeproj/project.pbxproj
    incubator/activemq/trunk/openwire-c/src/libopenwire/ow_commands_v1.c
    incubator/activemq/trunk/openwire-c/src/libopenwire/ow_commands_v1.h

Modified: incubator/activemq/trunk/openwire-c/openwire.xcodeproj/project.pbxproj
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-c/openwire.xcodeproj/project.pbxproj?rev=384829&r1=384828&r2=384829&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-c/openwire.xcodeproj/project.pbxproj (original)
+++ incubator/activemq/trunk/openwire-c/openwire.xcodeproj/project.pbxproj Fri Mar 10 07:55:58
2006
@@ -80,7 +80,7 @@
 		53C445BE08E4A266006387E9 /* main.c */ = {isa = PBXFileReference; fileEncoding = 30; lastKnownFileType
= sourcecode.c.c; name = main.c; path = src/examples/main.c; sourceTree = "<group>";
};
 		53C445C308E4A3CA006387E9 /* openwire.dylib */ = {isa = PBXFileReference; explicitFileType
= "compiled.mach-o.dylib"; includeInIndex = 0; path = openwire.dylib; sourceTree = BUILT_PRODUCTS_DIR;
};
 		53C445CD08E4A6B2006387E9 /* activemq.dylib */ = {isa = PBXFileReference; explicitFileType
= "compiled.mach-o.dylib"; includeInIndex = 0; path = activemq.dylib; sourceTree = BUILT_PRODUCTS_DIR;
};
-		53C445D108E4A6CA006387E9 /* main */ = {isa = PBXFileReference; explicitFileType = "compiled.mach-o.executable";
includeInIndex = 0; path = main; sourceTree = BUILT_PRODUCTS_DIR; };
+		53C445D108E4A6CA006387E9 /* main */ = {isa = PBXFileReference; includeInIndex = 0; lastKnownFileType
= "compiled.mach-o.executable"; path = main; sourceTree = BUILT_PRODUCTS_DIR; };
 		53D4A4E508A9091000CAE09B /* libapr-1.a */ = {isa = PBXFileReference; lastKnownFileType
= archive.ar; name = "libapr-1.a"; path = "../../apr/lib/libapr-1.a"; sourceTree = "<group>";
};
 /* End PBXFileReference section */
 

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=384829&r1=384828&r2=384829&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 Fri Mar 10 07:55:58
2006
@@ -78,6 +78,54 @@
 	return APR_SUCCESS;
 }
 
+ow_boolean ow_is_a_PartialCommand(ow_DataStructure *object) {
+   if( object == 0 )
+      return 0;
+      
+   switch(object->structType) {
+   case OW_PARTIALCOMMAND_TYPE:
+   case OW_LASTPARTIALCOMMAND_TYPE:
+      return 1;
+   }
+   return 0;
+}
+
+
+ow_PartialCommand *ow_PartialCommand_create(apr_pool_t *pool) 
+{
+   ow_PartialCommand *value = apr_pcalloc(pool,sizeof(ow_PartialCommand));
+   if( value!=0 ) {
+      ((ow_DataStructure*)value)->structType = OW_PARTIALCOMMAND_TYPE;
+   }
+   return value;
+}
+
+
+apr_status_t ow_marshal1_PartialCommand(ow_bit_buffer *buffer, ow_PartialCommand *object)
+{
+   ow_marshal1_BaseCommand(buffer, (ow_BaseCommand*)object);
+   
+                        ow_bit_buffer_append(buffer,  object->data!=0 );
+                        
+   
+	return APR_SUCCESS;
+}
+apr_status_t ow_marshal2_PartialCommand(ow_byte_buffer *buffer, ow_bit_buffer *bitbuffer,
ow_PartialCommand *object)
+{
+   ow_marshal2_BaseCommand(buffer, bitbuffer, (ow_BaseCommand*)object);   
+   SUCCESS_CHECK(ow_marshal2_byte_array(buffer, bitbuffer, object->data));
+   
+	return APR_SUCCESS;
+}
+
+apr_status_t ow_unmarshal_PartialCommand(ow_byte_array *buffer, ow_bit_buffer *bitbuffer,
ow_PartialCommand *object, apr_pool_t *pool)
+{
+   ow_unmarshal_BaseCommand(buffer, bitbuffer, (ow_BaseCommand*)object, pool);   
+   SUCCESS_CHECK(ow_unmarshal_byte_array(buffer, bitbuffer, &object->data, pool));
+   
+	return APR_SUCCESS;
+}
+
 ow_boolean ow_is_a_IntegerResponse(ow_DataStructure *object) {
    if( object == 0 )
       return 0;
@@ -1020,7 +1068,7 @@
 apr_status_t ow_marshal2_Response(ow_byte_buffer *buffer, ow_bit_buffer *bitbuffer, ow_Response
*object)
 {
    ow_marshal2_BaseCommand(buffer, bitbuffer, (ow_BaseCommand*)object);   
-   SUCCESS_CHECK(ow_byte_buffer_append_short(buffer, object->correlationId));
+   SUCCESS_CHECK(ow_byte_buffer_append_int(buffer, object->correlationId));
    
 	return APR_SUCCESS;
 }
@@ -1028,7 +1076,7 @@
 apr_status_t ow_unmarshal_Response(ow_byte_array *buffer, ow_bit_buffer *bitbuffer, ow_Response
*object, apr_pool_t *pool)
 {
    ow_unmarshal_BaseCommand(buffer, bitbuffer, (ow_BaseCommand*)object, pool);   
-   SUCCESS_CHECK(ow_byte_array_read_short(buffer, &object->correlationId));
+   SUCCESS_CHECK(ow_byte_array_read_int(buffer, &object->correlationId));
    
 	return APR_SUCCESS;
 }
@@ -1511,6 +1559,48 @@
 	return APR_SUCCESS;
 }
 
+ow_boolean ow_is_a_LastPartialCommand(ow_DataStructure *object) {
+   if( object == 0 )
+      return 0;
+      
+   switch(object->structType) {
+   case OW_LASTPARTIALCOMMAND_TYPE:
+      return 1;
+   }
+   return 0;
+}
+
+
+ow_LastPartialCommand *ow_LastPartialCommand_create(apr_pool_t *pool) 
+{
+   ow_LastPartialCommand *value = apr_pcalloc(pool,sizeof(ow_LastPartialCommand));
+   if( value!=0 ) {
+      ((ow_DataStructure*)value)->structType = OW_LASTPARTIALCOMMAND_TYPE;
+   }
+   return value;
+}
+
+
+apr_status_t ow_marshal1_LastPartialCommand(ow_bit_buffer *buffer, ow_LastPartialCommand
*object)
+{
+   ow_marshal1_PartialCommand(buffer, (ow_PartialCommand*)object);
+   
+	return APR_SUCCESS;
+}
+apr_status_t ow_marshal2_LastPartialCommand(ow_byte_buffer *buffer, ow_bit_buffer *bitbuffer,
ow_LastPartialCommand *object)
+{
+   ow_marshal2_PartialCommand(buffer, bitbuffer, (ow_PartialCommand*)object);   
+   
+	return APR_SUCCESS;
+}
+
+apr_status_t ow_unmarshal_LastPartialCommand(ow_byte_array *buffer, ow_bit_buffer *bitbuffer,
ow_LastPartialCommand *object, apr_pool_t *pool)
+{
+   ow_unmarshal_PartialCommand(buffer, bitbuffer, (ow_PartialCommand*)object, pool);   
+   
+	return APR_SUCCESS;
+}
+
 ow_boolean ow_is_a_NetworkBridgeFilter(ow_DataStructure *object) {
    if( object == 0 )
       return 0;
@@ -1803,11 +1893,15 @@
 {
    ow_marshal1_BaseCommand(buffer, (ow_BaseCommand*)object);
    
+   
+   
 	return APR_SUCCESS;
 }
 apr_status_t ow_marshal2_ReplayCommand(ow_byte_buffer *buffer, ow_bit_buffer *bitbuffer,
ow_ReplayCommand *object)
 {
    ow_marshal2_BaseCommand(buffer, bitbuffer, (ow_BaseCommand*)object);   
+   SUCCESS_CHECK(ow_byte_buffer_append_int(buffer, object->firstNakNumber));
+   SUCCESS_CHECK(ow_byte_buffer_append_int(buffer, object->lastNakNumber));
    
 	return APR_SUCCESS;
 }
@@ -1815,6 +1909,8 @@
 apr_status_t ow_unmarshal_ReplayCommand(ow_byte_array *buffer, ow_bit_buffer *bitbuffer,
ow_ReplayCommand *object, apr_pool_t *pool)
 {
    ow_unmarshal_BaseCommand(buffer, bitbuffer, (ow_BaseCommand*)object, pool);   
+   SUCCESS_CHECK(ow_byte_array_read_int(buffer, &object->firstNakNumber));
+   SUCCESS_CHECK(ow_byte_array_read_int(buffer, &object->lastNakNumber));
    
 	return APR_SUCCESS;
 }
@@ -2263,6 +2359,7 @@
       return 0;
       
    switch(object->structType) {
+   case OW_PARTIALCOMMAND_TYPE:
    case OW_INTEGERRESPONSE_TYPE:
    case OW_ACTIVEMQOBJECTMESSAGE_TYPE:
    case OW_CONNECTIONINFO_TYPE:
@@ -2279,6 +2376,7 @@
    case OW_CONSUMERINFO_TYPE:
    case OW_ACTIVEMQTEXTMESSAGE_TYPE:
    case OW_CONTROLCOMMAND_TYPE:
+   case OW_LASTPARTIALCOMMAND_TYPE:
    case OW_ACTIVEMQBYTESMESSAGE_TYPE:
    case OW_REPLAYCOMMAND_TYPE:
    case OW_BROKERINFO_TYPE:
@@ -2308,7 +2406,7 @@
 apr_status_t ow_marshal2_BaseCommand(ow_byte_buffer *buffer, ow_bit_buffer *bitbuffer, ow_BaseCommand
*object)
 {
    ow_marshal2_DataStructure(buffer, bitbuffer, (ow_DataStructure*)object);   
-   SUCCESS_CHECK(ow_byte_buffer_append_short(buffer, object->commandId));
+   SUCCESS_CHECK(ow_byte_buffer_append_int(buffer, object->commandId));
    ow_bit_buffer_read(bitbuffer);
    
 	return APR_SUCCESS;
@@ -2317,7 +2415,7 @@
 apr_status_t ow_unmarshal_BaseCommand(ow_byte_array *buffer, ow_bit_buffer *bitbuffer, ow_BaseCommand
*object, apr_pool_t *pool)
 {
    ow_unmarshal_DataStructure(buffer, bitbuffer, (ow_DataStructure*)object, pool);   
-   SUCCESS_CHECK(ow_byte_array_read_short(buffer, &object->commandId));
+   SUCCESS_CHECK(ow_byte_array_read_int(buffer, &object->commandId));
    object->responseRequired = ow_bit_buffer_read(bitbuffer);
    
 	return APR_SUCCESS;
@@ -2708,6 +2806,7 @@
    switch( type ) {
 
       case OW_LOCALTRANSACTIONID_TYPE: return (ow_DataStructure *)ow_LocalTransactionId_create(pool);
+      case OW_PARTIALCOMMAND_TYPE: return (ow_DataStructure *)ow_PartialCommand_create(pool);
       case OW_INTEGERRESPONSE_TYPE: return (ow_DataStructure *)ow_IntegerResponse_create(pool);
       case OW_ACTIVEMQQUEUE_TYPE: return (ow_DataStructure *)ow_ActiveMQQueue_create(pool);
       case OW_ACTIVEMQOBJECTMESSAGE_TYPE: return (ow_DataStructure *)ow_ActiveMQObjectMessage_create(pool);
@@ -2736,6 +2835,7 @@
       case OW_SUBSCRIPTIONINFO_TYPE: return (ow_DataStructure *)ow_SubscriptionInfo_create(pool);
       case OW_JOURNALTRANSACTION_TYPE: return (ow_DataStructure *)ow_JournalTransaction_create(pool);
       case OW_CONTROLCOMMAND_TYPE: return (ow_DataStructure *)ow_ControlCommand_create(pool);
+      case OW_LASTPARTIALCOMMAND_TYPE: return (ow_DataStructure *)ow_LastPartialCommand_create(pool);
       case OW_NETWORKBRIDGEFILTER_TYPE: return (ow_DataStructure *)ow_NetworkBridgeFilter_create(pool);
       case OW_ACTIVEMQBYTESMESSAGE_TYPE: return (ow_DataStructure *)ow_ActiveMQBytesMessage_create(pool);
       case OW_WIREFORMATINFO_TYPE: return (ow_DataStructure *)ow_WireFormatInfo_create(pool);
@@ -2765,6 +2865,7 @@
    switch( object->structType ) {
 
       case OW_LOCALTRANSACTIONID_TYPE: return ow_marshal1_LocalTransactionId(buffer, (ow_LocalTransactionId*)object);
+      case OW_PARTIALCOMMAND_TYPE: return ow_marshal1_PartialCommand(buffer, (ow_PartialCommand*)object);
       case OW_INTEGERRESPONSE_TYPE: return ow_marshal1_IntegerResponse(buffer, (ow_IntegerResponse*)object);
       case OW_ACTIVEMQQUEUE_TYPE: return ow_marshal1_ActiveMQQueue(buffer, (ow_ActiveMQQueue*)object);
       case OW_ACTIVEMQOBJECTMESSAGE_TYPE: return ow_marshal1_ActiveMQObjectMessage(buffer,
(ow_ActiveMQObjectMessage*)object);
@@ -2793,6 +2894,7 @@
       case OW_SUBSCRIPTIONINFO_TYPE: return ow_marshal1_SubscriptionInfo(buffer, (ow_SubscriptionInfo*)object);
       case OW_JOURNALTRANSACTION_TYPE: return ow_marshal1_JournalTransaction(buffer, (ow_JournalTransaction*)object);
       case OW_CONTROLCOMMAND_TYPE: return ow_marshal1_ControlCommand(buffer, (ow_ControlCommand*)object);
+      case OW_LASTPARTIALCOMMAND_TYPE: return ow_marshal1_LastPartialCommand(buffer, (ow_LastPartialCommand*)object);
       case OW_NETWORKBRIDGEFILTER_TYPE: return ow_marshal1_NetworkBridgeFilter(buffer, (ow_NetworkBridgeFilter*)object);
       case OW_ACTIVEMQBYTESMESSAGE_TYPE: return ow_marshal1_ActiveMQBytesMessage(buffer,
(ow_ActiveMQBytesMessage*)object);
       case OW_WIREFORMATINFO_TYPE: return ow_marshal1_WireFormatInfo(buffer, (ow_WireFormatInfo*)object);
@@ -2822,6 +2924,7 @@
    switch( object->structType ) {
 
       case OW_LOCALTRANSACTIONID_TYPE: return ow_marshal2_LocalTransactionId(buffer, bitbuffer,
(ow_LocalTransactionId*)object);
+      case OW_PARTIALCOMMAND_TYPE: return ow_marshal2_PartialCommand(buffer, bitbuffer, (ow_PartialCommand*)object);
       case OW_INTEGERRESPONSE_TYPE: return ow_marshal2_IntegerResponse(buffer, bitbuffer,
(ow_IntegerResponse*)object);
       case OW_ACTIVEMQQUEUE_TYPE: return ow_marshal2_ActiveMQQueue(buffer, bitbuffer, (ow_ActiveMQQueue*)object);
       case OW_ACTIVEMQOBJECTMESSAGE_TYPE: return ow_marshal2_ActiveMQObjectMessage(buffer,
bitbuffer, (ow_ActiveMQObjectMessage*)object);
@@ -2850,6 +2953,7 @@
       case OW_SUBSCRIPTIONINFO_TYPE: return ow_marshal2_SubscriptionInfo(buffer, bitbuffer,
(ow_SubscriptionInfo*)object);
       case OW_JOURNALTRANSACTION_TYPE: return ow_marshal2_JournalTransaction(buffer, bitbuffer,
(ow_JournalTransaction*)object);
       case OW_CONTROLCOMMAND_TYPE: return ow_marshal2_ControlCommand(buffer, bitbuffer, (ow_ControlCommand*)object);
+      case OW_LASTPARTIALCOMMAND_TYPE: return ow_marshal2_LastPartialCommand(buffer, bitbuffer,
(ow_LastPartialCommand*)object);
       case OW_NETWORKBRIDGEFILTER_TYPE: return ow_marshal2_NetworkBridgeFilter(buffer, bitbuffer,
(ow_NetworkBridgeFilter*)object);
       case OW_ACTIVEMQBYTESMESSAGE_TYPE: return ow_marshal2_ActiveMQBytesMessage(buffer,
bitbuffer, (ow_ActiveMQBytesMessage*)object);
       case OW_WIREFORMATINFO_TYPE: return ow_marshal2_WireFormatInfo(buffer, bitbuffer, (ow_WireFormatInfo*)object);
@@ -2879,6 +2983,7 @@
    switch( object->structType ) {
 
       case OW_LOCALTRANSACTIONID_TYPE: return ow_unmarshal_LocalTransactionId(buffer, bitbuffer,
(ow_LocalTransactionId*)object, pool);
+      case OW_PARTIALCOMMAND_TYPE: return ow_unmarshal_PartialCommand(buffer, bitbuffer,
(ow_PartialCommand*)object, pool);
       case OW_INTEGERRESPONSE_TYPE: return ow_unmarshal_IntegerResponse(buffer, bitbuffer,
(ow_IntegerResponse*)object, pool);
       case OW_ACTIVEMQQUEUE_TYPE: return ow_unmarshal_ActiveMQQueue(buffer, bitbuffer, (ow_ActiveMQQueue*)object,
pool);
       case OW_ACTIVEMQOBJECTMESSAGE_TYPE: return ow_unmarshal_ActiveMQObjectMessage(buffer,
bitbuffer, (ow_ActiveMQObjectMessage*)object, pool);
@@ -2907,6 +3012,7 @@
       case OW_SUBSCRIPTIONINFO_TYPE: return ow_unmarshal_SubscriptionInfo(buffer, bitbuffer,
(ow_SubscriptionInfo*)object, pool);
       case OW_JOURNALTRANSACTION_TYPE: return ow_unmarshal_JournalTransaction(buffer, bitbuffer,
(ow_JournalTransaction*)object, pool);
       case OW_CONTROLCOMMAND_TYPE: return ow_unmarshal_ControlCommand(buffer, bitbuffer,
(ow_ControlCommand*)object, pool);
+      case OW_LASTPARTIALCOMMAND_TYPE: return ow_unmarshal_LastPartialCommand(buffer, bitbuffer,
(ow_LastPartialCommand*)object, pool);
       case OW_NETWORKBRIDGEFILTER_TYPE: return ow_unmarshal_NetworkBridgeFilter(buffer, bitbuffer,
(ow_NetworkBridgeFilter*)object, pool);
       case OW_ACTIVEMQBYTESMESSAGE_TYPE: return ow_unmarshal_ActiveMQBytesMessage(buffer,
bitbuffer, (ow_ActiveMQBytesMessage*)object, pool);
       case OW_WIREFORMATINFO_TYPE: return ow_unmarshal_WireFormatInfo(buffer, bitbuffer,
(ow_WireFormatInfo*)object, 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=384829&r1=384828&r2=384829&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 Fri Mar 10 07:55:58
2006
@@ -49,12 +49,23 @@
 ow_LocalTransactionId *ow_LocalTransactionId_create(apr_pool_t *pool);
 ow_boolean ow_is_a_LocalTransactionId(ow_DataStructure *object);
 
+typedef struct ow_PartialCommand {
+
+   ow_byte structType;
+   ow_int commandId;
+   ow_boolean responseRequired;
+   ow_byte_array *data;
+
+} ow_PartialCommand;
+ow_PartialCommand *ow_PartialCommand_create(apr_pool_t *pool);
+ow_boolean ow_is_a_PartialCommand(ow_DataStructure *object);
+
 typedef struct ow_IntegerResponse {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
-   ow_short correlationId;
+   ow_int correlationId;
    ow_int result;
 
 } ow_IntegerResponse;
@@ -81,7 +92,7 @@
 typedef struct ow_ActiveMQObjectMessage {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
    struct ow_ProducerId *producerId;
    struct ow_ActiveMQDestination *destination;
@@ -125,7 +136,7 @@
 typedef struct ow_ConnectionInfo {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
    struct ow_ConnectionId *connectionId;
    ow_string *clientId;
@@ -140,7 +151,7 @@
 typedef struct ow_ProducerInfo {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
    struct ow_ProducerId *producerId;
    struct ow_ActiveMQDestination *destination;
@@ -153,7 +164,7 @@
 typedef struct ow_MessageDispatchNotification {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
    struct ow_ConsumerId *consumerId;
    struct ow_ActiveMQDestination *destination;
@@ -167,7 +178,7 @@
 typedef struct ow_SessionInfo {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
    struct ow_SessionId *sessionId;
 
@@ -178,7 +189,7 @@
 typedef struct ow_TransactionInfo {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
    struct ow_ConnectionId *connectionId;
    struct ow_TransactionId *transactionId;
@@ -191,7 +202,7 @@
 typedef struct ow_ActiveMQStreamMessage {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
    struct ow_ProducerId *producerId;
    struct ow_ActiveMQDestination *destination;
@@ -226,7 +237,7 @@
 typedef struct ow_MessageAck {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
    struct ow_ActiveMQDestination *destination;
    struct ow_TransactionId *transactionId;
@@ -274,7 +285,7 @@
 typedef struct ow_RemoveSubscriptionInfo {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
    struct ow_ConnectionId *connectionId;
    ow_string *subcriptionName;
@@ -297,9 +308,9 @@
 typedef struct ow_DataArrayResponse {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
-   ow_short correlationId;
+   ow_int correlationId;
    ow_DataStructure_array *data;
 
 } ow_DataArrayResponse;
@@ -319,9 +330,9 @@
 typedef struct ow_Response {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
-   ow_short correlationId;
+   ow_int correlationId;
 
 } ow_Response;
 ow_Response *ow_Response_create(apr_pool_t *pool);
@@ -330,7 +341,7 @@
 typedef struct ow_ConnectionError {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
    ow_throwable *exception;
    struct ow_ConnectionId *connectionId;
@@ -342,7 +353,7 @@
 typedef struct ow_ConsumerInfo {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
    struct ow_ConsumerId *consumerId;
    ow_boolean browser;
@@ -398,7 +409,7 @@
 typedef struct ow_ActiveMQTextMessage {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
    struct ow_ProducerId *producerId;
    struct ow_ActiveMQDestination *destination;
@@ -456,7 +467,7 @@
 typedef struct ow_ControlCommand {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
    ow_string *command;
 
@@ -464,6 +475,17 @@
 ow_ControlCommand *ow_ControlCommand_create(apr_pool_t *pool);
 ow_boolean ow_is_a_ControlCommand(ow_DataStructure *object);
 
+typedef struct ow_LastPartialCommand {
+
+   ow_byte structType;
+   ow_int commandId;
+   ow_boolean responseRequired;
+   ow_byte_array *data;
+
+} ow_LastPartialCommand;
+ow_LastPartialCommand *ow_LastPartialCommand_create(apr_pool_t *pool);
+ow_boolean ow_is_a_LastPartialCommand(ow_DataStructure *object);
+
 typedef struct ow_NetworkBridgeFilter {
 
    ow_byte structType;
@@ -477,7 +499,7 @@
 typedef struct ow_ActiveMQBytesMessage {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
    struct ow_ProducerId *producerId;
    struct ow_ActiveMQDestination *destination;
@@ -551,8 +573,10 @@
 typedef struct ow_ReplayCommand {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
+   ow_int firstNakNumber;
+   ow_int lastNakNumber;
 
 } ow_ReplayCommand;
 ow_ReplayCommand *ow_ReplayCommand_create(apr_pool_t *pool);
@@ -579,7 +603,7 @@
 typedef struct ow_BrokerInfo {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
    struct ow_BrokerId *brokerId;
    ow_string *brokerURL;
@@ -594,7 +618,7 @@
 typedef struct ow_DestinationInfo {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
    struct ow_ConnectionId *connectionId;
    struct ow_ActiveMQDestination *destination;
@@ -609,7 +633,7 @@
 typedef struct ow_ShutdownInfo {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
 
 } ow_ShutdownInfo;
@@ -619,9 +643,9 @@
 typedef struct ow_DataResponse {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
-   ow_short correlationId;
+   ow_int correlationId;
    struct ow_DataStructure *data;
 
 } ow_DataResponse;
@@ -639,7 +663,7 @@
 typedef struct ow_Message {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
    struct ow_ProducerId *producerId;
    struct ow_ActiveMQDestination *destination;
@@ -674,7 +698,7 @@
 typedef struct ow_BaseCommand {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
 
 } ow_BaseCommand;
@@ -684,7 +708,7 @@
 typedef struct ow_FlushCommand {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
 
 } ow_FlushCommand;
@@ -717,7 +741,7 @@
 typedef struct ow_MessageDispatch {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
    struct ow_ConsumerId *consumerId;
    struct ow_ActiveMQDestination *destination;
@@ -731,7 +755,7 @@
 typedef struct ow_ActiveMQMapMessage {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
    struct ow_ProducerId *producerId;
    struct ow_ActiveMQDestination *destination;
@@ -766,7 +790,7 @@
 typedef struct ow_ActiveMQMessage {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
    struct ow_ProducerId *producerId;
    struct ow_ActiveMQDestination *destination;
@@ -801,7 +825,7 @@
 typedef struct ow_RemoveInfo {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
    struct ow_DataStructure *objectId;
 
@@ -812,9 +836,9 @@
 typedef struct ow_ExceptionResponse {
 
    ow_byte structType;
-   ow_short commandId;
+   ow_int commandId;
    ow_boolean responseRequired;
-   ow_short correlationId;
+   ow_int correlationId;
    ow_throwable *exception;
 
 } ow_ExceptionResponse;



Mime
View raw message