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/07/28 10:22:55 UTC
svn commit: r426431 [1/14] - in /incubator/activemq/branches/activemq-4.0:
activemq-core/src/gram/script/
activemq-core/src/main/java/org/apache/activemq/kaha/impl/
activemq-core/src/main/java/org/apache/activemq/openwire/v1/
activemq-core/src/test/jav...
Author: chirino
Date: Fri Jul 28 01:22:48 2006
New Revision: 426431
URL: http://svn.apache.org/viewvc?rev=426431&view=rev
Log:
did a few svn propset svn:eol-styl native
Modified:
incubator/activemq/branches/activemq-4.0/activemq-core/src/gram/script/GenerateCppClasses.groovy (props changed)
incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/kaha/impl/IndexLinkedList.java (contents, props changed)
incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConnectionControlMarshaller.java (contents, props changed)
incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConsumerControlMarshaller.java (contents, props changed)
incubator/activemq/branches/activemq-4.0/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConnectionControlTest.java (contents, props changed)
incubator/activemq/branches/activemq-4.0/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConsumerControlTest.java (contents, props changed)
incubator/activemq/branches/activemq-4.0/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConnectionControl.cs (contents, props changed)
incubator/activemq/branches/activemq-4.0/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConsumerControl.cs (contents, props changed)
incubator/activemq/branches/activemq-4.0/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionControlMarshaller.cs (contents, props changed)
incubator/activemq/branches/activemq-4.0/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConsumerControlMarshaller.cs (contents, props changed)
incubator/activemq/branches/activemq-4.0/activemq-rar/pom.xml (contents, props changed)
incubator/activemq/branches/activemq-4.0/activemq-rar/src/main/rar/META-INF/ra.xml (contents, props changed)
incubator/activemq/branches/activemq-4.0/activemq-rar/src/main/rar/broker-config.xml (contents, props changed)
incubator/activemq/branches/activemq-4.0/activemq-soaktest/maven.xml (contents, props changed)
incubator/activemq/branches/activemq-4.0/activemq-soaktest/project.xml (contents, props changed)
incubator/activemq/branches/activemq-4.0/maven-bundle-plugin/pom.xml (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/AcknowledgementMode.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/BrokerException.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/BrokerException.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/Connection.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/Connection.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/ConnectionClosedException.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/ConnectionClosedException.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/ConnectionException.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/ConnectionFactory.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/ConnectionFactory.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/ConsumerClosedException.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/ConsumerClosedException.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/DestinationFilter.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/DestinationFilter.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/Dispatcher.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/Dispatcher.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/IAcknowledger.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/ICommand.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/IDataStructure.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/ISynchronization.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/MessageAckType.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/MessageConsumer.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/MessageConsumer.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/MessageConsumerSynchronization.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/MessageConsumerSynchronization.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/MessageProducer.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/MessageProducer.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/Session.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/Session.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/TransactionContext.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/TransactionContext.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/TransactionType.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQBytesMessage.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQBytesMessage.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQDestination.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQDestination.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQMapMessage.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQMapMessage.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQMessage.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQMessage.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQObjectMessage.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQObjectMessage.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQQueue.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQQueue.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQStreamMessage.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQStreamMessage.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempDestination.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempDestination.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempQueue.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempQueue.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempTopic.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTempTopic.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTextMessage.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTextMessage.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTopic.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/ActiveMQTopic.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BaseCommand.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BaseCommand.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BooleanExpression.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BrokerError.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/BrokerError.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/command/WireFormatInfo.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/protocol/IMarshaller.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/protocol/IProtocol.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/protocol/openwire/OpenWireMarshaller.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/protocol/openwire/OpenWireMarshaller.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/protocol/openwire/OpenWireProtocol.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/transport/CorrelatorFilter.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/transport/CorrelatorFilter.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/transport/FutureResponse.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/transport/FutureResponse.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/transport/ICommandListener.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/transport/ITransport.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/transport/ITransportFactory.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/transport/LoggingFilter.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/transport/LoggingFilter.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/transport/MutexFilter.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/transport/MutexFilter.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/transport/TransportFactory.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/transport/TransportFactory.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/transport/TransportFilter.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/transport/TransportFilter.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/transport/tcp/TcpTransport.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/activemq/transport/tcp/TcpTransport.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/CmsException.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/CmsException.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/IBytesMessage.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/IConnection.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/IConnectionFactory.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/IDestination.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/IExceptionListener.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/IMapMessage.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/IMessage.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/IMessageConsumer.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/IMessageListener.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/IMessageProducer.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/IQueue.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/ISession.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/IStartable.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/ITemporaryQueue.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/ITemporaryTopic.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/ITextMessage.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/ITopic.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/MessageEOFException.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/MessageFormatException.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/MessageNotReadableException.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/cms/MessageNotWritableException.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/ConversionException.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/IllegalArgumentException.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/InvalidOperationException.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/TraceException.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/TraceException.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/io/ByteArrayInputStream.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/io/ByteArrayInputStream.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/io/ByteArrayOutputStream.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/io/ByteArrayOutputStream.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/io/DataInputStream.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/io/DataInputStream.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/io/DataOutputStream.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/io/DataOutputStream.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/io/EOFException.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/io/IInputStream.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/io/IOException.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/io/IOutputStream.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/io/SocketInputStream.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/io/SocketInputStream.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/io/SocketOutputStream.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/io/SocketOutputStream.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/net/IServerSocket.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/net/IServerSocketFactory.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/net/ISocket.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/net/ISocketFactory.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/net/ServerSocket.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/net/ServerSocket.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/net/ServerSocketFactory.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/net/Socket.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/net/Socket.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/net/SocketException.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/net/SocketFactory.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/net/Uri.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/net/Uri.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/thread/Semaphore.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/thread/SimpleMutex.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/thread/Thread.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/thread/Thread.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/util/Endian.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/util/Guid.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/util/Guid.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/util/Hex.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/util/Hex.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/util/MapItemHolder.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/util/MapItemHolder.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/util/Time.cpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/openwire-cpp/src/main/cpp/ppr/util/Time.hpp (contents, props changed)
incubator/activemq/branches/activemq-4.0/systest/weblogic-test/ActiveMQRAR/connectorModule/META-INF/weblogic-ra.xml (contents, props changed)
incubator/activemq/branches/activemq-4.0/systest/weblogic-test/ExampleEJB/ejbModule/org/apache/activemq/example/CounterMDB.java (contents, props changed)
incubator/activemq/branches/activemq-4.0/systest/weblogic-test/ExampleWAR/WebContent/WEB-INF/web.xml (contents, props changed)
Propchange: incubator/activemq/branches/activemq-4.0/activemq-core/src/gram/script/GenerateCppClasses.groovy
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/kaha/impl/IndexLinkedList.java
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/kaha/impl/IndexLinkedList.java?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/kaha/impl/IndexLinkedList.java (original)
+++ incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/kaha/impl/IndexLinkedList.java Fri Jul 28 01:22:48 2006
@@ -1,276 +1,276 @@
-/**
- *
- * Copyright 2005-2006 The Apache Software Foundation
- *
- * 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.
- */
-package org.apache.activemq.kaha.impl;
-
-/**
- * A linked list used by IndexItems
- *
- * @version $Revision: 1.2 $
- */
-final class IndexLinkedList implements Cloneable{
- private transient IndexItem root;
- private transient int size=0;
-
-
- /**
- * Constructs an empty list.
- */
- IndexLinkedList(IndexItem header){
- this.root = header;
- this.root.next=root.prev=root;
- }
-
- IndexItem getRoot(){
- return root;
- }
-
-
-
- /**
- * Returns the first element in this list.
- *
- * @return the first element in this list.
- */
- IndexItem getFirst(){
- if(size==0)
- return null;
- return root.next;
- }
-
- /**
- * Returns the last element in this list.
- *
- * @return the last element in this list.
- */
- IndexItem getLast(){
- if(size==0)
- return null;
- return root.prev;
- }
-
- /**
- * Removes and returns the first element from this list.
- *
- * @return the first element from this list.
- */
- IndexItem removeFirst(){
- if(size==0){
- return null;
- }
- IndexItem result=root.next;
- remove(root.next);
- return result;
- }
-
- /**
- * Removes and returns the last element from this list.
- *
- * @return the last element from this list.
- */
- Object removeLast(){
- if(size==0)
- return null;
- IndexItem result=root.prev;
- remove(root.prev);
- return result;
- }
-
- /**
- * Inserts the given element at the beginning of this list.
- *
- * @param o the element to be inserted at the beginning of this list.
- */
- void addFirst(IndexItem item){
- addBefore(item,root.next);
- }
-
- /**
- * Appends the given element to the end of this list. (Identical in function to the <tt>add</tt> method; included
- * only for consistency.)
- *
- * @param o the element to be inserted at the end of this list.
- */
- void addLast(IndexItem item){
- addBefore(item,root);
- }
-
- /**
- * Returns the number of elements in this list.
- *
- * @return the number of elements in this list.
- */
- int size(){
- return size;
- }
-
- /**
- * is the list empty?
- *
- * @return true if there are no elements in the list
- */
- boolean isEmpty(){
- return size==0;
- }
-
- /**
- * Appends the specified element to the end of this list.
- *
- * @param o element to be appended to this list.
- * @return <tt>true</tt> (as per the general contract of <tt>Collection.add</tt>).
- */
- boolean add(IndexItem item){
- addBefore(item,root);
- return true;
- }
-
- /**
- * Removes all of the elements from this list.
- */
- void clear(){
- root.next=root.prev=root;
- size=0;
- }
-
- // Positional Access Operations
- /**
- * Returns the element at the specified position in this list.
- *
- * @param index index of element to return.
- * @return the element at the specified position in this list.
- *
- * @throws IndexOutOfBoundsException if the specified index is is out of range (<tt>index < 0 || index >= size()</tt>).
- */
- IndexItem get(int index){
- return entry(index);
- }
-
- /**
- * Inserts the specified element at the specified position in this list. Shifts the element currently at that
- * position (if any) and any subsequent elements to the right (adds one to their indices).
- *
- * @param index index at which the specified element is to be inserted.
- * @param element element to be inserted.
- *
- * @throws IndexOutOfBoundsException if the specified index is out of range (<tt>index < 0 || index > size()</tt>).
- */
- void add(int index,IndexItem element){
- addBefore(element,(index==size?root:entry(index)));
- }
-
- /**
- * Removes the element at the specified position in this list. Shifts any subsequent elements to the left (subtracts
- * one from their indices). Returns the element that was removed from the list.
- *
- * @param index the index of the element to removed.
- * @return the element previously at the specified position.
- *
- * @throws IndexOutOfBoundsException if the specified index is out of range (<tt>index < 0 || index >= size()</tt>).
- */
- Object remove(int index){
- IndexItem e=entry(index);
- remove(e);
- return e;
- }
-
- /**
- * Return the indexed entry.
- */
- private IndexItem entry(int index){
- if(index<0||index>=size)
- throw new IndexOutOfBoundsException("Index: "+index+", Size: "+size);
- IndexItem e=root;
- if(index<size/2){
- for(int i=0;i<=index;i++)
- e=e.next;
- }else{
- for(int i=size;i>index;i--)
- e=e.prev;
- }
- return e;
- }
-
- // Search Operations
- /**
- * Returns the index in this list of the first occurrence of the specified element, or -1 if the List does not
- * contain this element. More formally, returns the lowest index i such that
- * <tt>(o==null ? get(i)==null : o.equals(get(i)))</tt>, or -1 if there is no such index.
- *
- * @param o element to search for.
- * @return the index in this list of the first occurrence of the specified element, or -1 if the list does not
- * contain this element.
- */
- int indexOf(IndexItem o){
- int index=0;
- for(IndexItem e=root.next;e!=root;e=e.next){
- if(o==e){
- return index;
- }
- index++;
- }
- return -1;
- }
-
- /**
- * Retrieve the next entry after this entry
- *
- * @param entry
- * @return next entry
- */
- IndexItem getNextEntry(IndexItem entry){
- return entry.next != root ? entry.next : null;
- }
-
- /**
- * Retrive the prev entry after this entry
- *
- * @param entry
- * @return prev entry
- */
- IndexItem getPrevEntry(IndexItem entry){
- return entry.prev != root ? entry.prev : null;
- }
-
- /**
- * Insert an Entry before this entry
- *
- * @param o the elment to insert
- * @param e the Entry to insert the object before
- *
- */
- void addBefore(IndexItem insert,IndexItem e){
- insert.next=e;
- insert.prev=e.prev;
- insert.prev.next=insert;
- insert.next.prev=insert;
- size++;
- }
-
- void remove(IndexItem e){
- if(e==root)
- return;
- e.prev.next=e.next;
- e.next.prev=e.prev;
- size--;
- }
-
- /**
- *@return clone
- */
- public Object clone(){
- IndexLinkedList clone=new IndexLinkedList(this.root);
- for(IndexItem e=root.next;e!=root;e=e.next)
- clone.add(e);
- return clone;
- }
-}
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * 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.
+ */
+package org.apache.activemq.kaha.impl;
+
+/**
+ * A linked list used by IndexItems
+ *
+ * @version $Revision: 1.2 $
+ */
+final class IndexLinkedList implements Cloneable{
+ private transient IndexItem root;
+ private transient int size=0;
+
+
+ /**
+ * Constructs an empty list.
+ */
+ IndexLinkedList(IndexItem header){
+ this.root = header;
+ this.root.next=root.prev=root;
+ }
+
+ IndexItem getRoot(){
+ return root;
+ }
+
+
+
+ /**
+ * Returns the first element in this list.
+ *
+ * @return the first element in this list.
+ */
+ IndexItem getFirst(){
+ if(size==0)
+ return null;
+ return root.next;
+ }
+
+ /**
+ * Returns the last element in this list.
+ *
+ * @return the last element in this list.
+ */
+ IndexItem getLast(){
+ if(size==0)
+ return null;
+ return root.prev;
+ }
+
+ /**
+ * Removes and returns the first element from this list.
+ *
+ * @return the first element from this list.
+ */
+ IndexItem removeFirst(){
+ if(size==0){
+ return null;
+ }
+ IndexItem result=root.next;
+ remove(root.next);
+ return result;
+ }
+
+ /**
+ * Removes and returns the last element from this list.
+ *
+ * @return the last element from this list.
+ */
+ Object removeLast(){
+ if(size==0)
+ return null;
+ IndexItem result=root.prev;
+ remove(root.prev);
+ return result;
+ }
+
+ /**
+ * Inserts the given element at the beginning of this list.
+ *
+ * @param o the element to be inserted at the beginning of this list.
+ */
+ void addFirst(IndexItem item){
+ addBefore(item,root.next);
+ }
+
+ /**
+ * Appends the given element to the end of this list. (Identical in function to the <tt>add</tt> method; included
+ * only for consistency.)
+ *
+ * @param o the element to be inserted at the end of this list.
+ */
+ void addLast(IndexItem item){
+ addBefore(item,root);
+ }
+
+ /**
+ * Returns the number of elements in this list.
+ *
+ * @return the number of elements in this list.
+ */
+ int size(){
+ return size;
+ }
+
+ /**
+ * is the list empty?
+ *
+ * @return true if there are no elements in the list
+ */
+ boolean isEmpty(){
+ return size==0;
+ }
+
+ /**
+ * Appends the specified element to the end of this list.
+ *
+ * @param o element to be appended to this list.
+ * @return <tt>true</tt> (as per the general contract of <tt>Collection.add</tt>).
+ */
+ boolean add(IndexItem item){
+ addBefore(item,root);
+ return true;
+ }
+
+ /**
+ * Removes all of the elements from this list.
+ */
+ void clear(){
+ root.next=root.prev=root;
+ size=0;
+ }
+
+ // Positional Access Operations
+ /**
+ * Returns the element at the specified position in this list.
+ *
+ * @param index index of element to return.
+ * @return the element at the specified position in this list.
+ *
+ * @throws IndexOutOfBoundsException if the specified index is is out of range (<tt>index < 0 || index >= size()</tt>).
+ */
+ IndexItem get(int index){
+ return entry(index);
+ }
+
+ /**
+ * Inserts the specified element at the specified position in this list. Shifts the element currently at that
+ * position (if any) and any subsequent elements to the right (adds one to their indices).
+ *
+ * @param index index at which the specified element is to be inserted.
+ * @param element element to be inserted.
+ *
+ * @throws IndexOutOfBoundsException if the specified index is out of range (<tt>index < 0 || index > size()</tt>).
+ */
+ void add(int index,IndexItem element){
+ addBefore(element,(index==size?root:entry(index)));
+ }
+
+ /**
+ * Removes the element at the specified position in this list. Shifts any subsequent elements to the left (subtracts
+ * one from their indices). Returns the element that was removed from the list.
+ *
+ * @param index the index of the element to removed.
+ * @return the element previously at the specified position.
+ *
+ * @throws IndexOutOfBoundsException if the specified index is out of range (<tt>index < 0 || index >= size()</tt>).
+ */
+ Object remove(int index){
+ IndexItem e=entry(index);
+ remove(e);
+ return e;
+ }
+
+ /**
+ * Return the indexed entry.
+ */
+ private IndexItem entry(int index){
+ if(index<0||index>=size)
+ throw new IndexOutOfBoundsException("Index: "+index+", Size: "+size);
+ IndexItem e=root;
+ if(index<size/2){
+ for(int i=0;i<=index;i++)
+ e=e.next;
+ }else{
+ for(int i=size;i>index;i--)
+ e=e.prev;
+ }
+ return e;
+ }
+
+ // Search Operations
+ /**
+ * Returns the index in this list of the first occurrence of the specified element, or -1 if the List does not
+ * contain this element. More formally, returns the lowest index i such that
+ * <tt>(o==null ? get(i)==null : o.equals(get(i)))</tt>, or -1 if there is no such index.
+ *
+ * @param o element to search for.
+ * @return the index in this list of the first occurrence of the specified element, or -1 if the list does not
+ * contain this element.
+ */
+ int indexOf(IndexItem o){
+ int index=0;
+ for(IndexItem e=root.next;e!=root;e=e.next){
+ if(o==e){
+ return index;
+ }
+ index++;
+ }
+ return -1;
+ }
+
+ /**
+ * Retrieve the next entry after this entry
+ *
+ * @param entry
+ * @return next entry
+ */
+ IndexItem getNextEntry(IndexItem entry){
+ return entry.next != root ? entry.next : null;
+ }
+
+ /**
+ * Retrive the prev entry after this entry
+ *
+ * @param entry
+ * @return prev entry
+ */
+ IndexItem getPrevEntry(IndexItem entry){
+ return entry.prev != root ? entry.prev : null;
+ }
+
+ /**
+ * Insert an Entry before this entry
+ *
+ * @param o the elment to insert
+ * @param e the Entry to insert the object before
+ *
+ */
+ void addBefore(IndexItem insert,IndexItem e){
+ insert.next=e;
+ insert.prev=e.prev;
+ insert.prev.next=insert;
+ insert.next.prev=insert;
+ size++;
+ }
+
+ void remove(IndexItem e){
+ if(e==root)
+ return;
+ e.prev.next=e.next;
+ e.next.prev=e.prev;
+ size--;
+ }
+
+ /**
+ *@return clone
+ */
+ public Object clone(){
+ IndexLinkedList clone=new IndexLinkedList(this.root);
+ for(IndexItem e=root.next;e!=root;e=e.next)
+ clone.add(e);
+ return clone;
+ }
+}
Propchange: incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/kaha/impl/IndexLinkedList.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConnectionControlMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConnectionControlMarshaller.java?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConnectionControlMarshaller.java (original)
+++ incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConnectionControlMarshaller.java Fri Jul 28 01:22:48 2006
@@ -1 +1,148 @@
-/**
*
* Copyright 2005-2006 The Apache Software Foundation
*
* 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.
*/
package org.apache.activemq.openwire.v1;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/**
* Marshalling code for Open Wire Format for ConnectionControlMarshaller
*
*
* NOTE!: This file is auto generated - do not modify!
* if yo
u need to make a change, please see the modify the groovy scripts in the
* under src/gram/script and then use maven openwire:generate to regenerate
* this file.
*
* @version $Revision$
*/
public class ConnectionControlMarshaller extends BaseCommandMarshaller {
/**
* Return the type of Data Structure we marshal
* @return short representation of the type data structure
*/
public byte getDataStructureType() {
return ConnectionControl.DATA_STRUCTURE_TYPE;
}
/**
* @return a new object instance
*/
public DataStructure createObject() {
return new ConnectionControl();
}
/**
* Un-marshal an object instance from the data input stream
*
* @param o the object to un-marshal
* @param dataIn the data input stream to build the object from
* @throws IOException
*/
public void tightUnmarshal(OpenWireFormat wireFormat, Object o, DataInputStream dataIn, BooleanStream
bs) throws IOException {
super.tightUnmarshal(wireFormat, o, dataIn, bs);
ConnectionControl info = (ConnectionControl)o;
info.setClose(bs.readBoolean());
info.setExit(bs.readBoolean());
info.setFaultTolerant(bs.readBoolean());
info.setResume(bs.readBoolean());
info.setSuspend(bs.readBoolean());
}
/**
* Write the booleans that this object uses to a BooleanStream
*/
public int tightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) throws IOException {
ConnectionControl info = (ConnectionControl)o;
int rc = super.tightMarshal1(wireFormat, o, bs);
bs.writeBoolean(info.isClose());
bs.writeBoolean(info.isExit());
bs.writeBoolean(info.isFaultTolerant());
bs.writeBoolean(info.isResume());
bs.writeBoolean(info.isSuspend());
return rc + 0;
}
/**
* Write a object instance to data output stream
*
* @pa
ram o the instance to be marshaled
* @param dataOut the output stream
* @throws IOException thrown if an error occurs
*/
public void tightMarshal2(OpenWireFormat wireFormat, Object o, DataOutputStream dataOut, BooleanStream bs) throws IOException {
super.tightMarshal2(wireFormat, o, dataOut, bs);
ConnectionControl info = (ConnectionControl)o;
bs.readBoolean();
bs.readBoolean();
bs.readBoolean();
bs.readBoolean();
bs.readBoolean();
}
/**
* Un-marshal an object instance from the data input stream
*
* @param o the object to un-marshal
* @param dataIn the data input stream to build the object from
* @throws IOException
*/
public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInputStream dataIn) throws IOException {
super.looseUnmarshal(wireFormat, o, dataIn);
ConnectionControl info = (ConnectionControl)o;
info.setClose(dat
aIn.readBoolean());
info.setExit(dataIn.readBoolean());
info.setFaultTolerant(dataIn.readBoolean());
info.setResume(dataIn.readBoolean());
info.setSuspend(dataIn.readBoolean());
}
/**
* Write the booleans that this object uses to a BooleanStream
*/
public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutputStream dataOut) throws IOException {
ConnectionControl info = (ConnectionControl)o;
super.looseMarshal(wireFormat, o, dataOut);
dataOut.writeBoolean(info.isClose());
dataOut.writeBoolean(info.isExit());
dataOut.writeBoolean(info.isFaultTolerant());
dataOut.writeBoolean(info.isResume());
dataOut.writeBoolean(info.isSuspend());
}
}
\ No newline at end of file
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * 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.
+ */
+
+package org.apache.activemq.openwire.v1;
+
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+
+import org.apache.activemq.openwire.*;
+import org.apache.activemq.command.*;
+
+
+
+/**
+ * Marshalling code for Open Wire Format for ConnectionControlMarshaller
+ *
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the modify the groovy scripts in the
+ * under src/gram/script and then use maven openwire:generate to regenerate
+ * this file.
+ *
+ * @version $Revision$
+ */
+public class ConnectionControlMarshaller extends BaseCommandMarshaller {
+
+ /**
+ * Return the type of Data Structure we marshal
+ * @return short representation of the type data structure
+ */
+ public byte getDataStructureType() {
+ return ConnectionControl.DATA_STRUCTURE_TYPE;
+ }
+
+ /**
+ * @return a new object instance
+ */
+ public DataStructure createObject() {
+ return new ConnectionControl();
+ }
+
+ /**
+ * Un-marshal an object instance from the data input stream
+ *
+ * @param o the object to un-marshal
+ * @param dataIn the data input stream to build the object from
+ * @throws IOException
+ */
+ public void tightUnmarshal(OpenWireFormat wireFormat, Object o, DataInputStream dataIn, BooleanStream bs) throws IOException {
+ super.tightUnmarshal(wireFormat, o, dataIn, bs);
+
+ ConnectionControl info = (ConnectionControl)o;
+ info.setClose(bs.readBoolean());
+ info.setExit(bs.readBoolean());
+ info.setFaultTolerant(bs.readBoolean());
+ info.setResume(bs.readBoolean());
+ info.setSuspend(bs.readBoolean());
+
+ }
+
+
+ /**
+ * Write the booleans that this object uses to a BooleanStream
+ */
+ public int tightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) throws IOException {
+
+ ConnectionControl info = (ConnectionControl)o;
+
+ int rc = super.tightMarshal1(wireFormat, o, bs);
+ bs.writeBoolean(info.isClose());
+ bs.writeBoolean(info.isExit());
+ bs.writeBoolean(info.isFaultTolerant());
+ bs.writeBoolean(info.isResume());
+ bs.writeBoolean(info.isSuspend());
+
+ return rc + 0;
+ }
+
+ /**
+ * Write a object instance to data output stream
+ *
+ * @param o the instance to be marshaled
+ * @param dataOut the output stream
+ * @throws IOException thrown if an error occurs
+ */
+ public void tightMarshal2(OpenWireFormat wireFormat, Object o, DataOutputStream dataOut, BooleanStream bs) throws IOException {
+ super.tightMarshal2(wireFormat, o, dataOut, bs);
+
+ ConnectionControl info = (ConnectionControl)o;
+ bs.readBoolean();
+ bs.readBoolean();
+ bs.readBoolean();
+ bs.readBoolean();
+ bs.readBoolean();
+
+ }
+
+ /**
+ * Un-marshal an object instance from the data input stream
+ *
+ * @param o the object to un-marshal
+ * @param dataIn the data input stream to build the object from
+ * @throws IOException
+ */
+ public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInputStream dataIn) throws IOException {
+ super.looseUnmarshal(wireFormat, o, dataIn);
+
+ ConnectionControl info = (ConnectionControl)o;
+ info.setClose(dataIn.readBoolean());
+ info.setExit(dataIn.readBoolean());
+ info.setFaultTolerant(dataIn.readBoolean());
+ info.setResume(dataIn.readBoolean());
+ info.setSuspend(dataIn.readBoolean());
+
+ }
+
+
+ /**
+ * Write the booleans that this object uses to a BooleanStream
+ */
+ public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutputStream dataOut) throws IOException {
+
+ ConnectionControl info = (ConnectionControl)o;
+
+ super.looseMarshal(wireFormat, o, dataOut);
+ dataOut.writeBoolean(info.isClose());
+ dataOut.writeBoolean(info.isExit());
+ dataOut.writeBoolean(info.isFaultTolerant());
+ dataOut.writeBoolean(info.isResume());
+ dataOut.writeBoolean(info.isSuspend());
+
+ }
+}
Propchange: incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConnectionControlMarshaller.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConsumerControlMarshaller.java
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConsumerControlMarshaller.java?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConsumerControlMarshaller.java (original)
+++ incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConsumerControlMarshaller.java Fri Jul 28 01:22:48 2006
@@ -1 +1,137 @@
-/**
*
* Copyright 2005-2006 The Apache Software Foundation
*
* 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.
*/
package org.apache.activemq.openwire.v1;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/**
* Marshalling code for Open Wire Format for ConsumerControlMarshaller
*
*
* NOTE!: This file is auto generated - do not modify!
* if you
need to make a change, please see the modify the groovy scripts in the
* under src/gram/script and then use maven openwire:generate to regenerate
* this file.
*
* @version $Revision$
*/
public class ConsumerControlMarshaller extends BaseCommandMarshaller {
/**
* Return the type of Data Structure we marshal
* @return short representation of the type data structure
*/
public byte getDataStructureType() {
return ConsumerControl.DATA_STRUCTURE_TYPE;
}
/**
* @return a new object instance
*/
public DataStructure createObject() {
return new ConsumerControl();
}
/**
* Un-marshal an object instance from the data input stream
*
* @param o the object to un-marshal
* @param dataIn the data input stream to build the object from
* @throws IOException
*/
public void tightUnmarshal(OpenWireFormat wireFormat, Object o, DataInputStream dataIn, BooleanStream bs) thr
ows IOException {
super.tightUnmarshal(wireFormat, o, dataIn, bs);
ConsumerControl info = (ConsumerControl)o;
info.setClose(bs.readBoolean());
info.setConsumerId((org.apache.activemq.command.ConsumerId) tightUnmarsalNestedObject(wireFormat, dataIn, bs));
info.setPrefetch(dataIn.readInt());
}
/**
* Write the booleans that this object uses to a BooleanStream
*/
public int tightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) throws IOException {
ConsumerControl info = (ConsumerControl)o;
int rc = super.tightMarshal1(wireFormat, o, bs);
bs.writeBoolean(info.isClose());
rc += tightMarshalNestedObject1(wireFormat, (DataStructure)info.getConsumerId(), bs);
return rc + 4;
}
/**
* Write a object instance to data output stream
*
* @param o the instance to be marshaled
* @param dataOut the output stream
* @throws IOException thro
wn if an error occurs
*/
public void tightMarshal2(OpenWireFormat wireFormat, Object o, DataOutputStream dataOut, BooleanStream bs) throws IOException {
super.tightMarshal2(wireFormat, o, dataOut, bs);
ConsumerControl info = (ConsumerControl)o;
bs.readBoolean();
tightMarshalNestedObject2(wireFormat, (DataStructure)info.getConsumerId(), dataOut, bs);
dataOut.writeInt(info.getPrefetch());
}
/**
* Un-marshal an object instance from the data input stream
*
* @param o the object to un-marshal
* @param dataIn the data input stream to build the object from
* @throws IOException
*/
public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInputStream dataIn) throws IOException {
super.looseUnmarshal(wireFormat, o, dataIn);
ConsumerControl info = (ConsumerControl)o;
info.setClose(dataIn.readBoolean());
info.setConsumerId((org.apache.activemq.command
.ConsumerId) looseUnmarsalNestedObject(wireFormat, dataIn));
info.setPrefetch(dataIn.readInt());
}
/**
* Write the booleans that this object uses to a BooleanStream
*/
public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutputStream dataOut) throws IOException {
ConsumerControl info = (ConsumerControl)o;
super.looseMarshal(wireFormat, o, dataOut);
dataOut.writeBoolean(info.isClose());
looseMarshalNestedObject(wireFormat, (DataStructure)info.getConsumerId(), dataOut);
dataOut.writeInt(info.getPrefetch());
}
}
\ No newline at end of file
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * 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.
+ */
+
+package org.apache.activemq.openwire.v1;
+
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+
+import org.apache.activemq.openwire.*;
+import org.apache.activemq.command.*;
+
+
+
+/**
+ * Marshalling code for Open Wire Format for ConsumerControlMarshaller
+ *
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the modify the groovy scripts in the
+ * under src/gram/script and then use maven openwire:generate to regenerate
+ * this file.
+ *
+ * @version $Revision$
+ */
+public class ConsumerControlMarshaller extends BaseCommandMarshaller {
+
+ /**
+ * Return the type of Data Structure we marshal
+ * @return short representation of the type data structure
+ */
+ public byte getDataStructureType() {
+ return ConsumerControl.DATA_STRUCTURE_TYPE;
+ }
+
+ /**
+ * @return a new object instance
+ */
+ public DataStructure createObject() {
+ return new ConsumerControl();
+ }
+
+ /**
+ * Un-marshal an object instance from the data input stream
+ *
+ * @param o the object to un-marshal
+ * @param dataIn the data input stream to build the object from
+ * @throws IOException
+ */
+ public void tightUnmarshal(OpenWireFormat wireFormat, Object o, DataInputStream dataIn, BooleanStream bs) throws IOException {
+ super.tightUnmarshal(wireFormat, o, dataIn, bs);
+
+ ConsumerControl info = (ConsumerControl)o;
+ info.setClose(bs.readBoolean());
+ info.setConsumerId((org.apache.activemq.command.ConsumerId) tightUnmarsalNestedObject(wireFormat, dataIn, bs));
+ info.setPrefetch(dataIn.readInt());
+
+ }
+
+
+ /**
+ * Write the booleans that this object uses to a BooleanStream
+ */
+ public int tightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) throws IOException {
+
+ ConsumerControl info = (ConsumerControl)o;
+
+ int rc = super.tightMarshal1(wireFormat, o, bs);
+ bs.writeBoolean(info.isClose());
+ rc += tightMarshalNestedObject1(wireFormat, (DataStructure)info.getConsumerId(), bs);
+
+ return rc + 4;
+ }
+
+ /**
+ * Write a object instance to data output stream
+ *
+ * @param o the instance to be marshaled
+ * @param dataOut the output stream
+ * @throws IOException thrown if an error occurs
+ */
+ public void tightMarshal2(OpenWireFormat wireFormat, Object o, DataOutputStream dataOut, BooleanStream bs) throws IOException {
+ super.tightMarshal2(wireFormat, o, dataOut, bs);
+
+ ConsumerControl info = (ConsumerControl)o;
+ bs.readBoolean();
+ tightMarshalNestedObject2(wireFormat, (DataStructure)info.getConsumerId(), dataOut, bs);
+ dataOut.writeInt(info.getPrefetch());
+
+ }
+
+ /**
+ * Un-marshal an object instance from the data input stream
+ *
+ * @param o the object to un-marshal
+ * @param dataIn the data input stream to build the object from
+ * @throws IOException
+ */
+ public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInputStream dataIn) throws IOException {
+ super.looseUnmarshal(wireFormat, o, dataIn);
+
+ ConsumerControl info = (ConsumerControl)o;
+ info.setClose(dataIn.readBoolean());
+ info.setConsumerId((org.apache.activemq.command.ConsumerId) looseUnmarsalNestedObject(wireFormat, dataIn));
+ info.setPrefetch(dataIn.readInt());
+
+ }
+
+
+ /**
+ * Write the booleans that this object uses to a BooleanStream
+ */
+ public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutputStream dataOut) throws IOException {
+
+ ConsumerControl info = (ConsumerControl)o;
+
+ super.looseMarshal(wireFormat, o, dataOut);
+ dataOut.writeBoolean(info.isClose());
+ looseMarshalNestedObject(wireFormat, (DataStructure)info.getConsumerId(), dataOut);
+ dataOut.writeInt(info.getPrefetch());
+
+ }
+}
Propchange: incubator/activemq/branches/activemq-4.0/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConsumerControlMarshaller.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/branches/activemq-4.0/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConnectionControlTest.java
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConnectionControlTest.java?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConnectionControlTest.java (original)
+++ incubator/activemq/branches/activemq-4.0/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConnectionControlTest.java Fri Jul 28 01:22:48 2006
@@ -1 +1,60 @@
-/**
*
* Copyright 2005-2006 The Apache Software Foundation
*
* 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.
*/
package org.apache.activemq.openwire.v1;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/**
* Test case for the OpenWire marshalling for ConnectionControl
*
*
* NOTE!: This file is auto generated - do not modify!
* if you need to m
ake a change, please see the modify the groovy scripts in the
* under src/gram/script and then use maven openwire:generate to regenerate
* this file.
*
* @version $Revision: $
*/
public class ConnectionControlTest extends BaseCommandTestSupport {
public static ConnectionControlTest SINGLETON = new ConnectionControlTest();
public Object createObject() throws Exception {
ConnectionControl info = new ConnectionControl();
populateObject(info);
return info;
}
protected void populateObject(Object object) throws Exception {
super.populateObject(object);
ConnectionControl info = (ConnectionControl) object;
info.setClose(true);
info.setExit(false);
info.setFaultTolerant(true);
info.setResume(false);
info.setSuspend(true);
}
}
\ No newline at end of file
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * 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.
+ */
+package org.apache.activemq.openwire.v1;
+
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+
+import org.apache.activemq.openwire.*;
+import org.apache.activemq.command.*;
+
+
+/**
+ * Test case for the OpenWire marshalling for ConnectionControl
+ *
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the modify the groovy scripts in the
+ * under src/gram/script and then use maven openwire:generate to regenerate
+ * this file.
+ *
+ * @version $Revision: $
+ */
+public class ConnectionControlTest extends BaseCommandTestSupport {
+
+
+ public static ConnectionControlTest SINGLETON = new ConnectionControlTest();
+
+ public Object createObject() throws Exception {
+ ConnectionControl info = new ConnectionControl();
+ populateObject(info);
+ return info;
+ }
+
+
+ protected void populateObject(Object object) throws Exception {
+ super.populateObject(object);
+ ConnectionControl info = (ConnectionControl) object;
+ info.setClose(true);
+ info.setExit(false);
+ info.setFaultTolerant(true);
+ info.setResume(false);
+ info.setSuspend(true);
+
+ }
+ }
Propchange: incubator/activemq/branches/activemq-4.0/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConnectionControlTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/branches/activemq-4.0/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConsumerControlTest.java
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConsumerControlTest.java?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConsumerControlTest.java (original)
+++ incubator/activemq/branches/activemq-4.0/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConsumerControlTest.java Fri Jul 28 01:22:48 2006
@@ -1 +1,58 @@
-/**
*
* Copyright 2005-2006 The Apache Software Foundation
*
* 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.
*/
package org.apache.activemq.openwire.v1;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/**
* Test case for the OpenWire marshalling for ConsumerControl
*
*
* NOTE!: This file is auto generated - do not modify!
* if you need to mak
e a change, please see the modify the groovy scripts in the
* under src/gram/script and then use maven openwire:generate to regenerate
* this file.
*
* @version $Revision: $
*/
public class ConsumerControlTest extends BaseCommandTestSupport {
public static ConsumerControlTest SINGLETON = new ConsumerControlTest();
public Object createObject() throws Exception {
ConsumerControl info = new ConsumerControl();
populateObject(info);
return info;
}
protected void populateObject(Object object) throws Exception {
super.populateObject(object);
ConsumerControl info = (ConsumerControl) object;
info.setClose(true);
info.setConsumerId(createConsumerId("ConsumerId:1"));
info.setPrefetch(1);
}
}
\ No newline at end of file
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * 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.
+ */
+package org.apache.activemq.openwire.v1;
+
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+
+import org.apache.activemq.openwire.*;
+import org.apache.activemq.command.*;
+
+
+/**
+ * Test case for the OpenWire marshalling for ConsumerControl
+ *
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the modify the groovy scripts in the
+ * under src/gram/script and then use maven openwire:generate to regenerate
+ * this file.
+ *
+ * @version $Revision: $
+ */
+public class ConsumerControlTest extends BaseCommandTestSupport {
+
+
+ public static ConsumerControlTest SINGLETON = new ConsumerControlTest();
+
+ public Object createObject() throws Exception {
+ ConsumerControl info = new ConsumerControl();
+ populateObject(info);
+ return info;
+ }
+
+
+ protected void populateObject(Object object) throws Exception {
+ super.populateObject(object);
+ ConsumerControl info = (ConsumerControl) object;
+ info.setClose(true);
+ info.setConsumerId(createConsumerId("ConsumerId:1"));
+ info.setPrefetch(1);
+
+ }
+ }
Propchange: incubator/activemq/branches/activemq-4.0/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConsumerControlTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/branches/activemq-4.0/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConnectionControl.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConnectionControl.cs?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConnectionControl.cs (original)
+++ incubator/activemq/branches/activemq-4.0/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConnectionControl.cs Fri Jul 28 01:22:48 2006
@@ -1 +1,96 @@
-/*
* 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.
*/
//
// 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
//
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
/// <summary>
/// The ActiveMQ ConnectionControl Comm
and
/// </summary>
public class ConnectionControl : BaseCommand
{
public const byte ID_ConnectionControl = 18;
bool close;
bool exit;
bool faultTolerant;
bool resume;
bool suspend;
public override string ToString() {
return GetType().Name + "["
+ " Close=" + Close
+ " Exit=" + Exit
+ " FaultTolerant=" + FaultTolerant
+ " Resume=" + Resume
+ " Suspend=" + Suspend
+ " ]";
}
public override byte GetDataStructureType() {
return ID_ConnectionControl;
}
// Properties
public bool Close
{
get { return close; }
set { this.close = value; }
}
public bool Exit
{
get { return exit; }
set { this.exit = value; }
}
public bool FaultTolerant
{
get { return faultTolerant; }
set { this.faultTolerant = value; }
}
public bool Resume
{
get { return resume; }
set { this.resume = value; }
}
public bool Suspend
{
get { return suspend; }
set { this.suspend = value; }
}
}
}
\ 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.
+*/
+
+//
+// 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
+//
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ /// <summary>
+ /// The ActiveMQ ConnectionControl Command
+ /// </summary>
+ public class ConnectionControl : BaseCommand
+ {
+ public const byte ID_ConnectionControl = 18;
+
+ bool close;
+ bool exit;
+ bool faultTolerant;
+ bool resume;
+ bool suspend;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " Close=" + Close
+ + " Exit=" + Exit
+ + " FaultTolerant=" + FaultTolerant
+ + " Resume=" + Resume
+ + " Suspend=" + Suspend
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_ConnectionControl;
+ }
+
+
+ // Properties
+
+ public bool Close
+ {
+ get { return close; }
+ set { this.close = value; }
+ }
+
+ public bool Exit
+ {
+ get { return exit; }
+ set { this.exit = value; }
+ }
+
+ public bool FaultTolerant
+ {
+ get { return faultTolerant; }
+ set { this.faultTolerant = value; }
+ }
+
+ public bool Resume
+ {
+ get { return resume; }
+ set { this.resume = value; }
+ }
+
+ public bool Suspend
+ {
+ get { return suspend; }
+ set { this.suspend = value; }
+ }
+
+ }
+}
Propchange: incubator/activemq/branches/activemq-4.0/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConnectionControl.cs
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/branches/activemq-4.0/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConsumerControl.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConsumerControl.cs?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConsumerControl.cs (original)
+++ incubator/activemq/branches/activemq-4.0/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConsumerControl.cs Fri Jul 28 01:22:48 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.
*/
//
// 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
//
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
/// <summary>
/// The ActiveMQ ConsumerControl Comman
d
/// </summary>
public class ConsumerControl : BaseCommand
{
public const byte ID_ConsumerControl = 17;
bool close;
ConsumerId consumerId;
int prefetch;
public override string ToString() {
return GetType().Name + "["
+ " Close=" + Close
+ " ConsumerId=" + ConsumerId
+ " Prefetch=" + Prefetch
+ " ]";
}
public override byte GetDataStructureType() {
return ID_ConsumerControl;
}
// Properties
public bool Close
{
get { return close; }
set { this.close = value; }
}
public ConsumerId ConsumerId
{
get { return consumerId; }
set { this.consumerId = value; }
}
public int Prefetch
{
get { return prefetch; }
set { this.prefetch = value; }
}
}
}
\ 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.
+*/
+
+//
+// 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
+//
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ /// <summary>
+ /// The ActiveMQ ConsumerControl Command
+ /// </summary>
+ public class ConsumerControl : BaseCommand
+ {
+ public const byte ID_ConsumerControl = 17;
+
+ bool close;
+ ConsumerId consumerId;
+ int prefetch;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " Close=" + Close
+ + " ConsumerId=" + ConsumerId
+ + " Prefetch=" + Prefetch
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_ConsumerControl;
+ }
+
+
+ // Properties
+
+ public bool Close
+ {
+ get { return close; }
+ set { this.close = value; }
+ }
+
+ public ConsumerId ConsumerId
+ {
+ get { return consumerId; }
+ set { this.consumerId = value; }
+ }
+
+ public int Prefetch
+ {
+ get { return prefetch; }
+ set { this.prefetch = value; }
+ }
+
+ }
+}
Propchange: incubator/activemq/branches/activemq-4.0/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConsumerControl.cs
------------------------------------------------------------------------------
svn:eol-style = native
Modified: incubator/activemq/branches/activemq-4.0/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionControlMarshaller.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionControlMarshaller.cs?rev=426431&r1=426430&r2=426431&view=diff
==============================================================================
--- incubator/activemq/branches/activemq-4.0/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionControlMarshaller.cs (original)
+++ incubator/activemq/branches/activemq-4.0/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionControlMarshaller.cs Fri Jul 28 01:22:48 2006
@@ -1 +1,131 @@
-/*
* 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.
*/
//
// 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
//
using System;
using System.Collections;
using System.IO;
using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V1;
namespace ActiveMQ.OpenWire.V1
{
/// <summary
>
/// Marshalling code for Open Wire Format for ConnectionControl
/// </summary>
class ConnectionControlMarshaller : BaseCommandMarshaller
{
public override DataStructure CreateObject()
{
return new ConnectionControl();
}
public override byte GetDataStructureType()
{
return ConnectionControl.ID_ConnectionControl;
}
//
// Un-marshal an object instance from the data input stream
//
public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
{
base.TightUnmarshal(wireFormat, o, dataIn, bs);
ConnectionControl info = (ConnectionControl)o;
info.Close = bs.ReadBoolean();
info.Exit = bs.ReadBoolean();
info.FaultTolerant = bs.ReadBoolean();
info.Resume = bs.ReadBoolean();
info.Suspend = bs.ReadBoolean();
}
//
// Write the booleans that this object uses to a BooleanStream
//
publ
ic override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
ConnectionControl info = (ConnectionControl)o;
int rc = base.TightMarshal1(wireFormat, info, bs);
bs.WriteBoolean(info.Close);
bs.WriteBoolean(info.Exit);
bs.WriteBoolean(info.FaultTolerant);
bs.WriteBoolean(info.Resume);
bs.WriteBoolean(info.Suspend);
return rc + 0;
}
//
// Write a object instance to data output stream
//
public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
base.TightMarshal2(wireFormat, o, dataOut, bs);
ConnectionControl info = (ConnectionControl)o;
bs.ReadBoolean();
bs.ReadBoolean();
bs.ReadBoolean();
bs.ReadBoolean();
bs.ReadBoolean();
}
//
// Un-marshal an object instance from the data input stream
//
public override void LooseUnmarshal(OpenW
ireFormat wireFormat, Object o, BinaryReader dataIn)
{
base.LooseUnmarshal(wireFormat, o, dataIn);
ConnectionControl info = (ConnectionControl)o;
info.Close = dataIn.ReadBoolean();
info.Exit = dataIn.ReadBoolean();
info.FaultTolerant = dataIn.ReadBoolean();
info.Resume = dataIn.ReadBoolean();
info.Suspend = dataIn.ReadBoolean();
}
//
// Write a object instance to data output stream
//
public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
ConnectionControl info = (ConnectionControl)o;
base.LooseMarshal(wireFormat, o, dataOut);
dataOut.Write(info.Close);
dataOut.Write(info.Exit);
dataOut.Write(info.FaultTolerant);
dataOut.Write(info.Resume);
dataOut.Write(info.Suspend);
}
}
}
\ 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.
+*/
+
+//
+// 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
+//
+
+using System;
+using System.Collections;
+using System.IO;
+
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.V1;
+
+namespace ActiveMQ.OpenWire.V1
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for ConnectionControl
+ /// </summary>
+ class ConnectionControlMarshaller : BaseCommandMarshaller
+ {
+
+
+ public override DataStructure CreateObject()
+ {
+ return new ConnectionControl();
+ }
+
+ public override byte GetDataStructureType()
+ {
+ return ConnectionControl.ID_ConnectionControl;
+ }
+
+ //
+ // Un-marshal an object instance from the data input stream
+ //
+ public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs)
+ {
+ base.TightUnmarshal(wireFormat, o, dataIn, bs);
+
+ ConnectionControl info = (ConnectionControl)o;
+ info.Close = bs.ReadBoolean();
+ info.Exit = bs.ReadBoolean();
+ info.FaultTolerant = bs.ReadBoolean();
+ info.Resume = bs.ReadBoolean();
+ info.Suspend = bs.ReadBoolean();
+
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+ ConnectionControl info = (ConnectionControl)o;
+
+ int rc = base.TightMarshal1(wireFormat, info, bs);
+ bs.WriteBoolean(info.Close);
+ bs.WriteBoolean(info.Exit);
+ bs.WriteBoolean(info.FaultTolerant);
+ bs.WriteBoolean(info.Resume);
+ bs.WriteBoolean(info.Suspend);
+
+ return rc + 0;
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
+ base.TightMarshal2(wireFormat, o, dataOut, bs);
+
+ ConnectionControl info = (ConnectionControl)o;
+ bs.ReadBoolean();
+ bs.ReadBoolean();
+ bs.ReadBoolean();
+ bs.ReadBoolean();
+ bs.ReadBoolean();
+
+ }
+
+ //
+ // 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);
+
+ ConnectionControl info = (ConnectionControl)o;
+ info.Close = dataIn.ReadBoolean();
+ info.Exit = dataIn.ReadBoolean();
+ info.FaultTolerant = dataIn.ReadBoolean();
+ info.Resume = dataIn.ReadBoolean();
+ info.Suspend = dataIn.ReadBoolean();
+
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+ ConnectionControl info = (ConnectionControl)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ dataOut.Write(info.Close);
+ dataOut.Write(info.Exit);
+ dataOut.Write(info.FaultTolerant);
+ dataOut.Write(info.Resume);
+ dataOut.Write(info.Suspend);
+
+ }
+
+ }
+}
Propchange: incubator/activemq/branches/activemq-4.0/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionControlMarshaller.cs
------------------------------------------------------------------------------
svn:eol-style = native