activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r430504 [11/13] - in /incubator/activemq/trunk: activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V2/ openwire-c/src/libopenwire/ openwire-cpp/src/main/cpp/activemq/command/ openwire-cpp/sr...
Date Thu, 10 Aug 2006 19:52:05 GMT
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.hpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1 @@
+/*
* 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 JournalTopicAckMarshaller_hpp_
#define JournalTopicAckMarshaller_hpp_

#include <string>

#include "command/IDataStructure.hpp"

/* we could cut this down  - for now include all possible headers
  */
#include "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"

#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"

#include "command/BaseDataStreamMarshaller.hpp"
#include "util/ifr/p.hpp"

#include "protocol/ProtocolFormat.hpp"

namespace apache
{
  namespace activemq
  {
    namespace client
    {
      namespace marshal
      {
        using namespace ifr ;
        using namespace apache::activemq::client::command;
        using namespace apache::activemq::client::io;
        using namespace apache::activemq::client::protocol;

/*
 *
 */
class JournalTopicAckMarshaller : public BaseDataStreamMarshaller
{
public:
    JournalTopicAckMarshaller() ;
    virtual ~JournalTopicAckMarshaller() ;

    virtual IDataStructure* createCommand() ;
    virtual char getDataStructureType() ;
    
    virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryRe
 ader& dataIn, BooleanStream& bs) ;
    virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
    virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;

/* namespace */
     }
    }
  }
}
#endif /*JournalTopicAckMarshaller_hpp_*/
\ No newline at end of file

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.cpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.cpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1,85 @@
+/*
+ * 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 "marshal/JournalTraceMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for JournalTrace
+ *
+ * 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
+ */
+
+JournalTraceMarshaller::JournalTraceMarshaller()
+{
+    // no-op
+}
+
+JournalTraceMarshaller::~JournalTraceMarshaller()
+{
+    // no-op
+}
+
+
+
+IDataStructure* JournalTraceMarshaller::createObject() 
+{
+    return new JournalTrace();
+}
+
+char JournalTraceMarshaller::getDataStructureType() 
+{
+    return JournalTrace.ID_JournalTrace;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void JournalTraceMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    JournalTrace& info = (JournalTrace&) o;
+        info.setMessage(tightUnmarshalString(dataIn, bs));
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int JournalTraceMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) {
+    JournalTrace& info = (JournalTrace&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+    rc += writeString(info.getMessage(), bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void JournalTraceMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    JournalTrace& info = (JournalTrace&) o;
+    writeString(info.getMessage(), dataOut, bs);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.hpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1 @@
+/*
* 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 JournalTraceMarshaller_hpp_
#define JournalTraceMarshaller_hpp_

#include <string>

#include "command/IDataStructure.hpp"

/* we could cut this down  - for now include all possible headers */
#i
 nclude "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"

#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"

#include "command/BaseDataStreamMarshaller.hpp"
#include "util/ifr/p.hpp"

#include "protocol/ProtocolFormat.hpp"

namespace apache
{
  namespace activemq
  {
    namespace client
    {
      namespace marshal
      {
        using namespace ifr ;
        using namespace apache::activemq::client::command;
        using namespace apache::activemq::client::io;
        using namespace apache::activemq::client::protocol;

/*
 *
 */
class JournalTraceMarshaller : public BaseDataStreamMarshaller
{
public:
    JournalTraceMarshaller() ;
    virtual ~JournalTraceMarshaller() ;

    virtual IDataStructure* createCommand() ;
    virtual char getDataStructureType() ;
    
    virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, B
 ooleanStream& bs) ;
    virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
    virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;

/* namespace */
     }
    }
  }
}
#endif /*JournalTraceMarshaller_hpp_*/
\ No newline at end of file

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.cpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.cpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1,90 @@
+/*
+ * 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 "marshal/JournalTransactionMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for JournalTransaction
+ *
+ * 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
+ */
+
+JournalTransactionMarshaller::JournalTransactionMarshaller()
+{
+    // no-op
+}
+
+JournalTransactionMarshaller::~JournalTransactionMarshaller()
+{
+    // no-op
+}
+
+
+
+IDataStructure* JournalTransactionMarshaller::createObject() 
+{
+    return new JournalTransaction();
+}
+
+char JournalTransactionMarshaller::getDataStructureType() 
+{
+    return JournalTransaction.ID_JournalTransaction;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void JournalTransactionMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    JournalTransaction& info = (JournalTransaction&) o;
+        info.setTransactionId((org.apache.activemq.command.TransactionId) tightUnmarsalNestedObject(wireFormat, dataIn, bs));
+        info.setType(dataIn.readByte());
+        info.setWasPrepared(bs.readBoolean());
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int JournalTransactionMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) {
+    JournalTransaction& info = (JournalTransaction&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+    rc += marshal1NestedObject(wireFormat, info.getTransactionId(), bs);
+        bs.writeBoolean(info.getWasPrepared());
+
+    return rc + 1;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void JournalTransactionMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    JournalTransaction& info = (JournalTransaction&) o;
+    marshal2NestedObject(wireFormat, info.getTransactionId(), dataOut, bs);
+    DataStreamMarshaller.writeByte(info.getType(), dataOut);
+    bs.readBoolean();
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.hpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1 @@
+/*
* 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 JournalTransactionMarshaller_hpp_
#define JournalTransactionMarshaller_hpp_

#include <string>

#include "command/IDataStructure.hpp"

/* we could cut this down  - for now include all possible h
 eaders */
#include "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"

#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"

#include "command/BaseDataStreamMarshaller.hpp"
#include "util/ifr/p.hpp"

#include "protocol/ProtocolFormat.hpp"

namespace apache
{
  namespace activemq
  {
    namespace client
    {
      namespace marshal
      {
        using namespace ifr ;
        using namespace apache::activemq::client::command;
        using namespace apache::activemq::client::io;
        using namespace apache::activemq::client::protocol;

/*
 *
 */
class JournalTransactionMarshaller : public BaseDataStreamMarshaller
{
public:
    JournalTransactionMarshaller() ;
    virtual ~JournalTransactionMarshaller() ;

    virtual IDataStructure* createCommand() ;
    virtual char getDataStructureType() ;
    
    virtual void unmarshal(ProtocolFormat& wireFormat, Obj
 ect o, BinaryReader& dataIn, BooleanStream& bs) ;
    virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
    virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;

/* namespace */
     }
    }
  }
}
#endif /*JournalTransactionMarshaller_hpp_*/
\ No newline at end of file

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.cpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.cpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1,78 @@
+/*
+ * 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 "marshal/KeepAliveInfoMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for KeepAliveInfo
+ *
+ * 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
+ */
+
+KeepAliveInfoMarshaller::KeepAliveInfoMarshaller()
+{
+    // no-op
+}
+
+KeepAliveInfoMarshaller::~KeepAliveInfoMarshaller()
+{
+    // no-op
+}
+
+
+
+IDataStructure* KeepAliveInfoMarshaller::createObject() 
+{
+    return new KeepAliveInfo();
+}
+
+char KeepAliveInfoMarshaller::getDataStructureType() 
+{
+    return KeepAliveInfo.ID_KeepAliveInfo;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void KeepAliveInfoMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int KeepAliveInfoMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) {
+    KeepAliveInfo& info = (KeepAliveInfo&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void KeepAliveInfoMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.hpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1 @@
+/*
* 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 KeepAliveInfoMarshaller_hpp_
#define KeepAliveInfoMarshaller_hpp_

#include <string>

#include "command/IDataStructure.hpp"

/* we could cut this down  - for now include all possible headers */
 #include "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"

#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"

#include "command/BaseCommandMarshaller.hpp"
#include "util/ifr/p.hpp"

#include "protocol/ProtocolFormat.hpp"

namespace apache
{
  namespace activemq
  {
    namespace client
    {
      namespace marshal
      {
        using namespace ifr ;
        using namespace apache::activemq::client::command;
        using namespace apache::activemq::client::io;
        using namespace apache::activemq::client::protocol;

/*
 *
 */
class KeepAliveInfoMarshaller : public BaseCommandMarshaller
{
public:
    KeepAliveInfoMarshaller() ;
    virtual ~KeepAliveInfoMarshaller() ;

    virtual IDataStructure* createCommand() ;
    virtual char getDataStructureType() ;
    
    virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, Bo
 oleanStream& bs) ;
    virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
    virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;

/* namespace */
     }
    }
  }
}
#endif /*KeepAliveInfoMarshaller_hpp_*/
\ No newline at end of file

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.cpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.cpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1,78 @@
+/*
+ * 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 "marshal/LastPartialCommandMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for LastPartialCommand
+ *
+ * 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
+ */
+
+LastPartialCommandMarshaller::LastPartialCommandMarshaller()
+{
+    // no-op
+}
+
+LastPartialCommandMarshaller::~LastPartialCommandMarshaller()
+{
+    // no-op
+}
+
+
+
+IDataStructure* LastPartialCommandMarshaller::createObject() 
+{
+    return new LastPartialCommand();
+}
+
+char LastPartialCommandMarshaller::getDataStructureType() 
+{
+    return LastPartialCommand.ID_LastPartialCommand;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void LastPartialCommandMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int LastPartialCommandMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) {
+    LastPartialCommand& info = (LastPartialCommand&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void LastPartialCommandMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.hpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1 @@
+/*
* 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 LastPartialCommandMarshaller_hpp_
#define LastPartialCommandMarshaller_hpp_

#include <string>

#include "command/IDataStructure.hpp"

/* we could cut this down  - for now include all possible h
 eaders */
#include "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"

#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"

#include "command/PartialCommandMarshaller.hpp"
#include "util/ifr/p.hpp"

#include "protocol/ProtocolFormat.hpp"

namespace apache
{
  namespace activemq
  {
    namespace client
    {
      namespace marshal
      {
        using namespace ifr ;
        using namespace apache::activemq::client::command;
        using namespace apache::activemq::client::io;
        using namespace apache::activemq::client::protocol;

/*
 *
 */
class LastPartialCommandMarshaller : public PartialCommandMarshaller
{
public:
    LastPartialCommandMarshaller() ;
    virtual ~LastPartialCommandMarshaller() ;

    virtual IDataStructure* createCommand() ;
    virtual char getDataStructureType() ;
    
    virtual void unmarshal(ProtocolFormat& wireFormat, Obj
 ect o, BinaryReader& dataIn, BooleanStream& bs) ;
    virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
    virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;

/* namespace */
     }
    }
  }
}
#endif /*LastPartialCommandMarshaller_hpp_*/
\ No newline at end of file

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.cpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.cpp Thu Aug 10 12:51:56 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.
+ */
+#include "marshal/LocalTransactionIdMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for LocalTransactionId
+ *
+ * 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
+ */
+
+LocalTransactionIdMarshaller::LocalTransactionIdMarshaller()
+{
+    // no-op
+}
+
+LocalTransactionIdMarshaller::~LocalTransactionIdMarshaller()
+{
+    // no-op
+}
+
+
+
+IDataStructure* LocalTransactionIdMarshaller::createObject() 
+{
+    return new LocalTransactionId();
+}
+
+char LocalTransactionIdMarshaller::getDataStructureType() 
+{
+    return LocalTransactionId.ID_LocalTransactionId;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void LocalTransactionIdMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    LocalTransactionId& info = (LocalTransactionId&) o;
+        info.setValue(tightUnmarshalLong(wireFormat, dataIn, bs));
+        info.setConnectionId((org.apache.activemq.command.ConnectionId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int LocalTransactionIdMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) {
+    LocalTransactionId& info = (LocalTransactionId&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+    rc += marshal1Long(wireFormat, info.getValue(), bs);
+    rc += marshal1CachedObject(wireFormat, info.getConnectionId(), bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void LocalTransactionIdMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    LocalTransactionId& info = (LocalTransactionId&) o;
+    marshal2Long(wireFormat, info.getValue(), dataOut, bs);
+    marshal2CachedObject(wireFormat, info.getConnectionId(), dataOut, bs);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.hpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1 @@
+/*
* 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 LocalTransactionIdMarshaller_hpp_
#define LocalTransactionIdMarshaller_hpp_

#include <string>

#include "command/IDataStructure.hpp"

/* we could cut this down  - for now include all possible h
 eaders */
#include "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"

#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"

#include "command/TransactionIdMarshaller.hpp"
#include "util/ifr/p.hpp"

#include "protocol/ProtocolFormat.hpp"

namespace apache
{
  namespace activemq
  {
    namespace client
    {
      namespace marshal
      {
        using namespace ifr ;
        using namespace apache::activemq::client::command;
        using namespace apache::activemq::client::io;
        using namespace apache::activemq::client::protocol;

/*
 *
 */
class LocalTransactionIdMarshaller : public TransactionIdMarshaller
{
public:
    LocalTransactionIdMarshaller() ;
    virtual ~LocalTransactionIdMarshaller() ;

    virtual IDataStructure* createCommand() ;
    virtual char getDataStructureType() ;
    
    virtual void unmarshal(ProtocolFormat& wireFormat, Objec
 t o, BinaryReader& dataIn, BooleanStream& bs) ;
    virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
    virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;

/* namespace */
     }
    }
  }
}
#endif /*LocalTransactionIdMarshaller_hpp_*/
\ No newline at end of file

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.cpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.cpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1,144 @@
+/*
+* 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.
+*/
+
+// Marshalling code for Open Wire Format
+//
+//
+// NOTE!: This file is autogenerated - do not modify!
+//        if you need to make a change, please see the Groovy scripts in the
+//        activemq-openwire module
+//
+
+#include "marshal/ExceptionResponseMarshaller.hpp"
+
+#include "marshal/LocalTransactionIdMarshaller.hpp"
+#include "marshal/PartialCommandMarshaller.hpp"
+#include "marshal/IntegerResponseMarshaller.hpp"
+#include "marshal/ActiveMQQueueMarshaller.hpp"
+#include "marshal/ActiveMQObjectMessageMarshaller.hpp"
+#include "marshal/ConnectionIdMarshaller.hpp"
+#include "marshal/ConnectionInfoMarshaller.hpp"
+#include "marshal/ProducerInfoMarshaller.hpp"
+#include "marshal/MessageDispatchNotificationMarshaller.hpp"
+#include "marshal/SessionInfoMarshaller.hpp"
+#include "marshal/TransactionInfoMarshaller.hpp"
+#include "marshal/ActiveMQStreamMessageMarshaller.hpp"
+#include "marshal/MessageAckMarshaller.hpp"
+#include "marshal/ProducerIdMarshaller.hpp"
+#include "marshal/MessageIdMarshaller.hpp"
+#include "marshal/ActiveMQTempQueueMarshaller.hpp"
+#include "marshal/RemoveSubscriptionInfoMarshaller.hpp"
+#include "marshal/SessionIdMarshaller.hpp"
+#include "marshal/DataArrayResponseMarshaller.hpp"
+#include "marshal/JournalQueueAckMarshaller.hpp"
+#include "marshal/ResponseMarshaller.hpp"
+#include "marshal/ConnectionErrorMarshaller.hpp"
+#include "marshal/ConsumerInfoMarshaller.hpp"
+#include "marshal/XATransactionIdMarshaller.hpp"
+#include "marshal/JournalTraceMarshaller.hpp"
+#include "marshal/ConsumerIdMarshaller.hpp"
+#include "marshal/ActiveMQTextMessageMarshaller.hpp"
+#include "marshal/SubscriptionInfoMarshaller.hpp"
+#include "marshal/JournalTransactionMarshaller.hpp"
+#include "marshal/ControlCommandMarshaller.hpp"
+#include "marshal/LastPartialCommandMarshaller.hpp"
+#include "marshal/NetworkBridgeFilterMarshaller.hpp"
+#include "marshal/MessagePullMarshaller.hpp"
+#include "marshal/ActiveMQBytesMessageMarshaller.hpp"
+#include "marshal/WireFormatInfoMarshaller.hpp"
+#include "marshal/ActiveMQTempTopicMarshaller.hpp"
+#include "marshal/DiscoveryEventMarshaller.hpp"
+#include "marshal/ReplayCommandMarshaller.hpp"
+#include "marshal/ActiveMQTopicMarshaller.hpp"
+#include "marshal/BrokerInfoMarshaller.hpp"
+#include "marshal/DestinationInfoMarshaller.hpp"
+#include "marshal/ShutdownInfoMarshaller.hpp"
+#include "marshal/DataResponseMarshaller.hpp"
+#include "marshal/ConnectionControlMarshaller.hpp"
+#include "marshal/KeepAliveInfoMarshaller.hpp"
+#include "marshal/FlushCommandMarshaller.hpp"
+#include "marshal/ConsumerControlMarshaller.hpp"
+#include "marshal/JournalTopicAckMarshaller.hpp"
+#include "marshal/BrokerIdMarshaller.hpp"
+#include "marshal/MessageDispatchMarshaller.hpp"
+#include "marshal/ActiveMQMapMessageMarshaller.hpp"
+#include "marshal/ActiveMQMessageMarshaller.hpp"
+#include "marshal/RemoveInfoMarshaller.hpp"
+#include "marshal/ExceptionResponseMarshaller.hpp"
+
+
+using namespace apache::activemq::client::marshal;
+
+
+void MarshallerFactory::configure(ProtocolFormat& format) 
+{
+
+    format.addMarshaller(new LocalTransactionIdMarshaller());
+    format.addMarshaller(new PartialCommandMarshaller());
+    format.addMarshaller(new IntegerResponseMarshaller());
+    format.addMarshaller(new ActiveMQQueueMarshaller());
+    format.addMarshaller(new ActiveMQObjectMessageMarshaller());
+    format.addMarshaller(new ConnectionIdMarshaller());
+    format.addMarshaller(new ConnectionInfoMarshaller());
+    format.addMarshaller(new ProducerInfoMarshaller());
+    format.addMarshaller(new MessageDispatchNotificationMarshaller());
+    format.addMarshaller(new SessionInfoMarshaller());
+    format.addMarshaller(new TransactionInfoMarshaller());
+    format.addMarshaller(new ActiveMQStreamMessageMarshaller());
+    format.addMarshaller(new MessageAckMarshaller());
+    format.addMarshaller(new ProducerIdMarshaller());
+    format.addMarshaller(new MessageIdMarshaller());
+    format.addMarshaller(new ActiveMQTempQueueMarshaller());
+    format.addMarshaller(new RemoveSubscriptionInfoMarshaller());
+    format.addMarshaller(new SessionIdMarshaller());
+    format.addMarshaller(new DataArrayResponseMarshaller());
+    format.addMarshaller(new JournalQueueAckMarshaller());
+    format.addMarshaller(new ResponseMarshaller());
+    format.addMarshaller(new ConnectionErrorMarshaller());
+    format.addMarshaller(new ConsumerInfoMarshaller());
+    format.addMarshaller(new XATransactionIdMarshaller());
+    format.addMarshaller(new JournalTraceMarshaller());
+    format.addMarshaller(new ConsumerIdMarshaller());
+    format.addMarshaller(new ActiveMQTextMessageMarshaller());
+    format.addMarshaller(new SubscriptionInfoMarshaller());
+    format.addMarshaller(new JournalTransactionMarshaller());
+    format.addMarshaller(new ControlCommandMarshaller());
+    format.addMarshaller(new LastPartialCommandMarshaller());
+    format.addMarshaller(new NetworkBridgeFilterMarshaller());
+    format.addMarshaller(new MessagePullMarshaller());
+    format.addMarshaller(new ActiveMQBytesMessageMarshaller());
+    format.addMarshaller(new WireFormatInfoMarshaller());
+    format.addMarshaller(new ActiveMQTempTopicMarshaller());
+    format.addMarshaller(new DiscoveryEventMarshaller());
+    format.addMarshaller(new ReplayCommandMarshaller());
+    format.addMarshaller(new ActiveMQTopicMarshaller());
+    format.addMarshaller(new BrokerInfoMarshaller());
+    format.addMarshaller(new DestinationInfoMarshaller());
+    format.addMarshaller(new ShutdownInfoMarshaller());
+    format.addMarshaller(new DataResponseMarshaller());
+    format.addMarshaller(new ConnectionControlMarshaller());
+    format.addMarshaller(new KeepAliveInfoMarshaller());
+    format.addMarshaller(new FlushCommandMarshaller());
+    format.addMarshaller(new ConsumerControlMarshaller());
+    format.addMarshaller(new JournalTopicAckMarshaller());
+    format.addMarshaller(new BrokerIdMarshaller());
+    format.addMarshaller(new MessageDispatchMarshaller());
+    format.addMarshaller(new ActiveMQMapMessageMarshaller());
+    format.addMarshaller(new ActiveMQMessageMarshaller());
+    format.addMarshaller(new RemoveInfoMarshaller());
+    format.addMarshaller(new ExceptionResponseMarshaller());
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MarshallerFactory.hpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1,62 @@
+//*
+* 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.
+*/
+
+// Marshalling code for Open Wire Format 
+//
+//
+// NOTE!: This file is autogenerated - do not modify!
+//        if you need to make a change, please see the Groovy scripts in the
+//        activemq-openwire module
+//
+
+#ifndef MarshallerFactory_hpp_
+#define MarshallerFactory_hpp_
+
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace marshal
+      {
+        using namespace ifr ;
+        using namespace std ;
+        using namespace apache::activemq::client;
+        using namespace apache::activemq::client::command;
+        using namespace apache::activemq::client::io;
+
+/*
+ * 
+ */
+class MarshallerFactory
+{
+public:
+    MarshallerFactory() ;
+    virtual ~MarshallerFactory() ;
+
+	  virtual void configure(ProtocolFormat& format) ;
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*MarshallerFactory_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.cpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.cpp Thu Aug 10 12:51:56 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 "marshal/MessageAckMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for MessageAck
+ *
+ * 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
+ */
+
+MessageAckMarshaller::MessageAckMarshaller()
+{
+    // no-op
+}
+
+MessageAckMarshaller::~MessageAckMarshaller()
+{
+    // no-op
+}
+
+
+
+IDataStructure* MessageAckMarshaller::createObject() 
+{
+    return new MessageAck();
+}
+
+char MessageAckMarshaller::getDataStructureType() 
+{
+    return MessageAck.ID_MessageAck;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void MessageAckMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    MessageAck& info = (MessageAck&) o;
+        info.setDestination((org.apache.activemq.command.ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+        info.setTransactionId((org.apache.activemq.command.TransactionId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+        info.setConsumerId((org.apache.activemq.command.ConsumerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+        info.setAckType(dataIn.readByte());
+        info.setFirstMessageId((org.apache.activemq.command.MessageId) tightUnmarsalNestedObject(wireFormat, dataIn, bs));
+        info.setLastMessageId((org.apache.activemq.command.MessageId) tightUnmarsalNestedObject(wireFormat, dataIn, bs));
+        info.setMessageCount(dataIn.readInt());
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int MessageAckMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) {
+    MessageAck& info = (MessageAck&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+    rc += marshal1CachedObject(wireFormat, info.getDestination(), bs);
+    rc += marshal1CachedObject(wireFormat, info.getTransactionId(), bs);
+    rc += marshal1CachedObject(wireFormat, info.getConsumerId(), bs);
+        rc += marshal1NestedObject(wireFormat, info.getFirstMessageId(), bs);
+    rc += marshal1NestedObject(wireFormat, info.getLastMessageId(), bs);
+    
+    return rc + 2;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void MessageAckMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    MessageAck& info = (MessageAck&) o;
+    marshal2CachedObject(wireFormat, info.getDestination(), dataOut, bs);
+    marshal2CachedObject(wireFormat, info.getTransactionId(), dataOut, bs);
+    marshal2CachedObject(wireFormat, info.getConsumerId(), dataOut, bs);
+    DataStreamMarshaller.writeByte(info.getAckType(), dataOut);
+    marshal2NestedObject(wireFormat, info.getFirstMessageId(), dataOut, bs);
+    marshal2NestedObject(wireFormat, info.getLastMessageId(), dataOut, bs);
+    DataStreamMarshaller.writeInt(info.getMessageCount(), dataOut);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.hpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1 @@
+/*
* 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 MessageAckMarshaller_hpp_
#define MessageAckMarshaller_hpp_

#include <string>

#include "command/IDataStructure.hpp"

/* we could cut this down  - for now include all possible headers */
#inclu
 de "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"

#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"

#include "command/BaseCommandMarshaller.hpp"
#include "util/ifr/p.hpp"

#include "protocol/ProtocolFormat.hpp"

namespace apache
{
  namespace activemq
  {
    namespace client
    {
      namespace marshal
      {
        using namespace ifr ;
        using namespace apache::activemq::client::command;
        using namespace apache::activemq::client::io;
        using namespace apache::activemq::client::protocol;

/*
 *
 */
class MessageAckMarshaller : public BaseCommandMarshaller
{
public:
    MessageAckMarshaller() ;
    virtual ~MessageAckMarshaller() ;

    virtual IDataStructure* createCommand() ;
    virtual char getDataStructureType() ;
    
    virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs
 ) ;
    virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
    virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;

/* namespace */
     }
    }
  }
}
#endif /*MessageAckMarshaller_hpp_*/
\ No newline at end of file

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.cpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.cpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1,93 @@
+/*
+ * 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 "marshal/MessageDispatchMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for MessageDispatch
+ *
+ * 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
+ */
+
+MessageDispatchMarshaller::MessageDispatchMarshaller()
+{
+    // no-op
+}
+
+MessageDispatchMarshaller::~MessageDispatchMarshaller()
+{
+    // no-op
+}
+
+
+
+IDataStructure* MessageDispatchMarshaller::createObject() 
+{
+    return new MessageDispatch();
+}
+
+char MessageDispatchMarshaller::getDataStructureType() 
+{
+    return MessageDispatch.ID_MessageDispatch;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void MessageDispatchMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    MessageDispatch& info = (MessageDispatch&) o;
+        info.setConsumerId((org.apache.activemq.command.ConsumerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+        info.setDestination((org.apache.activemq.command.ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+        info.setMessage((org.apache.activemq.command.Message) tightUnmarsalNestedObject(wireFormat, dataIn, bs));
+        info.setRedeliveryCounter(dataIn.readInt());
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int MessageDispatchMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) {
+    MessageDispatch& info = (MessageDispatch&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+    rc += marshal1CachedObject(wireFormat, info.getConsumerId(), bs);
+    rc += marshal1CachedObject(wireFormat, info.getDestination(), bs);
+    rc += marshal1NestedObject(wireFormat, info.getMessage(), bs);
+    
+    return rc + 1;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void MessageDispatchMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    MessageDispatch& info = (MessageDispatch&) o;
+    marshal2CachedObject(wireFormat, info.getConsumerId(), dataOut, bs);
+    marshal2CachedObject(wireFormat, info.getDestination(), dataOut, bs);
+    marshal2NestedObject(wireFormat, info.getMessage(), dataOut, bs);
+    DataStreamMarshaller.writeInt(info.getRedeliveryCounter(), dataOut);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.hpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1 @@
+/*
* 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 MessageDispatchMarshaller_hpp_
#define MessageDispatchMarshaller_hpp_

#include <string>

#include "command/IDataStructure.hpp"

/* we could cut this down  - for now include all possible headers
  */
#include "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"

#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"

#include "command/BaseCommandMarshaller.hpp"
#include "util/ifr/p.hpp"

#include "protocol/ProtocolFormat.hpp"

namespace apache
{
  namespace activemq
  {
    namespace client
    {
      namespace marshal
      {
        using namespace ifr ;
        using namespace apache::activemq::client::command;
        using namespace apache::activemq::client::io;
        using namespace apache::activemq::client::protocol;

/*
 *
 */
class MessageDispatchMarshaller : public BaseCommandMarshaller
{
public:
    MessageDispatchMarshaller() ;
    virtual ~MessageDispatchMarshaller() ;

    virtual IDataStructure* createCommand() ;
    virtual char getDataStructureType() ;
    
    virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& 
 dataIn, BooleanStream& bs) ;
    virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
    virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;

/* namespace */
     }
    }
  }
}
#endif /*MessageDispatchMarshaller_hpp_*/
\ No newline at end of file

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.cpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.cpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1,94 @@
+/*
+ * 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 "marshal/MessageDispatchNotificationMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for MessageDispatchNotification
+ *
+ * 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
+ */
+
+MessageDispatchNotificationMarshaller::MessageDispatchNotificationMarshaller()
+{
+    // no-op
+}
+
+MessageDispatchNotificationMarshaller::~MessageDispatchNotificationMarshaller()
+{
+    // no-op
+}
+
+
+
+IDataStructure* MessageDispatchNotificationMarshaller::createObject() 
+{
+    return new MessageDispatchNotification();
+}
+
+char MessageDispatchNotificationMarshaller::getDataStructureType() 
+{
+    return MessageDispatchNotification.ID_MessageDispatchNotification;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void MessageDispatchNotificationMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    MessageDispatchNotification& info = (MessageDispatchNotification&) o;
+        info.setConsumerId((org.apache.activemq.command.ConsumerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+        info.setDestination((org.apache.activemq.command.ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+        info.setDeliverySequenceId(tightUnmarshalLong(wireFormat, dataIn, bs));
+        info.setMessageId((org.apache.activemq.command.MessageId) tightUnmarsalNestedObject(wireFormat, dataIn, bs));
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int MessageDispatchNotificationMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) {
+    MessageDispatchNotification& info = (MessageDispatchNotification&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+    rc += marshal1CachedObject(wireFormat, info.getConsumerId(), bs);
+    rc += marshal1CachedObject(wireFormat, info.getDestination(), bs);
+    rc += marshal1Long(wireFormat, info.getDeliverySequenceId(), bs);
+    rc += marshal1NestedObject(wireFormat, info.getMessageId(), bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void MessageDispatchNotificationMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    MessageDispatchNotification& info = (MessageDispatchNotification&) o;
+    marshal2CachedObject(wireFormat, info.getConsumerId(), dataOut, bs);
+    marshal2CachedObject(wireFormat, info.getDestination(), dataOut, bs);
+    marshal2Long(wireFormat, info.getDeliverySequenceId(), dataOut, bs);
+    marshal2NestedObject(wireFormat, info.getMessageId(), dataOut, bs);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.hpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1 @@
+/*
* 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 MessageDispatchNotificationMarshaller_hpp_
#define MessageDispatchNotificationMarshaller_hpp_

#include <string>

#include "command/IDataStructure.hpp"

/* we could cut this down  - for now incl
 ude all possible headers */
#include "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"

#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"

#include "command/BaseCommandMarshaller.hpp"
#include "util/ifr/p.hpp"

#include "protocol/ProtocolFormat.hpp"

namespace apache
{
  namespace activemq
  {
    namespace client
    {
      namespace marshal
      {
        using namespace ifr ;
        using namespace apache::activemq::client::command;
        using namespace apache::activemq::client::io;
        using namespace apache::activemq::client::protocol;

/*
 *
 */
class MessageDispatchNotificationMarshaller : public BaseCommandMarshaller
{
public:
    MessageDispatchNotificationMarshaller() ;
    virtual ~MessageDispatchNotificationMarshaller() ;

    virtual IDataStructure* createCommand() ;
    virtual char getDataStructureType() ;
    
    virtual void un
 marshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
    virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
    virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;

/* namespace */
     }
    }
  }
}
#endif /*MessageDispatchNotificationMarshaller_hpp_*/
\ No newline at end of file

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.cpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.cpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1,91 @@
+/*
+ * 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 "marshal/MessageIdMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for MessageId
+ *
+ * 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
+ */
+
+MessageIdMarshaller::MessageIdMarshaller()
+{
+    // no-op
+}
+
+MessageIdMarshaller::~MessageIdMarshaller()
+{
+    // no-op
+}
+
+
+
+IDataStructure* MessageIdMarshaller::createObject() 
+{
+    return new MessageId();
+}
+
+char MessageIdMarshaller::getDataStructureType() 
+{
+    return MessageId.ID_MessageId;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void MessageIdMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    MessageId& info = (MessageId&) o;
+        info.setProducerId((org.apache.activemq.command.ProducerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+        info.setProducerSequenceId(tightUnmarshalLong(wireFormat, dataIn, bs));
+        info.setBrokerSequenceId(tightUnmarshalLong(wireFormat, dataIn, bs));
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int MessageIdMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) {
+    MessageId& info = (MessageId&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+    rc += marshal1CachedObject(wireFormat, info.getProducerId(), bs);
+    rc += marshal1Long(wireFormat, info.getProducerSequenceId(), bs);
+    rc += marshal1Long(wireFormat, info.getBrokerSequenceId(), bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void MessageIdMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    MessageId& info = (MessageId&) o;
+    marshal2CachedObject(wireFormat, info.getProducerId(), dataOut, bs);
+    marshal2Long(wireFormat, info.getProducerSequenceId(), dataOut, bs);
+    marshal2Long(wireFormat, info.getBrokerSequenceId(), dataOut, bs);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.hpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1 @@
+/*
* 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 MessageIdMarshaller_hpp_
#define MessageIdMarshaller_hpp_

#include <string>

#include "command/IDataStructure.hpp"

/* we could cut this down  - for now include all possible headers */
#include
  "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"

#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"

#include "command/BaseDataStreamMarshaller.hpp"
#include "util/ifr/p.hpp"

#include "protocol/ProtocolFormat.hpp"

namespace apache
{
  namespace activemq
  {
    namespace client
    {
      namespace marshal
      {
        using namespace ifr ;
        using namespace apache::activemq::client::command;
        using namespace apache::activemq::client::io;
        using namespace apache::activemq::client::protocol;

/*
 *
 */
class MessageIdMarshaller : public BaseDataStreamMarshaller
{
public:
    MessageIdMarshaller() ;
    virtual ~MessageIdMarshaller() ;

    virtual IDataStructure* createCommand() ;
    virtual char getDataStructureType() ;
    
    virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& b
 s) ;
    virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
    virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;

/* namespace */
     }
    }
  }
}
#endif /*MessageIdMarshaller_hpp_*/
\ No newline at end of file

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.cpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.cpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1,162 @@
+/*
+ * 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 "marshal/MessageMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for Message
+ *
+ * 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
+ */
+
+MessageMarshaller::MessageMarshaller()
+{
+    // no-op
+}
+
+MessageMarshaller::~MessageMarshaller()
+{
+    // no-op
+}
+
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void MessageMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    Message& info = (Message&) o;
+        info.setProducerId((org.apache.activemq.command.ProducerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+        info.setDestination((org.apache.activemq.command.ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+        info.setTransactionId((org.apache.activemq.command.TransactionId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+        info.setOriginalDestination((org.apache.activemq.command.ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+        info.setMessageId((org.apache.activemq.command.MessageId) tightUnmarsalNestedObject(wireFormat, dataIn, bs));
+        info.setOriginalTransactionId((org.apache.activemq.command.TransactionId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+        info.setGroupID(tightUnmarshalString(dataIn, bs));
+        info.setGroupSequence(dataIn.readInt());
+        info.setCorrelationId(tightUnmarshalString(dataIn, bs));
+        info.setPersistent(bs.readBoolean());
+        info.setExpiration(tightUnmarshalLong(wireFormat, dataIn, bs));
+        info.setPriority(dataIn.readByte());
+        info.setReplyTo((org.apache.activemq.command.ActiveMQDestination) tightUnmarsalNestedObject(wireFormat, dataIn, bs));
+        info.setTimestamp(tightUnmarshalLong(wireFormat, dataIn, bs));
+        info.setType(tightUnmarshalString(dataIn, bs));
+        info.setContent(tightUnmarshalByteSequence(dataIn, bs));
+        info.setMarshalledProperties(tightUnmarshalByteSequence(dataIn, bs));
+        info.setDataStructure((org.apache.activemq.command.DataStructure) tightUnmarsalNestedObject(wireFormat, dataIn, bs));
+        info.setTargetConsumerId((org.apache.activemq.command.ConsumerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+        info.setCompressed(bs.readBoolean());
+        info.setRedeliveryCounter(dataIn.readInt());
+
+        if (bs.readBoolean()) {
+            short size = dataIn.readShort();
+            org.apache.activemq.command.BrokerId value[] = new org.apache.activemq.command.BrokerId[size];
+            for( int i=0; i < size; i++ ) {
+                value[i] = (org.apache.activemq.command.BrokerId) tightUnmarsalNestedObject(wireFormat,dataIn, bs);
+            }
+            info.setBrokerPath(value);
+        }
+        else {
+            info.setBrokerPath(null);
+        }
+        info.setArrival(tightUnmarshalLong(wireFormat, dataIn, bs));
+        info.setUserID(tightUnmarshalString(dataIn, bs));
+        info.setRecievedByDFBridge(bs.readBoolean());
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int MessageMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) {
+    Message& info = (Message&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+    rc += marshal1CachedObject(wireFormat, info.getProducerId(), bs);
+    rc += marshal1CachedObject(wireFormat, info.getDestination(), bs);
+    rc += marshal1CachedObject(wireFormat, info.getTransactionId(), bs);
+    rc += marshal1CachedObject(wireFormat, info.getOriginalDestination(), bs);
+    rc += marshal1NestedObject(wireFormat, info.getMessageId(), bs);
+    rc += marshal1CachedObject(wireFormat, info.getOriginalTransactionId(), bs);
+    rc += writeString(info.getGroupID(), bs);
+        rc += writeString(info.getCorrelationId(), bs);
+    bs.writeBoolean(info.isPersistent());
+    rc += marshal1Long(wireFormat, info.getExpiration(), bs);
+        rc += marshal1NestedObject(wireFormat, info.getReplyTo(), bs);
+    rc += marshal1Long(wireFormat, info.getTimestamp(), bs);
+    rc += writeString(info.getType(), bs);
+    bs.writeBoolean(info.getContent()!=null);
+    rc += info.getContent()==null ? 0 : info.getContent().Length+4;
+    bs.writeBoolean(info.getMarshalledProperties()!=null);
+    rc += info.getMarshalledProperties()==null ? 0 : info.getMarshalledProperties().Length+4;
+    rc += marshal1NestedObject(wireFormat, info.getDataStructure(), bs);
+    rc += marshal1CachedObject(wireFormat, info.getTargetConsumerId(), bs);
+    bs.writeBoolean(info.isCompressed());
+        rc += marshalObjectArray(wireFormat, info.getBrokerPath(), bs);
+    rc += marshal1Long(wireFormat, info.getArrival(), bs);
+    rc += writeString(info.getUserID(), bs);
+    bs.writeBoolean(info.isRecievedByDFBridge());
+
+    return rc + 3;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void MessageMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    Message& info = (Message&) o;
+    marshal2CachedObject(wireFormat, info.getProducerId(), dataOut, bs);
+    marshal2CachedObject(wireFormat, info.getDestination(), dataOut, bs);
+    marshal2CachedObject(wireFormat, info.getTransactionId(), dataOut, bs);
+    marshal2CachedObject(wireFormat, info.getOriginalDestination(), dataOut, bs);
+    marshal2NestedObject(wireFormat, info.getMessageId(), dataOut, bs);
+    marshal2CachedObject(wireFormat, info.getOriginalTransactionId(), dataOut, bs);
+    writeString(info.getGroupID(), dataOut, bs);
+    DataStreamMarshaller.writeInt(info.getGroupSequence(), dataOut);
+    writeString(info.getCorrelationId(), dataOut, bs);
+    bs.readBoolean();
+    marshal2Long(wireFormat, info.getExpiration(), dataOut, bs);
+    DataStreamMarshaller.writeByte(info.getPriority(), dataOut);
+    marshal2NestedObject(wireFormat, info.getReplyTo(), dataOut, bs);
+    marshal2Long(wireFormat, info.getTimestamp(), dataOut, bs);
+    writeString(info.getType(), dataOut, bs);
+    if(bs.readBoolean()) {
+       DataStreamMarshaller.writeInt(info.getContent().Length, dataOut);
+       dataOut.write(info.getContent());
+    }
+    if(bs.readBoolean()) {
+       DataStreamMarshaller.writeInt(info.getMarshalledProperties().Length, dataOut);
+       dataOut.write(info.getMarshalledProperties());
+    }
+    marshal2NestedObject(wireFormat, info.getDataStructure(), dataOut, bs);
+    marshal2CachedObject(wireFormat, info.getTargetConsumerId(), dataOut, bs);
+    bs.readBoolean();
+    DataStreamMarshaller.writeInt(info.getRedeliveryCounter(), dataOut);
+    marshalObjectArray(wireFormat, info.getBrokerPath(), dataOut, bs);
+    marshal2Long(wireFormat, info.getArrival(), dataOut, bs);
+    writeString(info.getUserID(), dataOut, bs);
+    bs.readBoolean();
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessageMarshaller.hpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1 @@
+/*
* 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 MessageMarshaller_hpp_
#define MessageMarshaller_hpp_

#include <string>

#include "command/IDataStructure.hpp"

/* we could cut this down  - for now include all possible headers */
#include "co
 mmand/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"

#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"

#include "command/BaseCommandMarshaller.hpp"
#include "util/ifr/p.hpp"

#include "protocol/ProtocolFormat.hpp"

namespace apache
{
  namespace activemq
  {
    namespace client
    {
      namespace marshal
      {
        using namespace ifr ;
        using namespace apache::activemq::client::command;
        using namespace apache::activemq::client::io;
        using namespace apache::activemq::client::protocol;

/*
 *
 */
class MessageMarshaller : public BaseCommandMarshaller
{
public:
    MessageMarshaller() ;
    virtual ~MessageMarshaller() ;

    virtual IDataStructure* createCommand() ;
    virtual char getDataStructureType() ;
    
    virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
    virtual
  int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
    virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;

/* namespace */
     }
    }
  }
}
#endif /*MessageMarshaller_hpp_*/
\ No newline at end of file

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessagePullMarshaller.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessagePullMarshaller.cpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MessagePullMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessagePullMarshaller.cpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1,91 @@
+/*
+ * 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 "marshal/MessagePullMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for MessagePull
+ *
+ * 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
+ */
+
+MessagePullMarshaller::MessagePullMarshaller()
+{
+    // no-op
+}
+
+MessagePullMarshaller::~MessagePullMarshaller()
+{
+    // no-op
+}
+
+
+
+IDataStructure* MessagePullMarshaller::createObject() 
+{
+    return new MessagePull();
+}
+
+char MessagePullMarshaller::getDataStructureType() 
+{
+    return MessagePull.ID_MessagePull;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void MessagePullMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    MessagePull& info = (MessagePull&) o;
+        info.setConsumerId((org.apache.activemq.command.ConsumerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+        info.setDestination((org.apache.activemq.command.ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+        info.setTimeout(tightUnmarshalLong(wireFormat, dataIn, bs));
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int MessagePullMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) {
+    MessagePull& info = (MessagePull&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+    rc += marshal1CachedObject(wireFormat, info.getConsumerId(), bs);
+    rc += marshal1CachedObject(wireFormat, info.getDestination(), bs);
+    rc += marshal1Long(wireFormat, info.getTimeout(), bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void MessagePullMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    MessagePull& info = (MessagePull&) o;
+    marshal2CachedObject(wireFormat, info.getConsumerId(), dataOut, bs);
+    marshal2CachedObject(wireFormat, info.getDestination(), dataOut, bs);
+    marshal2Long(wireFormat, info.getTimeout(), dataOut, bs);
+
+}



Mime
View raw message