activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject 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...
Date Fri, 28 Jul 2006 08:22:55 GMT
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 &lt; 0 || index &gt;= 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 &lt; 0 || index &gt; 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 &lt; 0 || index &gt;= 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 &lt; 0 || index &gt;= 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 &lt; 0 || index &gt; 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 &lt; 0 || index &gt;= 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



Mime
View raw message