activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r430504 [12/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
Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/MessagePullMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

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

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/MessagePullMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/MessagePullMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/MessagePullMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/MessagePullMarshaller.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 MessagePullMarshaller_hpp_
#define MessagePullMarshaller_hpp_

#include <string>

#include "command/IDataStructure.hpp"

/* we could cut this down  - for now include all possible headers */
#inc
 lude "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 MessagePullMarshaller : public BaseCommandMarshaller
{
public:
    MessagePullMarshaller() ;
    virtual ~MessagePullMarshaller() ;

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

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

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

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

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

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.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 NetworkBridgeFilterMarshaller_hpp_
#define NetworkBridgeFilterMarshaller_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 NetworkBridgeFilterMarshaller : public BaseDataStreamMarshaller
{
public:
    NetworkBridgeFilterMarshaller() ;
    virtual ~NetworkBridgeFilterMarshaller() ;

    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 /*NetworkBridgeFilterMarshaller_hpp_*/
\ No newline at end of file

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/PartialCommandMarshaller.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/PartialCommandMarshaller.cpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/PartialCommandMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/PartialCommandMarshaller.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/PartialCommandMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for PartialCommand
+ *
+ * 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
+ */
+
+PartialCommandMarshaller::PartialCommandMarshaller()
+{
+    // no-op
+}
+
+PartialCommandMarshaller::~PartialCommandMarshaller()
+{
+    // no-op
+}
+
+
+
+IDataStructure* PartialCommandMarshaller::createObject() 
+{
+    return new PartialCommand();
+}
+
+char PartialCommandMarshaller::getDataStructureType() 
+{
+    return PartialCommand.ID_PartialCommand;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void PartialCommandMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    PartialCommand& info = (PartialCommand&) o;
+        info.setCommandId(dataIn.readInt());
+        info.setData(tightUnmarshalByteArray(dataIn, bs));
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int PartialCommandMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) {
+    PartialCommand& info = (PartialCommand&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+        bs.writeBoolean(info.getData()!=null);
+    rc += info.getData()==null ? 0 : info.getData().Length+4;
+
+    return rc + 1;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void PartialCommandMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    PartialCommand& info = (PartialCommand&) o;
+    DataStreamMarshaller.writeInt(info.getCommandId(), dataOut);
+    if(bs.readBoolean()) {
+       DataStreamMarshaller.writeInt(info.getData().Length, dataOut);
+       dataOut.write(info.getData());
+    }
+
+}

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

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

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/PartialCommandMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/PartialCommandMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/PartialCommandMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/PartialCommandMarshaller.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 PartialCommandMarshaller_hpp_
#define PartialCommandMarshaller_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 PartialCommandMarshaller : public BaseDataStreamMarshaller
{
public:
    PartialCommandMarshaller() ;
    virtual ~PartialCommandMarshaller() ;

    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 /*PartialCommandMarshaller_hpp_*/
\ No newline at end of file

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

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

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

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.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 ProducerIdMarshaller_hpp_
#define ProducerIdMarshaller_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/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 ProducerIdMarshaller : public BaseDataStreamMarshaller
{
public:
    ProducerIdMarshaller() ;
    virtual ~ProducerIdMarshaller() ;

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

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

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

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

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

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerInfoMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerInfoMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerInfoMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ProducerInfoMarshaller.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 ProducerInfoMarshaller_hpp_
#define ProducerInfoMarshaller_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/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 ProducerInfoMarshaller : public BaseCommandMarshaller
{
public:
    ProducerInfoMarshaller() ;
    virtual ~ProducerInfoMarshaller() ;

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

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

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

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

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

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveInfoMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveInfoMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveInfoMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveInfoMarshaller.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 RemoveInfoMarshaller_hpp_
#define RemoveInfoMarshaller_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 RemoveInfoMarshaller : public BaseCommandMarshaller
{
public:
    RemoveInfoMarshaller() ;
    virtual ~RemoveInfoMarshaller() ;

    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 /*RemoveInfoMarshaller_hpp_*/
\ No newline at end of file

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

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

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

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveSubscriptionInfoMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveSubscriptionInfoMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveSubscriptionInfoMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/RemoveSubscriptionInfoMarshaller.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 RemoveSubscriptionInfoMarshaller_hpp_
#define RemoveSubscriptionInfoMarshaller_hpp_

#include <string>

#include "command/IDataStructure.hpp"

/* we could cut this down  - for now include all po
 ssible 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 RemoveSubscriptionInfoMarshaller : public BaseCommandMarshaller
{
public:
    RemoveSubscriptionInfoMarshaller() ;
    virtual ~RemoveSubscriptionInfoMarshaller() ;

    virtual IDataStructure* createCommand() ;
    virtual char getDataStructureType() ;
    
    virtual void unmarshal(ProtocolFormat& w
 ireFormat, 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 /*RemoveSubscriptionInfoMarshaller_hpp_*/
\ No newline at end of file

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

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

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

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ReplayCommandMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/ReplayCommandMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ReplayCommandMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ReplayCommandMarshaller.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 ReplayCommandMarshaller_hpp_
#define ReplayCommandMarshaller_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 ReplayCommandMarshaller : public BaseCommandMarshaller
{
public:
    ReplayCommandMarshaller() ;
    virtual ~ReplayCommandMarshaller() ;

    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 /*ReplayCommandMarshaller_hpp_*/
\ No newline at end of file

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

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

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

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ResponseMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/ResponseMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ResponseMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ResponseMarshaller.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 ResponseMarshaller_hpp_
#define ResponseMarshaller_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 ResponseMarshaller : public BaseCommandMarshaller
{
public:
    ResponseMarshaller() ;
    virtual ~ResponseMarshaller() ;

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

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

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

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

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

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/SessionIdMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/SessionIdMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/SessionIdMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/SessionIdMarshaller.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 SessionIdMarshaller_hpp_
#define SessionIdMarshaller_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 SessionIdMarshaller : public BaseDataStreamMarshaller
{
public:
    SessionIdMarshaller() ;
    virtual ~SessionIdMarshaller() ;

    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 /*SessionIdMarshaller_hpp_*/
\ No newline at end of file

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

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

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

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/SessionInfoMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/SessionInfoMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/SessionInfoMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/SessionInfoMarshaller.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 SessionInfoMarshaller_hpp_
#define SessionInfoMarshaller_hpp_

#include <string>

#include "command/IDataStructure.hpp"

/* we could cut this down  - for now include all possible headers */
#inc
 lude "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 SessionInfoMarshaller : public BaseCommandMarshaller
{
public:
    SessionInfoMarshaller() ;
    virtual ~SessionInfoMarshaller() ;

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

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

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.cpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.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/ShutdownInfoMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for ShutdownInfo
+ *
+ * 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
+ */
+
+ShutdownInfoMarshaller::ShutdownInfoMarshaller()
+{
+    // no-op
+}
+
+ShutdownInfoMarshaller::~ShutdownInfoMarshaller()
+{
+    // no-op
+}
+
+
+
+IDataStructure* ShutdownInfoMarshaller::createObject() 
+{
+    return new ShutdownInfo();
+}
+
+char ShutdownInfoMarshaller::getDataStructureType() 
+{
+    return ShutdownInfo.ID_ShutdownInfo;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void ShutdownInfoMarshaller::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 ShutdownInfoMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) {
+    ShutdownInfo& info = (ShutdownInfo&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void ShutdownInfoMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+}

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

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

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.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 ShutdownInfoMarshaller_hpp_
#define ShutdownInfoMarshaller_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/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 ShutdownInfoMarshaller : public BaseCommandMarshaller
{
public:
    ShutdownInfoMarshaller() ;
    virtual ~ShutdownInfoMarshaller() ;

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

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

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.cpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.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/SubscriptionInfoMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for SubscriptionInfo
+ *
+ * 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
+ */
+
+SubscriptionInfoMarshaller::SubscriptionInfoMarshaller()
+{
+    // no-op
+}
+
+SubscriptionInfoMarshaller::~SubscriptionInfoMarshaller()
+{
+    // no-op
+}
+
+
+
+IDataStructure* SubscriptionInfoMarshaller::createObject() 
+{
+    return new SubscriptionInfo();
+}
+
+char SubscriptionInfoMarshaller::getDataStructureType() 
+{
+    return SubscriptionInfo.ID_SubscriptionInfo;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void SubscriptionInfoMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    SubscriptionInfo& info = (SubscriptionInfo&) o;
+        info.setClientId(tightUnmarshalString(dataIn, bs));
+        info.setDestination((org.apache.activemq.command.ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+        info.setSelector(tightUnmarshalString(dataIn, bs));
+        info.setSubcriptionName(tightUnmarshalString(dataIn, bs));
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int SubscriptionInfoMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) {
+    SubscriptionInfo& info = (SubscriptionInfo&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+    rc += writeString(info.getClientId(), bs);
+    rc += marshal1CachedObject(wireFormat, info.getDestination(), bs);
+    rc += writeString(info.getSelector(), bs);
+    rc += writeString(info.getSubcriptionName(), bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void SubscriptionInfoMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    SubscriptionInfo& info = (SubscriptionInfo&) o;
+    writeString(info.getClientId(), dataOut, bs);
+    marshal2CachedObject(wireFormat, info.getDestination(), dataOut, bs);
+    writeString(info.getSelector(), dataOut, bs);
+    writeString(info.getSubcriptionName(), dataOut, bs);
+
+}

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

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

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.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 SubscriptionInfoMarshaller_hpp_
#define SubscriptionInfoMarshaller_hpp_

#include <string>

#include "command/IDataStructure.hpp"

/* we could cut this down  - for now include all possible heade
 rs */
#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 SubscriptionInfoMarshaller : public BaseDataStreamMarshaller
{
public:
    SubscriptionInfoMarshaller() ;
    virtual ~SubscriptionInfoMarshaller() ;

    virtual IDataStructure* createCommand() ;
    virtual char getDataStructureType() ;
    
    virtual void unmarshal(ProtocolFormat& wireFormat, Object o, Bin
 aryReader& 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 /*SubscriptionInfoMarshaller_hpp_*/
\ No newline at end of file

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.cpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.cpp Thu Aug 10 12:51:56 2006
@@ -0,0 +1,67 @@
+/*
+ * 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/TransactionIdMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  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, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int TransactionIdMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) {
+    TransactionId& info = (TransactionId&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void TransactionIdMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+}

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

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

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.hpp?rev=430504&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.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 TransactionIdMarshaller_hpp_
#define TransactionIdMarshaller_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 TransactionIdMarshaller : public BaseDataStreamMarshaller
{
public:
    TransactionIdMarshaller() ;
    virtual ~TransactionIdMarshaller() ;

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

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



Mime
View raw message