You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2013/03/24 22:30:56 UTC
svn commit: r1460467 [9/15] - in
/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq: commands/
wireformat/openwire/marshal/generated/
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionErrorMarshaller.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionErrorMarshaller.cpp?rev=1460467&r1=1460466&r2=1460467&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionErrorMarshaller.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionErrorMarshaller.cpp Sun Mar 24 21:30:52 2013
@@ -51,91 +51,91 @@ unsigned char ConnectionErrorMarshaller:
}
///////////////////////////////////////////////////////////////////////////////
-void ConnectionErrorMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) {
+void ConnectionErrorMarshaller::tightUnmarshal(OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs) {
try {
- BaseCommandMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs );
+ BaseCommandMarshaller::tightUnmarshal(wireFormat, dataStructure, dataIn, bs);
ConnectionError* info =
- dynamic_cast<ConnectionError*>( dataStructure );
- info->setException( Pointer<BrokerError>( dynamic_cast< BrokerError* >(
- tightUnmarshalBrokerError( wireFormat, dataIn, bs ) ) ) );
- info->setConnectionId( Pointer<ConnectionId>( dynamic_cast< ConnectionId* >(
- tightUnmarshalNestedObject( wireFormat, dataIn, bs ) ) ) );
+ dynamic_cast<ConnectionError*>(dataStructure);
+ info->setException(Pointer<BrokerError>(dynamic_cast<BrokerError* >(
+ tightUnmarshalBrokerError(wireFormat, dataIn, bs))));
+ info->setConnectionId(Pointer<ConnectionId>(dynamic_cast<ConnectionId* >(
+ tightUnmarshalNestedObject(wireFormat, dataIn, bs))));
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT(exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
///////////////////////////////////////////////////////////////////////////////
-int ConnectionErrorMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) {
+int ConnectionErrorMarshaller::tightMarshal1(OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs) {
try {
ConnectionError* info =
- dynamic_cast<ConnectionError*>( dataStructure );
+ dynamic_cast<ConnectionError*>(dataStructure);
- int rc = BaseCommandMarshaller::tightMarshal1( wireFormat, dataStructure, bs );
- rc += tightMarshalBrokerError1( wireFormat, info->getException().get(), bs );
- rc += tightMarshalNestedObject1( wireFormat, info->getConnectionId().get(), bs );
+ int rc = BaseCommandMarshaller::tightMarshal1(wireFormat, dataStructure, bs);
+ rc += tightMarshalBrokerError1(wireFormat, info->getException().get(), bs);
+ rc += tightMarshalNestedObject1(wireFormat, info->getConnectionId().get(), bs);
return rc + 0;
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT(exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
///////////////////////////////////////////////////////////////////////////////
-void ConnectionErrorMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) {
+void ConnectionErrorMarshaller::tightMarshal2(OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs) {
try {
- BaseCommandMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs );
+ BaseCommandMarshaller::tightMarshal2(wireFormat, dataStructure, dataOut, bs );
ConnectionError* info =
- dynamic_cast<ConnectionError*>( dataStructure );
- tightMarshalBrokerError2( wireFormat, info->getException().get(), dataOut, bs );
- tightMarshalNestedObject2( wireFormat, info->getConnectionId().get(), dataOut, bs );
+ dynamic_cast<ConnectionError*>(dataStructure);
+ tightMarshalBrokerError2(wireFormat, info->getException().get(), dataOut, bs);
+ tightMarshalNestedObject2(wireFormat, info->getConnectionId().get(), dataOut, bs);
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
///////////////////////////////////////////////////////////////////////////////
-void ConnectionErrorMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) {
+void ConnectionErrorMarshaller::looseUnmarshal(OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn) {
try {
- BaseCommandMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn );
+ BaseCommandMarshaller::looseUnmarshal(wireFormat, dataStructure, dataIn);
ConnectionError* info =
- dynamic_cast<ConnectionError*>( dataStructure );
- info->setException( Pointer<BrokerError>( dynamic_cast< BrokerError* >(
- looseUnmarshalBrokerError( wireFormat, dataIn ) ) ) );
- info->setConnectionId( Pointer<ConnectionId>( dynamic_cast< ConnectionId* >(
- looseUnmarshalNestedObject( wireFormat, dataIn ) ) ) );
+ dynamic_cast<ConnectionError*>(dataStructure);
+ info->setException(Pointer<BrokerError>(dynamic_cast< BrokerError*>(
+ looseUnmarshalBrokerError(wireFormat, dataIn))));
+ info->setConnectionId(Pointer<ConnectionId>(dynamic_cast<ConnectionId*>(
+ looseUnmarshalNestedObject(wireFormat, dataIn))));
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT(exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
///////////////////////////////////////////////////////////////////////////////
-void ConnectionErrorMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) {
+void ConnectionErrorMarshaller::looseMarshal(OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut) {
try {
ConnectionError* info =
- dynamic_cast<ConnectionError*>( dataStructure );
- BaseCommandMarshaller::looseMarshal( wireFormat, dataStructure, dataOut );
- looseMarshalBrokerError( wireFormat, info->getException().get(), dataOut );
- looseMarshalNestedObject( wireFormat, info->getConnectionId().get(), dataOut );
+ dynamic_cast<ConnectionError*>(dataStructure);
+ BaseCommandMarshaller::looseMarshal(wireFormat, dataStructure, dataOut);
+ looseMarshalBrokerError(wireFormat, info->getException().get(), dataOut);
+ looseMarshalNestedObject(wireFormat, info->getConnectionId().get(), dataOut);
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT(exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionErrorMarshaller.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionErrorMarshaller.h?rev=1460467&r1=1460466&r2=1460467&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionErrorMarshaller.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionErrorMarshaller.h Sun Mar 24 21:30:52 2013
@@ -33,11 +33,11 @@
#include <activemq/wireformat/openwire/OpenWireFormat.h>
#include <activemq/wireformat/openwire/utils/BooleanStream.h>
-namespace activemq{
-namespace wireformat{
-namespace openwire{
-namespace marshal{
-namespace generated{
+namespace activemq {
+namespace wireformat {
+namespace openwire {
+namespace marshal {
+namespace generated {
/**
* Marshaling code for Open Wire Format for ConnectionErrorMarshaller
@@ -56,27 +56,27 @@ namespace generated{
virtual unsigned char getDataStructureType() const;
- virtual void tightUnmarshal( OpenWireFormat* wireFormat,
- commands::DataStructure* dataStructure,
- decaf::io::DataInputStream* dataIn,
- utils::BooleanStream* bs );
+ virtual void tightUnmarshal(OpenWireFormat* wireFormat,
+ commands::DataStructure* dataStructure,
+ decaf::io::DataInputStream* dataIn,
+ utils::BooleanStream* bs);
+
+ virtual int tightMarshal1(OpenWireFormat* wireFormat,
+ commands::DataStructure* dataStructure,
+ utils::BooleanStream* bs);
- virtual int tightMarshal1( OpenWireFormat* wireFormat,
+ virtual void tightMarshal2(OpenWireFormat* wireFormat,
commands::DataStructure* dataStructure,
- utils::BooleanStream* bs );
+ decaf::io::DataOutputStream* dataOut,
+ utils::BooleanStream* bs);
- virtual void tightMarshal2( OpenWireFormat* wireFormat,
+ virtual void looseUnmarshal(OpenWireFormat* wireFormat,
commands::DataStructure* dataStructure,
- decaf::io::DataOutputStream* dataOut,
- utils::BooleanStream* bs );
+ decaf::io::DataInputStream* dataIn);
- virtual void looseUnmarshal( OpenWireFormat* wireFormat,
- commands::DataStructure* dataStructure,
- decaf::io::DataInputStream* dataIn );
-
- virtual void looseMarshal( OpenWireFormat* wireFormat,
- commands::DataStructure* dataStructure,
- decaf::io::DataOutputStream* dataOut );
+ virtual void looseMarshal(OpenWireFormat* wireFormat,
+ commands::DataStructure* dataStructure,
+ decaf::io::DataOutputStream* dataOut);
};
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionIdMarshaller.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionIdMarshaller.cpp?rev=1460467&r1=1460466&r2=1460467&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionIdMarshaller.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionIdMarshaller.cpp Sun Mar 24 21:30:52 2013
@@ -51,82 +51,82 @@ unsigned char ConnectionIdMarshaller::ge
}
///////////////////////////////////////////////////////////////////////////////
-void ConnectionIdMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) {
+void ConnectionIdMarshaller::tightUnmarshal(OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs) {
try {
- BaseDataStreamMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs );
+ BaseDataStreamMarshaller::tightUnmarshal(wireFormat, dataStructure, dataIn, bs);
ConnectionId* info =
- dynamic_cast<ConnectionId*>( dataStructure );
- info->setValue( tightUnmarshalString( dataIn, bs ) );
+ dynamic_cast<ConnectionId*>(dataStructure);
+ info->setValue(tightUnmarshalString(dataIn, bs));
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT(exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
///////////////////////////////////////////////////////////////////////////////
-int ConnectionIdMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) {
+int ConnectionIdMarshaller::tightMarshal1(OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs) {
try {
ConnectionId* info =
- dynamic_cast<ConnectionId*>( dataStructure );
+ dynamic_cast<ConnectionId*>(dataStructure);
- int rc = BaseDataStreamMarshaller::tightMarshal1( wireFormat, dataStructure, bs );
- rc += tightMarshalString1( info->getValue(), bs );
+ int rc = BaseDataStreamMarshaller::tightMarshal1(wireFormat, dataStructure, bs);
+ rc += tightMarshalString1(info->getValue(), bs);
return rc + 0;
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT(exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
///////////////////////////////////////////////////////////////////////////////
-void ConnectionIdMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) {
+void ConnectionIdMarshaller::tightMarshal2(OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs) {
try {
- BaseDataStreamMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs );
+ BaseDataStreamMarshaller::tightMarshal2(wireFormat, dataStructure, dataOut, bs );
ConnectionId* info =
- dynamic_cast<ConnectionId*>( dataStructure );
- tightMarshalString2( info->getValue(), dataOut, bs );
+ dynamic_cast<ConnectionId*>(dataStructure);
+ tightMarshalString2(info->getValue(), dataOut, bs);
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
///////////////////////////////////////////////////////////////////////////////
-void ConnectionIdMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) {
+void ConnectionIdMarshaller::looseUnmarshal(OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn) {
try {
- BaseDataStreamMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn );
+ BaseDataStreamMarshaller::looseUnmarshal(wireFormat, dataStructure, dataIn);
ConnectionId* info =
- dynamic_cast<ConnectionId*>( dataStructure );
- info->setValue( looseUnmarshalString( dataIn ) );
+ dynamic_cast<ConnectionId*>(dataStructure);
+ info->setValue(looseUnmarshalString(dataIn));
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT(exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
///////////////////////////////////////////////////////////////////////////////
-void ConnectionIdMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) {
+void ConnectionIdMarshaller::looseMarshal(OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut) {
try {
ConnectionId* info =
- dynamic_cast<ConnectionId*>( dataStructure );
- BaseDataStreamMarshaller::looseMarshal( wireFormat, dataStructure, dataOut );
- looseMarshalString( info->getValue(), dataOut );
+ dynamic_cast<ConnectionId*>(dataStructure);
+ BaseDataStreamMarshaller::looseMarshal(wireFormat, dataStructure, dataOut);
+ looseMarshalString(info->getValue(), dataOut);
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT(exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionIdMarshaller.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionIdMarshaller.h?rev=1460467&r1=1460466&r2=1460467&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionIdMarshaller.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionIdMarshaller.h Sun Mar 24 21:30:52 2013
@@ -33,11 +33,11 @@
#include <activemq/wireformat/openwire/OpenWireFormat.h>
#include <activemq/wireformat/openwire/utils/BooleanStream.h>
-namespace activemq{
-namespace wireformat{
-namespace openwire{
-namespace marshal{
-namespace generated{
+namespace activemq {
+namespace wireformat {
+namespace openwire {
+namespace marshal {
+namespace generated {
/**
* Marshaling code for Open Wire Format for ConnectionIdMarshaller
@@ -56,27 +56,27 @@ namespace generated{
virtual unsigned char getDataStructureType() const;
- virtual void tightUnmarshal( OpenWireFormat* wireFormat,
- commands::DataStructure* dataStructure,
- decaf::io::DataInputStream* dataIn,
- utils::BooleanStream* bs );
+ virtual void tightUnmarshal(OpenWireFormat* wireFormat,
+ commands::DataStructure* dataStructure,
+ decaf::io::DataInputStream* dataIn,
+ utils::BooleanStream* bs);
+
+ virtual int tightMarshal1(OpenWireFormat* wireFormat,
+ commands::DataStructure* dataStructure,
+ utils::BooleanStream* bs);
- virtual int tightMarshal1( OpenWireFormat* wireFormat,
+ virtual void tightMarshal2(OpenWireFormat* wireFormat,
commands::DataStructure* dataStructure,
- utils::BooleanStream* bs );
+ decaf::io::DataOutputStream* dataOut,
+ utils::BooleanStream* bs);
- virtual void tightMarshal2( OpenWireFormat* wireFormat,
+ virtual void looseUnmarshal(OpenWireFormat* wireFormat,
commands::DataStructure* dataStructure,
- decaf::io::DataOutputStream* dataOut,
- utils::BooleanStream* bs );
+ decaf::io::DataInputStream* dataIn);
- virtual void looseUnmarshal( OpenWireFormat* wireFormat,
- commands::DataStructure* dataStructure,
- decaf::io::DataInputStream* dataIn );
-
- virtual void looseMarshal( OpenWireFormat* wireFormat,
- commands::DataStructure* dataStructure,
- decaf::io::DataOutputStream* dataOut );
+ virtual void looseMarshal(OpenWireFormat* wireFormat,
+ commands::DataStructure* dataStructure,
+ decaf::io::DataOutputStream* dataOut);
};
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionInfoMarshaller.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionInfoMarshaller.cpp?rev=1460467&r1=1460466&r2=1460467&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionInfoMarshaller.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionInfoMarshaller.cpp Sun Mar 24 21:30:52 2013
@@ -51,209 +51,209 @@ unsigned char ConnectionInfoMarshaller::
}
///////////////////////////////////////////////////////////////////////////////
-void ConnectionInfoMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) {
+void ConnectionInfoMarshaller::tightUnmarshal(OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs) {
try {
- BaseCommandMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs );
+ BaseCommandMarshaller::tightUnmarshal(wireFormat, dataStructure, dataIn, bs);
ConnectionInfo* info =
- dynamic_cast<ConnectionInfo*>( dataStructure );
+ dynamic_cast<ConnectionInfo*>(dataStructure);
int wireVersion = wireFormat->getVersion();
- info->setConnectionId( Pointer<ConnectionId>( dynamic_cast< ConnectionId* >(
- tightUnmarshalCachedObject( wireFormat, dataIn, bs ) ) ) );
- info->setClientId( tightUnmarshalString( dataIn, bs ) );
- info->setPassword( tightUnmarshalString( dataIn, bs ) );
- info->setUserName( tightUnmarshalString( dataIn, bs ) );
+ info->setConnectionId(Pointer<ConnectionId>(dynamic_cast<ConnectionId* >(
+ tightUnmarshalCachedObject(wireFormat, dataIn, bs))));
+ info->setClientId(tightUnmarshalString(dataIn, bs));
+ info->setPassword(tightUnmarshalString(dataIn, bs));
+ info->setUserName(tightUnmarshalString(dataIn, bs));
- if( bs->readBoolean() ) {
+ if (bs->readBoolean()) {
short size = dataIn->readShort();
- info->getBrokerPath().reserve( size );
- for( int i = 0; i < size; i++ ) {
- info->getBrokerPath().push_back( Pointer<BrokerId>( dynamic_cast< BrokerId* >(
- tightUnmarshalNestedObject( wireFormat, dataIn, bs ) ) ) );
+ info->getBrokerPath().reserve(size);
+ for (int i = 0; i < size; i++) {
+ info->getBrokerPath().push_back(Pointer<BrokerId>(dynamic_cast<BrokerId*>(
+ tightUnmarshalNestedObject(wireFormat, dataIn, bs))));
}
} else {
info->getBrokerPath().clear();
}
- info->setBrokerMasterConnector( bs->readBoolean() );
- info->setManageable( bs->readBoolean() );
- if( wireVersion >= 2 ) {
- info->setClientMaster( bs->readBoolean() );
+ info->setBrokerMasterConnector(bs->readBoolean());
+ info->setManageable(bs->readBoolean());
+ if (wireVersion >= 2) {
+ info->setClientMaster(bs->readBoolean());
}
- if( wireVersion >= 6 ) {
- info->setFaultTolerant( bs->readBoolean() );
+ if (wireVersion >= 6) {
+ info->setFaultTolerant(bs->readBoolean());
}
- if( wireVersion >= 6 ) {
- info->setFailoverReconnect( bs->readBoolean() );
+ if (wireVersion >= 6) {
+ info->setFailoverReconnect(bs->readBoolean());
}
- if( wireVersion >= 8 ) {
- info->setClientIp( tightUnmarshalString( dataIn, bs ) );
+ if (wireVersion >= 8) {
+ info->setClientIp(tightUnmarshalString(dataIn, bs));
}
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT(exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
///////////////////////////////////////////////////////////////////////////////
-int ConnectionInfoMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) {
+int ConnectionInfoMarshaller::tightMarshal1(OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs) {
try {
ConnectionInfo* info =
- dynamic_cast<ConnectionInfo*>( dataStructure );
+ dynamic_cast<ConnectionInfo*>(dataStructure);
- int rc = BaseCommandMarshaller::tightMarshal1( wireFormat, dataStructure, bs );
+ int rc = BaseCommandMarshaller::tightMarshal1(wireFormat, dataStructure, bs);
int wireVersion = wireFormat->getVersion();
- rc += tightMarshalCachedObject1( wireFormat, info->getConnectionId().get(), bs );
- rc += tightMarshalString1( info->getClientId(), bs );
- rc += tightMarshalString1( info->getPassword(), bs );
- rc += tightMarshalString1( info->getUserName(), bs );
- rc += tightMarshalObjectArray1( wireFormat, info->getBrokerPath(), bs );
- bs->writeBoolean( info->isBrokerMasterConnector() );
- bs->writeBoolean( info->isManageable() );
- if( wireVersion >= 2 ) {
- bs->writeBoolean( info->isClientMaster() );
+ rc += tightMarshalCachedObject1(wireFormat, info->getConnectionId().get(), bs);
+ rc += tightMarshalString1(info->getClientId(), bs);
+ rc += tightMarshalString1(info->getPassword(), bs);
+ rc += tightMarshalString1(info->getUserName(), bs);
+ rc += tightMarshalObjectArray1(wireFormat, info->getBrokerPath(), bs);
+ bs->writeBoolean(info->isBrokerMasterConnector());
+ bs->writeBoolean(info->isManageable());
+ if (wireVersion >= 2) {
+ bs->writeBoolean(info->isClientMaster());
}
- if( wireVersion >= 6 ) {
- bs->writeBoolean( info->isFaultTolerant() );
+ if (wireVersion >= 6) {
+ bs->writeBoolean(info->isFaultTolerant());
}
- if( wireVersion >= 6 ) {
- bs->writeBoolean( info->isFailoverReconnect() );
+ if (wireVersion >= 6) {
+ bs->writeBoolean(info->isFailoverReconnect());
}
- if( wireVersion >= 8 ) {
- rc += tightMarshalString1( info->getClientIp(), bs );
+ if (wireVersion >= 8) {
+ rc += tightMarshalString1(info->getClientIp(), bs);
}
return rc + 0;
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT(exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
///////////////////////////////////////////////////////////////////////////////
-void ConnectionInfoMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) {
+void ConnectionInfoMarshaller::tightMarshal2(OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs) {
try {
- BaseCommandMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs );
+ BaseCommandMarshaller::tightMarshal2(wireFormat, dataStructure, dataOut, bs );
ConnectionInfo* info =
- dynamic_cast<ConnectionInfo*>( dataStructure );
+ dynamic_cast<ConnectionInfo*>(dataStructure);
int wireVersion = wireFormat->getVersion();
- tightMarshalCachedObject2( wireFormat, info->getConnectionId().get(), dataOut, bs );
- tightMarshalString2( info->getClientId(), dataOut, bs );
- tightMarshalString2( info->getPassword(), dataOut, bs );
- tightMarshalString2( info->getUserName(), dataOut, bs );
- tightMarshalObjectArray2( wireFormat, info->getBrokerPath(), dataOut, bs );
+ tightMarshalCachedObject2(wireFormat, info->getConnectionId().get(), dataOut, bs);
+ tightMarshalString2(info->getClientId(), dataOut, bs);
+ tightMarshalString2(info->getPassword(), dataOut, bs);
+ tightMarshalString2(info->getUserName(), dataOut, bs);
+ tightMarshalObjectArray2(wireFormat, info->getBrokerPath(), dataOut, bs);
bs->readBoolean();
bs->readBoolean();
- if( wireVersion >= 2 ) {
+ if (wireVersion >= 2) {
bs->readBoolean();
}
- if( wireVersion >= 6 ) {
+ if (wireVersion >= 6) {
bs->readBoolean();
}
- if( wireVersion >= 6 ) {
+ if (wireVersion >= 6) {
bs->readBoolean();
}
- if( wireVersion >= 8 ) {
- tightMarshalString2( info->getClientIp(), dataOut, bs );
+ if (wireVersion >= 8) {
+ tightMarshalString2(info->getClientIp(), dataOut, bs);
}
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
///////////////////////////////////////////////////////////////////////////////
-void ConnectionInfoMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) {
+void ConnectionInfoMarshaller::looseUnmarshal(OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn) {
try {
- BaseCommandMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn );
+ BaseCommandMarshaller::looseUnmarshal(wireFormat, dataStructure, dataIn);
ConnectionInfo* info =
- dynamic_cast<ConnectionInfo*>( dataStructure );
+ dynamic_cast<ConnectionInfo*>(dataStructure);
int wireVersion = wireFormat->getVersion();
- info->setConnectionId( Pointer<ConnectionId>( dynamic_cast< ConnectionId* >(
- looseUnmarshalCachedObject( wireFormat, dataIn ) ) ) );
- info->setClientId( looseUnmarshalString( dataIn ) );
- info->setPassword( looseUnmarshalString( dataIn ) );
- info->setUserName( looseUnmarshalString( dataIn ) );
+ info->setConnectionId(Pointer<ConnectionId>(dynamic_cast<ConnectionId*>(
+ looseUnmarshalCachedObject(wireFormat, dataIn))));
+ info->setClientId(looseUnmarshalString(dataIn));
+ info->setPassword(looseUnmarshalString(dataIn));
+ info->setUserName(looseUnmarshalString(dataIn));
- if( dataIn->readBoolean() ) {
+ if (dataIn->readBoolean()) {
short size = dataIn->readShort();
- info->getBrokerPath().reserve( size );
- for( int i = 0; i < size; i++ ) {
- info->getBrokerPath().push_back( Pointer<BrokerId>( dynamic_cast<BrokerId* >(
- looseUnmarshalNestedObject( wireFormat, dataIn ) ) ) );
+ info->getBrokerPath().reserve(size);
+ for (int i = 0; i < size; i++) {
+ info->getBrokerPath().push_back( Pointer<BrokerId>(dynamic_cast<BrokerId*>(
+ looseUnmarshalNestedObject(wireFormat, dataIn))));
}
} else {
info->getBrokerPath().clear();
}
- info->setBrokerMasterConnector( dataIn->readBoolean() );
- info->setManageable( dataIn->readBoolean() );
- if( wireVersion >= 2 ) {
- info->setClientMaster( dataIn->readBoolean() );
+ info->setBrokerMasterConnector(dataIn->readBoolean());
+ info->setManageable(dataIn->readBoolean());
+ if (wireVersion >= 2) {
+ info->setClientMaster(dataIn->readBoolean());
}
- if( wireVersion >= 6 ) {
- info->setFaultTolerant( dataIn->readBoolean() );
+ if (wireVersion >= 6) {
+ info->setFaultTolerant(dataIn->readBoolean());
}
- if( wireVersion >= 6 ) {
- info->setFailoverReconnect( dataIn->readBoolean() );
+ if (wireVersion >= 6) {
+ info->setFailoverReconnect(dataIn->readBoolean());
}
- if( wireVersion >= 8 ) {
- info->setClientIp( looseUnmarshalString( dataIn ) );
+ if (wireVersion >= 8) {
+ info->setClientIp(looseUnmarshalString(dataIn));
}
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT(exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
///////////////////////////////////////////////////////////////////////////////
-void ConnectionInfoMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) {
+void ConnectionInfoMarshaller::looseMarshal(OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut) {
try {
ConnectionInfo* info =
- dynamic_cast<ConnectionInfo*>( dataStructure );
- BaseCommandMarshaller::looseMarshal( wireFormat, dataStructure, dataOut );
+ dynamic_cast<ConnectionInfo*>(dataStructure);
+ BaseCommandMarshaller::looseMarshal(wireFormat, dataStructure, dataOut);
int wireVersion = wireFormat->getVersion();
- looseMarshalCachedObject( wireFormat, info->getConnectionId().get(), dataOut );
- looseMarshalString( info->getClientId(), dataOut );
- looseMarshalString( info->getPassword(), dataOut );
- looseMarshalString( info->getUserName(), dataOut );
- looseMarshalObjectArray( wireFormat, info->getBrokerPath(), dataOut );
- dataOut->writeBoolean( info->isBrokerMasterConnector() );
- dataOut->writeBoolean( info->isManageable() );
- if( wireVersion >= 2 ) {
- dataOut->writeBoolean( info->isClientMaster() );
+ looseMarshalCachedObject(wireFormat, info->getConnectionId().get(), dataOut);
+ looseMarshalString(info->getClientId(), dataOut);
+ looseMarshalString(info->getPassword(), dataOut);
+ looseMarshalString(info->getUserName(), dataOut);
+ looseMarshalObjectArray(wireFormat, info->getBrokerPath(), dataOut);
+ dataOut->writeBoolean(info->isBrokerMasterConnector());
+ dataOut->writeBoolean(info->isManageable());
+ if (wireVersion >= 2) {
+ dataOut->writeBoolean(info->isClientMaster());
}
- if( wireVersion >= 6 ) {
- dataOut->writeBoolean( info->isFaultTolerant() );
+ if (wireVersion >= 6) {
+ dataOut->writeBoolean(info->isFaultTolerant());
}
- if( wireVersion >= 6 ) {
- dataOut->writeBoolean( info->isFailoverReconnect() );
+ if (wireVersion >= 6) {
+ dataOut->writeBoolean(info->isFailoverReconnect());
}
- if( wireVersion >= 8 ) {
- looseMarshalString( info->getClientIp(), dataOut );
+ if (wireVersion >= 8) {
+ looseMarshalString(info->getClientIp(), dataOut);
}
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT(exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionInfoMarshaller.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionInfoMarshaller.h?rev=1460467&r1=1460466&r2=1460467&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionInfoMarshaller.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConnectionInfoMarshaller.h Sun Mar 24 21:30:52 2013
@@ -33,11 +33,11 @@
#include <activemq/wireformat/openwire/OpenWireFormat.h>
#include <activemq/wireformat/openwire/utils/BooleanStream.h>
-namespace activemq{
-namespace wireformat{
-namespace openwire{
-namespace marshal{
-namespace generated{
+namespace activemq {
+namespace wireformat {
+namespace openwire {
+namespace marshal {
+namespace generated {
/**
* Marshaling code for Open Wire Format for ConnectionInfoMarshaller
@@ -56,27 +56,27 @@ namespace generated{
virtual unsigned char getDataStructureType() const;
- virtual void tightUnmarshal( OpenWireFormat* wireFormat,
- commands::DataStructure* dataStructure,
- decaf::io::DataInputStream* dataIn,
- utils::BooleanStream* bs );
+ virtual void tightUnmarshal(OpenWireFormat* wireFormat,
+ commands::DataStructure* dataStructure,
+ decaf::io::DataInputStream* dataIn,
+ utils::BooleanStream* bs);
+
+ virtual int tightMarshal1(OpenWireFormat* wireFormat,
+ commands::DataStructure* dataStructure,
+ utils::BooleanStream* bs);
- virtual int tightMarshal1( OpenWireFormat* wireFormat,
+ virtual void tightMarshal2(OpenWireFormat* wireFormat,
commands::DataStructure* dataStructure,
- utils::BooleanStream* bs );
+ decaf::io::DataOutputStream* dataOut,
+ utils::BooleanStream* bs);
- virtual void tightMarshal2( OpenWireFormat* wireFormat,
+ virtual void looseUnmarshal(OpenWireFormat* wireFormat,
commands::DataStructure* dataStructure,
- decaf::io::DataOutputStream* dataOut,
- utils::BooleanStream* bs );
+ decaf::io::DataInputStream* dataIn);
- virtual void looseUnmarshal( OpenWireFormat* wireFormat,
- commands::DataStructure* dataStructure,
- decaf::io::DataInputStream* dataIn );
-
- virtual void looseMarshal( OpenWireFormat* wireFormat,
- commands::DataStructure* dataStructure,
- decaf::io::DataOutputStream* dataOut );
+ virtual void looseMarshal(OpenWireFormat* wireFormat,
+ commands::DataStructure* dataStructure,
+ decaf::io::DataOutputStream* dataOut);
};
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConsumerControlMarshaller.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConsumerControlMarshaller.cpp?rev=1460467&r1=1460466&r2=1460467&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConsumerControlMarshaller.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConsumerControlMarshaller.cpp Sun Mar 24 21:30:52 2013
@@ -51,170 +51,170 @@ unsigned char ConsumerControlMarshaller:
}
///////////////////////////////////////////////////////////////////////////////
-void ConsumerControlMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) {
+void ConsumerControlMarshaller::tightUnmarshal(OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs) {
try {
- BaseCommandMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs );
+ BaseCommandMarshaller::tightUnmarshal(wireFormat, dataStructure, dataIn, bs);
ConsumerControl* info =
- dynamic_cast<ConsumerControl*>( dataStructure );
+ dynamic_cast<ConsumerControl*>(dataStructure);
int wireVersion = wireFormat->getVersion();
- if( wireVersion >= 6 ) {
- info->setDestination( Pointer<ActiveMQDestination>( dynamic_cast< ActiveMQDestination* >(
- tightUnmarshalNestedObject( wireFormat, dataIn, bs ) ) ) );
- }
- info->setClose( bs->readBoolean() );
- info->setConsumerId( Pointer<ConsumerId>( dynamic_cast< ConsumerId* >(
- tightUnmarshalNestedObject( wireFormat, dataIn, bs ) ) ) );
- info->setPrefetch( dataIn->readInt() );
- if( wireVersion >= 2 ) {
- info->setFlush( bs->readBoolean() );
+ if (wireVersion >= 6) {
+ info->setDestination(Pointer<ActiveMQDestination>(dynamic_cast<ActiveMQDestination* >(
+ tightUnmarshalNestedObject(wireFormat, dataIn, bs))));
+ }
+ info->setClose(bs->readBoolean());
+ info->setConsumerId(Pointer<ConsumerId>(dynamic_cast<ConsumerId* >(
+ tightUnmarshalNestedObject(wireFormat, dataIn, bs))));
+ info->setPrefetch(dataIn->readInt());
+ if (wireVersion >= 2) {
+ info->setFlush(bs->readBoolean());
}
- if( wireVersion >= 2 ) {
- info->setStart( bs->readBoolean() );
+ if (wireVersion >= 2) {
+ info->setStart(bs->readBoolean());
}
- if( wireVersion >= 2 ) {
- info->setStop( bs->readBoolean() );
+ if (wireVersion >= 2) {
+ info->setStop(bs->readBoolean());
}
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT(exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
///////////////////////////////////////////////////////////////////////////////
-int ConsumerControlMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) {
+int ConsumerControlMarshaller::tightMarshal1(OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs) {
try {
ConsumerControl* info =
- dynamic_cast<ConsumerControl*>( dataStructure );
+ dynamic_cast<ConsumerControl*>(dataStructure);
- int rc = BaseCommandMarshaller::tightMarshal1( wireFormat, dataStructure, bs );
+ int rc = BaseCommandMarshaller::tightMarshal1(wireFormat, dataStructure, bs);
int wireVersion = wireFormat->getVersion();
- if( wireVersion >= 6 ) {
- rc += tightMarshalNestedObject1( wireFormat, info->getDestination().get(), bs );
+ if (wireVersion >= 6) {
+ rc += tightMarshalNestedObject1(wireFormat, info->getDestination().get(), bs);
}
- bs->writeBoolean( info->isClose() );
- rc += tightMarshalNestedObject1( wireFormat, info->getConsumerId().get(), bs );
- if( wireVersion >= 2 ) {
- bs->writeBoolean( info->isFlush() );
+ bs->writeBoolean(info->isClose());
+ rc += tightMarshalNestedObject1(wireFormat, info->getConsumerId().get(), bs);
+ if (wireVersion >= 2) {
+ bs->writeBoolean(info->isFlush());
}
- if( wireVersion >= 2 ) {
- bs->writeBoolean( info->isStart() );
+ if (wireVersion >= 2) {
+ bs->writeBoolean(info->isStart());
}
- if( wireVersion >= 2 ) {
- bs->writeBoolean( info->isStop() );
+ if (wireVersion >= 2) {
+ bs->writeBoolean(info->isStop());
}
return rc + 4;
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT(exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
///////////////////////////////////////////////////////////////////////////////
-void ConsumerControlMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) {
+void ConsumerControlMarshaller::tightMarshal2(OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs) {
try {
- BaseCommandMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs );
+ BaseCommandMarshaller::tightMarshal2(wireFormat, dataStructure, dataOut, bs );
ConsumerControl* info =
- dynamic_cast<ConsumerControl*>( dataStructure );
+ dynamic_cast<ConsumerControl*>(dataStructure);
int wireVersion = wireFormat->getVersion();
- if( wireVersion >= 6 ) {
- tightMarshalNestedObject2( wireFormat, info->getDestination().get(), dataOut, bs );
+ if (wireVersion >= 6) {
+ tightMarshalNestedObject2(wireFormat, info->getDestination().get(), dataOut, bs);
}
bs->readBoolean();
- tightMarshalNestedObject2( wireFormat, info->getConsumerId().get(), dataOut, bs );
- dataOut->writeInt( info->getPrefetch() );
- if( wireVersion >= 2 ) {
+ tightMarshalNestedObject2(wireFormat, info->getConsumerId().get(), dataOut, bs);
+ dataOut->writeInt(info->getPrefetch());
+ if (wireVersion >= 2) {
bs->readBoolean();
}
- if( wireVersion >= 2 ) {
+ if (wireVersion >= 2) {
bs->readBoolean();
}
- if( wireVersion >= 2 ) {
+ if (wireVersion >= 2) {
bs->readBoolean();
}
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
///////////////////////////////////////////////////////////////////////////////
-void ConsumerControlMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) {
+void ConsumerControlMarshaller::looseUnmarshal(OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn) {
try {
- BaseCommandMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn );
+ BaseCommandMarshaller::looseUnmarshal(wireFormat, dataStructure, dataIn);
ConsumerControl* info =
- dynamic_cast<ConsumerControl*>( dataStructure );
+ dynamic_cast<ConsumerControl*>(dataStructure);
int wireVersion = wireFormat->getVersion();
- if( wireVersion >= 6 ) {
- info->setDestination( Pointer<ActiveMQDestination>( dynamic_cast< ActiveMQDestination* >(
- looseUnmarshalNestedObject( wireFormat, dataIn ) ) ) );
- }
- info->setClose( dataIn->readBoolean() );
- info->setConsumerId( Pointer<ConsumerId>( dynamic_cast< ConsumerId* >(
- looseUnmarshalNestedObject( wireFormat, dataIn ) ) ) );
- info->setPrefetch( dataIn->readInt() );
- if( wireVersion >= 2 ) {
- info->setFlush( dataIn->readBoolean() );
+ if (wireVersion >= 6) {
+ info->setDestination(Pointer<ActiveMQDestination>(dynamic_cast<ActiveMQDestination*>(
+ looseUnmarshalNestedObject(wireFormat, dataIn))));
+ }
+ info->setClose(dataIn->readBoolean());
+ info->setConsumerId(Pointer<ConsumerId>(dynamic_cast<ConsumerId*>(
+ looseUnmarshalNestedObject(wireFormat, dataIn))));
+ info->setPrefetch(dataIn->readInt());
+ if (wireVersion >= 2) {
+ info->setFlush(dataIn->readBoolean());
}
- if( wireVersion >= 2 ) {
- info->setStart( dataIn->readBoolean() );
+ if (wireVersion >= 2) {
+ info->setStart(dataIn->readBoolean());
}
- if( wireVersion >= 2 ) {
- info->setStop( dataIn->readBoolean() );
+ if (wireVersion >= 2) {
+ info->setStop(dataIn->readBoolean());
}
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT(exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
///////////////////////////////////////////////////////////////////////////////
-void ConsumerControlMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) {
+void ConsumerControlMarshaller::looseMarshal(OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut) {
try {
ConsumerControl* info =
- dynamic_cast<ConsumerControl*>( dataStructure );
- BaseCommandMarshaller::looseMarshal( wireFormat, dataStructure, dataOut );
+ dynamic_cast<ConsumerControl*>(dataStructure);
+ BaseCommandMarshaller::looseMarshal(wireFormat, dataStructure, dataOut);
int wireVersion = wireFormat->getVersion();
- if( wireVersion >= 6 ) {
- looseMarshalNestedObject( wireFormat, info->getDestination().get(), dataOut );
+ if (wireVersion >= 6) {
+ looseMarshalNestedObject(wireFormat, info->getDestination().get(), dataOut);
}
- dataOut->writeBoolean( info->isClose() );
- looseMarshalNestedObject( wireFormat, info->getConsumerId().get(), dataOut );
- dataOut->writeInt( info->getPrefetch() );
- if( wireVersion >= 2 ) {
- dataOut->writeBoolean( info->isFlush() );
+ dataOut->writeBoolean(info->isClose());
+ looseMarshalNestedObject(wireFormat, info->getConsumerId().get(), dataOut);
+ dataOut->writeInt(info->getPrefetch());
+ if (wireVersion >= 2) {
+ dataOut->writeBoolean(info->isFlush());
}
- if( wireVersion >= 2 ) {
- dataOut->writeBoolean( info->isStart() );
+ if (wireVersion >= 2) {
+ dataOut->writeBoolean(info->isStart());
}
- if( wireVersion >= 2 ) {
- dataOut->writeBoolean( info->isStop() );
+ if (wireVersion >= 2) {
+ dataOut->writeBoolean(info->isStop());
}
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT(exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConsumerControlMarshaller.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConsumerControlMarshaller.h?rev=1460467&r1=1460466&r2=1460467&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConsumerControlMarshaller.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConsumerControlMarshaller.h Sun Mar 24 21:30:52 2013
@@ -33,11 +33,11 @@
#include <activemq/wireformat/openwire/OpenWireFormat.h>
#include <activemq/wireformat/openwire/utils/BooleanStream.h>
-namespace activemq{
-namespace wireformat{
-namespace openwire{
-namespace marshal{
-namespace generated{
+namespace activemq {
+namespace wireformat {
+namespace openwire {
+namespace marshal {
+namespace generated {
/**
* Marshaling code for Open Wire Format for ConsumerControlMarshaller
@@ -56,27 +56,27 @@ namespace generated{
virtual unsigned char getDataStructureType() const;
- virtual void tightUnmarshal( OpenWireFormat* wireFormat,
- commands::DataStructure* dataStructure,
- decaf::io::DataInputStream* dataIn,
- utils::BooleanStream* bs );
+ virtual void tightUnmarshal(OpenWireFormat* wireFormat,
+ commands::DataStructure* dataStructure,
+ decaf::io::DataInputStream* dataIn,
+ utils::BooleanStream* bs);
+
+ virtual int tightMarshal1(OpenWireFormat* wireFormat,
+ commands::DataStructure* dataStructure,
+ utils::BooleanStream* bs);
- virtual int tightMarshal1( OpenWireFormat* wireFormat,
+ virtual void tightMarshal2(OpenWireFormat* wireFormat,
commands::DataStructure* dataStructure,
- utils::BooleanStream* bs );
+ decaf::io::DataOutputStream* dataOut,
+ utils::BooleanStream* bs);
- virtual void tightMarshal2( OpenWireFormat* wireFormat,
+ virtual void looseUnmarshal(OpenWireFormat* wireFormat,
commands::DataStructure* dataStructure,
- decaf::io::DataOutputStream* dataOut,
- utils::BooleanStream* bs );
+ decaf::io::DataInputStream* dataIn);
- virtual void looseUnmarshal( OpenWireFormat* wireFormat,
- commands::DataStructure* dataStructure,
- decaf::io::DataInputStream* dataIn );
-
- virtual void looseMarshal( OpenWireFormat* wireFormat,
- commands::DataStructure* dataStructure,
- decaf::io::DataOutputStream* dataOut );
+ virtual void looseMarshal(OpenWireFormat* wireFormat,
+ commands::DataStructure* dataStructure,
+ decaf::io::DataOutputStream* dataOut);
};
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConsumerIdMarshaller.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConsumerIdMarshaller.cpp?rev=1460467&r1=1460466&r2=1460467&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConsumerIdMarshaller.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConsumerIdMarshaller.cpp Sun Mar 24 21:30:52 2013
@@ -51,92 +51,92 @@ unsigned char ConsumerIdMarshaller::getD
}
///////////////////////////////////////////////////////////////////////////////
-void ConsumerIdMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) {
+void ConsumerIdMarshaller::tightUnmarshal(OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs) {
try {
- BaseDataStreamMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs );
+ BaseDataStreamMarshaller::tightUnmarshal(wireFormat, dataStructure, dataIn, bs);
ConsumerId* info =
- dynamic_cast<ConsumerId*>( dataStructure );
- info->setConnectionId( tightUnmarshalString( dataIn, bs ) );
- info->setSessionId( tightUnmarshalLong( wireFormat, dataIn, bs ) );
- info->setValue( tightUnmarshalLong( wireFormat, dataIn, bs ) );
+ dynamic_cast<ConsumerId*>(dataStructure);
+ info->setConnectionId(tightUnmarshalString(dataIn, bs));
+ info->setSessionId(tightUnmarshalLong(wireFormat, dataIn, bs));
+ info->setValue(tightUnmarshalLong(wireFormat, dataIn, bs));
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT(exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
///////////////////////////////////////////////////////////////////////////////
-int ConsumerIdMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) {
+int ConsumerIdMarshaller::tightMarshal1(OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs) {
try {
ConsumerId* info =
- dynamic_cast<ConsumerId*>( dataStructure );
+ dynamic_cast<ConsumerId*>(dataStructure);
- int rc = BaseDataStreamMarshaller::tightMarshal1( wireFormat, dataStructure, bs );
- rc += tightMarshalString1( info->getConnectionId(), bs );
- rc += tightMarshalLong1( wireFormat, info->getSessionId(), bs );
- rc += tightMarshalLong1( wireFormat, info->getValue(), bs );
+ int rc = BaseDataStreamMarshaller::tightMarshal1(wireFormat, dataStructure, bs);
+ rc += tightMarshalString1(info->getConnectionId(), bs);
+ rc += tightMarshalLong1(wireFormat, info->getSessionId(), bs);
+ rc += tightMarshalLong1(wireFormat, info->getValue(), bs);
return rc + 0;
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT(exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
///////////////////////////////////////////////////////////////////////////////
-void ConsumerIdMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) {
+void ConsumerIdMarshaller::tightMarshal2(OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs) {
try {
- BaseDataStreamMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs );
+ BaseDataStreamMarshaller::tightMarshal2(wireFormat, dataStructure, dataOut, bs );
ConsumerId* info =
- dynamic_cast<ConsumerId*>( dataStructure );
- tightMarshalString2( info->getConnectionId(), dataOut, bs );
- tightMarshalLong2( wireFormat, info->getSessionId(), dataOut, bs );
- tightMarshalLong2( wireFormat, info->getValue(), dataOut, bs );
+ dynamic_cast<ConsumerId*>(dataStructure);
+ tightMarshalString2(info->getConnectionId(), dataOut, bs);
+ tightMarshalLong2(wireFormat, info->getSessionId(), dataOut, bs);
+ tightMarshalLong2(wireFormat, info->getValue(), dataOut, bs);
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
///////////////////////////////////////////////////////////////////////////////
-void ConsumerIdMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) {
+void ConsumerIdMarshaller::looseUnmarshal(OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn) {
try {
- BaseDataStreamMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn );
+ BaseDataStreamMarshaller::looseUnmarshal(wireFormat, dataStructure, dataIn);
ConsumerId* info =
- dynamic_cast<ConsumerId*>( dataStructure );
- info->setConnectionId( looseUnmarshalString( dataIn ) );
- info->setSessionId( looseUnmarshalLong( wireFormat, dataIn ) );
- info->setValue( looseUnmarshalLong( wireFormat, dataIn ) );
+ dynamic_cast<ConsumerId*>(dataStructure);
+ info->setConnectionId(looseUnmarshalString(dataIn));
+ info->setSessionId(looseUnmarshalLong(wireFormat, dataIn));
+ info->setValue(looseUnmarshalLong(wireFormat, dataIn));
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT(exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
///////////////////////////////////////////////////////////////////////////////
-void ConsumerIdMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) {
+void ConsumerIdMarshaller::looseMarshal(OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut) {
try {
ConsumerId* info =
- dynamic_cast<ConsumerId*>( dataStructure );
- BaseDataStreamMarshaller::looseMarshal( wireFormat, dataStructure, dataOut );
- looseMarshalString( info->getConnectionId(), dataOut );
- looseMarshalLong( wireFormat, info->getSessionId(), dataOut );
- looseMarshalLong( wireFormat, info->getValue(), dataOut );
+ dynamic_cast<ConsumerId*>(dataStructure);
+ BaseDataStreamMarshaller::looseMarshal(wireFormat, dataStructure, dataOut);
+ looseMarshalString(info->getConnectionId(), dataOut);
+ looseMarshalLong(wireFormat, info->getSessionId(), dataOut);
+ looseMarshalLong(wireFormat, info->getValue(), dataOut);
}
- AMQ_CATCH_RETHROW( decaf::io::IOException )
- AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, decaf::io::IOException )
- AMQ_CATCHALL_THROW( decaf::io::IOException )
+ AMQ_CATCH_RETHROW(decaf::io::IOException)
+ AMQ_CATCH_EXCEPTION_CONVERT(exceptions::ActiveMQException, decaf::io::IOException)
+ AMQ_CATCHALL_THROW(decaf::io::IOException)
}
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConsumerIdMarshaller.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConsumerIdMarshaller.h?rev=1460467&r1=1460466&r2=1460467&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConsumerIdMarshaller.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/wireformat/openwire/marshal/generated/ConsumerIdMarshaller.h Sun Mar 24 21:30:52 2013
@@ -33,11 +33,11 @@
#include <activemq/wireformat/openwire/OpenWireFormat.h>
#include <activemq/wireformat/openwire/utils/BooleanStream.h>
-namespace activemq{
-namespace wireformat{
-namespace openwire{
-namespace marshal{
-namespace generated{
+namespace activemq {
+namespace wireformat {
+namespace openwire {
+namespace marshal {
+namespace generated {
/**
* Marshaling code for Open Wire Format for ConsumerIdMarshaller
@@ -56,27 +56,27 @@ namespace generated{
virtual unsigned char getDataStructureType() const;
- virtual void tightUnmarshal( OpenWireFormat* wireFormat,
- commands::DataStructure* dataStructure,
- decaf::io::DataInputStream* dataIn,
- utils::BooleanStream* bs );
+ virtual void tightUnmarshal(OpenWireFormat* wireFormat,
+ commands::DataStructure* dataStructure,
+ decaf::io::DataInputStream* dataIn,
+ utils::BooleanStream* bs);
+
+ virtual int tightMarshal1(OpenWireFormat* wireFormat,
+ commands::DataStructure* dataStructure,
+ utils::BooleanStream* bs);
- virtual int tightMarshal1( OpenWireFormat* wireFormat,
+ virtual void tightMarshal2(OpenWireFormat* wireFormat,
commands::DataStructure* dataStructure,
- utils::BooleanStream* bs );
+ decaf::io::DataOutputStream* dataOut,
+ utils::BooleanStream* bs);
- virtual void tightMarshal2( OpenWireFormat* wireFormat,
+ virtual void looseUnmarshal(OpenWireFormat* wireFormat,
commands::DataStructure* dataStructure,
- decaf::io::DataOutputStream* dataOut,
- utils::BooleanStream* bs );
+ decaf::io::DataInputStream* dataIn);
- virtual void looseUnmarshal( OpenWireFormat* wireFormat,
- commands::DataStructure* dataStructure,
- decaf::io::DataInputStream* dataIn );
-
- virtual void looseMarshal( OpenWireFormat* wireFormat,
- commands::DataStructure* dataStructure,
- decaf::io::DataOutputStream* dataOut );
+ virtual void looseMarshal(OpenWireFormat* wireFormat,
+ commands::DataStructure* dataStructure,
+ decaf::io::DataOutputStream* dataOut);
};