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/09/27 00:45:19 UTC
svn commit: r450245 [3/4] -
/incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/
Modified: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/JournalQueueAckMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/JournalQueueAckMarshaller.hpp?view=diff&rev=450245&r1=450244&r2=450245
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/JournalQueueAckMarshaller.hpp (original)
+++ incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/JournalQueueAckMarshaller.hpp Tue Sep 26 15:45:16 2006
@@ -1 +1,74 @@
-/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef JournalQueueAckMarshaller_hpp_
#define JournalQueueAckMarshaller_hpp_
#include <string>
#include "command/IDataStructure.hpp"
/* we could cut this down - for now include all possible headers
*/
#include "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"
#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"
#include "command/BaseDataStreamMarshaller.hpp"
#include "util/ifr/p.hpp"
#include "protocol/ProtocolFormat.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace marshal
{
using namespace ifr ;
using namespace apache::activemq::client::command;
using namespace apache::activemq::client::io;
using namespace apache::activemq::client::protocol;
/*
*
*/
class JournalQueueAckMarshaller : public BaseDataStreamMarshaller
{
public:
JournalQueueAckMarshaller() ;
virtual ~JournalQueueAckMarshaller() ;
virtual IDataStructure* createCommand() ;
virtual char getDataStructureType() ;
virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryRe
ader& dataIn, BooleanStream& bs) ;
virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;
/* namespace */
}
}
}
}
#endif /*JournalQueueAckMarshaller_hpp_*/
\ No newline at end of file
+/*
+* Licensed to the Apache Software Foundation (ASF) under one or more
+* contributor license agreements. See the NOTICE file distributed with
+* this work for additional information regarding copyright ownership.
+* The ASF licenses this file to You under the Apache License, Version 2.0
+* (the "License"); you may not use this file except in compliance with
+* the License. You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef JournalQueueAckMarshaller_hpp_
+#define JournalQueueAckMarshaller_hpp_
+
+#include <string>
+
+#include "command/IDataStructure.hpp"
+
+/* we could cut this down - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/BaseDataStreamMarshaller.hpp"
+#include "util/ifr/p.hpp"
+
+#include "protocol/ProtocolFormat.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace marshal
+ {
+ using namespace ifr ;
+ using namespace apache::activemq::client::command;
+ using namespace apache::activemq::client::io;
+ using namespace apache::activemq::client::protocol;
+
+/*
+ *
+ */
+class JournalQueueAckMarshaller : public BaseDataStreamMarshaller
+{
+public:
+ JournalQueueAckMarshaller() ;
+ virtual ~JournalQueueAckMarshaller() ;
+
+ virtual IDataStructure* createCommand() ;
+ virtual char getDataStructureType() ;
+
+ virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+ virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
+ virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+#endif /*JournalQueueAckMarshaller_hpp_*/
Propchange: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/JournalQueueAckMarshaller.hpp
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.hpp?view=diff&rev=450245&r1=450244&r2=450245
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.hpp (original)
+++ incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.hpp Tue Sep 26 15:45:16 2006
@@ -1 +1,74 @@
-/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef JournalTopicAckMarshaller_hpp_
#define JournalTopicAckMarshaller_hpp_
#include <string>
#include "command/IDataStructure.hpp"
/* we could cut this down - for now include all possible headers
*/
#include "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"
#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"
#include "command/BaseDataStreamMarshaller.hpp"
#include "util/ifr/p.hpp"
#include "protocol/ProtocolFormat.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace marshal
{
using namespace ifr ;
using namespace apache::activemq::client::command;
using namespace apache::activemq::client::io;
using namespace apache::activemq::client::protocol;
/*
*
*/
class JournalTopicAckMarshaller : public BaseDataStreamMarshaller
{
public:
JournalTopicAckMarshaller() ;
virtual ~JournalTopicAckMarshaller() ;
virtual IDataStructure* createCommand() ;
virtual char getDataStructureType() ;
virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryRe
ader& dataIn, BooleanStream& bs) ;
virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;
/* namespace */
}
}
}
}
#endif /*JournalTopicAckMarshaller_hpp_*/
\ No newline at end of file
+/*
+* Licensed to the Apache Software Foundation (ASF) under one or more
+* contributor license agreements. See the NOTICE file distributed with
+* this work for additional information regarding copyright ownership.
+* The ASF licenses this file to You under the Apache License, Version 2.0
+* (the "License"); you may not use this file except in compliance with
+* the License. You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef JournalTopicAckMarshaller_hpp_
+#define JournalTopicAckMarshaller_hpp_
+
+#include <string>
+
+#include "command/IDataStructure.hpp"
+
+/* we could cut this down - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/BaseDataStreamMarshaller.hpp"
+#include "util/ifr/p.hpp"
+
+#include "protocol/ProtocolFormat.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace marshal
+ {
+ using namespace ifr ;
+ using namespace apache::activemq::client::command;
+ using namespace apache::activemq::client::io;
+ using namespace apache::activemq::client::protocol;
+
+/*
+ *
+ */
+class JournalTopicAckMarshaller : public BaseDataStreamMarshaller
+{
+public:
+ JournalTopicAckMarshaller() ;
+ virtual ~JournalTopicAckMarshaller() ;
+
+ virtual IDataStructure* createCommand() ;
+ virtual char getDataStructureType() ;
+
+ virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+ virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
+ virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+#endif /*JournalTopicAckMarshaller_hpp_*/
Propchange: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.hpp
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.hpp?view=diff&rev=450245&r1=450244&r2=450245
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.hpp (original)
+++ incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.hpp Tue Sep 26 15:45:16 2006
@@ -1 +1,74 @@
-/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef JournalTraceMarshaller_hpp_
#define JournalTraceMarshaller_hpp_
#include <string>
#include "command/IDataStructure.hpp"
/* we could cut this down - for now include all possible headers */
#i
nclude "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"
#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"
#include "command/BaseDataStreamMarshaller.hpp"
#include "util/ifr/p.hpp"
#include "protocol/ProtocolFormat.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace marshal
{
using namespace ifr ;
using namespace apache::activemq::client::command;
using namespace apache::activemq::client::io;
using namespace apache::activemq::client::protocol;
/*
*
*/
class JournalTraceMarshaller : public BaseDataStreamMarshaller
{
public:
JournalTraceMarshaller() ;
virtual ~JournalTraceMarshaller() ;
virtual IDataStructure* createCommand() ;
virtual char getDataStructureType() ;
virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, B
ooleanStream& bs) ;
virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;
/* namespace */
}
}
}
}
#endif /*JournalTraceMarshaller_hpp_*/
\ No newline at end of file
+/*
+* Licensed to the Apache Software Foundation (ASF) under one or more
+* contributor license agreements. See the NOTICE file distributed with
+* this work for additional information regarding copyright ownership.
+* The ASF licenses this file to You under the Apache License, Version 2.0
+* (the "License"); you may not use this file except in compliance with
+* the License. You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef JournalTraceMarshaller_hpp_
+#define JournalTraceMarshaller_hpp_
+
+#include <string>
+
+#include "command/IDataStructure.hpp"
+
+/* we could cut this down - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/BaseDataStreamMarshaller.hpp"
+#include "util/ifr/p.hpp"
+
+#include "protocol/ProtocolFormat.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace marshal
+ {
+ using namespace ifr ;
+ using namespace apache::activemq::client::command;
+ using namespace apache::activemq::client::io;
+ using namespace apache::activemq::client::protocol;
+
+/*
+ *
+ */
+class JournalTraceMarshaller : public BaseDataStreamMarshaller
+{
+public:
+ JournalTraceMarshaller() ;
+ virtual ~JournalTraceMarshaller() ;
+
+ virtual IDataStructure* createCommand() ;
+ virtual char getDataStructureType() ;
+
+ virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+ virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
+ virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+#endif /*JournalTraceMarshaller_hpp_*/
Propchange: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.hpp
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.hpp?view=diff&rev=450245&r1=450244&r2=450245
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.hpp (original)
+++ incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.hpp Tue Sep 26 15:45:16 2006
@@ -1 +1,74 @@
-/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef JournalTransactionMarshaller_hpp_
#define JournalTransactionMarshaller_hpp_
#include <string>
#include "command/IDataStructure.hpp"
/* we could cut this down - for now include all possible h
eaders */
#include "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"
#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"
#include "command/BaseDataStreamMarshaller.hpp"
#include "util/ifr/p.hpp"
#include "protocol/ProtocolFormat.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace marshal
{
using namespace ifr ;
using namespace apache::activemq::client::command;
using namespace apache::activemq::client::io;
using namespace apache::activemq::client::protocol;
/*
*
*/
class JournalTransactionMarshaller : public BaseDataStreamMarshaller
{
public:
JournalTransactionMarshaller() ;
virtual ~JournalTransactionMarshaller() ;
virtual IDataStructure* createCommand() ;
virtual char getDataStructureType() ;
virtual void unmarshal(ProtocolFormat& wireFormat, Obj
ect o, BinaryReader& dataIn, BooleanStream& bs) ;
virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;
/* namespace */
}
}
}
}
#endif /*JournalTransactionMarshaller_hpp_*/
\ No newline at end of file
+/*
+* Licensed to the Apache Software Foundation (ASF) under one or more
+* contributor license agreements. See the NOTICE file distributed with
+* this work for additional information regarding copyright ownership.
+* The ASF licenses this file to You under the Apache License, Version 2.0
+* (the "License"); you may not use this file except in compliance with
+* the License. You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef JournalTransactionMarshaller_hpp_
+#define JournalTransactionMarshaller_hpp_
+
+#include <string>
+
+#include "command/IDataStructure.hpp"
+
+/* we could cut this down - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/BaseDataStreamMarshaller.hpp"
+#include "util/ifr/p.hpp"
+
+#include "protocol/ProtocolFormat.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace marshal
+ {
+ using namespace ifr ;
+ using namespace apache::activemq::client::command;
+ using namespace apache::activemq::client::io;
+ using namespace apache::activemq::client::protocol;
+
+/*
+ *
+ */
+class JournalTransactionMarshaller : public BaseDataStreamMarshaller
+{
+public:
+ JournalTransactionMarshaller() ;
+ virtual ~JournalTransactionMarshaller() ;
+
+ virtual IDataStructure* createCommand() ;
+ virtual char getDataStructureType() ;
+
+ virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+ virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
+ virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+#endif /*JournalTransactionMarshaller_hpp_*/
Propchange: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.hpp
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.hpp?view=diff&rev=450245&r1=450244&r2=450245
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.hpp (original)
+++ incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.hpp Tue Sep 26 15:45:16 2006
@@ -1 +1,74 @@
-/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef KeepAliveInfoMarshaller_hpp_
#define KeepAliveInfoMarshaller_hpp_
#include <string>
#include "command/IDataStructure.hpp"
/* we could cut this down - for now include all possible headers */
#include "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"
#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"
#include "command/BaseCommandMarshaller.hpp"
#include "util/ifr/p.hpp"
#include "protocol/ProtocolFormat.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace marshal
{
using namespace ifr ;
using namespace apache::activemq::client::command;
using namespace apache::activemq::client::io;
using namespace apache::activemq::client::protocol;
/*
*
*/
class KeepAliveInfoMarshaller : public BaseCommandMarshaller
{
public:
KeepAliveInfoMarshaller() ;
virtual ~KeepAliveInfoMarshaller() ;
virtual IDataStructure* createCommand() ;
virtual char getDataStructureType() ;
virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, Bo
oleanStream& bs) ;
virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;
/* namespace */
}
}
}
}
#endif /*KeepAliveInfoMarshaller_hpp_*/
\ No newline at end of file
+/*
+* Licensed to the Apache Software Foundation (ASF) under one or more
+* contributor license agreements. See the NOTICE file distributed with
+* this work for additional information regarding copyright ownership.
+* The ASF licenses this file to You under the Apache License, Version 2.0
+* (the "License"); you may not use this file except in compliance with
+* the License. You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef KeepAliveInfoMarshaller_hpp_
+#define KeepAliveInfoMarshaller_hpp_
+
+#include <string>
+
+#include "command/IDataStructure.hpp"
+
+/* we could cut this down - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/BaseCommandMarshaller.hpp"
+#include "util/ifr/p.hpp"
+
+#include "protocol/ProtocolFormat.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace marshal
+ {
+ using namespace ifr ;
+ using namespace apache::activemq::client::command;
+ using namespace apache::activemq::client::io;
+ using namespace apache::activemq::client::protocol;
+
+/*
+ *
+ */
+class KeepAliveInfoMarshaller : public BaseCommandMarshaller
+{
+public:
+ KeepAliveInfoMarshaller() ;
+ virtual ~KeepAliveInfoMarshaller() ;
+
+ virtual IDataStructure* createCommand() ;
+ virtual char getDataStructureType() ;
+
+ virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+ virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
+ virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+#endif /*KeepAliveInfoMarshaller_hpp_*/
Propchange: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.hpp
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.hpp?view=diff&rev=450245&r1=450244&r2=450245
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.hpp (original)
+++ incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.hpp Tue Sep 26 15:45:16 2006
@@ -1 +1,74 @@
-/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef LastPartialCommandMarshaller_hpp_
#define LastPartialCommandMarshaller_hpp_
#include <string>
#include "command/IDataStructure.hpp"
/* we could cut this down - for now include all possible h
eaders */
#include "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"
#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"
#include "command/PartialCommandMarshaller.hpp"
#include "util/ifr/p.hpp"
#include "protocol/ProtocolFormat.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace marshal
{
using namespace ifr ;
using namespace apache::activemq::client::command;
using namespace apache::activemq::client::io;
using namespace apache::activemq::client::protocol;
/*
*
*/
class LastPartialCommandMarshaller : public PartialCommandMarshaller
{
public:
LastPartialCommandMarshaller() ;
virtual ~LastPartialCommandMarshaller() ;
virtual IDataStructure* createCommand() ;
virtual char getDataStructureType() ;
virtual void unmarshal(ProtocolFormat& wireFormat, Obj
ect o, BinaryReader& dataIn, BooleanStream& bs) ;
virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;
/* namespace */
}
}
}
}
#endif /*LastPartialCommandMarshaller_hpp_*/
\ No newline at end of file
+/*
+* Licensed to the Apache Software Foundation (ASF) under one or more
+* contributor license agreements. See the NOTICE file distributed with
+* this work for additional information regarding copyright ownership.
+* The ASF licenses this file to You under the Apache License, Version 2.0
+* (the "License"); you may not use this file except in compliance with
+* the License. You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef LastPartialCommandMarshaller_hpp_
+#define LastPartialCommandMarshaller_hpp_
+
+#include <string>
+
+#include "command/IDataStructure.hpp"
+
+/* we could cut this down - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/PartialCommandMarshaller.hpp"
+#include "util/ifr/p.hpp"
+
+#include "protocol/ProtocolFormat.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace marshal
+ {
+ using namespace ifr ;
+ using namespace apache::activemq::client::command;
+ using namespace apache::activemq::client::io;
+ using namespace apache::activemq::client::protocol;
+
+/*
+ *
+ */
+class LastPartialCommandMarshaller : public PartialCommandMarshaller
+{
+public:
+ LastPartialCommandMarshaller() ;
+ virtual ~LastPartialCommandMarshaller() ;
+
+ virtual IDataStructure* createCommand() ;
+ virtual char getDataStructureType() ;
+
+ virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+ virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
+ virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+#endif /*LastPartialCommandMarshaller_hpp_*/
Propchange: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/LastPartialCommandMarshaller.hpp
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.hpp?view=diff&rev=450245&r1=450244&r2=450245
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.hpp (original)
+++ incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.hpp Tue Sep 26 15:45:16 2006
@@ -1 +1,74 @@
-/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef LocalTransactionIdMarshaller_hpp_
#define LocalTransactionIdMarshaller_hpp_
#include <string>
#include "command/IDataStructure.hpp"
/* we could cut this down - for now include all possible h
eaders */
#include "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"
#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"
#include "command/TransactionIdMarshaller.hpp"
#include "util/ifr/p.hpp"
#include "protocol/ProtocolFormat.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace marshal
{
using namespace ifr ;
using namespace apache::activemq::client::command;
using namespace apache::activemq::client::io;
using namespace apache::activemq::client::protocol;
/*
*
*/
class LocalTransactionIdMarshaller : public TransactionIdMarshaller
{
public:
LocalTransactionIdMarshaller() ;
virtual ~LocalTransactionIdMarshaller() ;
virtual IDataStructure* createCommand() ;
virtual char getDataStructureType() ;
virtual void unmarshal(ProtocolFormat& wireFormat, Objec
t o, BinaryReader& dataIn, BooleanStream& bs) ;
virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;
/* namespace */
}
}
}
}
#endif /*LocalTransactionIdMarshaller_hpp_*/
\ No newline at end of file
+/*
+* Licensed to the Apache Software Foundation (ASF) under one or more
+* contributor license agreements. See the NOTICE file distributed with
+* this work for additional information regarding copyright ownership.
+* The ASF licenses this file to You under the Apache License, Version 2.0
+* (the "License"); you may not use this file except in compliance with
+* the License. You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef LocalTransactionIdMarshaller_hpp_
+#define LocalTransactionIdMarshaller_hpp_
+
+#include <string>
+
+#include "command/IDataStructure.hpp"
+
+/* we could cut this down - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/TransactionIdMarshaller.hpp"
+#include "util/ifr/p.hpp"
+
+#include "protocol/ProtocolFormat.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace marshal
+ {
+ using namespace ifr ;
+ using namespace apache::activemq::client::command;
+ using namespace apache::activemq::client::io;
+ using namespace apache::activemq::client::protocol;
+
+/*
+ *
+ */
+class LocalTransactionIdMarshaller : public TransactionIdMarshaller
+{
+public:
+ LocalTransactionIdMarshaller() ;
+ virtual ~LocalTransactionIdMarshaller() ;
+
+ virtual IDataStructure* createCommand() ;
+ virtual char getDataStructureType() ;
+
+ virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+ virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
+ virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+#endif /*LocalTransactionIdMarshaller_hpp_*/
Propchange: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.hpp
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MarshallerFactory.hpp
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.hpp?view=diff&rev=450245&r1=450244&r2=450245
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.hpp (original)
+++ incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.hpp Tue Sep 26 15:45:16 2006
@@ -1 +1,74 @@
-/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef MessageAckMarshaller_hpp_
#define MessageAckMarshaller_hpp_
#include <string>
#include "command/IDataStructure.hpp"
/* we could cut this down - for now include all possible headers */
#inclu
de "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"
#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"
#include "command/BaseCommandMarshaller.hpp"
#include "util/ifr/p.hpp"
#include "protocol/ProtocolFormat.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace marshal
{
using namespace ifr ;
using namespace apache::activemq::client::command;
using namespace apache::activemq::client::io;
using namespace apache::activemq::client::protocol;
/*
*
*/
class MessageAckMarshaller : public BaseCommandMarshaller
{
public:
MessageAckMarshaller() ;
virtual ~MessageAckMarshaller() ;
virtual IDataStructure* createCommand() ;
virtual char getDataStructureType() ;
virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs
) ;
virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;
/* namespace */
}
}
}
}
#endif /*MessageAckMarshaller_hpp_*/
\ No newline at end of file
+/*
+* Licensed to the Apache Software Foundation (ASF) under one or more
+* contributor license agreements. See the NOTICE file distributed with
+* this work for additional information regarding copyright ownership.
+* The ASF licenses this file to You under the Apache License, Version 2.0
+* (the "License"); you may not use this file except in compliance with
+* the License. You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef MessageAckMarshaller_hpp_
+#define MessageAckMarshaller_hpp_
+
+#include <string>
+
+#include "command/IDataStructure.hpp"
+
+/* we could cut this down - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/BaseCommandMarshaller.hpp"
+#include "util/ifr/p.hpp"
+
+#include "protocol/ProtocolFormat.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace marshal
+ {
+ using namespace ifr ;
+ using namespace apache::activemq::client::command;
+ using namespace apache::activemq::client::io;
+ using namespace apache::activemq::client::protocol;
+
+/*
+ *
+ */
+class MessageAckMarshaller : public BaseCommandMarshaller
+{
+public:
+ MessageAckMarshaller() ;
+ virtual ~MessageAckMarshaller() ;
+
+ virtual IDataStructure* createCommand() ;
+ virtual char getDataStructureType() ;
+
+ virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+ virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
+ virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+#endif /*MessageAckMarshaller_hpp_*/
Propchange: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageAckMarshaller.hpp
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.hpp?view=diff&rev=450245&r1=450244&r2=450245
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.hpp (original)
+++ incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.hpp Tue Sep 26 15:45:16 2006
@@ -1 +1,74 @@
-/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef MessageDispatchMarshaller_hpp_
#define MessageDispatchMarshaller_hpp_
#include <string>
#include "command/IDataStructure.hpp"
/* we could cut this down - for now include all possible headers
*/
#include "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"
#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"
#include "command/BaseCommandMarshaller.hpp"
#include "util/ifr/p.hpp"
#include "protocol/ProtocolFormat.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace marshal
{
using namespace ifr ;
using namespace apache::activemq::client::command;
using namespace apache::activemq::client::io;
using namespace apache::activemq::client::protocol;
/*
*
*/
class MessageDispatchMarshaller : public BaseCommandMarshaller
{
public:
MessageDispatchMarshaller() ;
virtual ~MessageDispatchMarshaller() ;
virtual IDataStructure* createCommand() ;
virtual char getDataStructureType() ;
virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader&
dataIn, BooleanStream& bs) ;
virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;
/* namespace */
}
}
}
}
#endif /*MessageDispatchMarshaller_hpp_*/
\ No newline at end of file
+/*
+* Licensed to the Apache Software Foundation (ASF) under one or more
+* contributor license agreements. See the NOTICE file distributed with
+* this work for additional information regarding copyright ownership.
+* The ASF licenses this file to You under the Apache License, Version 2.0
+* (the "License"); you may not use this file except in compliance with
+* the License. You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef MessageDispatchMarshaller_hpp_
+#define MessageDispatchMarshaller_hpp_
+
+#include <string>
+
+#include "command/IDataStructure.hpp"
+
+/* we could cut this down - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/BaseCommandMarshaller.hpp"
+#include "util/ifr/p.hpp"
+
+#include "protocol/ProtocolFormat.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace marshal
+ {
+ using namespace ifr ;
+ using namespace apache::activemq::client::command;
+ using namespace apache::activemq::client::io;
+ using namespace apache::activemq::client::protocol;
+
+/*
+ *
+ */
+class MessageDispatchMarshaller : public BaseCommandMarshaller
+{
+public:
+ MessageDispatchMarshaller() ;
+ virtual ~MessageDispatchMarshaller() ;
+
+ virtual IDataStructure* createCommand() ;
+ virtual char getDataStructureType() ;
+
+ virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+ virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
+ virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+#endif /*MessageDispatchMarshaller_hpp_*/
Propchange: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageDispatchMarshaller.hpp
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.hpp?view=diff&rev=450245&r1=450244&r2=450245
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.hpp (original)
+++ incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.hpp Tue Sep 26 15:45:16 2006
@@ -1 +1,74 @@
-/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef MessageDispatchNotificationMarshaller_hpp_
#define MessageDispatchNotificationMarshaller_hpp_
#include <string>
#include "command/IDataStructure.hpp"
/* we could cut this down - for now incl
ude all possible headers */
#include "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"
#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"
#include "command/BaseCommandMarshaller.hpp"
#include "util/ifr/p.hpp"
#include "protocol/ProtocolFormat.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace marshal
{
using namespace ifr ;
using namespace apache::activemq::client::command;
using namespace apache::activemq::client::io;
using namespace apache::activemq::client::protocol;
/*
*
*/
class MessageDispatchNotificationMarshaller : public BaseCommandMarshaller
{
public:
MessageDispatchNotificationMarshaller() ;
virtual ~MessageDispatchNotificationMarshaller() ;
virtual IDataStructure* createCommand() ;
virtual char getDataStructureType() ;
virtual void un
marshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;
/* namespace */
}
}
}
}
#endif /*MessageDispatchNotificationMarshaller_hpp_*/
\ No newline at end of file
+/*
+* Licensed to the Apache Software Foundation (ASF) under one or more
+* contributor license agreements. See the NOTICE file distributed with
+* this work for additional information regarding copyright ownership.
+* The ASF licenses this file to You under the Apache License, Version 2.0
+* (the "License"); you may not use this file except in compliance with
+* the License. You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef MessageDispatchNotificationMarshaller_hpp_
+#define MessageDispatchNotificationMarshaller_hpp_
+
+#include <string>
+
+#include "command/IDataStructure.hpp"
+
+/* we could cut this down - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/BaseCommandMarshaller.hpp"
+#include "util/ifr/p.hpp"
+
+#include "protocol/ProtocolFormat.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace marshal
+ {
+ using namespace ifr ;
+ using namespace apache::activemq::client::command;
+ using namespace apache::activemq::client::io;
+ using namespace apache::activemq::client::protocol;
+
+/*
+ *
+ */
+class MessageDispatchNotificationMarshaller : public BaseCommandMarshaller
+{
+public:
+ MessageDispatchNotificationMarshaller() ;
+ virtual ~MessageDispatchNotificationMarshaller() ;
+
+ virtual IDataStructure* createCommand() ;
+ virtual char getDataStructureType() ;
+
+ virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+ virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
+ virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+#endif /*MessageDispatchNotificationMarshaller_hpp_*/
Propchange: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageDispatchNotificationMarshaller.hpp
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.hpp?view=diff&rev=450245&r1=450244&r2=450245
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.hpp (original)
+++ incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.hpp Tue Sep 26 15:45:16 2006
@@ -1 +1,74 @@
-/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef MessageIdMarshaller_hpp_
#define MessageIdMarshaller_hpp_
#include <string>
#include "command/IDataStructure.hpp"
/* we could cut this down - for now include all possible headers */
#include
"command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"
#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"
#include "command/BaseDataStreamMarshaller.hpp"
#include "util/ifr/p.hpp"
#include "protocol/ProtocolFormat.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace marshal
{
using namespace ifr ;
using namespace apache::activemq::client::command;
using namespace apache::activemq::client::io;
using namespace apache::activemq::client::protocol;
/*
*
*/
class MessageIdMarshaller : public BaseDataStreamMarshaller
{
public:
MessageIdMarshaller() ;
virtual ~MessageIdMarshaller() ;
virtual IDataStructure* createCommand() ;
virtual char getDataStructureType() ;
virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& b
s) ;
virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;
/* namespace */
}
}
}
}
#endif /*MessageIdMarshaller_hpp_*/
\ No newline at end of file
+/*
+* Licensed to the Apache Software Foundation (ASF) under one or more
+* contributor license agreements. See the NOTICE file distributed with
+* this work for additional information regarding copyright ownership.
+* The ASF licenses this file to You under the Apache License, Version 2.0
+* (the "License"); you may not use this file except in compliance with
+* the License. You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef MessageIdMarshaller_hpp_
+#define MessageIdMarshaller_hpp_
+
+#include <string>
+
+#include "command/IDataStructure.hpp"
+
+/* we could cut this down - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/BaseDataStreamMarshaller.hpp"
+#include "util/ifr/p.hpp"
+
+#include "protocol/ProtocolFormat.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace marshal
+ {
+ using namespace ifr ;
+ using namespace apache::activemq::client::command;
+ using namespace apache::activemq::client::io;
+ using namespace apache::activemq::client::protocol;
+
+/*
+ *
+ */
+class MessageIdMarshaller : public BaseDataStreamMarshaller
+{
+public:
+ MessageIdMarshaller() ;
+ virtual ~MessageIdMarshaller() ;
+
+ virtual IDataStructure* createCommand() ;
+ virtual char getDataStructureType() ;
+
+ virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+ virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
+ virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+#endif /*MessageIdMarshaller_hpp_*/
Propchange: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageIdMarshaller.hpp
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageMarshaller.hpp?view=diff&rev=450245&r1=450244&r2=450245
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageMarshaller.hpp (original)
+++ incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageMarshaller.hpp Tue Sep 26 15:45:16 2006
@@ -1 +1,74 @@
-/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef MessageMarshaller_hpp_
#define MessageMarshaller_hpp_
#include <string>
#include "command/IDataStructure.hpp"
/* we could cut this down - for now include all possible headers */
#include "co
mmand/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"
#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"
#include "command/BaseCommandMarshaller.hpp"
#include "util/ifr/p.hpp"
#include "protocol/ProtocolFormat.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace marshal
{
using namespace ifr ;
using namespace apache::activemq::client::command;
using namespace apache::activemq::client::io;
using namespace apache::activemq::client::protocol;
/*
*
*/
class MessageMarshaller : public BaseCommandMarshaller
{
public:
MessageMarshaller() ;
virtual ~MessageMarshaller() ;
virtual IDataStructure* createCommand() ;
virtual char getDataStructureType() ;
virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
virtual
int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;
/* namespace */
}
}
}
}
#endif /*MessageMarshaller_hpp_*/
\ No newline at end of file
+/*
+* Licensed to the Apache Software Foundation (ASF) under one or more
+* contributor license agreements. See the NOTICE file distributed with
+* this work for additional information regarding copyright ownership.
+* The ASF licenses this file to You under the Apache License, Version 2.0
+* (the "License"); you may not use this file except in compliance with
+* the License. You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef MessageMarshaller_hpp_
+#define MessageMarshaller_hpp_
+
+#include <string>
+
+#include "command/IDataStructure.hpp"
+
+/* we could cut this down - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/BaseCommandMarshaller.hpp"
+#include "util/ifr/p.hpp"
+
+#include "protocol/ProtocolFormat.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace marshal
+ {
+ using namespace ifr ;
+ using namespace apache::activemq::client::command;
+ using namespace apache::activemq::client::io;
+ using namespace apache::activemq::client::protocol;
+
+/*
+ *
+ */
+class MessageMarshaller : public BaseCommandMarshaller
+{
+public:
+ MessageMarshaller() ;
+ virtual ~MessageMarshaller() ;
+
+ virtual IDataStructure* createCommand() ;
+ virtual char getDataStructureType() ;
+
+ virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+ virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
+ virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+#endif /*MessageMarshaller_hpp_*/
Propchange: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessageMarshaller.hpp
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessagePullMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessagePullMarshaller.hpp?view=diff&rev=450245&r1=450244&r2=450245
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessagePullMarshaller.hpp (original)
+++ incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessagePullMarshaller.hpp Tue Sep 26 15:45:16 2006
@@ -1 +1,74 @@
-/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef MessagePullMarshaller_hpp_
#define MessagePullMarshaller_hpp_
#include <string>
#include "command/IDataStructure.hpp"
/* we could cut this down - for now include all possible headers */
#inc
lude "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"
#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"
#include "command/BaseCommandMarshaller.hpp"
#include "util/ifr/p.hpp"
#include "protocol/ProtocolFormat.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace marshal
{
using namespace ifr ;
using namespace apache::activemq::client::command;
using namespace apache::activemq::client::io;
using namespace apache::activemq::client::protocol;
/*
*
*/
class MessagePullMarshaller : public BaseCommandMarshaller
{
public:
MessagePullMarshaller() ;
virtual ~MessagePullMarshaller() ;
virtual IDataStructure* createCommand() ;
virtual char getDataStructureType() ;
virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStrea
m& bs) ;
virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;
/* namespace */
}
}
}
}
#endif /*MessagePullMarshaller_hpp_*/
\ No newline at end of file
+/*
+* Licensed to the Apache Software Foundation (ASF) under one or more
+* contributor license agreements. See the NOTICE file distributed with
+* this work for additional information regarding copyright ownership.
+* The ASF licenses this file to You under the Apache License, Version 2.0
+* (the "License"); you may not use this file except in compliance with
+* the License. You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef MessagePullMarshaller_hpp_
+#define MessagePullMarshaller_hpp_
+
+#include <string>
+
+#include "command/IDataStructure.hpp"
+
+/* we could cut this down - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/BaseCommandMarshaller.hpp"
+#include "util/ifr/p.hpp"
+
+#include "protocol/ProtocolFormat.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace marshal
+ {
+ using namespace ifr ;
+ using namespace apache::activemq::client::command;
+ using namespace apache::activemq::client::io;
+ using namespace apache::activemq::client::protocol;
+
+/*
+ *
+ */
+class MessagePullMarshaller : public BaseCommandMarshaller
+{
+public:
+ MessagePullMarshaller() ;
+ virtual ~MessagePullMarshaller() ;
+
+ virtual IDataStructure* createCommand() ;
+ virtual char getDataStructureType() ;
+
+ virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+ virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
+ virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+#endif /*MessagePullMarshaller_hpp_*/
Propchange: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/MessagePullMarshaller.hpp
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.hpp?view=diff&rev=450245&r1=450244&r2=450245
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.hpp (original)
+++ incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.hpp Tue Sep 26 15:45:16 2006
@@ -1 +1,74 @@
-/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef NetworkBridgeFilterMarshaller_hpp_
#define NetworkBridgeFilterMarshaller_hpp_
#include <string>
#include "command/IDataStructure.hpp"
/* we could cut this down - for now include all possible
headers */
#include "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"
#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"
#include "command/BaseDataStreamMarshaller.hpp"
#include "util/ifr/p.hpp"
#include "protocol/ProtocolFormat.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace marshal
{
using namespace ifr ;
using namespace apache::activemq::client::command;
using namespace apache::activemq::client::io;
using namespace apache::activemq::client::protocol;
/*
*
*/
class NetworkBridgeFilterMarshaller : public BaseDataStreamMarshaller
{
public:
NetworkBridgeFilterMarshaller() ;
virtual ~NetworkBridgeFilterMarshaller() ;
virtual IDataStructure* createCommand() ;
virtual char getDataStructureType() ;
virtual void unmarshal(ProtocolFormat& wireFormat
, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;
/* namespace */
}
}
}
}
#endif /*NetworkBridgeFilterMarshaller_hpp_*/
\ No newline at end of file
+/*
+* Licensed to the Apache Software Foundation (ASF) under one or more
+* contributor license agreements. See the NOTICE file distributed with
+* this work for additional information regarding copyright ownership.
+* The ASF licenses this file to You under the Apache License, Version 2.0
+* (the "License"); you may not use this file except in compliance with
+* the License. You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef NetworkBridgeFilterMarshaller_hpp_
+#define NetworkBridgeFilterMarshaller_hpp_
+
+#include <string>
+
+#include "command/IDataStructure.hpp"
+
+/* we could cut this down - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/BaseDataStreamMarshaller.hpp"
+#include "util/ifr/p.hpp"
+
+#include "protocol/ProtocolFormat.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace marshal
+ {
+ using namespace ifr ;
+ using namespace apache::activemq::client::command;
+ using namespace apache::activemq::client::io;
+ using namespace apache::activemq::client::protocol;
+
+/*
+ *
+ */
+class NetworkBridgeFilterMarshaller : public BaseDataStreamMarshaller
+{
+public:
+ NetworkBridgeFilterMarshaller() ;
+ virtual ~NetworkBridgeFilterMarshaller() ;
+
+ virtual IDataStructure* createCommand() ;
+ virtual char getDataStructureType() ;
+
+ virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+ virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
+ virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+#endif /*NetworkBridgeFilterMarshaller_hpp_*/
Propchange: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.hpp
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/PartialCommandMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/PartialCommandMarshaller.hpp?view=diff&rev=450245&r1=450244&r2=450245
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/PartialCommandMarshaller.hpp (original)
+++ incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/PartialCommandMarshaller.hpp Tue Sep 26 15:45:16 2006
@@ -1 +1,74 @@
-/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef PartialCommandMarshaller_hpp_
#define PartialCommandMarshaller_hpp_
#include <string>
#include "command/IDataStructure.hpp"
/* we could cut this down - for now include all possible headers *
/
#include "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"
#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"
#include "command/BaseDataStreamMarshaller.hpp"
#include "util/ifr/p.hpp"
#include "protocol/ProtocolFormat.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace marshal
{
using namespace ifr ;
using namespace apache::activemq::client::command;
using namespace apache::activemq::client::io;
using namespace apache::activemq::client::protocol;
/*
*
*/
class PartialCommandMarshaller : public BaseDataStreamMarshaller
{
public:
PartialCommandMarshaller() ;
virtual ~PartialCommandMarshaller() ;
virtual IDataStructure* createCommand() ;
virtual char getDataStructureType() ;
virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader&
dataIn, BooleanStream& bs) ;
virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;
/* namespace */
}
}
}
}
#endif /*PartialCommandMarshaller_hpp_*/
\ No newline at end of file
+/*
+* Licensed to the Apache Software Foundation (ASF) under one or more
+* contributor license agreements. See the NOTICE file distributed with
+* this work for additional information regarding copyright ownership.
+* The ASF licenses this file to You under the Apache License, Version 2.0
+* (the "License"); you may not use this file except in compliance with
+* the License. You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef PartialCommandMarshaller_hpp_
+#define PartialCommandMarshaller_hpp_
+
+#include <string>
+
+#include "command/IDataStructure.hpp"
+
+/* we could cut this down - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/BaseDataStreamMarshaller.hpp"
+#include "util/ifr/p.hpp"
+
+#include "protocol/ProtocolFormat.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace marshal
+ {
+ using namespace ifr ;
+ using namespace apache::activemq::client::command;
+ using namespace apache::activemq::client::io;
+ using namespace apache::activemq::client::protocol;
+
+/*
+ *
+ */
+class PartialCommandMarshaller : public BaseDataStreamMarshaller
+{
+public:
+ PartialCommandMarshaller() ;
+ virtual ~PartialCommandMarshaller() ;
+
+ virtual IDataStructure* createCommand() ;
+ virtual char getDataStructureType() ;
+
+ virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+ virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
+ virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+#endif /*PartialCommandMarshaller_hpp_*/
Propchange: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/PartialCommandMarshaller.hpp
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.hpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.hpp?view=diff&rev=450245&r1=450244&r2=450245
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.hpp (original)
+++ incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.hpp Tue Sep 26 15:45:16 2006
@@ -1 +1,74 @@
-/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef ProducerIdMarshaller_hpp_
#define ProducerIdMarshaller_hpp_
#include <string>
#include "command/IDataStructure.hpp"
/* we could cut this down - for now include all possible headers */
#inclu
de "command/BrokerId.hpp"
#include "command/ConnectionId.hpp"
#include "command/ConsumerId.hpp"
#include "command/ProducerId.hpp"
#include "command/SessionId.hpp"
#include "io/BinaryReader.hpp"
#include "io/BinaryWriter.hpp"
#include "command/BaseDataStreamMarshaller.hpp"
#include "util/ifr/p.hpp"
#include "protocol/ProtocolFormat.hpp"
namespace apache
{
namespace activemq
{
namespace client
{
namespace marshal
{
using namespace ifr ;
using namespace apache::activemq::client::command;
using namespace apache::activemq::client::io;
using namespace apache::activemq::client::protocol;
/*
*
*/
class ProducerIdMarshaller : public BaseDataStreamMarshaller
{
public:
ProducerIdMarshaller() ;
virtual ~ProducerIdMarshaller() ;
virtual IDataStructure* createCommand() ;
virtual char getDataStructureType() ;
virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStre
am& bs) ;
virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
} ;
/* namespace */
}
}
}
}
#endif /*ProducerIdMarshaller_hpp_*/
\ No newline at end of file
+/*
+* Licensed to the Apache Software Foundation (ASF) under one or more
+* contributor license agreements. See the NOTICE file distributed with
+* this work for additional information regarding copyright ownership.
+* The ASF licenses this file to You under the Apache License, Version 2.0
+* (the "License"); you may not use this file except in compliance with
+* the License. You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#ifndef ProducerIdMarshaller_hpp_
+#define ProducerIdMarshaller_hpp_
+
+#include <string>
+
+#include "command/IDataStructure.hpp"
+
+/* we could cut this down - for now include all possible headers */
+#include "command/BrokerId.hpp"
+#include "command/ConnectionId.hpp"
+#include "command/ConsumerId.hpp"
+#include "command/ProducerId.hpp"
+#include "command/SessionId.hpp"
+
+#include "io/BinaryReader.hpp"
+#include "io/BinaryWriter.hpp"
+
+#include "command/BaseDataStreamMarshaller.hpp"
+#include "util/ifr/p.hpp"
+
+#include "protocol/ProtocolFormat.hpp"
+
+namespace apache
+{
+ namespace activemq
+ {
+ namespace client
+ {
+ namespace marshal
+ {
+ using namespace ifr ;
+ using namespace apache::activemq::client::command;
+ using namespace apache::activemq::client::io;
+ using namespace apache::activemq::client::protocol;
+
+/*
+ *
+ */
+class ProducerIdMarshaller : public BaseDataStreamMarshaller
+{
+public:
+ ProducerIdMarshaller() ;
+ virtual ~ProducerIdMarshaller() ;
+
+ virtual IDataStructure* createCommand() ;
+ virtual char getDataStructureType() ;
+
+ virtual void unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ;
+ virtual int marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) ;
+ virtual void marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ;
+} ;
+
+/* namespace */
+ }
+ }
+ }
+}
+#endif /*ProducerIdMarshaller_hpp_*/
Propchange: incubator/activemq/activemq-cpp/trunk/openwire-cpp/src/marshal/ProducerIdMarshaller.hpp
------------------------------------------------------------------------------
svn:eol-style = native