You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by js...@apache.org on 2006/07/31 11:36:51 UTC
svn commit: r427057 [22/22] - in /incubator/activemq/trunk/amazon: ./
amq_brokersession/ amq_corelib/ amq_examples/ amq_examples/bs_async_recv/
amq_examples/bs_send/ amq_examples/bs_sync_recv/ amq_examples/cl_send/
amq_transport/ command/ marshal/
Added: incubator/activemq/trunk/amazon/marshal/TransactionIdMarshaller.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/marshal/TransactionIdMarshaller.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/marshal/TransactionIdMarshaller.cpp (added)
+++ incubator/activemq/trunk/amazon/marshal/TransactionIdMarshaller.cpp Mon Jul 31 02:36:40 2006
@@ -0,0 +1,79 @@
+/*
+ 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 "netinet/in.h"
+#include "marshal/TransactionIdMarshaller.h"
+#include "command/TransactionId.h"
+#include "boost/shared_ptr.hpp"
+
+using namespace ActiveMQ::Marshalling;
+using namespace ActiveMQ::Command;
+using namespace ActiveMQ::IO;
+using std::auto_ptr;
+using boost::shared_ptr;
+
+/*
+ * Marshalling code for Open Wire Format for TransactionId
+ *
+ * NOTE!: This file is autogenerated - do not modify!
+ * if you need to make a change, please see the Groovy scripts in the
+ * activemq-core module
+ */
+
+TransactionIdMarshaller::TransactionIdMarshaller()
+{
+ // no-op
+}
+
+TransactionIdMarshaller::~TransactionIdMarshaller()
+{
+ // no-op
+}
+
+/*
+ * Un-marshal an object instance from the data input stream
+ */
+void
+TransactionIdMarshaller::unmarshal(ProtocolFormat& wireFormat, IDataStructure& o, BinaryReader& dataIn, BooleanStream& bs)
+{
+
+ TransactionId& info = (TransactionId&) o;
+
+}
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+size_t
+TransactionIdMarshaller::marshal1(ProtocolFormat& wireFormat, const IDataStructure& o, BooleanStream& bs) {
+ TransactionId& info = (TransactionId&) o;
+
+ int rc = 0;
+
+ return rc + 0;
+}
+
+/*
+ * Write a object instance to data output stream
+ */
+void
+TransactionIdMarshaller::marshal2(ProtocolFormat& wireFormat, const IDataStructure& o, BinaryWriter& dataOut, BooleanStream& bs) {
+ // }
+
+}
Propchange: incubator/activemq/trunk/amazon/marshal/TransactionIdMarshaller.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/marshal/TransactionIdMarshaller.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/marshal/TransactionIdMarshaller.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/marshal/TransactionIdMarshaller.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/marshal/TransactionIdMarshaller.h (added)
+++ incubator/activemq/trunk/amazon/marshal/TransactionIdMarshaller.h Mon Jul 31 02:36:40 2006
@@ -0,0 +1,72 @@
+/*
+ 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 TransactionIdMarshaller_h_
+#define TransactionIdMarshaller_h_
+
+#include <string>
+#include <memory>
+
+#include "command/IDataStructure.h"
+
+/* auto-generated! */
+/* we could cut this down - for now include all possible headers */
+#include "command/BrokerId.h"
+#include "command/ConnectionId.h"
+#include "command/ConsumerId.h"
+#include "command/ProducerId.h"
+#include "command/SessionId.h"
+#include "command/BaseCommand.h"
+
+#include "marshal/BinaryReader.h"
+#include "marshal/BinaryWriter.h"
+
+#include "marshal/BaseDataStreamMarshaller.h"
+
+#include "marshal/ProtocolFormat.h"
+
+namespace ActiveMQ {
+ namespace Marshalling {
+
+ class TransactionIdMarshaller : public BaseDataStreamMarshaller
+ {
+ public:
+ TransactionIdMarshaller();
+ virtual ~TransactionIdMarshaller();
+
+ virtual auto_ptr<ActiveMQ::Command::IDataStructure> createCommand() = 0;
+ virtual char getDataStructureType() = 0;
+
+ virtual void unmarshal(ProtocolFormat& wireFormat,
+ ActiveMQ::Command::IDataStructure& o,
+ ActiveMQ::IO::BinaryReader& dataIn,
+ ActiveMQ::IO::BooleanStream& bs);
+
+ virtual size_t marshal1(ProtocolFormat& wireFormat,
+ const ActiveMQ::Command::IDataStructure& o,
+ ActiveMQ::IO::BooleanStream& bs);
+
+ virtual void marshal2(ProtocolFormat& wireFormat,
+ const ActiveMQ::Command::IDataStructure& o,
+ ActiveMQ::IO::BinaryWriter& dataOut,
+ ActiveMQ::IO::BooleanStream& bs);
+ };
+ }
+}
+#endif /*TransactionIdMarshaller_h_*/
Propchange: incubator/activemq/trunk/amazon/marshal/TransactionIdMarshaller.h
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/marshal/TransactionIdMarshaller.h
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/marshal/TransactionInfoMarshaller.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/marshal/TransactionInfoMarshaller.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/marshal/TransactionInfoMarshaller.cpp (added)
+++ incubator/activemq/trunk/amazon/marshal/TransactionInfoMarshaller.cpp Mon Jul 31 02:36:40 2006
@@ -0,0 +1,101 @@
+/*
+ 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 "netinet/in.h"
+#include "marshal/TransactionInfoMarshaller.h"
+#include "command/TransactionInfo.h"
+#include "boost/shared_ptr.hpp"
+
+using namespace ActiveMQ::Marshalling;
+using namespace ActiveMQ::Command;
+using namespace ActiveMQ::IO;
+using std::auto_ptr;
+using boost::shared_ptr;
+
+/*
+ * Marshalling code for Open Wire Format for TransactionInfo
+ *
+ * NOTE!: This file is autogenerated - do not modify!
+ * if you need to make a change, please see the Groovy scripts in the
+ * activemq-core module
+ */
+
+TransactionInfoMarshaller::TransactionInfoMarshaller()
+{
+ // no-op
+}
+
+TransactionInfoMarshaller::~TransactionInfoMarshaller()
+{
+ // no-op
+}
+
+auto_ptr<IDataStructure> TransactionInfoMarshaller::createCommand()
+{
+ return auto_ptr<IDataStructure>(new TransactionInfo());
+}
+
+char TransactionInfoMarshaller::getDataStructureType()
+{
+ return TransactionInfo::TYPE;
+}
+
+/*
+ * Un-marshal an object instance from the data input stream
+ */
+void
+TransactionInfoMarshaller::unmarshal(ProtocolFormat& wireFormat, IDataStructure& o, BinaryReader& dataIn, BooleanStream& bs)
+{
+ BaseCommandMarshaller::unmarshal(wireFormat, o, dataIn, bs);
+
+ TransactionInfo& info = (TransactionInfo&) o;
+ info.setConnectionId( shared_ptr<ConnectionId>(static_cast<ConnectionId*>(unmarshalCachedObject(wireFormat, dataIn, bs).release())) );
+ info.setTransactionId( shared_ptr<TransactionId>(static_cast<TransactionId*>(unmarshalCachedObject(wireFormat, dataIn, bs).release())) );
+ info.setType( dataIn.readByte() );
+
+}
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+size_t
+TransactionInfoMarshaller::marshal1(ProtocolFormat& wireFormat, const IDataStructure& o, BooleanStream& bs) {
+ TransactionInfo& info = (TransactionInfo&) o;
+
+ int rc = BaseCommandMarshaller::marshal1(wireFormat, info, bs);
+ rc += marshal1CachedObject(wireFormat, info.getConnectionId(), bs);
+ rc += marshal1CachedObject(wireFormat, info.getTransactionId(), bs);
+
+ return rc + 1;
+}
+
+/*
+ * Write a object instance to data output stream
+ */
+void
+TransactionInfoMarshaller::marshal2(ProtocolFormat& wireFormat, const IDataStructure& o, BinaryWriter& dataOut, BooleanStream& bs) {
+ // }
+
+ BaseCommandMarshaller::marshal2(wireFormat, o, dataOut, bs);
+
+ TransactionInfo& info = (TransactionInfo&) o;
+ marshal2CachedObject(wireFormat, info.getConnectionId(), dataOut, bs);
+ marshal2CachedObject(wireFormat, info.getTransactionId(), dataOut, bs);
+ dataOut.writeByte(info.getType());
+}
Propchange: incubator/activemq/trunk/amazon/marshal/TransactionInfoMarshaller.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/marshal/TransactionInfoMarshaller.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/marshal/TransactionInfoMarshaller.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/marshal/TransactionInfoMarshaller.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/marshal/TransactionInfoMarshaller.h (added)
+++ incubator/activemq/trunk/amazon/marshal/TransactionInfoMarshaller.h Mon Jul 31 02:36:40 2006
@@ -0,0 +1,72 @@
+/*
+ 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 TransactionInfoMarshaller_h_
+#define TransactionInfoMarshaller_h_
+
+#include <string>
+#include <memory>
+
+#include "command/IDataStructure.h"
+
+/* auto-generated! */
+/* we could cut this down - for now include all possible headers */
+#include "command/BrokerId.h"
+#include "command/ConnectionId.h"
+#include "command/ConsumerId.h"
+#include "command/ProducerId.h"
+#include "command/SessionId.h"
+#include "command/BaseCommand.h"
+
+#include "marshal/BinaryReader.h"
+#include "marshal/BinaryWriter.h"
+
+#include "marshal/BaseCommandMarshaller.h"
+
+#include "marshal/ProtocolFormat.h"
+
+namespace ActiveMQ {
+ namespace Marshalling {
+
+ class TransactionInfoMarshaller : public BaseCommandMarshaller
+ {
+ public:
+ TransactionInfoMarshaller();
+ virtual ~TransactionInfoMarshaller();
+
+ virtual auto_ptr<ActiveMQ::Command::IDataStructure> createCommand();
+ virtual char getDataStructureType();
+
+ virtual void unmarshal(ProtocolFormat& wireFormat,
+ ActiveMQ::Command::IDataStructure& o,
+ ActiveMQ::IO::BinaryReader& dataIn,
+ ActiveMQ::IO::BooleanStream& bs);
+
+ virtual size_t marshal1(ProtocolFormat& wireFormat,
+ const ActiveMQ::Command::IDataStructure& o,
+ ActiveMQ::IO::BooleanStream& bs);
+
+ virtual void marshal2(ProtocolFormat& wireFormat,
+ const ActiveMQ::Command::IDataStructure& o,
+ ActiveMQ::IO::BinaryWriter& dataOut,
+ ActiveMQ::IO::BooleanStream& bs);
+ };
+ }
+}
+#endif /*TransactionInfoMarshaller_h_*/
Propchange: incubator/activemq/trunk/amazon/marshal/TransactionInfoMarshaller.h
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/marshal/TransactionInfoMarshaller.h
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/marshal/WireFormatInfoMarshaller.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/marshal/WireFormatInfoMarshaller.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/marshal/WireFormatInfoMarshaller.cpp (added)
+++ incubator/activemq/trunk/amazon/marshal/WireFormatInfoMarshaller.cpp Mon Jul 31 02:36:40 2006
@@ -0,0 +1,102 @@
+/*
+ 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 "netinet/in.h"
+#include "marshal/WireFormatInfoMarshaller.h"
+#include "command/WireFormatInfo.h"
+#include "boost/shared_ptr.hpp"
+
+using namespace ActiveMQ::Marshalling;
+using namespace ActiveMQ::Command;
+using namespace ActiveMQ::IO;
+using std::auto_ptr;
+using boost::shared_ptr;
+
+/*
+ * Marshalling code for Open Wire Format for WireFormatInfo
+ *
+ * NOTE!: This file is autogenerated - do not modify!
+ * if you need to make a change, please see the Groovy scripts in the
+ * activemq-core module
+ */
+
+WireFormatInfoMarshaller::WireFormatInfoMarshaller()
+{
+ // no-op
+}
+
+WireFormatInfoMarshaller::~WireFormatInfoMarshaller()
+{
+ // no-op
+}
+
+auto_ptr<IDataStructure> WireFormatInfoMarshaller::createCommand()
+{
+ return auto_ptr<IDataStructure>(new WireFormatInfo());
+}
+
+char WireFormatInfoMarshaller::getDataStructureType()
+{
+ return WireFormatInfo::TYPE;
+}
+
+/*
+ * Un-marshal an object instance from the data input stream
+ */
+void
+WireFormatInfoMarshaller::unmarshal(ProtocolFormat& wireFormat, IDataStructure& o, BinaryReader& dataIn, BooleanStream& bs)
+{
+
+ WireFormatInfo& info = (WireFormatInfo&) o;
+ info.setMagic( unmarshalConstByteSequence(wireFormat, dataIn, bs, 8) );
+ info.setVersion( dataIn.readInt() );
+ info.setMarshalledProperties( unmarshalByteSequence(wireFormat, dataIn, bs) );
+
+}
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+size_t
+WireFormatInfoMarshaller::marshal1(ProtocolFormat& wireFormat, const IDataStructure& o, BooleanStream& bs) {
+ WireFormatInfo& info = (WireFormatInfo&) o;
+
+ int rc = 0;
+ bs.writeBoolean(!(info.getMarshalledProperties().empty()));
+ rc += info.getMarshalledProperties().empty() ? 0 : info.getMarshalledProperties().size()+4;
+
+ return rc + 12;
+}
+
+/*
+ * Write a object instance to data output stream
+ */
+void
+WireFormatInfoMarshaller::marshal2(ProtocolFormat& wireFormat, const IDataStructure& o, BinaryWriter& dataOut, BooleanStream& bs) {
+ // }
+
+
+ WireFormatInfo& info = (WireFormatInfo&) o;
+ dataOut.write(&((info.getMagic())[0]), 8);
+ dataOut.writeInt(info.getVersion());
+ if(bs.readBoolean()) {
+ dataOut.writeInt(info.getMarshalledProperties().size());
+ dataOut.write(&((info.getMarshalledProperties())[0]), info.getMarshalledProperties().size());
+ }
+}
Propchange: incubator/activemq/trunk/amazon/marshal/WireFormatInfoMarshaller.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/marshal/WireFormatInfoMarshaller.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/marshal/WireFormatInfoMarshaller.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/marshal/WireFormatInfoMarshaller.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/marshal/WireFormatInfoMarshaller.h (added)
+++ incubator/activemq/trunk/amazon/marshal/WireFormatInfoMarshaller.h Mon Jul 31 02:36:40 2006
@@ -0,0 +1,72 @@
+/*
+ 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 WireFormatInfoMarshaller_h_
+#define WireFormatInfoMarshaller_h_
+
+#include <string>
+#include <memory>
+
+#include "command/IDataStructure.h"
+
+/* auto-generated! */
+/* we could cut this down - for now include all possible headers */
+#include "command/BrokerId.h"
+#include "command/ConnectionId.h"
+#include "command/ConsumerId.h"
+#include "command/ProducerId.h"
+#include "command/SessionId.h"
+#include "command/BaseCommand.h"
+
+#include "marshal/BinaryReader.h"
+#include "marshal/BinaryWriter.h"
+
+#include "marshal/BaseDataStreamMarshaller.h"
+
+#include "marshal/ProtocolFormat.h"
+
+namespace ActiveMQ {
+ namespace Marshalling {
+
+ class WireFormatInfoMarshaller : public BaseDataStreamMarshaller
+ {
+ public:
+ WireFormatInfoMarshaller();
+ virtual ~WireFormatInfoMarshaller();
+
+ virtual auto_ptr<ActiveMQ::Command::IDataStructure> createCommand();
+ virtual char getDataStructureType();
+
+ virtual void unmarshal(ProtocolFormat& wireFormat,
+ ActiveMQ::Command::IDataStructure& o,
+ ActiveMQ::IO::BinaryReader& dataIn,
+ ActiveMQ::IO::BooleanStream& bs);
+
+ virtual size_t marshal1(ProtocolFormat& wireFormat,
+ const ActiveMQ::Command::IDataStructure& o,
+ ActiveMQ::IO::BooleanStream& bs);
+
+ virtual void marshal2(ProtocolFormat& wireFormat,
+ const ActiveMQ::Command::IDataStructure& o,
+ ActiveMQ::IO::BinaryWriter& dataOut,
+ ActiveMQ::IO::BooleanStream& bs);
+ };
+ }
+}
+#endif /*WireFormatInfoMarshaller_h_*/
Propchange: incubator/activemq/trunk/amazon/marshal/WireFormatInfoMarshaller.h
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/marshal/WireFormatInfoMarshaller.h
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/marshal/XATransactionIdMarshaller.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/marshal/XATransactionIdMarshaller.cpp?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/marshal/XATransactionIdMarshaller.cpp (added)
+++ incubator/activemq/trunk/amazon/marshal/XATransactionIdMarshaller.cpp Mon Jul 31 02:36:40 2006
@@ -0,0 +1,109 @@
+/*
+ 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 "netinet/in.h"
+#include "marshal/XATransactionIdMarshaller.h"
+#include "command/XATransactionId.h"
+#include "boost/shared_ptr.hpp"
+
+using namespace ActiveMQ::Marshalling;
+using namespace ActiveMQ::Command;
+using namespace ActiveMQ::IO;
+using std::auto_ptr;
+using boost::shared_ptr;
+
+/*
+ * Marshalling code for Open Wire Format for XATransactionId
+ *
+ * NOTE!: This file is autogenerated - do not modify!
+ * if you need to make a change, please see the Groovy scripts in the
+ * activemq-core module
+ */
+
+XATransactionIdMarshaller::XATransactionIdMarshaller()
+{
+ // no-op
+}
+
+XATransactionIdMarshaller::~XATransactionIdMarshaller()
+{
+ // no-op
+}
+
+auto_ptr<IDataStructure> XATransactionIdMarshaller::createCommand()
+{
+ return auto_ptr<IDataStructure>(new XATransactionId());
+}
+
+char XATransactionIdMarshaller::getDataStructureType()
+{
+ return XATransactionId::TYPE;
+}
+
+/*
+ * Un-marshal an object instance from the data input stream
+ */
+void
+XATransactionIdMarshaller::unmarshal(ProtocolFormat& wireFormat, IDataStructure& o, BinaryReader& dataIn, BooleanStream& bs)
+{
+ TransactionIdMarshaller::unmarshal(wireFormat, o, dataIn, bs);
+
+ XATransactionId& info = (XATransactionId&) o;
+ info.setFormatId( dataIn.readInt() );
+ info.setGlobalTransactionId( unmarshalByteSequence(wireFormat, dataIn, bs) );
+ info.setBranchQualifier( unmarshalByteSequence(wireFormat, dataIn, bs) );
+
+}
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+size_t
+XATransactionIdMarshaller::marshal1(ProtocolFormat& wireFormat, const IDataStructure& o, BooleanStream& bs) {
+ XATransactionId& info = (XATransactionId&) o;
+
+ int rc = TransactionIdMarshaller::marshal1(wireFormat, info, bs);
+ bs.writeBoolean(!(info.getGlobalTransactionId().empty()));
+ rc += info.getGlobalTransactionId().empty() ? 0 : info.getGlobalTransactionId().size()+4;
+ bs.writeBoolean(!(info.getBranchQualifier().empty()));
+ rc += info.getBranchQualifier().empty() ? 0 : info.getBranchQualifier().size()+4;
+
+ return rc + 4;
+}
+
+/*
+ * Write a object instance to data output stream
+ */
+void
+XATransactionIdMarshaller::marshal2(ProtocolFormat& wireFormat, const IDataStructure& o, BinaryWriter& dataOut, BooleanStream& bs) {
+ // }
+
+ TransactionIdMarshaller::marshal2(wireFormat, o, dataOut, bs);
+
+ XATransactionId& info = (XATransactionId&) o;
+ dataOut.writeInt(info.getFormatId());
+ if(bs.readBoolean()) {
+ dataOut.writeInt(info.getGlobalTransactionId().size());
+ dataOut.write(&((info.getGlobalTransactionId())[0]), info.getGlobalTransactionId().size());
+ }
+ if(bs.readBoolean()) {
+ dataOut.writeInt(info.getBranchQualifier().size());
+ dataOut.write(&((info.getBranchQualifier())[0]), info.getBranchQualifier().size());
+ }
+}
Propchange: incubator/activemq/trunk/amazon/marshal/XATransactionIdMarshaller.cpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/marshal/XATransactionIdMarshaller.cpp
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/marshal/XATransactionIdMarshaller.h
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/marshal/XATransactionIdMarshaller.h?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/marshal/XATransactionIdMarshaller.h (added)
+++ incubator/activemq/trunk/amazon/marshal/XATransactionIdMarshaller.h Mon Jul 31 02:36:40 2006
@@ -0,0 +1,72 @@
+/*
+ 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 XATransactionIdMarshaller_h_
+#define XATransactionIdMarshaller_h_
+
+#include <string>
+#include <memory>
+
+#include "command/IDataStructure.h"
+
+/* auto-generated! */
+/* we could cut this down - for now include all possible headers */
+#include "command/BrokerId.h"
+#include "command/ConnectionId.h"
+#include "command/ConsumerId.h"
+#include "command/ProducerId.h"
+#include "command/SessionId.h"
+#include "command/BaseCommand.h"
+
+#include "marshal/BinaryReader.h"
+#include "marshal/BinaryWriter.h"
+
+#include "marshal/TransactionIdMarshaller.h"
+
+#include "marshal/ProtocolFormat.h"
+
+namespace ActiveMQ {
+ namespace Marshalling {
+
+ class XATransactionIdMarshaller : public TransactionIdMarshaller
+ {
+ public:
+ XATransactionIdMarshaller();
+ virtual ~XATransactionIdMarshaller();
+
+ virtual auto_ptr<ActiveMQ::Command::IDataStructure> createCommand();
+ virtual char getDataStructureType();
+
+ virtual void unmarshal(ProtocolFormat& wireFormat,
+ ActiveMQ::Command::IDataStructure& o,
+ ActiveMQ::IO::BinaryReader& dataIn,
+ ActiveMQ::IO::BooleanStream& bs);
+
+ virtual size_t marshal1(ProtocolFormat& wireFormat,
+ const ActiveMQ::Command::IDataStructure& o,
+ ActiveMQ::IO::BooleanStream& bs);
+
+ virtual void marshal2(ProtocolFormat& wireFormat,
+ const ActiveMQ::Command::IDataStructure& o,
+ ActiveMQ::IO::BinaryWriter& dataOut,
+ ActiveMQ::IO::BooleanStream& bs);
+ };
+ }
+}
+#endif /*XATransactionIdMarshaller_h_*/
Propchange: incubator/activemq/trunk/amazon/marshal/XATransactionIdMarshaller.h
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/trunk/amazon/marshal/XATransactionIdMarshaller.h
------------------------------------------------------------------------------
svn:keywords = Date Author Id Revision HeadURL
Added: incubator/activemq/trunk/amazon/missing
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/amazon/missing?rev=427057&view=auto
==============================================================================
--- incubator/activemq/trunk/amazon/missing (added)
+++ incubator/activemq/trunk/amazon/missing Mon Jul 31 02:36:40 2006
@@ -0,0 +1,360 @@
+#! /bin/sh
+# Common stub for a few missing GNU programs while installing.
+
+scriptversion=2005-06-08.21
+
+# Copyright (C) 1996, 1997, 1999, 2000, 2002, 2003, 2004, 2005
+# Free Software Foundation, Inc.
+# Originally by Fran,cois Pinard <pi...@iro.umontreal.ca>, 1996.
+
+# This program is free software; you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation; either version 2, or (at your option)
+# any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+# GNU General Public License for more details.
+
+# You should have received a copy of the GNU General Public License
+# along with this program; if not, write to the Free Software
+# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
+# 02110-1301, USA.
+
+# As a special exception to the GNU General Public License, if you
+# distribute this file as part of a program that contains a
+# configuration script generated by Autoconf, you may include it under
+# the same distribution terms that you use for the rest of that program.
+
+if test $# -eq 0; then
+ echo 1>&2 "Try \`$0 --help' for more information"
+ exit 1
+fi
+
+run=:
+
+# In the cases where this matters, `missing' is being run in the
+# srcdir already.
+if test -f configure.ac; then
+ configure_ac=configure.ac
+else
+ configure_ac=configure.in
+fi
+
+msg="missing on your system"
+
+case "$1" in
+--run)
+ # Try to run requested program, and just exit if it succeeds.
+ run=
+ shift
+ "$@" && exit 0
+ # Exit code 63 means version mismatch. This often happens
+ # when the user try to use an ancient version of a tool on
+ # a file that requires a minimum version. In this case we
+ # we should proceed has if the program had been absent, or
+ # if --run hadn't been passed.
+ if test $? = 63; then
+ run=:
+ msg="probably too old"
+ fi
+ ;;
+
+ -h|--h|--he|--hel|--help)
+ echo "\
+$0 [OPTION]... PROGRAM [ARGUMENT]...
+
+Handle \`PROGRAM [ARGUMENT]...' for when PROGRAM is missing, or return an
+error status if there is no known handling for PROGRAM.
+
+Options:
+ -h, --help display this help and exit
+ -v, --version output version information and exit
+ --run try to run the given command, and emulate it if it fails
+
+Supported PROGRAM values:
+ aclocal touch file \`aclocal.m4'
+ autoconf touch file \`configure'
+ autoheader touch file \`config.h.in'
+ automake touch all \`Makefile.in' files
+ bison create \`y.tab.[ch]', if possible, from existing .[ch]
+ flex create \`lex.yy.c', if possible, from existing .c
+ help2man touch the output file
+ lex create \`lex.yy.c', if possible, from existing .c
+ makeinfo touch the output file
+ tar try tar, gnutar, gtar, then tar without non-portable flags
+ yacc create \`y.tab.[ch]', if possible, from existing .[ch]
+
+Send bug reports to <bu...@gnu.org>."
+ exit $?
+ ;;
+
+ -v|--v|--ve|--ver|--vers|--versi|--versio|--version)
+ echo "missing $scriptversion (GNU Automake)"
+ exit $?
+ ;;
+
+ -*)
+ echo 1>&2 "$0: Unknown \`$1' option"
+ echo 1>&2 "Try \`$0 --help' for more information"
+ exit 1
+ ;;
+
+esac
+
+# Now exit if we have it, but it failed. Also exit now if we
+# don't have it and --version was passed (most likely to detect
+# the program).
+case "$1" in
+ lex|yacc)
+ # Not GNU programs, they don't have --version.
+ ;;
+
+ tar)
+ if test -n "$run"; then
+ echo 1>&2 "ERROR: \`tar' requires --run"
+ exit 1
+ elif test "x$2" = "x--version" || test "x$2" = "x--help"; then
+ exit 1
+ fi
+ ;;
+
+ *)
+ if test -z "$run" && ($1 --version) > /dev/null 2>&1; then
+ # We have it, but it failed.
+ exit 1
+ elif test "x$2" = "x--version" || test "x$2" = "x--help"; then
+ # Could not run --version or --help. This is probably someone
+ # running `$TOOL --version' or `$TOOL --help' to check whether
+ # $TOOL exists and not knowing $TOOL uses missing.
+ exit 1
+ fi
+ ;;
+esac
+
+# If it does not exist, or fails to run (possibly an outdated version),
+# try to emulate it.
+case "$1" in
+ aclocal*)
+ echo 1>&2 "\
+WARNING: \`$1' is $msg. You should only need it if
+ you modified \`acinclude.m4' or \`${configure_ac}'. You might want
+ to install the \`Automake' and \`Perl' packages. Grab them from
+ any GNU archive site."
+ touch aclocal.m4
+ ;;
+
+ autoconf)
+ echo 1>&2 "\
+WARNING: \`$1' is $msg. You should only need it if
+ you modified \`${configure_ac}'. You might want to install the
+ \`Autoconf' and \`GNU m4' packages. Grab them from any GNU
+ archive site."
+ touch configure
+ ;;
+
+ autoheader)
+ echo 1>&2 "\
+WARNING: \`$1' is $msg. You should only need it if
+ you modified \`acconfig.h' or \`${configure_ac}'. You might want
+ to install the \`Autoconf' and \`GNU m4' packages. Grab them
+ from any GNU archive site."
+ files=`sed -n 's/^[ ]*A[CM]_CONFIG_HEADER(\([^)]*\)).*/\1/p' ${configure_ac}`
+ test -z "$files" && files="config.h"
+ touch_files=
+ for f in $files; do
+ case "$f" in
+ *:*) touch_files="$touch_files "`echo "$f" |
+ sed -e 's/^[^:]*://' -e 's/:.*//'`;;
+ *) touch_files="$touch_files $f.in";;
+ esac
+ done
+ touch $touch_files
+ ;;
+
+ automake*)
+ echo 1>&2 "\
+WARNING: \`$1' is $msg. You should only need it if
+ you modified \`Makefile.am', \`acinclude.m4' or \`${configure_ac}'.
+ You might want to install the \`Automake' and \`Perl' packages.
+ Grab them from any GNU archive site."
+ find . -type f -name Makefile.am -print |
+ sed 's/\.am$/.in/' |
+ while read f; do touch "$f"; done
+ ;;
+
+ autom4te)
+ echo 1>&2 "\
+WARNING: \`$1' is needed, but is $msg.
+ You might have modified some files without having the
+ proper tools for further handling them.
+ You can get \`$1' as part of \`Autoconf' from any GNU
+ archive site."
+
+ file=`echo "$*" | sed -n 's/.*--output[ =]*\([^ ]*\).*/\1/p'`
+ test -z "$file" && file=`echo "$*" | sed -n 's/.*-o[ ]*\([^ ]*\).*/\1/p'`
+ if test -f "$file"; then
+ touch $file
+ else
+ test -z "$file" || exec >$file
+ echo "#! /bin/sh"
+ echo "# Created by GNU Automake missing as a replacement of"
+ echo "# $ $@"
+ echo "exit 0"
+ chmod +x $file
+ exit 1
+ fi
+ ;;
+
+ bison|yacc)
+ echo 1>&2 "\
+WARNING: \`$1' $msg. You should only need it if
+ you modified a \`.y' file. You may need the \`Bison' package
+ in order for those modifications to take effect. You can get
+ \`Bison' from any GNU archive site."
+ rm -f y.tab.c y.tab.h
+ if [ $# -ne 1 ]; then
+ eval LASTARG="\${$#}"
+ case "$LASTARG" in
+ *.y)
+ SRCFILE=`echo "$LASTARG" | sed 's/y$/c/'`
+ if [ -f "$SRCFILE" ]; then
+ cp "$SRCFILE" y.tab.c
+ fi
+ SRCFILE=`echo "$LASTARG" | sed 's/y$/h/'`
+ if [ -f "$SRCFILE" ]; then
+ cp "$SRCFILE" y.tab.h
+ fi
+ ;;
+ esac
+ fi
+ if [ ! -f y.tab.h ]; then
+ echo >y.tab.h
+ fi
+ if [ ! -f y.tab.c ]; then
+ echo 'main() { return 0; }' >y.tab.c
+ fi
+ ;;
+
+ lex|flex)
+ echo 1>&2 "\
+WARNING: \`$1' is $msg. You should only need it if
+ you modified a \`.l' file. You may need the \`Flex' package
+ in order for those modifications to take effect. You can get
+ \`Flex' from any GNU archive site."
+ rm -f lex.yy.c
+ if [ $# -ne 1 ]; then
+ eval LASTARG="\${$#}"
+ case "$LASTARG" in
+ *.l)
+ SRCFILE=`echo "$LASTARG" | sed 's/l$/c/'`
+ if [ -f "$SRCFILE" ]; then
+ cp "$SRCFILE" lex.yy.c
+ fi
+ ;;
+ esac
+ fi
+ if [ ! -f lex.yy.c ]; then
+ echo 'main() { return 0; }' >lex.yy.c
+ fi
+ ;;
+
+ help2man)
+ echo 1>&2 "\
+WARNING: \`$1' is $msg. You should only need it if
+ you modified a dependency of a manual page. You may need the
+ \`Help2man' package in order for those modifications to take
+ effect. You can get \`Help2man' from any GNU archive site."
+
+ file=`echo "$*" | sed -n 's/.*-o \([^ ]*\).*/\1/p'`
+ if test -z "$file"; then
+ file=`echo "$*" | sed -n 's/.*--output=\([^ ]*\).*/\1/p'`
+ fi
+ if [ -f "$file" ]; then
+ touch $file
+ else
+ test -z "$file" || exec >$file
+ echo ".ab help2man is required to generate this page"
+ exit 1
+ fi
+ ;;
+
+ makeinfo)
+ echo 1>&2 "\
+WARNING: \`$1' is $msg. You should only need it if
+ you modified a \`.texi' or \`.texinfo' file, or any other file
+ indirectly affecting the aspect of the manual. The spurious
+ call might also be the consequence of using a buggy \`make' (AIX,
+ DU, IRIX). You might want to install the \`Texinfo' package or
+ the \`GNU make' package. Grab either from any GNU archive site."
+ # The file to touch is that specified with -o ...
+ file=`echo "$*" | sed -n 's/.*-o \([^ ]*\).*/\1/p'`
+ if test -z "$file"; then
+ # ... or it is the one specified with @setfilename ...
+ infile=`echo "$*" | sed 's/.* \([^ ]*\) *$/\1/'`
+ file=`sed -n '/^@setfilename/ { s/.* \([^ ]*\) *$/\1/; p; q; }' $infile`
+ # ... or it is derived from the source name (dir/f.texi becomes f.info)
+ test -z "$file" && file=`echo "$infile" | sed 's,.*/,,;s,.[^.]*$,,'`.info
+ fi
+ # If the file does not exist, the user really needs makeinfo;
+ # let's fail without touching anything.
+ test -f $file || exit 1
+ touch $file
+ ;;
+
+ tar)
+ shift
+
+ # We have already tried tar in the generic part.
+ # Look for gnutar/gtar before invocation to avoid ugly error
+ # messages.
+ if (gnutar --version > /dev/null 2>&1); then
+ gnutar "$@" && exit 0
+ fi
+ if (gtar --version > /dev/null 2>&1); then
+ gtar "$@" && exit 0
+ fi
+ firstarg="$1"
+ if shift; then
+ case "$firstarg" in
+ *o*)
+ firstarg=`echo "$firstarg" | sed s/o//`
+ tar "$firstarg" "$@" && exit 0
+ ;;
+ esac
+ case "$firstarg" in
+ *h*)
+ firstarg=`echo "$firstarg" | sed s/h//`
+ tar "$firstarg" "$@" && exit 0
+ ;;
+ esac
+ fi
+
+ echo 1>&2 "\
+WARNING: I can't seem to be able to run \`tar' with the given arguments.
+ You may want to install GNU tar or Free paxutils, or check the
+ command line arguments."
+ exit 1
+ ;;
+
+ *)
+ echo 1>&2 "\
+WARNING: \`$1' is needed, and is $msg.
+ You might have modified some files without having the
+ proper tools for further handling them. Check the \`README' file,
+ it often tells you about the needed prerequisites for installing
+ this package. You may also peek at any GNU archive site, in case
+ some other package would contain this missing \`$1' program."
+ exit 1
+ ;;
+esac
+
+exit 0
+
+# Local variables:
+# eval: (add-hook 'write-file-hooks 'time-stamp)
+# time-stamp-start: "scriptversion="
+# time-stamp-format: "%:y-%02m-%02d.%02H"
+# time-stamp-end: "$"
+# End:
Propchange: incubator/activemq/trunk/amazon/missing
------------------------------------------------------------------------------
svn:executable = *