You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2006/10/02 16:30:22 UTC
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/...
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