activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject 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/
Date Mon, 31 Jul 2006 09:36:51 GMT
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 <pinard@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 <bug-automake@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 = *



Mime
View raw message