Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Latest generated openwire 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384829 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
James Strachan 2006-03-10 15:55:58 +00:00
parent 73f173852c
commit 555e7e296f
3 changed files with 170 additions and 40 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
openwire-c/openwire.xcodeproj/project.pbxproj
View File

@ -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 */

114
openwire-c/src/libopenwire/ow_commands_v1.c
View File

@ -78,6 +78,54 @@ apr_status_t ow_unmarshal_LocalTransactionId(ow_byte_array *buffer, ow_bit_buffe
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_marshal1_Response(ow_bit_buffer *buffer, ow_Response *object)
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_marshal2_Response(ow_byte_buffer *buffer, ow_bit_buffer *bitbuff
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 @@ apr_status_t ow_unmarshal_ControlCommand(ow_byte_array *buffer, ow_bit_buffer *b
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 @@ apr_status_t ow_marshal1_ReplayCommand(ow_bit_buffer *buffer, ow_ReplayCommand *
{
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_marshal2_ReplayCommand(ow_byte_buffer *buffer, ow_bit_buffer *bi
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 @@ ow_boolean ow_is_a_BaseCommand(ow_DataStructure *object) {
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 @@ ow_boolean ow_is_a_BaseCommand(ow_DataStructure *object) {
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_marshal1_BaseCommand(ow_bit_buffer *buffer, ow_BaseCommand *obje
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_marshal2_BaseCommand(ow_byte_buffer *buffer, ow_bit_buffer *bitb
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 @@ ow_DataStructure *ow_create_object(ow_byte type, apr_pool_t *pool)
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 @@ ow_DataStructure *ow_create_object(ow_byte type, apr_pool_t *pool)
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 @@ apr_status_t ow_marshal1_object(ow_bit_buffer *buffer, ow_DataStructure *object)
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 @@ apr_status_t ow_marshal1_object(ow_bit_buffer *buffer, ow_DataStructure *object)
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 @@ apr_status_t ow_marshal2_object(ow_byte_buffer *buffer, ow_bit_buffer *bitbuffer
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 @@ apr_status_t ow_marshal2_object(ow_byte_buffer *buffer, ow_bit_buffer *bitbuffer
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 @@ apr_status_t ow_unmarshal_object(ow_byte_array *buffer, ow_bit_buffer *bitbuffer
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 @@ apr_status_t ow_unmarshal_object(ow_byte_array *buffer, ow_bit_buffer *bitbuffer
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);

94
openwire-c/src/libopenwire/ow_commands_v1.h
View File

@ -49,12 +49,23 @@ typedef struct ow_LocalTransactionId {
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 @@ ow_boolean ow_is_a_TransactionId(ow_DataStructure *object);
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 @@ ow_boolean ow_is_a_ConnectionId(ow_DataStructure *object);
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 @@ ow_boolean ow_is_a_ConnectionInfo(ow_DataStructure *object);
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 @@ ow_boolean ow_is_a_ProducerInfo(ow_DataStructure *object);
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 @@ ow_boolean ow_is_a_MessageDispatchNotification(ow_DataStructure *object);
typedef struct ow_SessionInfo {
ow_byte structType;
ow_short commandId;
ow_int commandId;
ow_boolean responseRequired;
struct ow_SessionId *sessionId;
@ -178,7 +189,7 @@ ow_boolean ow_is_a_SessionInfo(ow_DataStructure *object);
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 @@ ow_boolean ow_is_a_TransactionInfo(ow_DataStructure *object);
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 @@ ow_boolean ow_is_a_ActiveMQStreamMessage(ow_DataStructure *object);
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 @@ ow_boolean ow_is_a_ActiveMQTempQueue(ow_DataStructure *object);
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 @@ ow_boolean ow_is_a_SessionId(ow_DataStructure *object);
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 @@ ow_boolean ow_is_a_JournalQueueAck(ow_DataStructure *object);
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 @@ ow_boolean ow_is_a_Response(ow_DataStructure *object);
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 @@ ow_boolean ow_is_a_ConnectionError(ow_DataStructure *object);
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 @@ ow_boolean ow_is_a_ConsumerId(ow_DataStructure *object);
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 @@ ow_boolean ow_is_a_JournalTransaction(ow_DataStructure *object);
typedef struct ow_ControlCommand {
ow_byte structType;
ow_short commandId;
ow_int commandId;
ow_boolean responseRequired;
ow_string *command;
@ -464,6 +475,17 @@ typedef struct ow_ControlCommand {
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 @@ ow_boolean ow_is_a_NetworkBridgeFilter(ow_DataStructure *object);
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 @@ ow_boolean ow_is_a_ActiveMQTempDestination(ow_DataStructure *object);
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 @@ ow_boolean ow_is_a_ActiveMQTopic(ow_DataStructure *object);
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 @@ ow_boolean ow_is_a_BrokerInfo(ow_DataStructure *object);
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 @@ ow_boolean ow_is_a_DestinationInfo(ow_DataStructure *object);
typedef struct ow_ShutdownInfo {
ow_byte structType;
ow_short commandId;
ow_int commandId;
ow_boolean responseRequired;
} ow_ShutdownInfo;
@ -619,9 +643,9 @@ ow_boolean ow_is_a_ShutdownInfo(ow_DataStructure *object);
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 @@ ow_boolean ow_is_a_KeepAliveInfo(ow_DataStructure *object);
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 @@ ow_boolean ow_is_a_Message(ow_DataStructure *object);
typedef struct ow_BaseCommand {
ow_byte structType;
ow_short commandId;
ow_int commandId;
ow_boolean responseRequired;
} ow_BaseCommand;
@ -684,7 +708,7 @@ ow_boolean ow_is_a_BaseCommand(ow_DataStructure *object);
typedef struct ow_FlushCommand {
ow_byte structType;
ow_short commandId;
ow_int commandId;
ow_boolean responseRequired;
} ow_FlushCommand;
@ -717,7 +741,7 @@ ow_boolean ow_is_a_BrokerId(ow_DataStructure *object);
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 @@ ow_boolean ow_is_a_MessageDispatch(ow_DataStructure *object);
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 @@ ow_boolean ow_is_a_ActiveMQMapMessage(ow_DataStructure *object);
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 @@ ow_boolean ow_is_a_ActiveMQMessage(ow_DataStructure *object);
typedef struct ow_RemoveInfo {
ow_byte structType;
ow_short commandId;
ow_int commandId;
ow_boolean responseRequired;
struct ow_DataStructure *objectId;
@ -812,9 +836,9 @@ ow_boolean ow_is_a_RemoveInfo(ow_DataStructure *object);
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;