activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r450293 [3/3] - in /incubator/activemq/sandbox/openwire-c: openwire.xcodeproj/project.pbxproj pom.xml src/libactivemq/amqcs.c src/libactivemq/amqcs.h src/libopenwire/ow_commands_v2.c src/libopenwire/ow_commands_v2.h
Date Wed, 27 Sep 2006 02:59:06 GMT
Modified: incubator/activemq/sandbox/openwire-c/src/libopenwire/ow_commands_v2.h
URL: http://svn.apache.org/viewvc/incubator/activemq/sandbox/openwire-c/src/libopenwire/ow_commands_v2.h?view=diff&rev=450293&r1=450292&r2=450293
==============================================================================
--- incubator/activemq/sandbox/openwire-c/src/libopenwire/ow_commands_v2.h (original)
+++ incubator/activemq/sandbox/openwire-c/src/libopenwire/ow_commands_v2.h Tue Sep 26 19:59:05
2006
@@ -29,100 +29,101 @@
 #define OW_COMMANDS_V2_H
 
 #include "ow.h"
-#include "ow_command_types_v2.h"
 
 #ifdef __cplusplus
 extern "C" {
 #endif /* __cplusplus */
       
 #define OW_WIREFORMAT_VERSION 2
+#define OW_WIREFORMAT_STACK_TRACE_MASK     0x00000001;
+#define OW_WIREFORMAT_TCP_NO_DELAY_MASK    0x00000002;
+#define OW_WIREFORMAT_CACHE_MASK           0x00000004;
+#define OW_WIREFORMAT_COMPRESSION_MASK     0x00000008;
+#define OW_BROKERID_TYPE 124
+#define OW_CONNECTIONID_TYPE 120
+#define OW_CONSUMERID_TYPE 122
+#define OW_DISCOVERYEVENT_TYPE 40
+#define OW_JOURNALQUEUEACK_TYPE 52
+#define OW_JOURNALTOPICACK_TYPE 50
+#define OW_JOURNALTRACE_TYPE 53
+#define OW_JOURNALTRANSACTION_TYPE 54
+#define OW_MESSAGEID_TYPE 110
+#define OW_NETWORKBRIDGEFILTER_TYPE 91
+#define OW_PARTIALCOMMAND_TYPE 60
+#define OW_PRODUCERID_TYPE 123
+#define OW_SESSIONID_TYPE 121
+#define OW_SUBSCRIPTIONINFO_TYPE 55
+#define OW_WIREFORMATINFO_TYPE 1
+#define OW_ACTIVEMQBYTESMESSAGE_TYPE 24
+#define OW_ACTIVEMQMAPMESSAGE_TYPE 25
+#define OW_ACTIVEMQMESSAGE_TYPE 23
+#define OW_ACTIVEMQOBJECTMESSAGE_TYPE 26
+#define OW_ACTIVEMQQUEUE_TYPE 100
+#define OW_ACTIVEMQSTREAMMESSAGE_TYPE 27
+#define OW_ACTIVEMQTEMPQUEUE_TYPE 102
+#define OW_ACTIVEMQTEMPTOPIC_TYPE 103
+#define OW_ACTIVEMQTEXTMESSAGE_TYPE 28
+#define OW_ACTIVEMQTOPIC_TYPE 101
+#define OW_BROKERINFO_TYPE 2
+#define OW_CONNECTIONCONTROL_TYPE 18
+#define OW_CONNECTIONERROR_TYPE 16
+#define OW_CONNECTIONINFO_TYPE 3
+#define OW_CONSUMERCONTROL_TYPE 17
+#define OW_CONSUMERINFO_TYPE 5
+#define OW_CONTROLCOMMAND_TYPE 14
+#define OW_DATAARRAYRESPONSE_TYPE 33
+#define OW_DATARESPONSE_TYPE 32
+#define OW_DESTINATIONINFO_TYPE 8
+#define OW_EXCEPTIONRESPONSE_TYPE 31
+#define OW_FLUSHCOMMAND_TYPE 15
+#define OW_INTEGERRESPONSE_TYPE 34
+#define OW_KEEPALIVEINFO_TYPE 10
+#define OW_LASTPARTIALCOMMAND_TYPE 61
+#define OW_LOCALTRANSACTIONID_TYPE 111
+#define OW_MESSAGEACK_TYPE 22
+#define OW_MESSAGEDISPATCH_TYPE 21
+#define OW_MESSAGEDISPATCHNOTIFICATION_TYPE 90
+#define OW_MESSAGEPULL_TYPE 20
+#define OW_PRODUCERINFO_TYPE 6
+#define OW_REMOVEINFO_TYPE 12
+#define OW_REMOVESUBSCRIPTIONINFO_TYPE 0
+#define OW_REPLAYCOMMAND_TYPE 65
+#define OW_RESPONSE_TYPE 30
+#define OW_SESSIONINFO_TYPE 4
+#define OW_SHUTDOWNINFO_TYPE 11
+#define OW_TRANSACTIONINFO_TYPE 7
+#define OW_XATRANSACTIONID_TYPE 112
       
 apr_status_t ow_bitmarshall(ow_bit_buffer *buffer, ow_DataStructure *object);
 apr_status_t ow_marshall(ow_byte_buffer *buffer, ow_DataStructure *object);
 
-typedef struct ow_LocalTransactionId {
-
-   ow_byte structType;
-   ow_long value;
-   struct ow_ConnectionId *connectionId;
-
-} ow_LocalTransactionId;
-ow_LocalTransactionId *ow_LocalTransactionId_create(apr_pool_t *pool);
-ow_boolean ow_is_a_LocalTransactionId(ow_DataStructure *object);
-
-typedef struct ow_PartialCommand {
+typedef struct ow_ActiveMQDestination {
 
    ow_byte structType;
-   ow_int commandId;
-   ow_byte_array *data;
+   ow_string *physicalName;
 
-} ow_PartialCommand;
-ow_PartialCommand *ow_PartialCommand_create(apr_pool_t *pool);
-ow_boolean ow_is_a_PartialCommand(ow_DataStructure *object);
+} ow_ActiveMQDestination;
+ow_ActiveMQDestination *ow_ActiveMQDestination_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ActiveMQDestination(ow_DataStructure *object);
 
-typedef struct ow_IntegerResponse {
+typedef struct ow_BaseCommand {
 
    ow_byte structType;
    ow_int commandId;
    ow_boolean responseRequired;
-   ow_int correlationId;
-   ow_int result;
-
-} ow_IntegerResponse;
-ow_IntegerResponse *ow_IntegerResponse_create(apr_pool_t *pool);
-ow_boolean ow_is_a_IntegerResponse(ow_DataStructure *object);
 
-typedef struct ow_ActiveMQQueue {
-
-   ow_byte structType;
-   ow_string *physicalName;
-
-} ow_ActiveMQQueue;
-ow_ActiveMQQueue *ow_ActiveMQQueue_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ActiveMQQueue(ow_DataStructure *object);
-
-typedef struct ow_TransactionId {
-
-   ow_byte structType;
-
-} ow_TransactionId;
-ow_TransactionId *ow_TransactionId_create(apr_pool_t *pool);
-ow_boolean ow_is_a_TransactionId(ow_DataStructure *object);
+} ow_BaseCommand;
+ow_BaseCommand *ow_BaseCommand_create(apr_pool_t *pool);
+ow_boolean ow_is_a_BaseCommand(ow_DataStructure *object);
 
-typedef struct ow_ActiveMQObjectMessage {
+typedef struct ow_BrokerId {
 
    ow_byte structType;
-   ow_int commandId;
-   ow_boolean responseRequired;
-   struct ow_ProducerId *producerId;
-   struct ow_ActiveMQDestination *destination;
-   struct ow_TransactionId *transactionId;
-   struct ow_ActiveMQDestination *originalDestination;
-   struct ow_MessageId *messageId;
-   struct ow_TransactionId *originalTransactionId;
-   ow_string *groupID;
-   ow_int groupSequence;
-   ow_string *correlationId;
-   ow_boolean persistent;
-   ow_long expiration;
-   ow_byte priority;
-   struct ow_ActiveMQDestination *replyTo;
-   ow_long timestamp;
-   ow_string *type;
-   struct ow_ByteSequence *content;
-   struct ow_ByteSequence *marshalledProperties;
-   struct ow_DataStructure *dataStructure;
-   struct ow_ConsumerId *targetConsumerId;
-   ow_boolean compressed;
-   ow_int redeliveryCounter;
-   ow_DataStructure_array *brokerPath;
-   ow_long arrival;
-   ow_string *userID;
-   ow_boolean recievedByDFBridge;
+   ow_string *value;
 
-} ow_ActiveMQObjectMessage;
-ow_ActiveMQObjectMessage *ow_ActiveMQObjectMessage_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ActiveMQObjectMessage(ow_DataStructure *object);
+} ow_BrokerId;
+ow_BrokerId *ow_BrokerId_create(apr_pool_t *pool);
+ow_boolean ow_is_a_BrokerId(ow_DataStructure *object);
 
 typedef struct ow_ConnectionId {
 
@@ -133,136 +134,70 @@
 ow_ConnectionId *ow_ConnectionId_create(apr_pool_t *pool);
 ow_boolean ow_is_a_ConnectionId(ow_DataStructure *object);
 
-typedef struct ow_ConnectionInfo {
+typedef struct ow_ConsumerId {
 
    ow_byte structType;
-   ow_int commandId;
-   ow_boolean responseRequired;
-   struct ow_ConnectionId *connectionId;
-   ow_string *clientId;
-   ow_string *password;
-   ow_string *userName;
-   ow_DataStructure_array *brokerPath;
-   ow_boolean brokerMasterConnector;
-   ow_boolean manageable;
+   ow_string *connectionId;
+   ow_long sessionId;
+   ow_long value;
 
-} ow_ConnectionInfo;
-ow_ConnectionInfo *ow_ConnectionInfo_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ConnectionInfo(ow_DataStructure *object);
+} ow_ConsumerId;
+ow_ConsumerId *ow_ConsumerId_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ConsumerId(ow_DataStructure *object);
 
-typedef struct ow_ProducerInfo {
+typedef struct ow_DiscoveryEvent {
 
    ow_byte structType;
-   ow_int commandId;
-   ow_boolean responseRequired;
-   struct ow_ProducerId *producerId;
-   struct ow_ActiveMQDestination *destination;
-   ow_DataStructure_array *brokerPath;
+   ow_string *serviceName;
+   ow_string *brokerName;
 
-} ow_ProducerInfo;
-ow_ProducerInfo *ow_ProducerInfo_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ProducerInfo(ow_DataStructure *object);
+} ow_DiscoveryEvent;
+ow_DiscoveryEvent *ow_DiscoveryEvent_create(apr_pool_t *pool);
+ow_boolean ow_is_a_DiscoveryEvent(ow_DataStructure *object);
 
-typedef struct ow_MessageDispatchNotification {
+typedef struct ow_JournalQueueAck {
 
    ow_byte structType;
-   ow_int commandId;
-   ow_boolean responseRequired;
-   struct ow_ConsumerId *consumerId;
    struct ow_ActiveMQDestination *destination;
-   ow_long deliverySequenceId;
-   struct ow_MessageId *messageId;
-
-} ow_MessageDispatchNotification;
-ow_MessageDispatchNotification *ow_MessageDispatchNotification_create(apr_pool_t *pool);
-ow_boolean ow_is_a_MessageDispatchNotification(ow_DataStructure *object);
-
-typedef struct ow_SessionInfo {
-
-   ow_byte structType;
-   ow_int commandId;
-   ow_boolean responseRequired;
-   struct ow_SessionId *sessionId;
-
-} ow_SessionInfo;
-ow_SessionInfo *ow_SessionInfo_create(apr_pool_t *pool);
-ow_boolean ow_is_a_SessionInfo(ow_DataStructure *object);
-
-typedef struct ow_TransactionInfo {
-
-   ow_byte structType;
-   ow_int commandId;
-   ow_boolean responseRequired;
-   struct ow_ConnectionId *connectionId;
-   struct ow_TransactionId *transactionId;
-   ow_byte type;
+   struct ow_MessageAck *messageAck;
 
-} ow_TransactionInfo;
-ow_TransactionInfo *ow_TransactionInfo_create(apr_pool_t *pool);
-ow_boolean ow_is_a_TransactionInfo(ow_DataStructure *object);
+} ow_JournalQueueAck;
+ow_JournalQueueAck *ow_JournalQueueAck_create(apr_pool_t *pool);
+ow_boolean ow_is_a_JournalQueueAck(ow_DataStructure *object);
 
-typedef struct ow_ActiveMQStreamMessage {
+typedef struct ow_JournalTopicAck {
 
    ow_byte structType;
-   ow_int commandId;
-   ow_boolean responseRequired;
-   struct ow_ProducerId *producerId;
    struct ow_ActiveMQDestination *destination;
-   struct ow_TransactionId *transactionId;
-   struct ow_ActiveMQDestination *originalDestination;
    struct ow_MessageId *messageId;
-   struct ow_TransactionId *originalTransactionId;
-   ow_string *groupID;
-   ow_int groupSequence;
-   ow_string *correlationId;
-   ow_boolean persistent;
-   ow_long expiration;
-   ow_byte priority;
-   struct ow_ActiveMQDestination *replyTo;
-   ow_long timestamp;
-   ow_string *type;
-   struct ow_ByteSequence *content;
-   struct ow_ByteSequence *marshalledProperties;
-   struct ow_DataStructure *dataStructure;
-   struct ow_ConsumerId *targetConsumerId;
-   ow_boolean compressed;
-   ow_int redeliveryCounter;
-   ow_DataStructure_array *brokerPath;
-   ow_long arrival;
-   ow_string *userID;
-   ow_boolean recievedByDFBridge;
+   ow_long messageSequenceId;
+   ow_string *subscritionName;
+   ow_string *clientId;
+   struct ow_TransactionId *transactionId;
 
-} ow_ActiveMQStreamMessage;
-ow_ActiveMQStreamMessage *ow_ActiveMQStreamMessage_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ActiveMQStreamMessage(ow_DataStructure *object);
+} ow_JournalTopicAck;
+ow_JournalTopicAck *ow_JournalTopicAck_create(apr_pool_t *pool);
+ow_boolean ow_is_a_JournalTopicAck(ow_DataStructure *object);
 
-typedef struct ow_MessageAck {
+typedef struct ow_JournalTrace {
 
    ow_byte structType;
-   ow_int commandId;
-   ow_boolean responseRequired;
-   struct ow_ActiveMQDestination *destination;
-   struct ow_TransactionId *transactionId;
-   struct ow_ConsumerId *consumerId;
-   ow_byte ackType;
-   struct ow_MessageId *firstMessageId;
-   struct ow_MessageId *lastMessageId;
-   ow_int messageCount;
+   ow_string *message;
 
-} ow_MessageAck;
-ow_MessageAck *ow_MessageAck_create(apr_pool_t *pool);
-ow_boolean ow_is_a_MessageAck(ow_DataStructure *object);
+} ow_JournalTrace;
+ow_JournalTrace *ow_JournalTrace_create(apr_pool_t *pool);
+ow_boolean ow_is_a_JournalTrace(ow_DataStructure *object);
 
-typedef struct ow_ProducerId {
+typedef struct ow_JournalTransaction {
 
    ow_byte structType;
-   ow_string *connectionId;
-   ow_long value;
-   ow_long sessionId;
+   struct ow_TransactionId *transactionId;
+   ow_byte type;
+   ow_boolean wasPrepared;
 
-} ow_ProducerId;
-ow_ProducerId *ow_ProducerId_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ProducerId(ow_DataStructure *object);
+} ow_JournalTransaction;
+ow_JournalTransaction *ow_JournalTransaction_create(apr_pool_t *pool);
+ow_boolean ow_is_a_JournalTransaction(ow_DataStructure *object);
 
 typedef struct ow_MessageId {
 
@@ -275,27 +210,36 @@
 ow_MessageId *ow_MessageId_create(apr_pool_t *pool);
 ow_boolean ow_is_a_MessageId(ow_DataStructure *object);
 
-typedef struct ow_ActiveMQTempQueue {
+typedef struct ow_NetworkBridgeFilter {
 
    ow_byte structType;
-   ow_string *physicalName;
+   ow_int networkTTL;
+   struct ow_BrokerId *networkBrokerId;
 
-} ow_ActiveMQTempQueue;
-ow_ActiveMQTempQueue *ow_ActiveMQTempQueue_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ActiveMQTempQueue(ow_DataStructure *object);
+} ow_NetworkBridgeFilter;
+ow_NetworkBridgeFilter *ow_NetworkBridgeFilter_create(apr_pool_t *pool);
+ow_boolean ow_is_a_NetworkBridgeFilter(ow_DataStructure *object);
 
-typedef struct ow_RemoveSubscriptionInfo {
+typedef struct ow_PartialCommand {
 
    ow_byte structType;
    ow_int commandId;
-   ow_boolean responseRequired;
-   struct ow_ConnectionId *connectionId;
-   ow_string *subcriptionName;
-   ow_string *clientId;
+   ow_byte_array *data;
 
-} ow_RemoveSubscriptionInfo;
-ow_RemoveSubscriptionInfo *ow_RemoveSubscriptionInfo_create(apr_pool_t *pool);
-ow_boolean ow_is_a_RemoveSubscriptionInfo(ow_DataStructure *object);
+} ow_PartialCommand;
+ow_PartialCommand *ow_PartialCommand_create(apr_pool_t *pool);
+ow_boolean ow_is_a_PartialCommand(ow_DataStructure *object);
+
+typedef struct ow_ProducerId {
+
+   ow_byte structType;
+   ow_string *connectionId;
+   ow_long value;
+   ow_long sessionId;
+
+} ow_ProducerId;
+ow_ProducerId *ow_ProducerId_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ProducerId(ow_DataStructure *object);
 
 typedef struct ow_SessionId {
 
@@ -307,110 +251,187 @@
 ow_SessionId *ow_SessionId_create(apr_pool_t *pool);
 ow_boolean ow_is_a_SessionId(ow_DataStructure *object);
 
-typedef struct ow_DataArrayResponse {
+typedef struct ow_SubscriptionInfo {
 
    ow_byte structType;
-   ow_int commandId;
-   ow_boolean responseRequired;
-   ow_int correlationId;
-   ow_DataStructure_array *data;
+   ow_string *clientId;
+   struct ow_ActiveMQDestination *destination;
+   ow_string *selector;
+   ow_string *subcriptionName;
 
-} ow_DataArrayResponse;
-ow_DataArrayResponse *ow_DataArrayResponse_create(apr_pool_t *pool);
-ow_boolean ow_is_a_DataArrayResponse(ow_DataStructure *object);
+} ow_SubscriptionInfo;
+ow_SubscriptionInfo *ow_SubscriptionInfo_create(apr_pool_t *pool);
+ow_boolean ow_is_a_SubscriptionInfo(ow_DataStructure *object);
 
-typedef struct ow_JournalQueueAck {
+typedef struct ow_TransactionId {
 
    ow_byte structType;
-   struct ow_ActiveMQDestination *destination;
-   struct ow_MessageAck *messageAck;
 
-} ow_JournalQueueAck;
-ow_JournalQueueAck *ow_JournalQueueAck_create(apr_pool_t *pool);
-ow_boolean ow_is_a_JournalQueueAck(ow_DataStructure *object);
+} ow_TransactionId;
+ow_TransactionId *ow_TransactionId_create(apr_pool_t *pool);
+ow_boolean ow_is_a_TransactionId(ow_DataStructure *object);
 
-typedef struct ow_Response {
+typedef struct ow_WireFormatInfo {
 
    ow_byte structType;
-   ow_int commandId;
-   ow_boolean responseRequired;
-   ow_int correlationId;
+   ow_byte_array *magic;
+   ow_int version;
+   struct ow_ByteSequence *marshalledProperties;
 
-} ow_Response;
-ow_Response *ow_Response_create(apr_pool_t *pool);
-ow_boolean ow_is_a_Response(ow_DataStructure *object);
+} ow_WireFormatInfo;
+ow_WireFormatInfo *ow_WireFormatInfo_create(apr_pool_t *pool);
+ow_boolean ow_is_a_WireFormatInfo(ow_DataStructure *object);
 
-typedef struct ow_ConnectionError {
+typedef struct ow_ActiveMQBytesMessage {
 
    ow_byte structType;
    ow_int commandId;
    ow_boolean responseRequired;
-   ow_throwable *exception;
-   struct ow_ConnectionId *connectionId;
+   struct ow_ProducerId *producerId;
+   struct ow_ActiveMQDestination *destination;
+   struct ow_TransactionId *transactionId;
+   struct ow_ActiveMQDestination *originalDestination;
+   struct ow_MessageId *messageId;
+   struct ow_TransactionId *originalTransactionId;
+   ow_string *groupID;
+   ow_int groupSequence;
+   ow_string *correlationId;
+   ow_boolean persistent;
+   ow_long expiration;
+   ow_byte priority;
+   struct ow_ActiveMQDestination *replyTo;
+   ow_long timestamp;
+   ow_string *type;
+   struct ow_ByteSequence *content;
+   struct ow_ByteSequence *marshalledProperties;
+   struct ow_DataStructure *dataStructure;
+   struct ow_ConsumerId *targetConsumerId;
+   ow_boolean compressed;
+   ow_int redeliveryCounter;
+   ow_DataStructure_array *brokerPath;
+   ow_long arrival;
+   ow_string *userID;
+   ow_boolean recievedByDFBridge;
 
-} ow_ConnectionError;
-ow_ConnectionError *ow_ConnectionError_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ConnectionError(ow_DataStructure *object);
+} ow_ActiveMQBytesMessage;
+ow_ActiveMQBytesMessage *ow_ActiveMQBytesMessage_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ActiveMQBytesMessage(ow_DataStructure *object);
 
-typedef struct ow_ConsumerInfo {
+typedef struct ow_ActiveMQMapMessage {
 
    ow_byte structType;
    ow_int commandId;
    ow_boolean responseRequired;
-   struct ow_ConsumerId *consumerId;
-   ow_boolean browser;
+   struct ow_ProducerId *producerId;
    struct ow_ActiveMQDestination *destination;
-   ow_int prefetchSize;
-   ow_int maximumPendingMessageLimit;
-   ow_boolean dispatchAsync;
-   ow_string *selector;
-   ow_string *subcriptionName;
-   ow_boolean noLocal;
-   ow_boolean exclusive;
-   ow_boolean retroactive;
+   struct ow_TransactionId *transactionId;
+   struct ow_ActiveMQDestination *originalDestination;
+   struct ow_MessageId *messageId;
+   struct ow_TransactionId *originalTransactionId;
+   ow_string *groupID;
+   ow_int groupSequence;
+   ow_string *correlationId;
+   ow_boolean persistent;
+   ow_long expiration;
    ow_byte priority;
+   struct ow_ActiveMQDestination *replyTo;
+   ow_long timestamp;
+   ow_string *type;
+   struct ow_ByteSequence *content;
+   struct ow_ByteSequence *marshalledProperties;
+   struct ow_DataStructure *dataStructure;
+   struct ow_ConsumerId *targetConsumerId;
+   ow_boolean compressed;
+   ow_int redeliveryCounter;
    ow_DataStructure_array *brokerPath;
-   struct ow_BooleanExpression *additionalPredicate;
-   ow_boolean networkSubscription;
-   ow_boolean optimizedAcknowledge;
-   ow_boolean noRangeAcks;
+   ow_long arrival;
+   ow_string *userID;
+   ow_boolean recievedByDFBridge;
 
-} ow_ConsumerInfo;
-ow_ConsumerInfo *ow_ConsumerInfo_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ConsumerInfo(ow_DataStructure *object);
+} ow_ActiveMQMapMessage;
+ow_ActiveMQMapMessage *ow_ActiveMQMapMessage_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ActiveMQMapMessage(ow_DataStructure *object);
 
-typedef struct ow_XATransactionId {
+typedef struct ow_ActiveMQMessage {
 
    ow_byte structType;
-   ow_int formatId;
-   ow_byte_array *globalTransactionId;
-   ow_byte_array *branchQualifier;
+   ow_int commandId;
+   ow_boolean responseRequired;
+   struct ow_ProducerId *producerId;
+   struct ow_ActiveMQDestination *destination;
+   struct ow_TransactionId *transactionId;
+   struct ow_ActiveMQDestination *originalDestination;
+   struct ow_MessageId *messageId;
+   struct ow_TransactionId *originalTransactionId;
+   ow_string *groupID;
+   ow_int groupSequence;
+   ow_string *correlationId;
+   ow_boolean persistent;
+   ow_long expiration;
+   ow_byte priority;
+   struct ow_ActiveMQDestination *replyTo;
+   ow_long timestamp;
+   ow_string *type;
+   struct ow_ByteSequence *content;
+   struct ow_ByteSequence *marshalledProperties;
+   struct ow_DataStructure *dataStructure;
+   struct ow_ConsumerId *targetConsumerId;
+   ow_boolean compressed;
+   ow_int redeliveryCounter;
+   ow_DataStructure_array *brokerPath;
+   ow_long arrival;
+   ow_string *userID;
+   ow_boolean recievedByDFBridge;
 
-} ow_XATransactionId;
-ow_XATransactionId *ow_XATransactionId_create(apr_pool_t *pool);
-ow_boolean ow_is_a_XATransactionId(ow_DataStructure *object);
+} ow_ActiveMQMessage;
+ow_ActiveMQMessage *ow_ActiveMQMessage_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ActiveMQMessage(ow_DataStructure *object);
 
-typedef struct ow_JournalTrace {
+typedef struct ow_ActiveMQObjectMessage {
 
    ow_byte structType;
-   ow_string *message;
+   ow_int commandId;
+   ow_boolean responseRequired;
+   struct ow_ProducerId *producerId;
+   struct ow_ActiveMQDestination *destination;
+   struct ow_TransactionId *transactionId;
+   struct ow_ActiveMQDestination *originalDestination;
+   struct ow_MessageId *messageId;
+   struct ow_TransactionId *originalTransactionId;
+   ow_string *groupID;
+   ow_int groupSequence;
+   ow_string *correlationId;
+   ow_boolean persistent;
+   ow_long expiration;
+   ow_byte priority;
+   struct ow_ActiveMQDestination *replyTo;
+   ow_long timestamp;
+   ow_string *type;
+   struct ow_ByteSequence *content;
+   struct ow_ByteSequence *marshalledProperties;
+   struct ow_DataStructure *dataStructure;
+   struct ow_ConsumerId *targetConsumerId;
+   ow_boolean compressed;
+   ow_int redeliveryCounter;
+   ow_DataStructure_array *brokerPath;
+   ow_long arrival;
+   ow_string *userID;
+   ow_boolean recievedByDFBridge;
 
-} ow_JournalTrace;
-ow_JournalTrace *ow_JournalTrace_create(apr_pool_t *pool);
-ow_boolean ow_is_a_JournalTrace(ow_DataStructure *object);
+} ow_ActiveMQObjectMessage;
+ow_ActiveMQObjectMessage *ow_ActiveMQObjectMessage_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ActiveMQObjectMessage(ow_DataStructure *object);
 
-typedef struct ow_ConsumerId {
+typedef struct ow_ActiveMQQueue {
 
    ow_byte structType;
-   ow_string *connectionId;
-   ow_long sessionId;
-   ow_long value;
+   ow_string *physicalName;
 
-} ow_ConsumerId;
-ow_ConsumerId *ow_ConsumerId_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ConsumerId(ow_DataStructure *object);
+} ow_ActiveMQQueue;
+ow_ActiveMQQueue *ow_ActiveMQQueue_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ActiveMQQueue(ow_DataStructure *object);
 
-typedef struct ow_ActiveMQTextMessage {
+typedef struct ow_ActiveMQStreamMessage {
 
    ow_byte structType;
    ow_int commandId;
@@ -441,78 +462,38 @@
    ow_string *userID;
    ow_boolean recievedByDFBridge;
 
-} ow_ActiveMQTextMessage;
-ow_ActiveMQTextMessage *ow_ActiveMQTextMessage_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ActiveMQTextMessage(ow_DataStructure *object);
-
-typedef struct ow_SubscriptionInfo {
-
-   ow_byte structType;
-   ow_string *clientId;
-   struct ow_ActiveMQDestination *destination;
-   ow_string *selector;
-   ow_string *subcriptionName;
-
-} ow_SubscriptionInfo;
-ow_SubscriptionInfo *ow_SubscriptionInfo_create(apr_pool_t *pool);
-ow_boolean ow_is_a_SubscriptionInfo(ow_DataStructure *object);
-
-typedef struct ow_JournalTransaction {
-
-   ow_byte structType;
-   struct ow_TransactionId *transactionId;
-   ow_byte type;
-   ow_boolean wasPrepared;
-
-} ow_JournalTransaction;
-ow_JournalTransaction *ow_JournalTransaction_create(apr_pool_t *pool);
-ow_boolean ow_is_a_JournalTransaction(ow_DataStructure *object);
-
-typedef struct ow_ControlCommand {
-
-   ow_byte structType;
-   ow_int commandId;
-   ow_boolean responseRequired;
-   ow_string *command;
-
-} ow_ControlCommand;
-ow_ControlCommand *ow_ControlCommand_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ControlCommand(ow_DataStructure *object);
+} ow_ActiveMQStreamMessage;
+ow_ActiveMQStreamMessage *ow_ActiveMQStreamMessage_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ActiveMQStreamMessage(ow_DataStructure *object);
 
-typedef struct ow_LastPartialCommand {
+typedef struct ow_ActiveMQTempDestination {
 
    ow_byte structType;
-   ow_int commandId;
-   ow_byte_array *data;
+   ow_string *physicalName;
 
-} ow_LastPartialCommand;
-ow_LastPartialCommand *ow_LastPartialCommand_create(apr_pool_t *pool);
-ow_boolean ow_is_a_LastPartialCommand(ow_DataStructure *object);
+} ow_ActiveMQTempDestination;
+ow_ActiveMQTempDestination *ow_ActiveMQTempDestination_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ActiveMQTempDestination(ow_DataStructure *object);
 
-typedef struct ow_NetworkBridgeFilter {
+typedef struct ow_ActiveMQTempQueue {
 
    ow_byte structType;
-   ow_int networkTTL;
-   struct ow_BrokerId *networkBrokerId;
+   ow_string *physicalName;
 
-} ow_NetworkBridgeFilter;
-ow_NetworkBridgeFilter *ow_NetworkBridgeFilter_create(apr_pool_t *pool);
-ow_boolean ow_is_a_NetworkBridgeFilter(ow_DataStructure *object);
+} ow_ActiveMQTempQueue;
+ow_ActiveMQTempQueue *ow_ActiveMQTempQueue_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ActiveMQTempQueue(ow_DataStructure *object);
 
-typedef struct ow_MessagePull {
+typedef struct ow_ActiveMQTempTopic {
 
    ow_byte structType;
-   ow_int commandId;
-   ow_boolean responseRequired;
-   struct ow_ConsumerId *consumerId;
-   struct ow_ActiveMQDestination *destination;
-   ow_long timeout;
+   ow_string *physicalName;
 
-} ow_MessagePull;
-ow_MessagePull *ow_MessagePull_create(apr_pool_t *pool);
-ow_boolean ow_is_a_MessagePull(ow_DataStructure *object);
+} ow_ActiveMQTempTopic;
+ow_ActiveMQTempTopic *ow_ActiveMQTempTopic_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ActiveMQTempTopic(ow_DataStructure *object);
 
-typedef struct ow_ActiveMQBytesMessage {
+typedef struct ow_ActiveMQTextMessage {
 
    ow_byte structType;
    ow_int commandId;
@@ -543,95 +524,154 @@
    ow_string *userID;
    ow_boolean recievedByDFBridge;
 
-} ow_ActiveMQBytesMessage;
-ow_ActiveMQBytesMessage *ow_ActiveMQBytesMessage_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ActiveMQBytesMessage(ow_DataStructure *object);
+} ow_ActiveMQTextMessage;
+ow_ActiveMQTextMessage *ow_ActiveMQTextMessage_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ActiveMQTextMessage(ow_DataStructure *object);
 
-typedef struct ow_WireFormatInfo {
+typedef struct ow_ActiveMQTopic {
 
    ow_byte structType;
-   ow_byte_array *magic;
-   ow_int version;
-   struct ow_ByteSequence *marshalledProperties;
+   ow_string *physicalName;
 
-} ow_WireFormatInfo;
-ow_WireFormatInfo *ow_WireFormatInfo_create(apr_pool_t *pool);
-ow_boolean ow_is_a_WireFormatInfo(ow_DataStructure *object);
+} ow_ActiveMQTopic;
+ow_ActiveMQTopic *ow_ActiveMQTopic_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ActiveMQTopic(ow_DataStructure *object);
 
-typedef struct ow_ActiveMQTempTopic {
+typedef struct ow_BrokerInfo {
 
    ow_byte structType;
-   ow_string *physicalName;
+   ow_int commandId;
+   ow_boolean responseRequired;
+   struct ow_BrokerId *brokerId;
+   ow_string *brokerURL;
+   ow_DataStructure_array *peerBrokerInfos;
+   ow_string *brokerName;
+   ow_boolean slaveBroker;
+   ow_boolean masterBroker;
+   ow_boolean faultTolerantConfiguration;
 
-} ow_ActiveMQTempTopic;
-ow_ActiveMQTempTopic *ow_ActiveMQTempTopic_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ActiveMQTempTopic(ow_DataStructure *object);
+} ow_BrokerInfo;
+ow_BrokerInfo *ow_BrokerInfo_create(apr_pool_t *pool);
+ow_boolean ow_is_a_BrokerInfo(ow_DataStructure *object);
 
-typedef struct ow_DiscoveryEvent {
+typedef struct ow_ConnectionControl {
 
    ow_byte structType;
-   ow_string *serviceName;
-   ow_string *brokerName;
+   ow_int commandId;
+   ow_boolean responseRequired;
+   ow_boolean close;
+   ow_boolean exit;
+   ow_boolean faultTolerant;
+   ow_boolean resume;
+   ow_boolean suspend;
 
-} ow_DiscoveryEvent;
-ow_DiscoveryEvent *ow_DiscoveryEvent_create(apr_pool_t *pool);
-ow_boolean ow_is_a_DiscoveryEvent(ow_DataStructure *object);
+} ow_ConnectionControl;
+ow_ConnectionControl *ow_ConnectionControl_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ConnectionControl(ow_DataStructure *object);
 
-typedef struct ow_ActiveMQTempDestination {
+typedef struct ow_ConnectionError {
 
    ow_byte structType;
-   ow_string *physicalName;
+   ow_int commandId;
+   ow_boolean responseRequired;
+   ow_throwable *exception;
+   struct ow_ConnectionId *connectionId;
 
-} ow_ActiveMQTempDestination;
-ow_ActiveMQTempDestination *ow_ActiveMQTempDestination_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ActiveMQTempDestination(ow_DataStructure *object);
+} ow_ConnectionError;
+ow_ConnectionError *ow_ConnectionError_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ConnectionError(ow_DataStructure *object);
 
-typedef struct ow_ReplayCommand {
+typedef struct ow_ConnectionInfo {
 
    ow_byte structType;
    ow_int commandId;
    ow_boolean responseRequired;
-   ow_int firstNakNumber;
-   ow_int lastNakNumber;
+   struct ow_ConnectionId *connectionId;
+   ow_string *clientId;
+   ow_string *password;
+   ow_string *userName;
+   ow_DataStructure_array *brokerPath;
+   ow_boolean brokerMasterConnector;
+   ow_boolean manageable;
 
-} ow_ReplayCommand;
-ow_ReplayCommand *ow_ReplayCommand_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ReplayCommand(ow_DataStructure *object);
+} ow_ConnectionInfo;
+ow_ConnectionInfo *ow_ConnectionInfo_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ConnectionInfo(ow_DataStructure *object);
 
-typedef struct ow_ActiveMQDestination {
+typedef struct ow_ConsumerControl {
 
    ow_byte structType;
-   ow_string *physicalName;
+   ow_int commandId;
+   ow_boolean responseRequired;
+   ow_boolean close;
+   struct ow_ConsumerId *consumerId;
+   ow_int prefetch;
 
-} ow_ActiveMQDestination;
-ow_ActiveMQDestination *ow_ActiveMQDestination_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ActiveMQDestination(ow_DataStructure *object);
+} ow_ConsumerControl;
+ow_ConsumerControl *ow_ConsumerControl_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ConsumerControl(ow_DataStructure *object);
 
-typedef struct ow_ActiveMQTopic {
+typedef struct ow_ConsumerInfo {
 
    ow_byte structType;
-   ow_string *physicalName;
+   ow_int commandId;
+   ow_boolean responseRequired;
+   struct ow_ConsumerId *consumerId;
+   ow_boolean browser;
+   struct ow_ActiveMQDestination *destination;
+   ow_int prefetchSize;
+   ow_int maximumPendingMessageLimit;
+   ow_boolean dispatchAsync;
+   ow_string *selector;
+   ow_string *subcriptionName;
+   ow_boolean noLocal;
+   ow_boolean exclusive;
+   ow_boolean retroactive;
+   ow_byte priority;
+   ow_DataStructure_array *brokerPath;
+   struct ow_BooleanExpression *additionalPredicate;
+   ow_boolean networkSubscription;
+   ow_boolean optimizedAcknowledge;
+   ow_boolean noRangeAcks;
 
-} ow_ActiveMQTopic;
-ow_ActiveMQTopic *ow_ActiveMQTopic_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ActiveMQTopic(ow_DataStructure *object);
+} ow_ConsumerInfo;
+ow_ConsumerInfo *ow_ConsumerInfo_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ConsumerInfo(ow_DataStructure *object);
 
-typedef struct ow_BrokerInfo {
+typedef struct ow_ControlCommand {
 
    ow_byte structType;
    ow_int commandId;
    ow_boolean responseRequired;
-   struct ow_BrokerId *brokerId;
-   ow_string *brokerURL;
-   ow_DataStructure_array *peerBrokerInfos;
-   ow_string *brokerName;
-   ow_boolean slaveBroker;
-   ow_boolean masterBroker;
-   ow_boolean faultTolerantConfiguration;
+   ow_string *command;
 
-} ow_BrokerInfo;
-ow_BrokerInfo *ow_BrokerInfo_create(apr_pool_t *pool);
-ow_boolean ow_is_a_BrokerInfo(ow_DataStructure *object);
+} ow_ControlCommand;
+ow_ControlCommand *ow_ControlCommand_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ControlCommand(ow_DataStructure *object);
+
+typedef struct ow_DataArrayResponse {
+
+   ow_byte structType;
+   ow_int commandId;
+   ow_boolean responseRequired;
+   ow_int correlationId;
+   ow_DataStructure_array *data;
+
+} ow_DataArrayResponse;
+ow_DataArrayResponse *ow_DataArrayResponse_create(apr_pool_t *pool);
+ow_boolean ow_is_a_DataArrayResponse(ow_DataStructure *object);
+
+typedef struct ow_DataResponse {
+
+   ow_byte structType;
+   ow_int commandId;
+   ow_boolean responseRequired;
+   ow_int correlationId;
+   struct ow_DataStructure *data;
+
+} ow_DataResponse;
+ow_DataResponse *ow_DataResponse_create(apr_pool_t *pool);
+ow_boolean ow_is_a_DataResponse(ow_DataStructure *object);
 
 typedef struct ow_DestinationInfo {
 
@@ -648,42 +688,39 @@
 ow_DestinationInfo *ow_DestinationInfo_create(apr_pool_t *pool);
 ow_boolean ow_is_a_DestinationInfo(ow_DataStructure *object);
 
-typedef struct ow_ShutdownInfo {
+typedef struct ow_ExceptionResponse {
 
    ow_byte structType;
    ow_int commandId;
    ow_boolean responseRequired;
+   ow_int correlationId;
+   ow_throwable *exception;
 
-} ow_ShutdownInfo;
-ow_ShutdownInfo *ow_ShutdownInfo_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ShutdownInfo(ow_DataStructure *object);
+} ow_ExceptionResponse;
+ow_ExceptionResponse *ow_ExceptionResponse_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ExceptionResponse(ow_DataStructure *object);
 
-typedef struct ow_DataResponse {
+typedef struct ow_FlushCommand {
 
    ow_byte structType;
    ow_int commandId;
    ow_boolean responseRequired;
-   ow_int correlationId;
-   struct ow_DataStructure *data;
 
-} ow_DataResponse;
-ow_DataResponse *ow_DataResponse_create(apr_pool_t *pool);
-ow_boolean ow_is_a_DataResponse(ow_DataStructure *object);
+} ow_FlushCommand;
+ow_FlushCommand *ow_FlushCommand_create(apr_pool_t *pool);
+ow_boolean ow_is_a_FlushCommand(ow_DataStructure *object);
 
-typedef struct ow_ConnectionControl {
+typedef struct ow_IntegerResponse {
 
    ow_byte structType;
    ow_int commandId;
    ow_boolean responseRequired;
-   ow_boolean close;
-   ow_boolean exit;
-   ow_boolean faultTolerant;
-   ow_boolean resume;
-   ow_boolean suspend;
+   ow_int correlationId;
+   ow_int result;
 
-} ow_ConnectionControl;
-ow_ConnectionControl *ow_ConnectionControl_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ConnectionControl(ow_DataStructure *object);
+} ow_IntegerResponse;
+ow_IntegerResponse *ow_IntegerResponse_create(apr_pool_t *pool);
+ow_boolean ow_is_a_IntegerResponse(ow_DataStructure *object);
 
 typedef struct ow_KeepAliveInfo {
 
@@ -695,6 +732,26 @@
 ow_KeepAliveInfo *ow_KeepAliveInfo_create(apr_pool_t *pool);
 ow_boolean ow_is_a_KeepAliveInfo(ow_DataStructure *object);
 
+typedef struct ow_LastPartialCommand {
+
+   ow_byte structType;
+   ow_int commandId;
+   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_LocalTransactionId {
+
+   ow_byte structType;
+   ow_long value;
+   struct ow_ConnectionId *connectionId;
+
+} ow_LocalTransactionId;
+ow_LocalTransactionId *ow_LocalTransactionId_create(apr_pool_t *pool);
+ow_boolean ow_is_a_LocalTransactionId(ow_DataStructure *object);
+
 typedef struct ow_Message {
 
    ow_byte structType;
@@ -730,168 +787,168 @@
 ow_Message *ow_Message_create(apr_pool_t *pool);
 ow_boolean ow_is_a_Message(ow_DataStructure *object);
 
-typedef struct ow_BaseCommand {
+typedef struct ow_MessageAck {
 
    ow_byte structType;
    ow_int commandId;
    ow_boolean responseRequired;
+   struct ow_ActiveMQDestination *destination;
+   struct ow_TransactionId *transactionId;
+   struct ow_ConsumerId *consumerId;
+   ow_byte ackType;
+   struct ow_MessageId *firstMessageId;
+   struct ow_MessageId *lastMessageId;
+   ow_int messageCount;
 
-} ow_BaseCommand;
-ow_BaseCommand *ow_BaseCommand_create(apr_pool_t *pool);
-ow_boolean ow_is_a_BaseCommand(ow_DataStructure *object);
+} ow_MessageAck;
+ow_MessageAck *ow_MessageAck_create(apr_pool_t *pool);
+ow_boolean ow_is_a_MessageAck(ow_DataStructure *object);
 
-typedef struct ow_FlushCommand {
+typedef struct ow_MessageDispatch {
 
    ow_byte structType;
    ow_int commandId;
    ow_boolean responseRequired;
+   struct ow_ConsumerId *consumerId;
+   struct ow_ActiveMQDestination *destination;
+   struct ow_Message *message;
+   ow_int redeliveryCounter;
 
-} ow_FlushCommand;
-ow_FlushCommand *ow_FlushCommand_create(apr_pool_t *pool);
-ow_boolean ow_is_a_FlushCommand(ow_DataStructure *object);
+} ow_MessageDispatch;
+ow_MessageDispatch *ow_MessageDispatch_create(apr_pool_t *pool);
+ow_boolean ow_is_a_MessageDispatch(ow_DataStructure *object);
 
-typedef struct ow_ConsumerControl {
+typedef struct ow_MessageDispatchNotification {
 
    ow_byte structType;
    ow_int commandId;
    ow_boolean responseRequired;
-   ow_boolean close;
    struct ow_ConsumerId *consumerId;
-   ow_int prefetch;
+   struct ow_ActiveMQDestination *destination;
+   ow_long deliverySequenceId;
+   struct ow_MessageId *messageId;
 
-} ow_ConsumerControl;
-ow_ConsumerControl *ow_ConsumerControl_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ConsumerControl(ow_DataStructure *object);
+} ow_MessageDispatchNotification;
+ow_MessageDispatchNotification *ow_MessageDispatchNotification_create(apr_pool_t *pool);
+ow_boolean ow_is_a_MessageDispatchNotification(ow_DataStructure *object);
 
-typedef struct ow_JournalTopicAck {
+typedef struct ow_MessagePull {
 
    ow_byte structType;
+   ow_int commandId;
+   ow_boolean responseRequired;
+   struct ow_ConsumerId *consumerId;
    struct ow_ActiveMQDestination *destination;
-   struct ow_MessageId *messageId;
-   ow_long messageSequenceId;
-   ow_string *subscritionName;
-   ow_string *clientId;
-   struct ow_TransactionId *transactionId;
+   ow_long timeout;
 
-} ow_JournalTopicAck;
-ow_JournalTopicAck *ow_JournalTopicAck_create(apr_pool_t *pool);
-ow_boolean ow_is_a_JournalTopicAck(ow_DataStructure *object);
+} ow_MessagePull;
+ow_MessagePull *ow_MessagePull_create(apr_pool_t *pool);
+ow_boolean ow_is_a_MessagePull(ow_DataStructure *object);
 
-typedef struct ow_BrokerId {
+typedef struct ow_ProducerInfo {
 
    ow_byte structType;
-   ow_string *value;
+   ow_int commandId;
+   ow_boolean responseRequired;
+   struct ow_ProducerId *producerId;
+   struct ow_ActiveMQDestination *destination;
+   ow_DataStructure_array *brokerPath;
 
-} ow_BrokerId;
-ow_BrokerId *ow_BrokerId_create(apr_pool_t *pool);
-ow_boolean ow_is_a_BrokerId(ow_DataStructure *object);
+} ow_ProducerInfo;
+ow_ProducerInfo *ow_ProducerInfo_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ProducerInfo(ow_DataStructure *object);
 
-typedef struct ow_MessageDispatch {
+typedef struct ow_RemoveInfo {
 
    ow_byte structType;
    ow_int commandId;
    ow_boolean responseRequired;
-   struct ow_ConsumerId *consumerId;
-   struct ow_ActiveMQDestination *destination;
-   struct ow_Message *message;
-   ow_int redeliveryCounter;
+   struct ow_DataStructure *objectId;
 
-} ow_MessageDispatch;
-ow_MessageDispatch *ow_MessageDispatch_create(apr_pool_t *pool);
-ow_boolean ow_is_a_MessageDispatch(ow_DataStructure *object);
+} ow_RemoveInfo;
+ow_RemoveInfo *ow_RemoveInfo_create(apr_pool_t *pool);
+ow_boolean ow_is_a_RemoveInfo(ow_DataStructure *object);
 
-typedef struct ow_ActiveMQMapMessage {
+typedef struct ow_RemoveSubscriptionInfo {
 
    ow_byte structType;
    ow_int commandId;
    ow_boolean responseRequired;
-   struct ow_ProducerId *producerId;
-   struct ow_ActiveMQDestination *destination;
-   struct ow_TransactionId *transactionId;
-   struct ow_ActiveMQDestination *originalDestination;
-   struct ow_MessageId *messageId;
-   struct ow_TransactionId *originalTransactionId;
-   ow_string *groupID;
-   ow_int groupSequence;
-   ow_string *correlationId;
-   ow_boolean persistent;
-   ow_long expiration;
-   ow_byte priority;
-   struct ow_ActiveMQDestination *replyTo;
-   ow_long timestamp;
-   ow_string *type;
-   struct ow_ByteSequence *content;
-   struct ow_ByteSequence *marshalledProperties;
-   struct ow_DataStructure *dataStructure;
-   struct ow_ConsumerId *targetConsumerId;
-   ow_boolean compressed;
-   ow_int redeliveryCounter;
-   ow_DataStructure_array *brokerPath;
-   ow_long arrival;
-   ow_string *userID;
-   ow_boolean recievedByDFBridge;
+   struct ow_ConnectionId *connectionId;
+   ow_string *subcriptionName;
+   ow_string *clientId;
 
-} ow_ActiveMQMapMessage;
-ow_ActiveMQMapMessage *ow_ActiveMQMapMessage_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ActiveMQMapMessage(ow_DataStructure *object);
+} ow_RemoveSubscriptionInfo;
+ow_RemoveSubscriptionInfo *ow_RemoveSubscriptionInfo_create(apr_pool_t *pool);
+ow_boolean ow_is_a_RemoveSubscriptionInfo(ow_DataStructure *object);
 
-typedef struct ow_ActiveMQMessage {
+typedef struct ow_ReplayCommand {
 
    ow_byte structType;
    ow_int commandId;
    ow_boolean responseRequired;
-   struct ow_ProducerId *producerId;
-   struct ow_ActiveMQDestination *destination;
-   struct ow_TransactionId *transactionId;
-   struct ow_ActiveMQDestination *originalDestination;
-   struct ow_MessageId *messageId;
-   struct ow_TransactionId *originalTransactionId;
-   ow_string *groupID;
-   ow_int groupSequence;
-   ow_string *correlationId;
-   ow_boolean persistent;
-   ow_long expiration;
-   ow_byte priority;
-   struct ow_ActiveMQDestination *replyTo;
-   ow_long timestamp;
-   ow_string *type;
-   struct ow_ByteSequence *content;
-   struct ow_ByteSequence *marshalledProperties;
-   struct ow_DataStructure *dataStructure;
-   struct ow_ConsumerId *targetConsumerId;
-   ow_boolean compressed;
-   ow_int redeliveryCounter;
-   ow_DataStructure_array *brokerPath;
-   ow_long arrival;
-   ow_string *userID;
-   ow_boolean recievedByDFBridge;
+   ow_int firstNakNumber;
+   ow_int lastNakNumber;
 
-} ow_ActiveMQMessage;
-ow_ActiveMQMessage *ow_ActiveMQMessage_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ActiveMQMessage(ow_DataStructure *object);
+} ow_ReplayCommand;
+ow_ReplayCommand *ow_ReplayCommand_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ReplayCommand(ow_DataStructure *object);
 
-typedef struct ow_RemoveInfo {
+typedef struct ow_Response {
 
    ow_byte structType;
    ow_int commandId;
    ow_boolean responseRequired;
-   struct ow_DataStructure *objectId;
+   ow_int correlationId;
 
-} ow_RemoveInfo;
-ow_RemoveInfo *ow_RemoveInfo_create(apr_pool_t *pool);
-ow_boolean ow_is_a_RemoveInfo(ow_DataStructure *object);
+} ow_Response;
+ow_Response *ow_Response_create(apr_pool_t *pool);
+ow_boolean ow_is_a_Response(ow_DataStructure *object);
 
-typedef struct ow_ExceptionResponse {
+typedef struct ow_SessionInfo {
 
    ow_byte structType;
    ow_int commandId;
    ow_boolean responseRequired;
-   ow_int correlationId;
-   ow_throwable *exception;
+   struct ow_SessionId *sessionId;
 
-} ow_ExceptionResponse;
-ow_ExceptionResponse *ow_ExceptionResponse_create(apr_pool_t *pool);
-ow_boolean ow_is_a_ExceptionResponse(ow_DataStructure *object);
+} ow_SessionInfo;
+ow_SessionInfo *ow_SessionInfo_create(apr_pool_t *pool);
+ow_boolean ow_is_a_SessionInfo(ow_DataStructure *object);
+
+typedef struct ow_ShutdownInfo {
+
+   ow_byte structType;
+   ow_int commandId;
+   ow_boolean responseRequired;
+
+} ow_ShutdownInfo;
+ow_ShutdownInfo *ow_ShutdownInfo_create(apr_pool_t *pool);
+ow_boolean ow_is_a_ShutdownInfo(ow_DataStructure *object);
+
+typedef struct ow_TransactionInfo {
+
+   ow_byte structType;
+   ow_int commandId;
+   ow_boolean responseRequired;
+   struct ow_ConnectionId *connectionId;
+   struct ow_TransactionId *transactionId;
+   ow_byte type;
+
+} ow_TransactionInfo;
+ow_TransactionInfo *ow_TransactionInfo_create(apr_pool_t *pool);
+ow_boolean ow_is_a_TransactionInfo(ow_DataStructure *object);
+
+typedef struct ow_XATransactionId {
+
+   ow_byte structType;
+   ow_int formatId;
+   ow_byte_array *globalTransactionId;
+   ow_byte_array *branchQualifier;
+
+} ow_XATransactionId;
+ow_XATransactionId *ow_XATransactionId_create(apr_pool_t *pool);
+ow_boolean ow_is_a_XATransactionId(ow_DataStructure *object);
 
 #ifdef __cplusplus
 }



Mime
View raw message