You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2006/03/09 01:41:58 UTC
svn commit: r384390 [7/11] - in /incubator/activemq/trunk:
activemq-core/src/gram/java/org/apache/activemq/openwire/tool/
activemq-core/src/gram/script/
activemq-core/src/main/java/org/apache/activemq/command/
activemq-core/src/main/java/org/apache/act...
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SubscriptionInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SubscriptionInfoMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SubscriptionInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/SubscriptionInfoMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -62,7 +62,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -91,5 +90,36 @@
TightMarshalString2(info.SubcriptionName, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ SubscriptionInfo info = (SubscriptionInfo)o;
+ info.ClientId = LooseUnmarshalString(dataIn);
+ info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.Selector = LooseUnmarshalString(dataIn);
+ info.SubcriptionName = LooseUnmarshalString(dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ SubscriptionInfo info = (SubscriptionInfo)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalString(info.ClientId, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut);
+ LooseMarshalString(info.Selector, dataOut);
+ LooseMarshalString(info.SubcriptionName, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/TransactionIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/TransactionIdMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/TransactionIdMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/TransactionIdMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -45,7 +45,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -64,5 +63,24 @@
base.TightMarshal2(wireFormat, o, dataOut, bs);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/TransactionInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/TransactionInfoMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/TransactionInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/TransactionInfoMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -61,7 +61,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -87,5 +86,34 @@
dataOut.Write(info.Type);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ TransactionInfo info = (TransactionInfo)o;
+ info.ConnectionId = (ConnectionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.TransactionId = (TransactionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+ info.Type = dataIn.ReadByte();
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ TransactionInfo info = (TransactionInfo)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConnectionId, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.TransactionId, dataOut);
+ dataOut.Write(info.Type);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/WireFormatInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/WireFormatInfoMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/WireFormatInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/WireFormatInfoMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -66,7 +66,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -99,5 +98,47 @@
info.AfterMarshall(wireFormat);
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ WireFormatInfo info = (WireFormatInfo)o;
+
+ info.BeforeUnmarshall(wireFormat);
+
+ info.Magic = ReadBytes(dataIn, 8);
+ info.Version = dataIn.ReadInt32();
+ info.MarshalledProperties = ReadBytes(dataIn, dataIn.ReadBoolean());
+
+ info.AfterUnmarshall(wireFormat);
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ WireFormatInfo info = (WireFormatInfo)o;
+
+ info.BeforeMarshall(wireFormat);
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ dataOut.Write(info.Magic, 0, 8);
+ dataOut.Write(info.Version);
+ dataOut.Write(info.MarshalledProperties!=null);
+ if(info.MarshalledProperties!=null) {
+ dataOut.Write(info.MarshalledProperties.Length);
+ dataOut.Write(info.MarshalledProperties);
+ }
+
+ info.AfterMarshall(wireFormat);
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/XATransactionIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/XATransactionIdMarshaller.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/XATransactionIdMarshaller.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/XATransactionIdMarshaller.cs Wed Mar 8 16:41:39 2006
@@ -61,7 +61,6 @@
}
-
//
// Write the booleans that this object uses to a BooleanStream
//
@@ -95,5 +94,42 @@
}
}
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
+ {
+ base.LooseUnmarshal(wireFormat, o, dataIn);
+
+ XATransactionId info = (XATransactionId)o;
+ info.FormatId = dataIn.ReadInt32();
+ info.GlobalTransactionId = ReadBytes(dataIn, dataIn.ReadBoolean());
+ info.BranchQualifier = ReadBytes(dataIn, dataIn.ReadBoolean());
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ XATransactionId info = (XATransactionId)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ dataOut.Write(info.FormatId);
+ dataOut.Write(info.GlobalTransactionId!=null);
+ if(info.GlobalTransactionId!=null) {
+ dataOut.Write(info.GlobalTransactionId.Length);
+ dataOut.Write(info.GlobalTransactionId);
+ }
+ dataOut.Write(info.BranchQualifier!=null);
+ if(info.BranchQualifier!=null) {
+ dataOut.Write(info.BranchQualifier.Length);
+ dataOut.Write(info.BranchQualifier);
+ }
+
+ }
+
}
}
Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/Tcp/TcpTransport.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/Tcp/TcpTransport.cs?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/Tcp/TcpTransport.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/Tcp/TcpTransport.cs Wed Mar 8 16:41:39 2006
@@ -72,7 +72,14 @@
readThread.Start();
// lets send the wireformat we're using
- Oneway(wireformat.WireFormatInfo);
+ WireFormatInfo info = new WireFormatInfo();
+ info.StackTraceEnabled=false;
+ info.TightEncodingEnabled=false;
+ info.TcpNoDelayEnabled=false;
+ info.CacheEnabled=false;
+ info.SizePrefixDisabled=false;
+
+ Oneway(info);
}
}
Modified: incubator/activemq/trunk/assembly/src/test/java/org/apache/activemq/config/ConfigTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/assembly/src/test/java/org/apache/activemq/config/ConfigTest.java?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/assembly/src/test/java/org/apache/activemq/config/ConfigTest.java (original)
+++ incubator/activemq/trunk/assembly/src/test/java/org/apache/activemq/config/ConfigTest.java Wed Mar 8 16:41:39 2006
@@ -106,9 +106,9 @@
// Check spring configured wire format factory
WireFormat myWireFormat = myTransportServer.getWireFormatFactory().createWireFormat();
assertTrue("WireFormat should be OpenWireFormat", myWireFormat instanceof OpenWireFormat);
- assertEquals("WireFormat Config Error (stackTraceEnabled)", false, ((OpenWireFormat)myWireFormat).isStackTraceEnabled());
- assertEquals("WireFormat Config Error (tcpNoDelayEnabled)", true, ((OpenWireFormat)myWireFormat).isTcpNoDelayEnabled());
- assertEquals("WireFormat Config Error (cacheEnabled)", false, ((OpenWireFormat)myWireFormat).isCacheEnabled());
+ assertEquals("WireFormat Config Error (stackTraceEnabled)", false, ((OpenWireFormat)myWireFormat).getPreferedWireFormatInfo().isStackTraceEnabled());
+ assertEquals("WireFormat Config Error (tcpNoDelayEnabled)", true, ((OpenWireFormat)myWireFormat).getPreferedWireFormatInfo().isTcpNoDelayEnabled());
+ assertEquals("WireFormat Config Error (cacheEnabled)", false, ((OpenWireFormat)myWireFormat).getPreferedWireFormatInfo().isCacheEnabled());
System.out.println("Success");
// Check network connectors
Modified: incubator/activemq/trunk/openwire-cpp/src/command/ConnectionError.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ConnectionError.hpp?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ConnectionError.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ConnectionError.hpp Wed Mar 8 16:41:39 2006
@@ -1 +1,81 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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 ConnectionError_hpp_
#define ConnectionError_hpp_
#include <string>
#include "command/BaseCommand.hpp"
#include "BrokerError.hpp"
#include "command/ConnectionId.hpp"
#include "util/ifr/ap.hpp"
#include "util/ifr/p.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace command
{
using na
mespace ifr;
using namespace std;
using namespace apache::activemq::client;
/*
*
* Marshalling code for Open Wire Format for ConnectionError
*
*
* 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
*
*/
class ConnectionError : public BaseCommand
{
private:
p<BrokerError> exception ;
p<ConnectionId> connectionId ;
public:
const static int TYPE = 16;
public:
ConnectionError() ;
virtual ~ConnectionError() ;
virtual int getCommandType() ;
virtual p<BrokerError> getException() ;
virtual void setException(p<BrokerError> exception) ;
virtual p<ConnectionId> getConnectionId() ;
virtual void setConnectionId(p<ConnectionId> connectionId) ;
} ;
/* namespace */
}
}
}
}
#endif /*ConnectionError_hpp_*/
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 ConnectionError_hpp_
+#define ConnectionError_hpp_
+
+#include <string>
+#include "command/BaseCommand.hpp"
+
+#include "BrokerError.hpp"
+#include "command/ConnectionId.hpp"
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq::client;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for ConnectionError
+ *
+ *
+ * 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
+ *
+ */
+class ConnectionError : public BaseCommand
+{
+private:
+ p<BrokerError> exception ;
+ p<ConnectionId> connectionId ;
+
+public:
+ const static int TYPE = 16;
+
+public:
+ ConnectionError() ;
+ virtual ~ConnectionError() ;
+
+ virtual int getCommandType() ;
+
+ virtual p<BrokerError> getException() ;
+ virtual void setException(p<BrokerError> exception) ;
+
+ virtual p<ConnectionId> getConnectionId() ;
+ virtual void setConnectionId(p<ConnectionId> connectionId) ;
+
+
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+
+#endif /*ConnectionError_hpp_*/
Modified: incubator/activemq/trunk/openwire-cpp/src/command/ControlCommand.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/ControlCommand.hpp?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/ControlCommand.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/ControlCommand.hpp Wed Mar 8 16:41:39 2006
@@ -1 +1,75 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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 ControlCommand_hpp_
#define ControlCommand_hpp_
#include <string>
#include "command/BaseCommand.hpp"
#include "util/ifr/ap.hpp"
#include "util/ifr/p.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace command
{
using namespace ifr;
using namespace std;
using namespace
apache::activemq::client;
/*
*
* Marshalling code for Open Wire Format for ControlCommand
*
*
* 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
*
*/
class ControlCommand : public BaseCommand
{
private:
p<string> command ;
public:
const static int TYPE = 14;
public:
ControlCommand() ;
virtual ~ControlCommand() ;
virtual int getCommandType() ;
virtual p<string> getCommand() ;
virtual void setCommand(p<string> command) ;
} ;
/* namespace */
}
}
}
}
#endif /*ControlCommand_hpp_*/
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 ControlCommand_hpp_
+#define ControlCommand_hpp_
+
+#include <string>
+#include "command/BaseCommand.hpp"
+
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq::client;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for ControlCommand
+ *
+ *
+ * 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
+ *
+ */
+class ControlCommand : public BaseCommand
+{
+private:
+ p<string> command ;
+
+public:
+ const static int TYPE = 14;
+
+public:
+ ControlCommand() ;
+ virtual ~ControlCommand() ;
+
+ virtual int getCommandType() ;
+
+ virtual p<string> getCommand() ;
+ virtual void setCommand(p<string> command) ;
+
+
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+
+#endif /*ControlCommand_hpp_*/
Modified: incubator/activemq/trunk/openwire-cpp/src/command/DataArrayResponse.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/DataArrayResponse.hpp?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/DataArrayResponse.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/DataArrayResponse.hpp Wed Mar 8 16:41:39 2006
@@ -1 +1,76 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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 DataArrayResponse_hpp_
#define DataArrayResponse_hpp_
#include <string>
#include "command/Response.hpp"
#include "command/IDataStructure.hpp"
#include "util/ifr/ap.hpp"
#include "util/ifr/p.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace command
{
using namespace ifr;
usi
ng namespace std;
using namespace apache::activemq::client;
/*
*
* Marshalling code for Open Wire Format for DataArrayResponse
*
*
* 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
*
*/
class DataArrayResponse : public Response
{
private:
ap<IDataStructure> data ;
public:
const static int TYPE = 33;
public:
DataArrayResponse() ;
virtual ~DataArrayResponse() ;
virtual int getCommandType() ;
virtual ap<IDataStructure> getData() ;
virtual void setData(ap<IDataStructure> data) ;
} ;
/* namespace */
}
}
}
}
#endif /*DataArrayResponse_hpp_*/
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 DataArrayResponse_hpp_
+#define DataArrayResponse_hpp_
+
+#include <string>
+#include "command/Response.hpp"
+
+#include "command/IDataStructure.hpp"
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq::client;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for DataArrayResponse
+ *
+ *
+ * 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
+ *
+ */
+class DataArrayResponse : public Response
+{
+private:
+ ap<IDataStructure> data ;
+
+public:
+ const static int TYPE = 33;
+
+public:
+ DataArrayResponse() ;
+ virtual ~DataArrayResponse() ;
+
+ virtual int getCommandType() ;
+
+ virtual ap<IDataStructure> getData() ;
+ virtual void setData(ap<IDataStructure> data) ;
+
+
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+
+#endif /*DataArrayResponse_hpp_*/
Modified: incubator/activemq/trunk/openwire-cpp/src/command/DataResponse.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/DataResponse.hpp?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/DataResponse.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/DataResponse.hpp Wed Mar 8 16:41:39 2006
@@ -1 +1,76 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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 DataResponse_hpp_
#define DataResponse_hpp_
#include <string>
#include "command/Response.hpp"
#include "command/IDataStructure.hpp"
#include "util/ifr/ap.hpp"
#include "util/ifr/p.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace command
{
using namespace ifr;
using namespa
ce std;
using namespace apache::activemq::client;
/*
*
* Marshalling code for Open Wire Format for DataResponse
*
*
* 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
*
*/
class DataResponse : public Response
{
private:
p<IDataStructure> data ;
public:
const static int TYPE = 32;
public:
DataResponse() ;
virtual ~DataResponse() ;
virtual int getCommandType() ;
virtual p<IDataStructure> getData() ;
virtual void setData(p<IDataStructure> data) ;
} ;
/* namespace */
}
}
}
}
#endif /*DataResponse_hpp_*/
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 DataResponse_hpp_
+#define DataResponse_hpp_
+
+#include <string>
+#include "command/Response.hpp"
+
+#include "command/IDataStructure.hpp"
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq::client;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for DataResponse
+ *
+ *
+ * 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
+ *
+ */
+class DataResponse : public Response
+{
+private:
+ p<IDataStructure> data ;
+
+public:
+ const static int TYPE = 32;
+
+public:
+ DataResponse() ;
+ virtual ~DataResponse() ;
+
+ virtual int getCommandType() ;
+
+ virtual p<IDataStructure> getData() ;
+ virtual void setData(p<IDataStructure> data) ;
+
+
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+
+#endif /*DataResponse_hpp_*/
Modified: incubator/activemq/trunk/openwire-cpp/src/command/DestinationInfo.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/DestinationInfo.hpp?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/DestinationInfo.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/DestinationInfo.hpp Wed Mar 8 16:41:39 2006
@@ -1 +1,94 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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 DestinationInfo_hpp_
#define DestinationInfo_hpp_
#include <string>
#include "command/BaseCommand.hpp"
#include "command/ConnectionId.hpp"
#include "command/ActiveMQDestination.hpp"
#include "command/BrokerId.hpp"
#include "util/ifr/ap.hpp"
#include "util/ifr/p.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace command
{
using namespace ifr;
using namespace std;
using namespace apache::activemq::client;
/*
*
* Marshalling code for Open Wire Format for DestinationInfo
*
*
* 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
*
*/
class DestinationInfo : public BaseCommand
{
private:
p<ConnectionId> connectionId ;
p<ActiveMQDestination> destination ;
char operationType ;
long long timeout ;
ap<BrokerId> brokerPath ;
public:
const static int TYPE = 8;
public:
DestinationInfo() ;
virtual ~DestinationInfo() ;
virtual int getCommandType() ;
virtual p<ConnectionId> getConnectionId() ;
virtual void setConnectionId(p<ConnectionId> connectionId) ;
virtual p<ActiveMQDestination> getDestination() ;
virtual void setDestination(p<ActiveMQDestination> destination) ;
virtual
char getOperationType() ;
virtual void setOperationType(char operationType) ;
virtual long long getTimeout() ;
virtual void setTimeout(long long timeout) ;
virtual ap<BrokerId> getBrokerPath() ;
virtual void setBrokerPath(ap<BrokerId> brokerPath) ;
} ;
/* namespace */
}
}
}
}
#endif /*DestinationInfo_hpp_*/
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 DestinationInfo_hpp_
+#define DestinationInfo_hpp_
+
+#include <string>
+#include "command/BaseCommand.hpp"
+
+#include "command/ConnectionId.hpp"
+#include "command/ActiveMQDestination.hpp"
+#include "command/BrokerId.hpp"
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq::client;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for DestinationInfo
+ *
+ *
+ * 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
+ *
+ */
+class DestinationInfo : public BaseCommand
+{
+private:
+ p<ConnectionId> connectionId ;
+ p<ActiveMQDestination> destination ;
+ char operationType ;
+ long long timeout ;
+ ap<BrokerId> brokerPath ;
+
+public:
+ const static int TYPE = 8;
+
+public:
+ DestinationInfo() ;
+ virtual ~DestinationInfo() ;
+
+ virtual int getCommandType() ;
+
+ virtual p<ConnectionId> getConnectionId() ;
+ virtual void setConnectionId(p<ConnectionId> connectionId) ;
+
+ virtual p<ActiveMQDestination> getDestination() ;
+ virtual void setDestination(p<ActiveMQDestination> destination) ;
+
+ virtual char getOperationType() ;
+ virtual void setOperationType(char operationType) ;
+
+ virtual long long getTimeout() ;
+ virtual void setTimeout(long long timeout) ;
+
+ virtual ap<BrokerId> getBrokerPath() ;
+ virtual void setBrokerPath(ap<BrokerId> brokerPath) ;
+
+
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+
+#endif /*DestinationInfo_hpp_*/
Modified: incubator/activemq/trunk/openwire-cpp/src/command/DiscoveryEvent.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/DiscoveryEvent.hpp?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/DiscoveryEvent.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/DiscoveryEvent.hpp Wed Mar 8 16:41:39 2006
@@ -1 +1,79 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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 DiscoveryEvent_hpp_
#define DiscoveryEvent_hpp_
#include <string>
#include "command/AbstractCommand.hpp"
#include "util/ifr/ap.hpp"
#include "util/ifr/p.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace command
{
using namespace ifr;
using namespace std;
using names
pace apache::activemq::client;
/*
*
* Marshalling code for Open Wire Format for DiscoveryEvent
*
*
* 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
*
*/
class DiscoveryEvent : public AbstractCommand
{
private:
p<string> serviceName ;
p<string> brokerName ;
public:
const static int TYPE = 40;
public:
DiscoveryEvent() ;
virtual ~DiscoveryEvent() ;
virtual int getCommandType() ;
virtual p<string> getServiceName() ;
virtual void setServiceName(p<string> serviceName) ;
virtual p<string> getBrokerName() ;
virtual void setBrokerName(p<string> brokerName) ;
} ;
/* namespace */
}
}
}
}
#endif /*DiscoveryEvent_hpp_*/
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 DiscoveryEvent_hpp_
+#define DiscoveryEvent_hpp_
+
+#include <string>
+#include "command/AbstractCommand.hpp"
+
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq::client;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for DiscoveryEvent
+ *
+ *
+ * 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
+ *
+ */
+class DiscoveryEvent : public AbstractCommand
+{
+private:
+ p<string> serviceName ;
+ p<string> brokerName ;
+
+public:
+ const static int TYPE = 40;
+
+public:
+ DiscoveryEvent() ;
+ virtual ~DiscoveryEvent() ;
+
+ virtual int getCommandType() ;
+
+ virtual p<string> getServiceName() ;
+ virtual void setServiceName(p<string> serviceName) ;
+
+ virtual p<string> getBrokerName() ;
+ virtual void setBrokerName(p<string> brokerName) ;
+
+
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+
+#endif /*DiscoveryEvent_hpp_*/
Modified: incubator/activemq/trunk/openwire-cpp/src/command/FlushCommand.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/FlushCommand.hpp?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/FlushCommand.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/FlushCommand.hpp Wed Mar 8 16:41:39 2006
@@ -1 +1,71 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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 FlushCommand_hpp_
#define FlushCommand_hpp_
#include <string>
#include "command/BaseCommand.hpp"
#include "util/ifr/ap.hpp"
#include "util/ifr/p.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace command
{
using namespace ifr;
using namespace std;
using namespace apa
che::activemq::client;
/*
*
* Marshalling code for Open Wire Format for FlushCommand
*
*
* 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
*
*/
class FlushCommand : public BaseCommand
{
private:
public:
const static int TYPE = 15;
public:
FlushCommand() ;
virtual ~FlushCommand() ;
virtual int getCommandType() ;
} ;
/* namespace */
}
}
}
}
#endif /*FlushCommand_hpp_*/
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 FlushCommand_hpp_
+#define FlushCommand_hpp_
+
+#include <string>
+#include "command/BaseCommand.hpp"
+
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq::client;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for FlushCommand
+ *
+ *
+ * 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
+ *
+ */
+class FlushCommand : public BaseCommand
+{
+private:
+
+public:
+ const static int TYPE = 15;
+
+public:
+ FlushCommand() ;
+ virtual ~FlushCommand() ;
+
+ virtual int getCommandType() ;
+
+
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+
+#endif /*FlushCommand_hpp_*/
Modified: incubator/activemq/trunk/openwire-cpp/src/command/IntegerResponse.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/IntegerResponse.hpp?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/IntegerResponse.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/IntegerResponse.hpp Wed Mar 8 16:41:39 2006
@@ -1 +1,75 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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 IntegerResponse_hpp_
#define IntegerResponse_hpp_
#include <string>
#include "command/Response.hpp"
#include "util/ifr/ap.hpp"
#include "util/ifr/p.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace command
{
using namespace ifr;
using namespace std;
using namespace
apache::activemq::client;
/*
*
* Marshalling code for Open Wire Format for IntegerResponse
*
*
* 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
*
*/
class IntegerResponse : public Response
{
private:
int result ;
public:
const static int TYPE = 34;
public:
IntegerResponse() ;
virtual ~IntegerResponse() ;
virtual int getCommandType() ;
virtual int getResult() ;
virtual void setResult(int result) ;
} ;
/* namespace */
}
}
}
}
#endif /*IntegerResponse_hpp_*/
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 IntegerResponse_hpp_
+#define IntegerResponse_hpp_
+
+#include <string>
+#include "command/Response.hpp"
+
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq::client;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for IntegerResponse
+ *
+ *
+ * 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
+ *
+ */
+class IntegerResponse : public Response
+{
+private:
+ int result ;
+
+public:
+ const static int TYPE = 34;
+
+public:
+ IntegerResponse() ;
+ virtual ~IntegerResponse() ;
+
+ virtual int getCommandType() ;
+
+ virtual int getResult() ;
+ virtual void setResult(int result) ;
+
+
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+
+#endif /*IntegerResponse_hpp_*/
Modified: incubator/activemq/trunk/openwire-cpp/src/command/JournalQueueAck.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/JournalQueueAck.hpp?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/JournalQueueAck.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/JournalQueueAck.hpp Wed Mar 8 16:41:39 2006
@@ -1 +1,81 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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 JournalQueueAck_hpp_
#define JournalQueueAck_hpp_
#include <string>
#include "command/AbstractCommand.hpp"
#include "command/ActiveMQDestination.hpp"
#include "command/MessageAck.hpp"
#include "util/ifr/ap.hpp"
#include "util/ifr/p.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace command
{
using namespace ifr;
using namespace std;
using namespace apache::activemq::client;
/*
*
* Marshalling code for Open Wire Format for JournalQueueAck
*
*
* 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
*
*/
class JournalQueueAck : public AbstractCommand
{
private:
p<ActiveMQDestination> destination ;
p<MessageAck> messageAck ;
public:
const static int TYPE = 52;
public:
JournalQueueAck() ;
virtual ~JournalQueueAck() ;
virtual int getCommandType() ;
virtual p<ActiveMQDestination> getDestination() ;
virtual void setDestination(p<ActiveMQDestination> destination) ;
virtual p<MessageAck> getMessageAck() ;
virtual void setMessageAck(p<MessageAck> messageAck) ;
} ;
/* namespace */
}
}
}
}
#endif /*JournalQueueAck_hpp_*/
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 JournalQueueAck_hpp_
+#define JournalQueueAck_hpp_
+
+#include <string>
+#include "command/AbstractCommand.hpp"
+
+#include "command/ActiveMQDestination.hpp"
+#include "command/MessageAck.hpp"
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq::client;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for JournalQueueAck
+ *
+ *
+ * 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
+ *
+ */
+class JournalQueueAck : public AbstractCommand
+{
+private:
+ p<ActiveMQDestination> destination ;
+ p<MessageAck> messageAck ;
+
+public:
+ const static int TYPE = 52;
+
+public:
+ JournalQueueAck() ;
+ virtual ~JournalQueueAck() ;
+
+ virtual int getCommandType() ;
+
+ virtual p<ActiveMQDestination> getDestination() ;
+ virtual void setDestination(p<ActiveMQDestination> destination) ;
+
+ virtual p<MessageAck> getMessageAck() ;
+ virtual void setMessageAck(p<MessageAck> messageAck) ;
+
+
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+
+#endif /*JournalQueueAck_hpp_*/
Modified: incubator/activemq/trunk/openwire-cpp/src/command/JournalTopicAck.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/JournalTopicAck.hpp?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/JournalTopicAck.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/JournalTopicAck.hpp Wed Mar 8 16:41:39 2006
@@ -1 +1,98 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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 JournalTopicAck_hpp_
#define JournalTopicAck_hpp_
#include <string>
#include "command/AbstractCommand.hpp"
#include "command/ActiveMQDestination.hpp"
#include "command/MessageId.hpp"
#include "command/TransactionId.hpp"
#include "util/ifr/ap.hpp"
#include "util/ifr/p.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace command
{
using namespace ifr;
using namespace std;
using namespace apache::activemq::client;
/*
*
* Marshalling code for Open Wire Format for JournalTopicAck
*
*
* 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
*
*/
class JournalTopicAck : public AbstractCommand
{
private:
p<ActiveMQDestination> destination ;
p<MessageId> messageId ;
long long messageSequenceId ;
p<string> subscritionName ;
p<string> clientId ;
p<TransactionId> transactionId ;
public:
const static int TYPE = 50;
public:
JournalTopicAck() ;
virtual ~JournalTopicAck() ;
virtual int getCommandType() ;
virtual p<ActiveMQDestination> getDestination() ;
virtual void setDestination(p<ActiveMQDestination> destination) ;
virtual p<MessageId> getMessageId() ;
virtual void setMessageId
(p<MessageId> messageId) ;
virtual long long getMessageSequenceId() ;
virtual void setMessageSequenceId(long long messageSequenceId) ;
virtual p<string> getSubscritionName() ;
virtual void setSubscritionName(p<string> subscritionName) ;
virtual p<string> getClientId() ;
virtual void setClientId(p<string> clientId) ;
virtual p<TransactionId> getTransactionId() ;
virtual void setTransactionId(p<TransactionId> transactionId) ;
} ;
/* namespace */
}
}
}
}
#endif /*JournalTopicAck_hpp_*/
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 JournalTopicAck_hpp_
+#define JournalTopicAck_hpp_
+
+#include <string>
+#include "command/AbstractCommand.hpp"
+
+#include "command/ActiveMQDestination.hpp"
+#include "command/MessageId.hpp"
+#include "command/TransactionId.hpp"
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq::client;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for JournalTopicAck
+ *
+ *
+ * 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
+ *
+ */
+class JournalTopicAck : public AbstractCommand
+{
+private:
+ p<ActiveMQDestination> destination ;
+ p<MessageId> messageId ;
+ long long messageSequenceId ;
+ p<string> subscritionName ;
+ p<string> clientId ;
+ p<TransactionId> transactionId ;
+
+public:
+ const static int TYPE = 50;
+
+public:
+ JournalTopicAck() ;
+ virtual ~JournalTopicAck() ;
+
+ virtual int getCommandType() ;
+
+ virtual p<ActiveMQDestination> getDestination() ;
+ virtual void setDestination(p<ActiveMQDestination> destination) ;
+
+ virtual p<MessageId> getMessageId() ;
+ virtual void setMessageId(p<MessageId> messageId) ;
+
+ virtual long long getMessageSequenceId() ;
+ virtual void setMessageSequenceId(long long messageSequenceId) ;
+
+ virtual p<string> getSubscritionName() ;
+ virtual void setSubscritionName(p<string> subscritionName) ;
+
+ virtual p<string> getClientId() ;
+ virtual void setClientId(p<string> clientId) ;
+
+ virtual p<TransactionId> getTransactionId() ;
+ virtual void setTransactionId(p<TransactionId> transactionId) ;
+
+
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+
+#endif /*JournalTopicAck_hpp_*/
Modified: incubator/activemq/trunk/openwire-cpp/src/command/JournalTrace.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/JournalTrace.hpp?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/JournalTrace.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/JournalTrace.hpp Wed Mar 8 16:41:39 2006
@@ -1 +1,75 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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 JournalTrace_hpp_
#define JournalTrace_hpp_
#include <string>
#include "command/AbstractCommand.hpp"
#include "util/ifr/ap.hpp"
#include "util/ifr/p.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace command
{
using namespace ifr;
using namespace std;
using namespace
apache::activemq::client;
/*
*
* Marshalling code for Open Wire Format for JournalTrace
*
*
* NOTE!: This file is autogenerated - do not modify!
* if you need to make a change, please see the Groovy scripts in the
* activemq-core module
*
*/
class JournalTrace : public AbstractCommand
{
private:
p<string> message ;
public:
const static int TYPE = 53;
public:
JournalTrace() ;
virtual ~JournalTrace() ;
virtual int getCommandType() ;
virtual p<string> getMessage() ;
virtual void setMessage(p<string> message) ;
} ;
/* namespace */
}
}
}
}
#endif /*JournalTrace_hpp_*/
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 JournalTrace_hpp_
+#define JournalTrace_hpp_
+
+#include <string>
+#include "command/AbstractCommand.hpp"
+
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq::client;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for JournalTrace
+ *
+ *
+ * NOTE!: This file is autogenerated - do not modify!
+ * if you need to make a change, please see the Groovy scripts in the
+ * activemq-core module
+ *
+ */
+class JournalTrace : public AbstractCommand
+{
+private:
+ p<string> message ;
+
+public:
+ const static int TYPE = 53;
+
+public:
+ JournalTrace() ;
+ virtual ~JournalTrace() ;
+
+ virtual int getCommandType() ;
+
+ virtual p<string> getMessage() ;
+ virtual void setMessage(p<string> message) ;
+
+
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+
+#endif /*JournalTrace_hpp_*/
Modified: incubator/activemq/trunk/openwire-cpp/src/command/JournalTransaction.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/JournalTransaction.hpp?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/JournalTransaction.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/JournalTransaction.hpp Wed Mar 8 16:41:39 2006
@@ -1 +1,84 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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 JournalTransaction_hpp_
#define JournalTransaction_hpp_
#include <string>
#include "command/AbstractCommand.hpp"
#include "command/TransactionId.hpp"
#include "util/ifr/ap.hpp"
#include "util/ifr/p.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace command
{
using namespace ifr;
using namespace std;
using namespace apache::activemq::client;
/*
*
* Marshalling code for Open Wire Format for JournalTransaction
*
*
* NOTE!: This file is autogenerated - do not modify!
* if you need to make a change, please see the Groovy scripts in the
* activemq-core module
*
*/
class JournalTransaction : public AbstractCommand
{
private:
p<TransactionId> transactionId ;
char type ;
bool wasPrepared ;
public:
const static int TYPE = 54;
public:
JournalTransaction() ;
virtual ~JournalTransaction() ;
virtual int getCommandType() ;
virtual p<TransactionId> getTransactionId() ;
virtual void setTransactionId(p<TransactionId> transactionId) ;
virtual char getType() ;
virtual void setType(char type) ;
virtual bool getWasPrepared() ;
virtual void setWasPrepared(bool wasPrepared) ;
} ;
/* namespace */
}
}
}
}
#endif /*JournalTransaction_hpp_*/
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 JournalTransaction_hpp_
+#define JournalTransaction_hpp_
+
+#include <string>
+#include "command/AbstractCommand.hpp"
+
+#include "command/TransactionId.hpp"
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq::client;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for JournalTransaction
+ *
+ *
+ * NOTE!: This file is autogenerated - do not modify!
+ * if you need to make a change, please see the Groovy scripts in the
+ * activemq-core module
+ *
+ */
+class JournalTransaction : public AbstractCommand
+{
+private:
+ p<TransactionId> transactionId ;
+ char type ;
+ bool wasPrepared ;
+
+public:
+ const static int TYPE = 54;
+
+public:
+ JournalTransaction() ;
+ virtual ~JournalTransaction() ;
+
+ virtual int getCommandType() ;
+
+ virtual p<TransactionId> getTransactionId() ;
+ virtual void setTransactionId(p<TransactionId> transactionId) ;
+
+ virtual char getType() ;
+ virtual void setType(char type) ;
+
+ virtual bool getWasPrepared() ;
+ virtual void setWasPrepared(bool wasPrepared) ;
+
+
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+
+#endif /*JournalTransaction_hpp_*/
Modified: incubator/activemq/trunk/openwire-cpp/src/command/KeepAliveInfo.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/KeepAliveInfo.hpp?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/KeepAliveInfo.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/KeepAliveInfo.hpp Wed Mar 8 16:41:39 2006
@@ -1 +1,71 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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 KeepAliveInfo_hpp_
#define KeepAliveInfo_hpp_
#include <string>
#include "command/AbstractCommand.hpp"
#include "util/ifr/ap.hpp"
#include "util/ifr/p.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace command
{
using namespace ifr;
using namespace std;
using namespa
ce apache::activemq::client;
/*
*
* Marshalling code for Open Wire Format for KeepAliveInfo
*
*
* NOTE!: This file is autogenerated - do not modify!
* if you need to make a change, please see the Groovy scripts in the
* activemq-core module
*
*/
class KeepAliveInfo : public AbstractCommand
{
private:
public:
const static int TYPE = 10;
public:
KeepAliveInfo() ;
virtual ~KeepAliveInfo() ;
virtual int getCommandType() ;
} ;
/* namespace */
}
}
}
}
#endif /*KeepAliveInfo_hpp_*/
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 KeepAliveInfo_hpp_
+#define KeepAliveInfo_hpp_
+
+#include <string>
+#include "command/AbstractCommand.hpp"
+
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq::client;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for KeepAliveInfo
+ *
+ *
+ * NOTE!: This file is autogenerated - do not modify!
+ * if you need to make a change, please see the Groovy scripts in the
+ * activemq-core module
+ *
+ */
+class KeepAliveInfo : public AbstractCommand
+{
+private:
+
+public:
+ const static int TYPE = 10;
+
+public:
+ KeepAliveInfo() ;
+ virtual ~KeepAliveInfo() ;
+
+ virtual int getCommandType() ;
+
+
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+
+#endif /*KeepAliveInfo_hpp_*/
Modified: incubator/activemq/trunk/openwire-cpp/src/command/LocalTransactionId.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/LocalTransactionId.hpp?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/LocalTransactionId.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/LocalTransactionId.hpp Wed Mar 8 16:41:39 2006
@@ -1 +1,80 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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 LocalTransactionId_hpp_
#define LocalTransactionId_hpp_
#include <string>
#include "command/TransactionId.hpp"
#include "command/ConnectionId.hpp"
#include "util/ifr/ap.hpp"
#include "util/ifr/p.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace command
{
using namespace ifr;
using namespace std;
using namespace apache::activemq::client;
/*
*
* Marshalling code for Open Wire Format for LocalTransactionId
*
*
* NOTE!: This file is autogenerated - do not modify!
* if you need to make a change, please see the Groovy scripts in the
* activemq-core module
*
*/
class LocalTransactionId : public TransactionId
{
private:
long long value ;
p<ConnectionId> connectionId ;
public:
const static int TYPE = 111;
public:
LocalTransactionId() ;
virtual ~LocalTransactionId() ;
virtual int getCommandType() ;
virtual long long getValue() ;
virtual void setValue(long long value) ;
virtual p<ConnectionId> getConnectionId() ;
virtual void setConnectionId(p<ConnectionId> connectionId) ;
} ;
/* namespace */
}
}
}
}
#endif /*LocalTransactionId_hpp_*/
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 LocalTransactionId_hpp_
+#define LocalTransactionId_hpp_
+
+#include <string>
+#include "command/TransactionId.hpp"
+
+#include "command/ConnectionId.hpp"
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq::client;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for LocalTransactionId
+ *
+ *
+ * NOTE!: This file is autogenerated - do not modify!
+ * if you need to make a change, please see the Groovy scripts in the
+ * activemq-core module
+ *
+ */
+class LocalTransactionId : public TransactionId
+{
+private:
+ long long value ;
+ p<ConnectionId> connectionId ;
+
+public:
+ const static int TYPE = 111;
+
+public:
+ LocalTransactionId() ;
+ virtual ~LocalTransactionId() ;
+
+ virtual int getCommandType() ;
+
+ virtual long long getValue() ;
+ virtual void setValue(long long value) ;
+
+ virtual p<ConnectionId> getConnectionId() ;
+ virtual void setConnectionId(p<ConnectionId> connectionId) ;
+
+
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+
+#endif /*LocalTransactionId_hpp_*/
Modified: incubator/activemq/trunk/openwire-cpp/src/command/MessageDispatch.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/MessageDispatch.hpp?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/MessageDispatch.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/MessageDispatch.hpp Wed Mar 8 16:41:39 2006
@@ -1 +1,90 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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 MessageDispatch_hpp_
#define MessageDispatch_hpp_
#include <string>
#include "command/BaseCommand.hpp"
#include "command/ConsumerId.hpp"
#include "command/ActiveMQDestination.hpp"
#include "command/Message.hpp"
#include "util/ifr/ap.hpp"
#include "util/ifr/p.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace command
{
using namespace ifr;
using namespace std;
using namespace apache::activemq::client;
/*
*
* Marshalling code for Open Wire Format for MessageDispatch
*
*
* NOTE!: This file is autogenerated - do not modify!
* if you need to make a change, please see the Groovy scripts in the
* activemq-core module
*
*/
class MessageDispatch : public BaseCommand
{
private:
p<ConsumerId> consumerId ;
p<ActiveMQDestination> destination ;
p<Message> message ;
int redeliveryCounter ;
public:
const static int TYPE = 21;
public:
MessageDispatch() ;
virtual ~MessageDispatch() ;
virtual int getCommandType() ;
virtual p<ConsumerId> getConsumerId() ;
virtual void setConsumerId(p<ConsumerId> consumerId) ;
virtual p<ActiveMQDestination> getDestination() ;
virtual void setDestination(p<ActiveMQDestination> destination) ;
virtual p<Message> getMessage() ;
virtual voi
d setMessage(p<Message> message) ;
virtual int getRedeliveryCounter() ;
virtual void setRedeliveryCounter(int redeliveryCounter) ;
} ;
/* namespace */
}
}
}
}
#endif /*MessageDispatch_hpp_*/
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 MessageDispatch_hpp_
+#define MessageDispatch_hpp_
+
+#include <string>
+#include "command/BaseCommand.hpp"
+
+#include "command/ConsumerId.hpp"
+#include "command/ActiveMQDestination.hpp"
+#include "command/Message.hpp"
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq::client;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for MessageDispatch
+ *
+ *
+ * NOTE!: This file is autogenerated - do not modify!
+ * if you need to make a change, please see the Groovy scripts in the
+ * activemq-core module
+ *
+ */
+class MessageDispatch : public BaseCommand
+{
+private:
+ p<ConsumerId> consumerId ;
+ p<ActiveMQDestination> destination ;
+ p<Message> message ;
+ int redeliveryCounter ;
+
+public:
+ const static int TYPE = 21;
+
+public:
+ MessageDispatch() ;
+ virtual ~MessageDispatch() ;
+
+ virtual int getCommandType() ;
+
+ virtual p<ConsumerId> getConsumerId() ;
+ virtual void setConsumerId(p<ConsumerId> consumerId) ;
+
+ virtual p<ActiveMQDestination> getDestination() ;
+ virtual void setDestination(p<ActiveMQDestination> destination) ;
+
+ virtual p<Message> getMessage() ;
+ virtual void setMessage(p<Message> message) ;
+
+ virtual int getRedeliveryCounter() ;
+ virtual void setRedeliveryCounter(int redeliveryCounter) ;
+
+
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+
+#endif /*MessageDispatch_hpp_*/
Modified: incubator/activemq/trunk/openwire-cpp/src/command/MessageDispatchNotification.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/MessageDispatchNotification.hpp?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/MessageDispatchNotification.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/MessageDispatchNotification.hpp Wed Mar 8 16:41:39 2006
@@ -1 +1,90 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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 MessageDispatchNotification_hpp_
#define MessageDispatchNotification_hpp_
#include <string>
#include "command/BaseCommand.hpp"
#include "command/ConsumerId.hpp"
#include "command/ActiveMQDestination.hpp"
#include "command/MessageId.hpp"
#include "util/ifr/ap.hpp"
#include "util/ifr/p.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace command
{
using namespace ifr;
using namespace std;
using namespace apache::activemq::client;
/*
*
* Marshalling code for Open Wire Format for MessageDispatchNotification
*
*
* NOTE!: This file is autogenerated - do not modify!
* if you need to make a change, please see the Groovy scripts in the
* activemq-core module
*
*/
class MessageDispatchNotification : public BaseCommand
{
private:
p<ConsumerId> consumerId ;
p<ActiveMQDestination> destination ;
long long deliverySequenceId ;
p<MessageId> messageId ;
public:
const static int TYPE = 90;
public:
MessageDispatchNotification() ;
virtual ~MessageDispatchNotification() ;
virtual int getCommandType() ;
virtual p<ConsumerId> getConsumerId() ;
virtual void setConsumerId(p<ConsumerId> consumerId) ;
virtual p<ActiveMQDestination> getDestination() ;
virtual void setDestination(p<Activ
eMQDestination> destination) ;
virtual long long getDeliverySequenceId() ;
virtual void setDeliverySequenceId(long long deliverySequenceId) ;
virtual p<MessageId> getMessageId() ;
virtual void setMessageId(p<MessageId> messageId) ;
} ;
/* namespace */
}
}
}
}
#endif /*MessageDispatchNotification_hpp_*/
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 MessageDispatchNotification_hpp_
+#define MessageDispatchNotification_hpp_
+
+#include <string>
+#include "command/BaseCommand.hpp"
+
+#include "command/ConsumerId.hpp"
+#include "command/ActiveMQDestination.hpp"
+#include "command/MessageId.hpp"
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq::client;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for MessageDispatchNotification
+ *
+ *
+ * NOTE!: This file is autogenerated - do not modify!
+ * if you need to make a change, please see the Groovy scripts in the
+ * activemq-core module
+ *
+ */
+class MessageDispatchNotification : public BaseCommand
+{
+private:
+ p<ConsumerId> consumerId ;
+ p<ActiveMQDestination> destination ;
+ long long deliverySequenceId ;
+ p<MessageId> messageId ;
+
+public:
+ const static int TYPE = 90;
+
+public:
+ MessageDispatchNotification() ;
+ virtual ~MessageDispatchNotification() ;
+
+ virtual int getCommandType() ;
+
+ virtual p<ConsumerId> getConsumerId() ;
+ virtual void setConsumerId(p<ConsumerId> consumerId) ;
+
+ virtual p<ActiveMQDestination> getDestination() ;
+ virtual void setDestination(p<ActiveMQDestination> destination) ;
+
+ virtual long long getDeliverySequenceId() ;
+ virtual void setDeliverySequenceId(long long deliverySequenceId) ;
+
+ virtual p<MessageId> getMessageId() ;
+ virtual void setMessageId(p<MessageId> messageId) ;
+
+
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+
+#endif /*MessageDispatchNotification_hpp_*/
Modified: incubator/activemq/trunk/openwire-cpp/src/command/MessageId.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/MessageId.hpp?rev=384390&r1=384389&r2=384390&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/MessageId.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/MessageId.hpp Wed Mar 8 16:41:39 2006
@@ -1 +1,84 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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 MessageId_hpp_
#define MessageId_hpp_
#include <string>
#include "command/AbstractCommand.hpp"
#include "command/ProducerId.hpp"
#include "util/ifr/ap.hpp"
#include "util/ifr/p.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace command
{
using namespace ifr;
using namespace
std;
using namespace apache::activemq::client;
/*
*
* Marshalling code for Open Wire Format for MessageId
*
*
* NOTE!: This file is autogenerated - do not modify!
* if you need to make a change, please see the Groovy scripts in the
* activemq-core module
*
*/
class MessageId : public AbstractCommand
{
private:
p<ProducerId> producerId ;
long long producerSequenceId ;
long long brokerSequenceId ;
public:
const static int TYPE = 110;
public:
MessageId() ;
virtual ~MessageId() ;
virtual int getCommandType() ;
virtual p<ProducerId> getProducerId() ;
virtual void setProducerId(p<ProducerId> producerId) ;
virtual long long getProducerSequenceId() ;
virtual void setProducerSequenceId(long long producerSequenceId) ;
virtual long long getBrokerSequenceId() ;
virtual void setBrokerSequenceId(long long brokerSequenceId) ;
} ;
/* namespace */
}
}
}
}
#endif /*MessageId_hpp_*/
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed 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 MessageId_hpp_
+#define MessageId_hpp_
+
+#include <string>
+#include "command/AbstractCommand.hpp"
+
+#include "command/ProducerId.hpp"
+
+#include "util/ifr/ap.hpp"
+#include "util/ifr/p.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace command
+ {
+ using namespace ifr;
+ using namespace std;
+ using namespace apache::activemq::client;
+
+/*
+ *
+ * Marshalling code for Open Wire Format for MessageId
+ *
+ *
+ * NOTE!: This file is autogenerated - do not modify!
+ * if you need to make a change, please see the Groovy scripts in the
+ * activemq-core module
+ *
+ */
+class MessageId : public AbstractCommand
+{
+private:
+ p<ProducerId> producerId ;
+ long long producerSequenceId ;
+ long long brokerSequenceId ;
+
+public:
+ const static int TYPE = 110;
+
+public:
+ MessageId() ;
+ virtual ~MessageId() ;
+
+ virtual int getCommandType() ;
+
+ virtual p<ProducerId> getProducerId() ;
+ virtual void setProducerId(p<ProducerId> producerId) ;
+
+ virtual long long getProducerSequenceId() ;
+ virtual void setProducerSequenceId(long long producerSequenceId) ;
+
+ virtual long long getBrokerSequenceId() ;
+ virtual void setBrokerSequenceId(long long brokerSequenceId) ;
+
+
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+
+#endif /*MessageId_hpp_*/