activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r452053 [6/17] - in /incubator/activemq/activemq-cpp/trunk/activemq-cpp/src: main/activemq/connector/openwire/ main/activemq/connector/openwire/commands/ main/activemq/connector/openwire/marshal/ main/activemq/connector/openwire/marshal/V2/...
Date Mon, 02 Oct 2006 14:30:22 GMT
Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/KeepAliveInfo.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/KeepAliveInfo.cpp?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/KeepAliveInfo.cpp (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/KeepAliveInfo.cpp Mon Oct  2 07:30:10 2006
@@ -0,0 +1,50 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include <activemq/connector/openwire/commands/KeepAliveInfo.h>
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::connector;
+using namespace activemq::connector::openwire;
+using namespace activemq::connector::openwire::commands;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for KeepAliveInfo
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Java Classes in the
+ *         activemq-core module
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+KeepAliveInfo::KeepAliveInfo()
+{
+}
+
+////////////////////////////////////////////////////////////////////////////////
+KeepAliveInfo::~KeepAliveInfo()
+{
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char KeepAliveInfo::getDataStructureType() const
+{
+    return KeepAliveInfo::ID_KEEPALIVEINFO; 
+}
+

Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/KeepAliveInfo.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/KeepAliveInfo.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/KeepAliveInfo.h?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/KeepAliveInfo.h (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/KeepAliveInfo.h Mon Oct  2 07:30:10 2006
@@ -0,0 +1,65 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_KEEPALIVEINFO_H_
+#define _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_KEEPALIVEINFO_H_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <activemq/connector/openwire/commands/BaseCommand.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace connector{
+namespace openwire{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshalling code for OpenWire format for ${className}
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the activemq-openwire-generator module
+     *
+     */
+    class KeepAliveInfo : public BaseCommand
+    {
+    protected:
+
+
+    public:
+
+        const static unsigned char ID_KEEPALIVEINFO = 10;
+
+    public:
+
+        KeepAliveInfo();
+        virtual ~KeepAliveInfo();
+
+        virtual unsigned char getDataStructureType() const;
+    };
+
+}}}}
+
+#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_KEEPALIVEINFO_H_*/
+

Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/KeepAliveInfo.h
------------------------------------------------------------------------------
    svn:eol-style = native

Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/LastPartialCommand.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/LastPartialCommand.cpp?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/LastPartialCommand.cpp (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/LastPartialCommand.cpp Mon Oct  2 07:30:10 2006
@@ -0,0 +1,50 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include <activemq/connector/openwire/commands/LastPartialCommand.h>
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::connector;
+using namespace activemq::connector::openwire;
+using namespace activemq::connector::openwire::commands;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for LastPartialCommand
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Java Classes in the
+ *         activemq-core module
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+LastPartialCommand::LastPartialCommand()
+{
+}
+
+////////////////////////////////////////////////////////////////////////////////
+LastPartialCommand::~LastPartialCommand()
+{
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char LastPartialCommand::getDataStructureType() const
+{
+    return LastPartialCommand::ID_LASTPARTIALCOMMAND; 
+}
+

Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/LastPartialCommand.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/LastPartialCommand.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/LastPartialCommand.h?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/LastPartialCommand.h (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/LastPartialCommand.h Mon Oct  2 07:30:10 2006
@@ -0,0 +1,65 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_LASTPARTIALCOMMAND_H_
+#define _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_LASTPARTIALCOMMAND_H_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <activemq/connector/openwire/commands/PartialCommand.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace connector{
+namespace openwire{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshalling code for OpenWire format for ${className}
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the activemq-openwire-generator module
+     *
+     */
+    class LastPartialCommand : public PartialCommand
+    {
+    protected:
+
+
+    public:
+
+        const static unsigned char ID_LASTPARTIALCOMMAND = 61;
+
+    public:
+
+        LastPartialCommand();
+        virtual ~LastPartialCommand();
+
+        virtual unsigned char getDataStructureType() const;
+    };
+
+}}}}
+
+#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_LASTPARTIALCOMMAND_H_*/
+

Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/LastPartialCommand.h
------------------------------------------------------------------------------
    svn:eol-style = native

Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/LocalTransactionId.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/LocalTransactionId.cpp?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/LocalTransactionId.cpp (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/LocalTransactionId.cpp Mon Oct  2 07:30:10 2006
@@ -0,0 +1,83 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include <activemq/connector/openwire/commands/LocalTransactionId.h>
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::connector;
+using namespace activemq::connector::openwire;
+using namespace activemq::connector::openwire::commands;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for LocalTransactionId
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Java Classes in the
+ *         activemq-core module
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+LocalTransactionId::LocalTransactionId()
+{
+    this->value = 0;
+    this->connectionId = NULL;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+LocalTransactionId::~LocalTransactionId()
+{
+    delete this->connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char LocalTransactionId::getDataStructureType() const
+{
+    return LocalTransactionId::ID_LOCALTRANSACTIONID; 
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const long long LocalTransactionId::getValue() const {
+    return value;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long LocalTransactionId::getValue() {
+    return value;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void LocalTransactionId::setValue(long long value ) {
+    this->value = value;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ConnectionId* LocalTransactionId::getConnectionId() const {
+    return connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConnectionId* LocalTransactionId::getConnectionId() {
+    return connectionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void LocalTransactionId::setConnectionId(ConnectionId* connectionId ) {
+    this->connectionId = connectionId;
+}
+

Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/LocalTransactionId.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/LocalTransactionId.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/LocalTransactionId.h?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/LocalTransactionId.h (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/LocalTransactionId.h Mon Oct  2 07:30:10 2006
@@ -0,0 +1,76 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_LOCALTRANSACTIONID_H_
+#define _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_LOCALTRANSACTIONID_H_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <activemq/connector/openwire/commands/TransactionId.h>
+#include <activemq/connector/openwire/commands/ConnectionId.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace connector{
+namespace openwire{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshalling code for OpenWire format for ${className}
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the activemq-openwire-generator module
+     *
+     */
+    class LocalTransactionId : public TransactionId
+    {
+    protected:
+
+        long long value;
+        ConnectionId* connectionId;
+
+    public:
+
+        const static unsigned char ID_LOCALTRANSACTIONID = 111;
+
+    public:
+
+        LocalTransactionId();
+        virtual ~LocalTransactionId();
+
+        virtual unsigned char getDataStructureType() const;
+        virtual const long long getValue() const;
+        virtual long long getValue();
+        virtual void setValue( long long value );
+
+        virtual const ConnectionId* getConnectionId() const;
+        virtual ConnectionId* getConnectionId();
+        virtual void setConnectionId( ConnectionId* connectionId );
+
+    };
+
+}}}}
+
+#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_LOCALTRANSACTIONID_H_*/
+

Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/LocalTransactionId.h
------------------------------------------------------------------------------
    svn:eol-style = native

Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/Message.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/Message.cpp?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/Message.cpp (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/Message.cpp Mon Oct  2 07:30:10 2006
@@ -0,0 +1,459 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include <activemq/connector/openwire/commands/Message.h>
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::connector;
+using namespace activemq::connector::openwire;
+using namespace activemq::connector::openwire::commands;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for Message
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Java Classes in the
+ *         activemq-core module
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+Message::Message()
+{
+    this->producerId = NULL;
+    this->destination = NULL;
+    this->transactionId = NULL;
+    this->originalDestination = NULL;
+    this->messageId = NULL;
+    this->originalTransactionId = NULL;
+    this->groupID = "";
+    this->groupSequence = 0;
+    this->correlationId = "";
+    this->persistent = false;
+    this->expiration = 0;
+    this->priority = 0;
+    this->replyTo = NULL;
+    this->timestamp = 0;
+    this->type = "";
+    this->dataStructure = NULL;
+    this->targetConsumerId = NULL;
+    this->compressed = false;
+    this->redeliveryCounter = 0;
+    this->arrival = 0;
+    this->userID = "";
+    this->recievedByDFBridge = false;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+Message::~Message()
+{
+    delete this->producerId;
+    delete this->destination;
+    delete this->transactionId;
+    delete this->originalDestination;
+    delete this->messageId;
+    delete this->originalTransactionId;
+    delete this->replyTo;
+    delete this->dataStructure;
+    delete this->targetConsumerId;
+    for( size_t ibrokerPath = 0; ibrokerPath < brokerPath.size(); ++ibrokerPath ) {
+        delete brokerPath[ibrokerPath];
+    }
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char Message::getDataStructureType() const
+{
+    return Message::ID_MESSAGE; 
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ProducerId* Message::getProducerId() const {
+    return producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ProducerId* Message::getProducerId() {
+    return producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setProducerId(ProducerId* producerId ) {
+    this->producerId = producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ActiveMQDestination* Message::getDestination() const {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ActiveMQDestination* Message::getDestination() {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setDestination(ActiveMQDestination* destination ) {
+    this->destination = destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const TransactionId* Message::getTransactionId() const {
+    return transactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+TransactionId* Message::getTransactionId() {
+    return transactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setTransactionId(TransactionId* transactionId ) {
+    this->transactionId = transactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ActiveMQDestination* Message::getOriginalDestination() const {
+    return originalDestination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ActiveMQDestination* Message::getOriginalDestination() {
+    return originalDestination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setOriginalDestination(ActiveMQDestination* originalDestination ) {
+    this->originalDestination = originalDestination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const MessageId* Message::getMessageId() const {
+    return messageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessageId* Message::getMessageId() {
+    return messageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setMessageId(MessageId* messageId ) {
+    this->messageId = messageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const TransactionId* Message::getOriginalTransactionId() const {
+    return originalTransactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+TransactionId* Message::getOriginalTransactionId() {
+    return originalTransactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setOriginalTransactionId(TransactionId* originalTransactionId ) {
+    this->originalTransactionId = originalTransactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& Message::getGroupID() const {
+    return groupID;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& Message::getGroupID() {
+    return groupID;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setGroupID(const std::string& groupID ) {
+    this->groupID = groupID;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const int Message::getGroupSequence() const {
+    return groupSequence;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int Message::getGroupSequence() {
+    return groupSequence;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setGroupSequence(int groupSequence ) {
+    this->groupSequence = groupSequence;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& Message::getCorrelationId() const {
+    return correlationId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& Message::getCorrelationId() {
+    return correlationId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setCorrelationId(const std::string& correlationId ) {
+    this->correlationId = correlationId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const bool Message::getPersistent() const {
+    return persistent;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool Message::getPersistent() {
+    return persistent;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setPersistent(bool persistent ) {
+    this->persistent = persistent;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const long long Message::getExpiration() const {
+    return expiration;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long Message::getExpiration() {
+    return expiration;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setExpiration(long long expiration ) {
+    this->expiration = expiration;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const char Message::getPriority() const {
+    return priority;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+char Message::getPriority() {
+    return priority;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setPriority(char priority ) {
+    this->priority = priority;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ActiveMQDestination* Message::getReplyTo() const {
+    return replyTo;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ActiveMQDestination* Message::getReplyTo() {
+    return replyTo;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setReplyTo(ActiveMQDestination* replyTo ) {
+    this->replyTo = replyTo;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const long long Message::getTimestamp() const {
+    return timestamp;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long Message::getTimestamp() {
+    return timestamp;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setTimestamp(long long timestamp ) {
+    this->timestamp = timestamp;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& Message::getType() const {
+    return type;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& Message::getType() {
+    return type;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setType(const std::string& type ) {
+    this->type = type;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::vector<char> Message::getContent() const {
+    return content;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::vector<char> Message::getContent() {
+    return content;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setContent(std::vector<char> content ) {
+    this->content = content;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::vector<char> Message::getMarshalledProperties() const {
+    return marshalledProperties;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::vector<char> Message::getMarshalledProperties() {
+    return marshalledProperties;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setMarshalledProperties(std::vector<char> marshalledProperties ) {
+    this->marshalledProperties = marshalledProperties;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const DataStructure* Message::getDataStructure() const {
+    return dataStructure;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+DataStructure* Message::getDataStructure() {
+    return dataStructure;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setDataStructure(DataStructure* dataStructure ) {
+    this->dataStructure = dataStructure;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ConsumerId* Message::getTargetConsumerId() const {
+    return targetConsumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerId* Message::getTargetConsumerId() {
+    return targetConsumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setTargetConsumerId(ConsumerId* targetConsumerId ) {
+    this->targetConsumerId = targetConsumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const bool Message::getCompressed() const {
+    return compressed;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool Message::getCompressed() {
+    return compressed;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setCompressed(bool compressed ) {
+    this->compressed = compressed;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const int Message::getRedeliveryCounter() const {
+    return redeliveryCounter;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int Message::getRedeliveryCounter() {
+    return redeliveryCounter;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setRedeliveryCounter(int redeliveryCounter ) {
+    this->redeliveryCounter = redeliveryCounter;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::vector<BrokerId*> Message::getBrokerPath() const {
+    return brokerPath;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::vector<BrokerId*> Message::getBrokerPath() {
+    return brokerPath;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setBrokerPath(std::vector<BrokerId*> brokerPath ) {
+    this->brokerPath = brokerPath;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const long long Message::getArrival() const {
+    return arrival;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long Message::getArrival() {
+    return arrival;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setArrival(long long arrival ) {
+    this->arrival = arrival;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const std::string& Message::getUserID() const {
+    return userID;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+std::string& Message::getUserID() {
+    return userID;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setUserID(const std::string& userID ) {
+    this->userID = userID;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const bool Message::getRecievedByDFBridge() const {
+    return recievedByDFBridge;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+bool Message::getRecievedByDFBridge() {
+    return recievedByDFBridge;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void Message::setRecievedByDFBridge(bool recievedByDFBridge ) {
+    this->recievedByDFBridge = recievedByDFBridge;
+}
+

Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/Message.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/Message.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/Message.h?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/Message.h (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/Message.h Mon Oct  2 07:30:10 2006
@@ -0,0 +1,200 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_MESSAGE_H_
+#define _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_MESSAGE_H_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <activemq/connector/openwire/commands/BaseCommand.h>
+#include <activemq/connector/openwire/commands/ProducerId.h>
+#include <activemq/connector/openwire/commands/ActiveMQDestination.h>
+#include <activemq/connector/openwire/commands/TransactionId.h>
+#include <activemq/connector/openwire/commands/ActiveMQDestination.h>
+#include <activemq/connector/openwire/commands/MessageId.h>
+#include <activemq/connector/openwire/commands/TransactionId.h>
+#include <activemq/connector/openwire/commands/ActiveMQDestination.h>
+#include <activemq/connector/openwire/commands/DataStructure.h>
+#include <activemq/connector/openwire/commands/ConsumerId.h>
+#include <activemq/connector/openwire/commands/BrokerId.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace connector{
+namespace openwire{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshalling code for OpenWire format for ${className}
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the activemq-openwire-generator module
+     *
+     */
+    class Message : public BaseCommand
+    {
+    protected:
+
+        ProducerId* producerId;
+        ActiveMQDestination* destination;
+        TransactionId* transactionId;
+        ActiveMQDestination* originalDestination;
+        MessageId* messageId;
+        TransactionId* originalTransactionId;
+        std::string groupID;
+        int groupSequence;
+        std::string correlationId;
+        bool persistent;
+        long long expiration;
+        char priority;
+        ActiveMQDestination* replyTo;
+        long long timestamp;
+        std::string type;
+        std::vector<char> content;
+        std::vector<char> marshalledProperties;
+        DataStructure* dataStructure;
+        ConsumerId* targetConsumerId;
+        bool compressed;
+        int redeliveryCounter;
+        std::vector<BrokerId*> brokerPath;
+        long long arrival;
+        std::string userID;
+        bool recievedByDFBridge;
+
+    public:
+
+        const static unsigned char ID_MESSAGE = 0;
+
+    public:
+
+        Message();
+        virtual ~Message();
+
+        virtual unsigned char getDataStructureType() const;
+        virtual const ProducerId* getProducerId() const;
+        virtual ProducerId* getProducerId();
+        virtual void setProducerId( ProducerId* producerId );
+
+        virtual const ActiveMQDestination* getDestination() const;
+        virtual ActiveMQDestination* getDestination();
+        virtual void setDestination( ActiveMQDestination* destination );
+
+        virtual const TransactionId* getTransactionId() const;
+        virtual TransactionId* getTransactionId();
+        virtual void setTransactionId( TransactionId* transactionId );
+
+        virtual const ActiveMQDestination* getOriginalDestination() const;
+        virtual ActiveMQDestination* getOriginalDestination();
+        virtual void setOriginalDestination( ActiveMQDestination* originalDestination );
+
+        virtual const MessageId* getMessageId() const;
+        virtual MessageId* getMessageId();
+        virtual void setMessageId( MessageId* messageId );
+
+        virtual const TransactionId* getOriginalTransactionId() const;
+        virtual TransactionId* getOriginalTransactionId();
+        virtual void setOriginalTransactionId( TransactionId* originalTransactionId );
+
+        virtual const std::string& getGroupID() const;
+        virtual std::string& getGroupID();
+        virtual void setGroupID( const std::string& groupID );
+
+        virtual const int getGroupSequence() const;
+        virtual int getGroupSequence();
+        virtual void setGroupSequence( int groupSequence );
+
+        virtual const std::string& getCorrelationId() const;
+        virtual std::string& getCorrelationId();
+        virtual void setCorrelationId( const std::string& correlationId );
+
+        virtual const bool getPersistent() const;
+        virtual bool getPersistent();
+        virtual void setPersistent( bool persistent );
+
+        virtual const long long getExpiration() const;
+        virtual long long getExpiration();
+        virtual void setExpiration( long long expiration );
+
+        virtual const char getPriority() const;
+        virtual char getPriority();
+        virtual void setPriority( char priority );
+
+        virtual const ActiveMQDestination* getReplyTo() const;
+        virtual ActiveMQDestination* getReplyTo();
+        virtual void setReplyTo( ActiveMQDestination* replyTo );
+
+        virtual const long long getTimestamp() const;
+        virtual long long getTimestamp();
+        virtual void setTimestamp( long long timestamp );
+
+        virtual const std::string& getType() const;
+        virtual std::string& getType();
+        virtual void setType( const std::string& type );
+
+        virtual const std::vector<char> getContent() const;
+        virtual std::vector<char> getContent();
+        virtual void setContent( std::vector<char> content );
+
+        virtual const std::vector<char> getMarshalledProperties() const;
+        virtual std::vector<char> getMarshalledProperties();
+        virtual void setMarshalledProperties( std::vector<char> marshalledProperties );
+
+        virtual const DataStructure* getDataStructure() const;
+        virtual DataStructure* getDataStructure();
+        virtual void setDataStructure( DataStructure* dataStructure );
+
+        virtual const ConsumerId* getTargetConsumerId() const;
+        virtual ConsumerId* getTargetConsumerId();
+        virtual void setTargetConsumerId( ConsumerId* targetConsumerId );
+
+        virtual const bool getCompressed() const;
+        virtual bool getCompressed();
+        virtual void setCompressed( bool compressed );
+
+        virtual const int getRedeliveryCounter() const;
+        virtual int getRedeliveryCounter();
+        virtual void setRedeliveryCounter( int redeliveryCounter );
+
+        virtual const std::vector<BrokerId*> getBrokerPath() const;
+        virtual std::vector<BrokerId*> getBrokerPath();
+        virtual void setBrokerPath( std::vector<BrokerId*> brokerPath );
+
+        virtual const long long getArrival() const;
+        virtual long long getArrival();
+        virtual void setArrival( long long arrival );
+
+        virtual const std::string& getUserID() const;
+        virtual std::string& getUserID();
+        virtual void setUserID( const std::string& userID );
+
+        virtual const bool getRecievedByDFBridge() const;
+        virtual bool getRecievedByDFBridge();
+        virtual void setRecievedByDFBridge( bool recievedByDFBridge );
+
+    };
+
+}}}}
+
+#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_MESSAGE_H_*/
+

Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/Message.h
------------------------------------------------------------------------------
    svn:eol-style = native

Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageAck.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageAck.cpp?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageAck.cpp (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageAck.cpp Mon Oct  2 07:30:10 2006
@@ -0,0 +1,167 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include <activemq/connector/openwire/commands/MessageAck.h>
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::connector;
+using namespace activemq::connector::openwire;
+using namespace activemq::connector::openwire::commands;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for MessageAck
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Java Classes in the
+ *         activemq-core module
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+MessageAck::MessageAck()
+{
+    this->destination = NULL;
+    this->transactionId = NULL;
+    this->consumerId = NULL;
+    this->ackType = 0;
+    this->firstMessageId = NULL;
+    this->lastMessageId = NULL;
+    this->messageCount = 0;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessageAck::~MessageAck()
+{
+    delete this->destination;
+    delete this->transactionId;
+    delete this->consumerId;
+    delete this->firstMessageId;
+    delete this->lastMessageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char MessageAck::getDataStructureType() const
+{
+    return MessageAck::ID_MESSAGEACK; 
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ActiveMQDestination* MessageAck::getDestination() const {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ActiveMQDestination* MessageAck::getDestination() {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageAck::setDestination(ActiveMQDestination* destination ) {
+    this->destination = destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const TransactionId* MessageAck::getTransactionId() const {
+    return transactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+TransactionId* MessageAck::getTransactionId() {
+    return transactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageAck::setTransactionId(TransactionId* transactionId ) {
+    this->transactionId = transactionId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ConsumerId* MessageAck::getConsumerId() const {
+    return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerId* MessageAck::getConsumerId() {
+    return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageAck::setConsumerId(ConsumerId* consumerId ) {
+    this->consumerId = consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const char MessageAck::getAckType() const {
+    return ackType;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+char MessageAck::getAckType() {
+    return ackType;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageAck::setAckType(char ackType ) {
+    this->ackType = ackType;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const MessageId* MessageAck::getFirstMessageId() const {
+    return firstMessageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessageId* MessageAck::getFirstMessageId() {
+    return firstMessageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageAck::setFirstMessageId(MessageId* firstMessageId ) {
+    this->firstMessageId = firstMessageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const MessageId* MessageAck::getLastMessageId() const {
+    return lastMessageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessageId* MessageAck::getLastMessageId() {
+    return lastMessageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageAck::setLastMessageId(MessageId* lastMessageId ) {
+    this->lastMessageId = lastMessageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const int MessageAck::getMessageCount() const {
+    return messageCount;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int MessageAck::getMessageCount() {
+    return messageCount;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageAck::setMessageCount(int messageCount ) {
+    this->messageCount = messageCount;
+}
+

Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageAck.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageAck.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageAck.h?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageAck.h (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageAck.h Mon Oct  2 07:30:10 2006
@@ -0,0 +1,105 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_MESSAGEACK_H_
+#define _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_MESSAGEACK_H_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <activemq/connector/openwire/commands/BaseCommand.h>
+#include <activemq/connector/openwire/commands/ActiveMQDestination.h>
+#include <activemq/connector/openwire/commands/TransactionId.h>
+#include <activemq/connector/openwire/commands/ConsumerId.h>
+#include <activemq/connector/openwire/commands/MessageId.h>
+#include <activemq/connector/openwire/commands/MessageId.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace connector{
+namespace openwire{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshalling code for OpenWire format for ${className}
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the activemq-openwire-generator module
+     *
+     */
+    class MessageAck : public BaseCommand
+    {
+    protected:
+
+        ActiveMQDestination* destination;
+        TransactionId* transactionId;
+        ConsumerId* consumerId;
+        char ackType;
+        MessageId* firstMessageId;
+        MessageId* lastMessageId;
+        int messageCount;
+
+    public:
+
+        const static unsigned char ID_MESSAGEACK = 22;
+
+    public:
+
+        MessageAck();
+        virtual ~MessageAck();
+
+        virtual unsigned char getDataStructureType() const;
+        virtual const ActiveMQDestination* getDestination() const;
+        virtual ActiveMQDestination* getDestination();
+        virtual void setDestination( ActiveMQDestination* destination );
+
+        virtual const TransactionId* getTransactionId() const;
+        virtual TransactionId* getTransactionId();
+        virtual void setTransactionId( TransactionId* transactionId );
+
+        virtual const ConsumerId* getConsumerId() const;
+        virtual ConsumerId* getConsumerId();
+        virtual void setConsumerId( ConsumerId* consumerId );
+
+        virtual const char getAckType() const;
+        virtual char getAckType();
+        virtual void setAckType( char ackType );
+
+        virtual const MessageId* getFirstMessageId() const;
+        virtual MessageId* getFirstMessageId();
+        virtual void setFirstMessageId( MessageId* firstMessageId );
+
+        virtual const MessageId* getLastMessageId() const;
+        virtual MessageId* getLastMessageId();
+        virtual void setLastMessageId( MessageId* lastMessageId );
+
+        virtual const int getMessageCount() const;
+        virtual int getMessageCount();
+        virtual void setMessageCount( int messageCount );
+
+    };
+
+}}}}
+
+#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_MESSAGEACK_H_*/
+

Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageAck.h
------------------------------------------------------------------------------
    svn:eol-style = native

Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageDispatch.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageDispatch.cpp?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageDispatch.cpp (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageDispatch.cpp Mon Oct  2 07:30:10 2006
@@ -0,0 +1,117 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include <activemq/connector/openwire/commands/MessageDispatch.h>
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::connector;
+using namespace activemq::connector::openwire;
+using namespace activemq::connector::openwire::commands;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for MessageDispatch
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Java Classes in the
+ *         activemq-core module
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+MessageDispatch::MessageDispatch()
+{
+    this->consumerId = NULL;
+    this->destination = NULL;
+    this->message = NULL;
+    this->redeliveryCounter = 0;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessageDispatch::~MessageDispatch()
+{
+    delete this->consumerId;
+    delete this->destination;
+    delete this->message;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char MessageDispatch::getDataStructureType() const
+{
+    return MessageDispatch::ID_MESSAGEDISPATCH; 
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ConsumerId* MessageDispatch::getConsumerId() const {
+    return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerId* MessageDispatch::getConsumerId() {
+    return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageDispatch::setConsumerId(ConsumerId* consumerId ) {
+    this->consumerId = consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ActiveMQDestination* MessageDispatch::getDestination() const {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ActiveMQDestination* MessageDispatch::getDestination() {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageDispatch::setDestination(ActiveMQDestination* destination ) {
+    this->destination = destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const Message* MessageDispatch::getMessage() const {
+    return message;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+Message* MessageDispatch::getMessage() {
+    return message;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageDispatch::setMessage(Message* message ) {
+    this->message = message;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const int MessageDispatch::getRedeliveryCounter() const {
+    return redeliveryCounter;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int MessageDispatch::getRedeliveryCounter() {
+    return redeliveryCounter;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageDispatch::setRedeliveryCounter(int redeliveryCounter ) {
+    this->redeliveryCounter = redeliveryCounter;
+}
+

Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageDispatch.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageDispatch.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageDispatch.h?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageDispatch.h (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageDispatch.h Mon Oct  2 07:30:10 2006
@@ -0,0 +1,88 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_MESSAGEDISPATCH_H_
+#define _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_MESSAGEDISPATCH_H_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <activemq/connector/openwire/commands/BaseCommand.h>
+#include <activemq/connector/openwire/commands/ConsumerId.h>
+#include <activemq/connector/openwire/commands/ActiveMQDestination.h>
+#include <activemq/connector/openwire/commands/Message.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace connector{
+namespace openwire{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshalling code for OpenWire format for ${className}
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the activemq-openwire-generator module
+     *
+     */
+    class MessageDispatch : public BaseCommand
+    {
+    protected:
+
+        ConsumerId* consumerId;
+        ActiveMQDestination* destination;
+        Message* message;
+        int redeliveryCounter;
+
+    public:
+
+        const static unsigned char ID_MESSAGEDISPATCH = 21;
+
+    public:
+
+        MessageDispatch();
+        virtual ~MessageDispatch();
+
+        virtual unsigned char getDataStructureType() const;
+        virtual const ConsumerId* getConsumerId() const;
+        virtual ConsumerId* getConsumerId();
+        virtual void setConsumerId( ConsumerId* consumerId );
+
+        virtual const ActiveMQDestination* getDestination() const;
+        virtual ActiveMQDestination* getDestination();
+        virtual void setDestination( ActiveMQDestination* destination );
+
+        virtual const Message* getMessage() const;
+        virtual Message* getMessage();
+        virtual void setMessage( Message* message );
+
+        virtual const int getRedeliveryCounter() const;
+        virtual int getRedeliveryCounter();
+        virtual void setRedeliveryCounter( int redeliveryCounter );
+
+    };
+
+}}}}
+
+#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_MESSAGEDISPATCH_H_*/
+

Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageDispatch.h
------------------------------------------------------------------------------
    svn:eol-style = native

Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageDispatchNotification.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageDispatchNotification.cpp?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageDispatchNotification.cpp (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageDispatchNotification.cpp Mon Oct  2 07:30:10 2006
@@ -0,0 +1,117 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include <activemq/connector/openwire/commands/MessageDispatchNotification.h>
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::connector;
+using namespace activemq::connector::openwire;
+using namespace activemq::connector::openwire::commands;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for MessageDispatchNotification
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Java Classes in the
+ *         activemq-core module
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+MessageDispatchNotification::MessageDispatchNotification()
+{
+    this->consumerId = NULL;
+    this->destination = NULL;
+    this->deliverySequenceId = 0;
+    this->messageId = NULL;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessageDispatchNotification::~MessageDispatchNotification()
+{
+    delete this->consumerId;
+    delete this->destination;
+    delete this->messageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char MessageDispatchNotification::getDataStructureType() const
+{
+    return MessageDispatchNotification::ID_MESSAGEDISPATCHNOTIFICATION; 
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ConsumerId* MessageDispatchNotification::getConsumerId() const {
+    return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerId* MessageDispatchNotification::getConsumerId() {
+    return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageDispatchNotification::setConsumerId(ConsumerId* consumerId ) {
+    this->consumerId = consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ActiveMQDestination* MessageDispatchNotification::getDestination() const {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ActiveMQDestination* MessageDispatchNotification::getDestination() {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageDispatchNotification::setDestination(ActiveMQDestination* destination ) {
+    this->destination = destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const long long MessageDispatchNotification::getDeliverySequenceId() const {
+    return deliverySequenceId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long MessageDispatchNotification::getDeliverySequenceId() {
+    return deliverySequenceId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageDispatchNotification::setDeliverySequenceId(long long deliverySequenceId ) {
+    this->deliverySequenceId = deliverySequenceId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const MessageId* MessageDispatchNotification::getMessageId() const {
+    return messageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessageId* MessageDispatchNotification::getMessageId() {
+    return messageId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageDispatchNotification::setMessageId(MessageId* messageId ) {
+    this->messageId = messageId;
+}
+

Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageDispatchNotification.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageDispatchNotification.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageDispatchNotification.h?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageDispatchNotification.h (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageDispatchNotification.h Mon Oct  2 07:30:10 2006
@@ -0,0 +1,88 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_MESSAGEDISPATCHNOTIFICATION_H_
+#define _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_MESSAGEDISPATCHNOTIFICATION_H_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <activemq/connector/openwire/commands/BaseCommand.h>
+#include <activemq/connector/openwire/commands/ConsumerId.h>
+#include <activemq/connector/openwire/commands/ActiveMQDestination.h>
+#include <activemq/connector/openwire/commands/MessageId.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace connector{
+namespace openwire{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshalling code for OpenWire format for ${className}
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the activemq-openwire-generator module
+     *
+     */
+    class MessageDispatchNotification : public BaseCommand
+    {
+    protected:
+
+        ConsumerId* consumerId;
+        ActiveMQDestination* destination;
+        long long deliverySequenceId;
+        MessageId* messageId;
+
+    public:
+
+        const static unsigned char ID_MESSAGEDISPATCHNOTIFICATION = 90;
+
+    public:
+
+        MessageDispatchNotification();
+        virtual ~MessageDispatchNotification();
+
+        virtual unsigned char getDataStructureType() const;
+        virtual const ConsumerId* getConsumerId() const;
+        virtual ConsumerId* getConsumerId();
+        virtual void setConsumerId( ConsumerId* consumerId );
+
+        virtual const ActiveMQDestination* getDestination() const;
+        virtual ActiveMQDestination* getDestination();
+        virtual void setDestination( ActiveMQDestination* destination );
+
+        virtual const long long getDeliverySequenceId() const;
+        virtual long long getDeliverySequenceId();
+        virtual void setDeliverySequenceId( long long deliverySequenceId );
+
+        virtual const MessageId* getMessageId() const;
+        virtual MessageId* getMessageId();
+        virtual void setMessageId( MessageId* messageId );
+
+    };
+
+}}}}
+
+#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_MESSAGEDISPATCHNOTIFICATION_H_*/
+

Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageDispatchNotification.h
------------------------------------------------------------------------------
    svn:eol-style = native

Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageId.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageId.cpp?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageId.cpp (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageId.cpp Mon Oct  2 07:30:10 2006
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include <activemq/connector/openwire/commands/MessageId.h>
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::connector;
+using namespace activemq::connector::openwire;
+using namespace activemq::connector::openwire::commands;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for MessageId
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Java Classes in the
+ *         activemq-core module
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+MessageId::MessageId()
+{
+    this->producerId = NULL;
+    this->producerSequenceId = 0;
+    this->brokerSequenceId = 0;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessageId::~MessageId()
+{
+    delete this->producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char MessageId::getDataStructureType() const
+{
+    return MessageId::ID_MESSAGEID; 
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ProducerId* MessageId::getProducerId() const {
+    return producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ProducerId* MessageId::getProducerId() {
+    return producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageId::setProducerId(ProducerId* producerId ) {
+    this->producerId = producerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const long long MessageId::getProducerSequenceId() const {
+    return producerSequenceId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long MessageId::getProducerSequenceId() {
+    return producerSequenceId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageId::setProducerSequenceId(long long producerSequenceId ) {
+    this->producerSequenceId = producerSequenceId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const long long MessageId::getBrokerSequenceId() const {
+    return brokerSequenceId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long MessageId::getBrokerSequenceId() {
+    return brokerSequenceId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessageId::setBrokerSequenceId(long long brokerSequenceId ) {
+    this->brokerSequenceId = brokerSequenceId;
+}
+

Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageId.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageId.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageId.h?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageId.h (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageId.h Mon Oct  2 07:30:10 2006
@@ -0,0 +1,81 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_MESSAGEID_H_
+#define _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_MESSAGEID_H_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <activemq/connector/openwire/commands/BaseDataStructure.h>
+#include <activemq/connector/openwire/commands/ProducerId.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace connector{
+namespace openwire{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshalling code for OpenWire format for ${className}
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the activemq-openwire-generator module
+     *
+     */
+    class MessageId : public BaseDataStructure
+    {
+    protected:
+
+        ProducerId* producerId;
+        long long producerSequenceId;
+        long long brokerSequenceId;
+
+    public:
+
+        const static unsigned char ID_MESSAGEID = 110;
+
+    public:
+
+        MessageId();
+        virtual ~MessageId();
+
+        virtual unsigned char getDataStructureType() const;
+        virtual const ProducerId* getProducerId() const;
+        virtual ProducerId* getProducerId();
+        virtual void setProducerId( ProducerId* producerId );
+
+        virtual const long long getProducerSequenceId() const;
+        virtual long long getProducerSequenceId();
+        virtual void setProducerSequenceId( long long producerSequenceId );
+
+        virtual const long long getBrokerSequenceId() const;
+        virtual long long getBrokerSequenceId();
+        virtual void setBrokerSequenceId( long long brokerSequenceId );
+
+    };
+
+}}}}
+
+#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_MESSAGEID_H_*/
+

Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessageId.h
------------------------------------------------------------------------------
    svn:eol-style = native

Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessagePull.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessagePull.cpp?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessagePull.cpp (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessagePull.cpp Mon Oct  2 07:30:10 2006
@@ -0,0 +1,100 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include <activemq/connector/openwire/commands/MessagePull.h>
+
+using namespace std;
+using namespace activemq;
+using namespace activemq::connector;
+using namespace activemq::connector::openwire;
+using namespace activemq::connector::openwire::commands;
+
+/*
+ *
+ *  Command and marshalling code for OpenWire format for MessagePull
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Java Classes in the
+ *         activemq-core module
+ *
+ */
+////////////////////////////////////////////////////////////////////////////////
+MessagePull::MessagePull()
+{
+    this->consumerId = NULL;
+    this->destination = NULL;
+    this->timeout = 0;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+MessagePull::~MessagePull()
+{
+    delete this->consumerId;
+    delete this->destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char MessagePull::getDataStructureType() const
+{
+    return MessagePull::ID_MESSAGEPULL; 
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ConsumerId* MessagePull::getConsumerId() const {
+    return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ConsumerId* MessagePull::getConsumerId() {
+    return consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessagePull::setConsumerId(ConsumerId* consumerId ) {
+    this->consumerId = consumerId;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const ActiveMQDestination* MessagePull::getDestination() const {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+ActiveMQDestination* MessagePull::getDestination() {
+    return destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessagePull::setDestination(ActiveMQDestination* destination ) {
+    this->destination = destination;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+const long long MessagePull::getTimeout() const {
+    return timeout;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+long long MessagePull::getTimeout() {
+    return timeout;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void MessagePull::setTimeout(long long timeout ) {
+    this->timeout = timeout;
+}
+

Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessagePull.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Added: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessagePull.h
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessagePull.h?view=auto&rev=452053
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessagePull.h (added)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessagePull.h Mon Oct  2 07:30:10 2006
@@ -0,0 +1,82 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_MESSAGEPULL_H_
+#define _ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_MESSAGEPULL_H_
+
+// Turn off warning message for ignored exception specification
+#ifdef _MSC_VER
+#pragma warning( disable : 4290 )
+#endif
+
+#include <activemq/connector/openwire/commands/BaseCommand.h>
+#include <activemq/connector/openwire/commands/ConsumerId.h>
+#include <activemq/connector/openwire/commands/ActiveMQDestination.h>
+#include <vector>
+#include <string>
+
+namespace activemq{
+namespace connector{
+namespace openwire{
+namespace commands{
+
+    /*
+     *
+     *  Command and marshalling code for OpenWire format for ${className}
+     *
+     *
+     *  NOTE!: This file is autogenerated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the activemq-openwire-generator module
+     *
+     */
+    class MessagePull : public BaseCommand
+    {
+    protected:
+
+        ConsumerId* consumerId;
+        ActiveMQDestination* destination;
+        long long timeout;
+
+    public:
+
+        const static unsigned char ID_MESSAGEPULL = 20;
+
+    public:
+
+        MessagePull();
+        virtual ~MessagePull();
+
+        virtual unsigned char getDataStructureType() const;
+        virtual const ConsumerId* getConsumerId() const;
+        virtual ConsumerId* getConsumerId();
+        virtual void setConsumerId( ConsumerId* consumerId );
+
+        virtual const ActiveMQDestination* getDestination() const;
+        virtual ActiveMQDestination* getDestination();
+        virtual void setDestination( ActiveMQDestination* destination );
+
+        virtual const long long getTimeout() const;
+        virtual long long getTimeout();
+        virtual void setTimeout( long long timeout );
+
+    };
+
+}}}}
+
+#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_COMMANDS_MESSAGEPULL_H_*/
+

Propchange: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/MessagePull.h
------------------------------------------------------------------------------
    svn:eol-style = native



Mime
View raw message