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;
