activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r563982 [1/32] - in /activemq/trunk/activemq-core/src: main/java/org/apache/activemq/ main/java/org/apache/activemq/advisory/ main/java/org/apache/activemq/blob/ main/java/org/apache/activemq/broker/ main/java/org/apache/activemq/broker/jmx...
Date Wed, 08 Aug 2007 18:58:13 GMT
Author: chirino
Date: Wed Aug  8 11:56:59 2007
New Revision: 563982

URL: http://svn.apache.org/viewvc?view=rev&rev=563982
Log:
More checkstyle fixes

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageTransformation.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQQueueReceiver.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQQueueSender.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSessionExecutor.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQTopicSession.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/Closeable.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/StreamConnection.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisorySupport.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/blob/DefaultBlobUploadStrategy.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerFactory.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerStoppedException.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/Connection.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/BrokerView.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ConnectionView.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedTransportConnection.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/NetworkBridgeView.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/NetworkConnectorView.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/NetworkConnectorViewMBean.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionView.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/TopicSubscriptionView.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Destination.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFilter.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/NullMessageReference.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueBrowserSubscription.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueRegion.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FilePendingQueueMessageStoragePolicy.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FilePendingSubscriberMessageStoragePolicy.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StorePendingQueueMessageStoragePolicy.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingQueueMessageStoragePolicy.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingSubscriberMessageStoragePolicy.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/MulticastTraceBrokerPlugin.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/util/TimeStampingBrokerPlugin.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/view/DestinationDotFileInterceptor.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/CamelQueueSender.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQDestination.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMapMessage.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQObjectMessage.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQQueue.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQStreamMessage.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTempTopic.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BrokerId.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionError.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConnectionInfo.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ConsumerInfo.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/DataResponse.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageDispatch.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ProducerInfo.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/RemoveInfo.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SessionId.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SessionInfo.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ShutdownInfo.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SubscriptionInfo.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/TransactionInfo.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/WireFormatInfo.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/XATransactionId.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/ArithmeticExpression.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/ComparisonExpression.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/ConstantExpression.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationFilter.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/DestinationMapNode.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/PropertyExpression.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/UnaryExpression.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/XPathExpression.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/XQueryExpression.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/XalanXPathEvaluator.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/jndi/ActiveMQInitialContextFactory.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/BytesMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/ContainerId.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/ListContainer.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/MapContainer.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/MessageIdMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/ObjectMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/RuntimeStoreException.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/Store.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/StoreFactory.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/StringMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/DataManager.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/IndexRootContainer.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/StoreLockedExcpetion.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFileAccessor.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFileAppender.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataManagerFacade.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/JournalFacade.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/Location.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/NIODataFileAppender.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerEntrySet.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerEntrySetIterator.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerKeySet.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerKeySetIterator.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerListIterator.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerMapEntry.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerValueCollection.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ContainerValueCollectionIterator.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ListContainerImpl.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/MapContainerImpl.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/DataItem.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/DataManagerImpl.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/Item.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/SyncDataFileReader.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/SyncDataFileWriter.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/BadMagicException.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/Index.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexLinkedList.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/RedoStoreIndexItem.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/StoreIndexReader.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/StoreIndexWriter.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/VMIndex.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashEntry.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/tree/TreeEntry.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/tree/TreePageEntry.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/CountStatisticImpl.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/management/PollCountStatisticImpl.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/Cache.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/CacheEntry.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/CacheEntryList.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/CacheEvictionUsageListener.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/UsageManager.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/UsageManagerCacheFilter.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/list/SimpleMessageList.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/CompositeDemandForwardingBridge.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/ConduitBridge.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridge.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandSubscription.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DiscoveryNetworkConnector.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DurableConduitBridge.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/ForwardingBridge.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/MulticastNetworkConnector.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/NetworkBridgeFactory.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/NetworkBridgeListener.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/NetworkConnector.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/jms/InboundQueueBridge.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/jms/InboundTopicBridge.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/jms/JmsQueueConnector.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/jms/JmsTopicConnector.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/jms/OutboundQueueBridge.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/jms/OutboundTopicBridge.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/jms/QueueBridge.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/jms/SimpleJmsMessageConvertor.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/jms/TopicBridge.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/BooleanStream.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/OpenWireFormatFactory.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/BaseDataStreamMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConnectionInfoMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConsumerIdMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConsumerInfoMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/DataArrayResponseMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/DestinationInfoMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/MarshallerFactory.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/MessageIdMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ProducerIdMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/SessionIdMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v2/BaseDataStreamMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v2/BrokerInfoMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v2/ConnectionInfoMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v2/ConsumerIdMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v2/ConsumerInfoMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v2/DataArrayResponseMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v2/DestinationInfoMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v2/MessageIdMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v2/ProducerIdMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v2/SessionIdMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v3/BaseDataStreamMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v3/BrokerInfoMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v3/ConnectionInfoMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v3/ConsumerIdMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v3/ConsumerInfoMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v3/DataArrayResponseMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v3/DestinationInfoMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v3/MessagePullMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v3/ProducerInfoMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v3/SessionIdMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/pool/ConnectionKey.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/pool/ConnectionPool.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/pool/PooledConnection.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/pool/PooledConnectionFactory.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/proxy/ProxyConnector.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/security/AuthenticationUser.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/security/AuthorizationBroker.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/security/AuthorizationEntry.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/security/DefaultAuthorizationMap.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/security/JaasAuthenticationBroker.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/security/SecurityContext.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/security/SimpleAuthenticationBroker.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/security/SimpleAuthenticationPlugin.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/security/SimpleAuthorizationMap.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/CommandVisitor.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/CommandVisitorAdapter.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionState.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ProducerState.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/SessionState.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/Tracked.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/TransactionState.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/MessageStore.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/ProxyMessageStore.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/ProxyTopicMessageStore.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/ReferenceStore.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/ReferenceStoreAdapter.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/TopicMessageStore.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/TopicReferenceStore.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQMessageStore.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapterFactory.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQTopicMessageStore.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQTransactionStore.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQTx.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQTxOperation.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/RecoveryListenerAdapter.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/DataSourceSupport.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/JDBCAdapter.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/JDBCMessageStore.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/JDBCPersistenceAdapter.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/JDBCTopicMessageStore.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/Statements.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/TransactionContext.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/BlobJDBCAdapter.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/StreamJDBCAdapter.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalMessageStore.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalPersistenceAdapter.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalPersistenceAdapterFactory.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalTopicMessageStore.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalTransactionStore.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/AMQTxMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/AtomicIntegerMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/ConsumerMessageRef.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/ConsumerMessageRefMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/IntegerMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaMessageStore.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistenceAdapter.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStore.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStoreAdapter.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicMessageStore.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicReferenceStore.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTransaction.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTransactionStore.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/ReferenceRecord.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/ReferenceRecordMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/StoreEntryMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/TopicSubAck.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/TopicSubAckMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/TopicSubContainer.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/TransactionMarshaller.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/TxCommand.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/memory/MemoryMessageStore.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/memory/MemoryPersistenceAdapter.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/memory/MemoryTopicMessageStore.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/memory/MemoryTopicSub.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/memory/MemoryTransactionStore.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/thread/DedicatedTaskRunner.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/thread/PooledTaskRunner.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/thread/Scheduler.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/thread/TaskRunnerFactory.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/thread/Valve.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transaction/Synchronization.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transaction/Transaction.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transaction/XATransaction.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/FutureResponse.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/MutexTransport.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/ResponseCorrelator.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/Transport.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportDisposedIOException.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportFactory.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportFilter.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportLogger.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportServerSupport.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportServerThreadSupport.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportSupport.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportThreadSupport.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/WireFormatNegotiator.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryAgentFactory.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryTransportFactory.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/rendezvous/JmDNSFactory.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/rendezvous/RendezvousDiscoveryAgent.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/simple/SimpleDiscoveryAgent.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransportFactory.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransportFactory.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/mock/MockTransport.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/mock/MockTransportFactory.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/nio/NIOInputStream.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/nio/NIOOutputStream.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/nio/NIOTransport.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/nio/NIOTransportFactory.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/nio/SelectorManager.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/nio/SelectorWorker.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/peer/PeerTransportFactory.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/reliable/ReliableTransport.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/FrameTranslator.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/LegacyFrameTranslator.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/ProtocolConverter.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/ProtocolException.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/StompFrame.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/StompFrameError.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/StompSubscription.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/StompTransportFilter.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/StompWireFormat.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/SslTransport.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/SslTransportFactory.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpBufferedInputStream.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpBufferedOutputStream.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportFactory.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportServer.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/CommandDatagramChannel.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/CommandDatagramSocket.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransport.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransportFactory.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransportServer.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/BitArray.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/BitArrayBin.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/BrokerSupport.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/ByteArrayInputStream.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/ByteSequence.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/ByteSequenceData.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/DataByteArrayInputStream.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/FactoryFinder.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/IdGenerator.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/IntrospectionSupport.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/JMSExceptionSupport.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/LRUCache.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/LinkedNode.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/MarshallingSupport.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/MemoryIntPropertyEditor.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/MemoryPropertyEditor.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/ServiceStopper.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/SubscriptionKey.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/TransactionTemplate.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/URISupport.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/wireformat/ObjectStreamWireFormat.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/xbean/PooledBrokerFactoryBean.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/AMQDeadlockTest3.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQMessageAuditTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/CombinationTestSupport.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ConsumerReceiveWithTimeoutTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSConsumerTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSDurableTopicRedeliverTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSExclusiveConsumerTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSUsecaseTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsAutoAckListenerTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsBenchmark.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsDurableTopicSelectorTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsDurableTopicSendReceiveTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueSelectorTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueTransactionTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueWildcardSendReceiveTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTempDestinationTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTestSupport.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicWildcardSendReceiveTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/LargeMessageTestSupport.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/LargeStreamletTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/LoadTestBurnIn.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ProducerFlowControlTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ReconnectWithSameClientIDTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerBenchmark.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerServiceTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/DoubleSubscriptionTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/MessageExpirationTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/region/cursors/CursorDurableTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQDestinationTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/ForwardingBridgeTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/MulticastNetworkTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/SSHTunnelNetworkReconnectTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/NumberRangesWhileMarshallingTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQBytesMessageTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQDestinationTestSupport.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQMapMessageTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQMessageTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQObjectMessageTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQQueueTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQStreamMessageTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTempDestinationTestSupport.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTempQueueTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTempTopicTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTextMessageTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTopicTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/BaseCommandTestSupport.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/BrokerIdTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConnectionControlTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConnectionErrorTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConnectionIdTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConsumerControlTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConsumerIdTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ControlCommandTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/DataResponseTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/DiscoveryEventTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ExceptionResponseTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/FlushCommandTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/IntegerResponseTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/JournalQueueAckTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/JournalTopicAckTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/JournalTraceTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/JournalTransactionTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/KeepAliveInfoTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/LastPartialCommandTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/LocalTransactionIdTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/MessageAckTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/MessageDispatchNotificationTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/MessageDispatchTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/MessageIdTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/NetworkBridgeFilterTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/PartialCommandTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ProducerIdTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/RemoveInfoTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/RemoveSubscriptionInfoTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ReplayCommandTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ResponseTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/SessionIdTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/SessionInfoTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ShutdownInfoTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/SubscriptionInfoTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/TransactionIdTestSupport.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/TransactionInfoTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/XATransactionIdTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v2/ActiveMQBytesMessageTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v2/ActiveMQDestinationTestSupport.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v2/ActiveMQMapMessageTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v2/ActiveMQMessageTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v2/ActiveMQObjectMessageTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v2/ActiveMQQueueTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v2/ActiveMQStreamMessageTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v2/ActiveMQTempDestinationTestSupport.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v2/ActiveMQTempQueueTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v2/ActiveMQTempTopicTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v2/ActiveMQTextMessageTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v2/ActiveMQTopicTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v2/BaseCommandTestSupport.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v3/BaseCommandTestSupport.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/proxy/ProxyConnectorTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/security/AuthorizationMapTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/security/SecurityTestSupport.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/QueueClusterTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/StubTransport.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverConsumerTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/reliable/ReliableTransportTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/reliable/UnreliableCommandDatagramSocket.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompConnection.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompSubscriptionRemoveTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/tcp/SslTransportFactoryTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/tcp/StubSSLSocketFactory.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/tcp/StubX509Certificate.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/udp/UdpTestSupport.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/AMQFailoverIssue.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/AMQStackOverFlowTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/TwoBrokerTopicSendReceiveTest.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageTransformation.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageTransformation.java?view=diff&rev=563982&r1=563981&r2=563982
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageTransformation.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageTransformation.java Wed Aug  8 11:56:59 2007
@@ -32,7 +32,6 @@
 import javax.jms.TextMessage;
 import javax.jms.Topic;
 
-
 import org.apache.activemq.command.ActiveMQBytesMessage;
 import org.apache.activemq.command.ActiveMQDestination;
 import org.apache.activemq.command.ActiveMQMapMessage;
@@ -46,65 +45,66 @@
 import org.apache.activemq.command.ActiveMQTopic;
 
 /**
- * A helper class for converting normal JMS interfaces into ActiveMQ specific ones.
+ * A helper class for converting normal JMS interfaces into ActiveMQ specific
+ * ones.
  * 
  * @version $Revision: 1.1 $
  */
 public class ActiveMQMessageTransformation {
 
-	/**
+    /**
      * Creates a an available JMS message from another provider.
-	 * 
-	 * @param destination -  Destination to be converted into ActiveMQ's implementation.
-	 * @return ActiveMQDestination - ActiveMQ's implementation of the destination.
-	 * @throws JMSException if an error occurs
-	 */
-	public static ActiveMQDestination transformDestination(Destination destination) throws JMSException {
+     * 
+     * @param destination - Destination to be converted into ActiveMQ's
+     *                implementation.
+     * @return ActiveMQDestination - ActiveMQ's implementation of the
+     *         destination.
+     * @throws JMSException if an error occurs
+     */
+    public static ActiveMQDestination transformDestination(Destination destination) throws JMSException {
         ActiveMQDestination activeMQDestination = null;
-        
+
         if (destination != null) {
             if (destination instanceof ActiveMQDestination) {
-            	return (ActiveMQDestination) destination;
-            	
-            }
-            else {
+                return (ActiveMQDestination)destination;
+
+            } else {
                 if (destination instanceof TemporaryQueue) {
-                	activeMQDestination = new ActiveMQTempQueue(((Queue) destination).getQueueName());
-                }
-                else if (destination instanceof TemporaryTopic) {
-                	activeMQDestination = new ActiveMQTempTopic(((Topic) destination).getTopicName());
-                }
-                else if (destination instanceof Queue) {
-                	activeMQDestination = new ActiveMQQueue(((Queue) destination).getQueueName());
-                }
-                else if (destination instanceof Topic) {
-                	activeMQDestination = new ActiveMQTopic(((Topic) destination).getTopicName());
+                    activeMQDestination = new ActiveMQTempQueue(((Queue)destination).getQueueName());
+                } else if (destination instanceof TemporaryTopic) {
+                    activeMQDestination = new ActiveMQTempTopic(((Topic)destination).getTopicName());
+                } else if (destination instanceof Queue) {
+                    activeMQDestination = new ActiveMQQueue(((Queue)destination).getQueueName());
+                } else if (destination instanceof Topic) {
+                    activeMQDestination = new ActiveMQTopic(((Topic)destination).getTopicName());
                 }
             }
         }
 
-        return activeMQDestination;		
-	}
-	
-	
+        return activeMQDestination;
+    }
+
     /**
-     * Creates a fast shallow copy of the current ActiveMQMessage or creates a whole new
-     * message instance from an available JMS message from another provider.
-     *
+     * Creates a fast shallow copy of the current ActiveMQMessage or creates a
+     * whole new message instance from an available JMS message from another
+     * provider.
+     * 
      * @param message - Message to be converted into ActiveMQ's implementation.
-     * @param connection 
-     * @return ActiveMQMessage -  ActiveMQ's implementation object of the message.
+     * @param connection
+     * @return ActiveMQMessage - ActiveMQ's implementation object of the
+     *         message.
      * @throws JMSException if an error occurs
      */
-	public static final ActiveMQMessage transformMessage(Message message, ActiveMQConnection connection) throws JMSException {
+    public static final ActiveMQMessage transformMessage(Message message, ActiveMQConnection connection)
+        throws JMSException {
         if (message instanceof ActiveMQMessage) {
-            return (ActiveMQMessage) message;
+            return (ActiveMQMessage)message;
 
         } else {
             ActiveMQMessage activeMessage = null;
 
             if (message instanceof BytesMessage) {
-                BytesMessage bytesMsg = (BytesMessage) message;
+                BytesMessage bytesMsg = (BytesMessage)message;
                 bytesMsg.reset();
                 ActiveMQBytesMessage msg = new ActiveMQBytesMessage();
                 msg.setConnection(connection);
@@ -121,7 +121,7 @@
 
                 activeMessage = msg;
             } else if (message instanceof MapMessage) {
-                MapMessage mapMsg = (MapMessage) message;
+                MapMessage mapMsg = (MapMessage)message;
                 ActiveMQMapMessage msg = new ActiveMQMapMessage();
                 msg.setConnection(connection);
                 Enumeration iter = mapMsg.getMapNames();
@@ -133,14 +133,14 @@
 
                 activeMessage = msg;
             } else if (message instanceof ObjectMessage) {
-                ObjectMessage objMsg = (ObjectMessage) message;
+                ObjectMessage objMsg = (ObjectMessage)message;
                 ActiveMQObjectMessage msg = new ActiveMQObjectMessage();
                 msg.setConnection(connection);
                 msg.setObject(objMsg.getObject());
                 msg.storeContent();
                 activeMessage = msg;
             } else if (message instanceof StreamMessage) {
-                StreamMessage streamMessage = (StreamMessage) message;
+                StreamMessage streamMessage = (StreamMessage)message;
                 streamMessage.reset();
                 ActiveMQStreamMessage msg = new ActiveMQStreamMessage();
                 msg.setConnection(connection);
@@ -157,7 +157,7 @@
 
                 activeMessage = msg;
             } else if (message instanceof TextMessage) {
-                TextMessage textMsg = (TextMessage) message;
+                TextMessage textMsg = (TextMessage)message;
                 ActiveMQTextMessage msg = new ActiveMQTextMessage();
                 msg.setConnection(connection);
                 msg.setText(textMsg.getText());
@@ -174,8 +174,9 @@
     }
 
     /**
-     * Copies the standard JMS and user defined properties from the givem message to the specified message
-     *
+     * Copies the standard JMS and user defined properties from the givem
+     * message to the specified message
+     * 
      * @param fromMessage the message to take the properties from
      * @param toMesage the message to add the properties to
      * @throws JMSException

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQQueueReceiver.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQQueueReceiver.java?view=diff&rev=563982&r1=563981&r2=563982
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQQueueReceiver.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQQueueReceiver.java Wed Aug  8 11:56:59 2007
@@ -16,22 +16,20 @@
  */
 package org.apache.activemq;
 
-import org.apache.activemq.command.ActiveMQDestination;
-import org.apache.activemq.command.ConsumerId;
-
 import javax.jms.JMSException;
 import javax.jms.Queue;
 import javax.jms.QueueReceiver;
 
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ConsumerId;
+
 /**
  * A client uses a <CODE>QueueReceiver</CODE> object to receive messages that
- * have been delivered to a queue.
- * <p/>
+ * have been delivered to a queue. <p/>
  * <P>
  * Although it is possible to have multiple <CODE>QueueReceiver</CODE> s for
  * the same queue, the JMS API does not define how messages are distributed
- * between the <CODE>QueueReceiver</CODE>s.
- * <p/>
+ * between the <CODE>QueueReceiver</CODE>s. <p/>
  * <P>
  * If a <CODE>QueueReceiver</CODE> specifies a message selector, the messages
  * that are not selected remain on the queue. By definition, a message selector
@@ -39,14 +37,14 @@
  * the skipped messages are eventually read, the total ordering of the reads
  * does not retain the partial order defined by each message producer. Only
  * <CODE>QueueReceiver</CODE> s without a message selector will read messages
- * in message producer order.
- * <p/>
+ * in message producer order. <p/>
  * <P>
  * Creating a <CODE>MessageConsumer</CODE> provides the same features as
  * creating a <CODE>QueueReceiver</CODE>. A <CODE>MessageConsumer</CODE>
  * object is recommended for creating new code. The <CODE>QueueReceiver
- * </CODE> is provided to support existing code.
- *
+ * </CODE>
+ * is provided to support existing code.
+ * 
  * @see javax.jms.Session#createConsumer(javax.jms.Destination, String)
  * @see javax.jms.Session#createConsumer(javax.jms.Destination)
  * @see javax.jms.QueueSession#createReceiver(Queue, String)
@@ -54,8 +52,7 @@
  * @see javax.jms.MessageConsumer
  */
 
-public class ActiveMQQueueReceiver extends ActiveMQMessageConsumer implements
-        QueueReceiver {
+public class ActiveMQQueueReceiver extends ActiveMQMessageConsumer implements QueueReceiver {
 
     /**
      * @param theSession
@@ -63,26 +60,28 @@
      * @param destination
      * @param messageSelector
      * @param prefetch
-     * @param asyncDispatch 
+     * @param asyncDispatch
      * @throws JMSException
      */
-    protected ActiveMQQueueReceiver(ActiveMQSession theSession,
-                                    ConsumerId consumerId, ActiveMQDestination destination, String selector, int prefetch, int maximumPendingMessageCount, boolean asyncDispatch)
-            throws JMSException {
-        super(theSession, consumerId, destination, null, selector, prefetch, maximumPendingMessageCount, false, false, asyncDispatch);
+    protected ActiveMQQueueReceiver(ActiveMQSession theSession, ConsumerId consumerId,
+                                    ActiveMQDestination destination, String selector, int prefetch,
+                                    int maximumPendingMessageCount, boolean asyncDispatch)
+        throws JMSException {
+        super(theSession, consumerId, destination, null, selector, prefetch, maximumPendingMessageCount,
+              false, false, asyncDispatch);
     }
 
     /**
      * Gets the <CODE>Queue</CODE> associated with this queue receiver.
-     *
+     * 
      * @return this receiver's <CODE>Queue</CODE>
-     * @throws JMSException if the JMS provider fails to get the queue for this queue
-     *                      receiver due to some internal error.
+     * @throws JMSException if the JMS provider fails to get the queue for this
+     *                 queue receiver due to some internal error.
      */
 
     public Queue getQueue() throws JMSException {
         checkClosed();
-        return (Queue) super.getDestination();
+        return (Queue)super.getDestination();
     }
-    
+
 }

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQQueueSender.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQQueueSender.java?view=diff&rev=563982&r1=563981&r2=563982
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQQueueSender.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQQueueSender.java Wed Aug  8 11:56:59 2007
@@ -26,47 +26,46 @@
 
 /**
  * A client uses a <CODE>QueueSender</CODE> object to send messages to a
- * queue.
- * <p/>
+ * queue. <p/>
  * <P>
  * Normally, the <CODE>Queue</CODE> is specified when a <CODE>QueueSender
- * </CODE> is created. In this case, an attempt to use the <CODE>send</CODE>
- * methods for an unidentified <CODE>QueueSender</CODE> will throw a <CODE>
+ * </CODE>
+ * is created. In this case, an attempt to use the <CODE>send</CODE> methods
+ * for an unidentified <CODE>QueueSender</CODE> will throw a <CODE>
  * java.lang.UnsupportedOperationException</CODE>.
  * <p/>
  * <P>
  * If the <CODE>QueueSender</CODE> is created with an unidentified <CODE>
- * Queue</CODE>, an attempt to use the <CODE>send</CODE> methods that
- * assume that the <CODE>Queue</CODE> has been identified will throw a <CODE>
+ * Queue</CODE>,
+ * an attempt to use the <CODE>send</CODE> methods that assume that the
+ * <CODE>Queue</CODE> has been identified will throw a <CODE>
  * java.lang.UnsupportedOperationException</CODE>.
  * <p/>
  * <P>
- * During the execution of its <CODE>send</CODE> method, a message must not
- * be changed by other threads within the client. If the message is modified,
- * the result of the <CODE>send</CODE> is undefined.
- * <p/>
+ * During the execution of its <CODE>send</CODE> method, a message must not be
+ * changed by other threads within the client. If the message is modified, the
+ * result of the <CODE>send</CODE> is undefined. <p/>
  * <P>
  * After sending a message, a client may retain and modify it without affecting
  * the message that has been sent. The same message object may be sent multiple
- * times.
- * <p/>
+ * times. <p/>
  * <P>
- * The following message headers are set as part of sending a message: <code>JMSDestination</code>,
- * <code>JMSDeliveryMode</code>,<code>JMSExpiration</code>,<code>JMSPriority</code>,
+ * The following message headers are set as part of sending a message:
+ * <code>JMSDestination</code>, <code>JMSDeliveryMode</code>,<code>JMSExpiration</code>,<code>JMSPriority</code>,
  * <code>JMSMessageID</code> and <code>JMSTimeStamp</code>. When the
  * message is sent, the values of these headers are ignored. After the
- * completion of the <CODE>send</CODE>, the headers hold the values
- * specified by the method sending the message. It is possible for the <code>send</code>
+ * completion of the <CODE>send</CODE>, the headers hold the values specified
+ * by the method sending the message. It is possible for the <code>send</code>
  * method not to set <code>JMSMessageID</code> and <code>JMSTimeStamp</code>
- * if the setting of these headers is explicitly disabled by the <code>MessageProducer.setDisableMessageID</code>
- * or <code>MessageProducer.setDisableMessageTimestamp</code> method.
- * <p/>
+ * if the setting of these headers is explicitly disabled by the
+ * <code>MessageProducer.setDisableMessageID</code> or
+ * <code>MessageProducer.setDisableMessageTimestamp</code> method. <p/>
  * <P>
  * Creating a <CODE>MessageProducer</CODE> provides the same features as
  * creating a <CODE>QueueSender</CODE>. A <CODE>MessageProducer</CODE>
  * object is recommended when creating new code. The <CODE>QueueSender</CODE>
  * is provided to support existing code.
- *
+ * 
  * @see javax.jms.MessageProducer
  * @see javax.jms.QueueSession#createSender(Queue)
  */
@@ -74,38 +73,35 @@
 public class ActiveMQQueueSender extends ActiveMQMessageProducer implements QueueSender {
 
     protected ActiveMQQueueSender(ActiveMQSession session, ActiveMQDestination destination)
-            throws JMSException {
-        super(session,
-              session.getNextProducerId(),
-              destination);
+        throws JMSException {
+        super(session, session.getNextProducerId(), destination);
     }
 
     /**
      * Gets the queue associated with this <CODE>QueueSender</CODE>.
-     *
+     * 
      * @return this sender's queue
      * @throws JMSException if the JMS provider fails to get the queue for this
-     *                      <CODE>QueueSender</CODE> due to some internal error.
+     *                 <CODE>QueueSender</CODE> due to some internal error.
      */
 
     public Queue getQueue() throws JMSException {
-        return (Queue) super.getDestination();
+        return (Queue)super.getDestination();
     }
 
     /**
-     * Sends a message to a queue for an unidentified message producer. Uses
-     * the <CODE>QueueSender</CODE>'s default delivery mode, priority, and
-     * time to live.
-     * <p/>
+     * Sends a message to a queue for an unidentified message producer. Uses the
+     * <CODE>QueueSender</CODE>'s default delivery mode, priority, and time
+     * to live. <p/>
      * <P>
      * Typically, a message producer is assigned a queue at creation time;
      * however, the JMS API also supports unidentified message producers, which
      * require that the queue be supplied every time a message is sent.
-     *
-     * @param queue   the queue to send this message to
+     * 
+     * @param queue the queue to send this message to
      * @param message the message to send
-     * @throws JMSException                if the JMS provider fails to send the message due to some
-     *                                     internal error.
+     * @throws JMSException if the JMS provider fails to send the message due to
+     *                 some internal error.
      * @see javax.jms.MessageProducer#getDeliveryMode()
      * @see javax.jms.MessageProducer#getTimeToLive()
      * @see javax.jms.MessageProducer#getPriority()
@@ -117,28 +113,23 @@
 
     /**
      * Sends a message to a queue for an unidentified message producer,
-     * specifying delivery mode, priority and time to live.
-     * <p/>
+     * specifying delivery mode, priority and time to live. <p/>
      * <P>
      * Typically, a message producer is assigned a queue at creation time;
      * however, the JMS API also supports unidentified message producers, which
      * require that the queue be supplied every time a message is sent.
-     *
-     * @param queue        the queue to send this message to
-     * @param message      the message to send
+     * 
+     * @param queue the queue to send this message to
+     * @param message the message to send
      * @param deliveryMode the delivery mode to use
-     * @param priority     the priority for this message
-     * @param timeToLive   the message's lifetime (in milliseconds)
-     * @throws JMSException                if the JMS provider fails to send the message due to some
-     *                                     internal error.
+     * @param priority the priority for this message
+     * @param timeToLive the message's lifetime (in milliseconds)
+     * @throws JMSException if the JMS provider fails to send the message due to
+     *                 some internal error.
      */
 
     public void send(Queue queue, Message message, int deliveryMode, int priority, long timeToLive)
-            throws JMSException {
-        super.send(queue,
-                   message,
-                   deliveryMode,
-                   priority,
-                   timeToLive);
+        throws JMSException {
+        super.send(queue, message, deliveryMode, priority, timeToLive);
     }
 }

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSessionExecutor.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSessionExecutor.java?view=diff&rev=563982&r1=563981&r2=563982
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSessionExecutor.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSessionExecutor.java Wed Aug  8 11:56:59 2007
@@ -96,8 +96,8 @@
                     Thread.currentThread().interrupt();
                 }
             } else {
-                while (iterate())
-                    ;
+                while (iterate()) {                    
+                }
             }
         }
     }
@@ -128,8 +128,9 @@
     synchronized void start() {
         if (!messageQueue.isRunning()) {
             messageQueue.start();
-            if (hasUncomsumedMessages())
+            if (hasUncomsumedMessages()) {
                 wakeup();
+            }
         }
     }
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQTopicSession.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQTopicSession.java?view=diff&rev=563982&r1=563981&r2=563982
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQTopicSession.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQTopicSession.java Wed Aug  8 11:56:59 2007
@@ -104,8 +104,9 @@
      * @throws JMSException
      */
     public MessageConsumer createConsumer(Destination destination) throws JMSException {
-        if (destination instanceof Queue)
+        if (destination instanceof Queue) {
             throw new InvalidDestinationException("Queues are not supported by a TopicSession");
+        }
         return next.createConsumer(destination);
     }
 
@@ -116,8 +117,9 @@
      * @throws JMSException
      */
     public MessageConsumer createConsumer(Destination destination, String messageSelector) throws JMSException {
-        if (destination instanceof Queue)
+        if (destination instanceof Queue) {
             throw new InvalidDestinationException("Queues are not supported by a TopicSession");
+        }
         return next.createConsumer(destination, messageSelector);
     }
 
@@ -129,8 +131,9 @@
      * @throws JMSException
      */
     public MessageConsumer createConsumer(Destination destination, String messageSelector, boolean NoLocal) throws JMSException {
-        if (destination instanceof Queue)
+        if (destination instanceof Queue) {
             throw new InvalidDestinationException("Queues are not supported by a TopicSession");
+        }
         return next.createConsumer(destination, messageSelector, NoLocal);
     }
 
@@ -195,8 +198,9 @@
      * @throws JMSException
      */
     public MessageProducer createProducer(Destination destination) throws JMSException {
-        if (destination instanceof Queue)
+        if (destination instanceof Queue) {
             throw new InvalidDestinationException("Queues are not supported by a TopicSession");
+        }
         return next.createProducer(destination);
     }
 

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/Closeable.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/Closeable.java?view=diff&rev=563982&r1=563981&r2=563982
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/Closeable.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/Closeable.java Wed Aug  8 11:56:59 2007
@@ -20,20 +20,21 @@
 
 /**
  * Provides a uniform interface that can be used to close all the JMS obejcts
- * that provide a close() method.  Useful for when you want to collect
- * a heterogeous set of JMS object in a collection to be closed at a later time.
- *
+ * that provide a close() method. Useful for when you want to collect a
+ * heterogeous set of JMS object in a collection to be closed at a later time.
+ * 
  * @version $Revision: 1.2 $
  */
 public interface Closeable {
-	
-	/**
-	 * Closes a JMS object.
-	 * <P>
-	 * Many JMS objects are closeable such as Connections, Sessions, Consumers and Producers.
-	 *
-	 * @throws JMSException if the JMS provider fails to close the object due to
-	 *                      some internal error.
-	 */
-	public void close() throws JMSException;
+
+    /**
+     * Closes a JMS object.
+     * <P>
+     * Many JMS objects are closeable such as Connections, Sessions, Consumers
+     * and Producers.
+     * 
+     * @throws JMSException if the JMS provider fails to close the object due to
+     *                 some internal error.
+     */
+    public void close() throws JMSException;
 }

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/StreamConnection.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/StreamConnection.java?view=diff&rev=563982&r1=563981&r2=563982
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/StreamConnection.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/StreamConnection.java Wed Aug  8 11:56:59 2007
@@ -27,27 +27,31 @@
 import javax.jms.Topic;
 
 /**
- * The StreamConnection interface allows you to send and receive 
- * data from a Destination in using standard java InputStream and OutputStream
- * objects.  It's best use case is to send and receive large amounts of data
- * that would be to large to hold in a single JMS message.
+ * The StreamConnection interface allows you to send and receive data from a
+ * Destination in using standard java InputStream and OutputStream objects. It's
+ * best use case is to send and receive large amounts of data that would be to
+ * large to hold in a single JMS message.
  * 
  * @version $Revision$
  */
 public interface StreamConnection extends Connection {
 
-	public InputStream createInputStream(Destination dest) throws JMSException;
+    public InputStream createInputStream(Destination dest) throws JMSException;
+
     public InputStream createInputStream(Destination dest, String messageSelector) throws JMSException;
+
     public InputStream createInputStream(Destination dest, String messageSelector, boolean noLocal) throws JMSException;
-    
+
     public InputStream createDurableInputStream(Topic dest, String name) throws JMSException;
+
     public InputStream createDurableInputStream(Topic dest, String name, String messageSelector) throws JMSException;
+
     public InputStream createDurableInputStream(Topic dest, String name, String messageSelector, boolean noLocal) throws JMSException;
 
     public OutputStream createOutputStream(Destination dest) throws JMSException;
-    public OutputStream createOutputStream(Destination dest, Map streamProperties, int deliveryMode,
-            int priority, long timeToLive) throws JMSException;
- 
+
+    public OutputStream createOutputStream(Destination dest, Map streamProperties, int deliveryMode, int priority, long timeToLive) throws JMSException;
+
     /**
      * Unsubscribes a durable subscription that has been created by a client.
      * <P>
@@ -55,17 +59,16 @@
      * subscriber by its provider.
      * <P>
      * It is erroneous for a client to delete a durable subscription while there
-     * is an active <CODE>MessageConsumer </CODE> or <CODE>TopicSubscriber</CODE>
-     * for the subscription, or while a consumed message is part of a pending
-     * transaction or has not been acknowledged in the session.
+     * is an active <CODE>MessageConsumer </CODE> or
+     * <CODE>TopicSubscriber</CODE> for the subscription, or while a consumed
+     * message is part of a pending transaction or has not been acknowledged in
+     * the session.
      * 
-     * @param name
-     *            the name used to identify this subscription
-     * @throws JMSException
-     *             if the session fails to unsubscribe to the durable
-     *             subscription due to some internal error.
-     * @throws InvalidDestinationException
-     *             if an invalid subscription name is specified.
+     * @param name the name used to identify this subscription
+     * @throws JMSException if the session fails to unsubscribe to the durable
+     *                 subscription due to some internal error.
+     * @throws InvalidDestinationException if an invalid subscription name is
+     *                 specified.
      * @since 1.1
      */
     public void unsubscribe(String name) throws JMSException;

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisorySupport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisorySupport.java?view=diff&rev=563982&r1=563981&r2=563982
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisorySupport.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisorySupport.java Wed Aug  8 11:56:59 2007
@@ -50,17 +50,19 @@
     }
 
     public static ActiveMQTopic getConsumerAdvisoryTopic(ActiveMQDestination destination) {
-        if (destination.isQueue())
+        if (destination.isQueue()) {
             return new ActiveMQTopic(QUEUE_CONSUMER_ADVISORY_TOPIC_PREFIX + destination.getPhysicalName());
-        else
+        } else {
             return new ActiveMQTopic(TOPIC_CONSUMER_ADVISORY_TOPIC_PREFIX + destination.getPhysicalName());
+        }
     }
 
     public static ActiveMQTopic getProducerAdvisoryTopic(ActiveMQDestination destination) {
-        if (destination.isQueue())
+        if (destination.isQueue()) {
             return new ActiveMQTopic(QUEUE_PRODUCER_ADVISORY_TOPIC_PREFIX + destination.getPhysicalName());
-        else
+        } else {
             return new ActiveMQTopic(TOPIC_PRODUCER_ADVISORY_TOPIC_PREFIX + destination.getPhysicalName());
+        }
     }
 
     public static ActiveMQTopic getExpiredMessageTopic(ActiveMQDestination destination) {

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/blob/DefaultBlobUploadStrategy.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/blob/DefaultBlobUploadStrategy.java?view=diff&rev=563982&r1=563981&r2=563982
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/blob/DefaultBlobUploadStrategy.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/blob/DefaultBlobUploadStrategy.java Wed Aug  8 11:56:59 2007
@@ -30,8 +30,8 @@
 import org.apache.activemq.command.ActiveMQBlobMessage;
 
 /**
- * A default implementation of {@link BlobUploadStrategy} which uses the URL class to upload
- * files or streams to a remote URL
+ * A default implementation of {@link BlobUploadStrategy} which uses the URL
+ * class to upload files or streams to a remote URL
  */
 public class DefaultBlobUploadStrategy implements BlobUploadStrategy {
     private BlobTransferPolicy transferPolicy;
@@ -50,30 +50,31 @@
         HttpURLConnection connection = (HttpURLConnection)url.openConnection();
         connection.setRequestMethod("PUT");
         connection.setDoOutput(true);
-        
-        // use chunked mode or otherwise URLConnection loads everything into memory
+
+        // use chunked mode or otherwise URLConnection loads everything into
+        // memory
         // (chunked mode not supported before JRE 1.5)
         connection.setChunkedStreamingMode(transferPolicy.getBufferSize());
-        
+
         OutputStream os = connection.getOutputStream();
 
         byte[] buf = new byte[transferPolicy.getBufferSize()];
         for (int c = fis.read(buf); c != -1; c = fis.read(buf)) {
-        	os.write(buf, 0, c);
-        	os.flush();
+            os.write(buf, 0, c);
+            os.flush();
         }
         os.close();
         fis.close();
-        
+
         if (!isSuccessfulCode(connection.getResponseCode())) {
-        	throw new IOException("PUT was not successful: "
-        			+ connection.getResponseCode() + " " + connection.getResponseMessage());
+            throw new IOException("PUT was not successful: " + connection.getResponseCode() + " "
+                                  + connection.getResponseMessage());
         }
 
         return url;
     }
 
-	public void deleteFile(ActiveMQBlobMessage message) throws IOException, JMSException {
+    public void deleteFile(ActiveMQBlobMessage message) throws IOException, JMSException {
         URL url = createUploadURL(message);
 
         HttpURLConnection connection = (HttpURLConnection)url.openConnection();
@@ -82,16 +83,16 @@
         connection.disconnect();
 
         if (!isSuccessfulCode(connection.getResponseCode())) {
-        	throw new IOException("DELETE was not successful: "
-        			+ connection.getResponseCode() + " " + connection.getResponseMessage());
+            throw new IOException("DELETE was not successful: " + connection.getResponseCode() + " "
+                                  + connection.getResponseMessage());
         }
-	}
-	
+    }
+
     private boolean isSuccessfulCode(int responseCode) {
-		return responseCode >= 200 && responseCode < 300; // 2xx => successful
-	}
+        return responseCode >= 200 && responseCode < 300; // 2xx => successful
+    }
 
-	protected URL createUploadURL(ActiveMQBlobMessage message) throws JMSException, MalformedURLException {
+    protected URL createUploadURL(ActiveMQBlobMessage message) throws JMSException, MalformedURLException {
         return new URL(transferPolicy.getUploadUrl() + message.getMessageId().toString());
     }
 }

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerFactory.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerFactory.java?view=diff&rev=563982&r1=563981&r2=563982
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerFactory.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerFactory.java Wed Aug  8 11:56:59 2007
@@ -23,26 +23,28 @@
 import org.apache.activemq.util.IOExceptionSupport;
 
 /**
- * A helper class to create a fully configured broker service using a URI.
- * The list of currently supported URI syntaxes is described
- * <a href="http://activemq.apache.org/how-do-i-embed-a-broker-inside-a-connection.html">here</a>
+ * A helper class to create a fully configured broker service using a URI. The
+ * list of currently supported URI syntaxes is described <a
+ * href="http://activemq.apache.org/how-do-i-embed-a-broker-inside-a-connection.html">here</a>
  * 
  * @version $Revision$
  */
 public class BrokerFactory {
 
-    static final private FactoryFinder brokerFactoryHandlerFinder = new FactoryFinder("META-INF/services/org/apache/activemq/broker/");
+    static final private FactoryFinder brokerFactoryHandlerFinder = new FactoryFinder(
+                                                                                      "META-INF/services/org/apache/activemq/broker/");
 
     public static BrokerFactoryHandler createBrokerFactoryHandler(String type) throws IOException {
         try {
             return (BrokerFactoryHandler)brokerFactoryHandlerFinder.newInstance(type);
         } catch (Throwable e) {
-            throw IOExceptionSupport.create("Could load "+type+" factory:"+e, e);
+            throw IOExceptionSupport.create("Could load " + type + " factory:" + e, e);
         }
     }
 
     /**
      * Creates a broker from a URI configuration
+     * 
      * @param brokerURI the URI scheme to configure the broker
      * @throws Exception
      */
@@ -52,14 +54,17 @@
 
     /**
      * Creates a broker from a URI configuration
+     * 
      * @param brokerURI the URI scheme to configure the broker
-     * @param startBroker whether or not the broker should have its {@link BrokerService#start()} method called after construction
+     * @param startBroker whether or not the broker should have its
+     *                {@link BrokerService#start()} method called after
+     *                construction
      * @throws Exception
      */
     public static BrokerService createBroker(URI brokerURI, boolean startBroker) throws Exception {
-        if( brokerURI.getScheme() == null )
-            throw new IllegalArgumentException("Invalid broker URI, no scheme specified: "+brokerURI);
-        
+        if (brokerURI.getScheme() == null) {
+            throw new IllegalArgumentException("Invalid broker URI, no scheme specified: " + brokerURI);
+        }
         BrokerFactoryHandler handler = createBrokerFactoryHandler(brokerURI.getScheme());
         BrokerService broker = handler.createBroker(brokerURI);
         if (startBroker) {
@@ -68,9 +73,9 @@
         return broker;
     }
 
-
     /**
      * Creates a broker from a URI configuration
+     * 
      * @param brokerURI the URI scheme to configure the broker
      * @throws Exception
      */
@@ -78,16 +83,17 @@
         return createBroker(new URI(brokerURI));
     }
 
-
     /**
      * Creates a broker from a URI configuration
+     * 
      * @param brokerURI the URI scheme to configure the broker
-     * @param startBroker whether or not the broker should have its {@link BrokerService#start()} method called after construction
+     * @param startBroker whether or not the broker should have its
+     *                {@link BrokerService#start()} method called after
+     *                construction
      * @throws Exception
      */
     public static BrokerService createBroker(String brokerURI, boolean startBroker) throws Exception {
         return createBroker(new URI(brokerURI), startBroker);
     }
-
 
 }

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerStoppedException.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerStoppedException.java?view=diff&rev=563982&r1=563981&r2=563982
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerStoppedException.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerStoppedException.java Wed Aug  8 11:56:59 2007
@@ -17,29 +17,30 @@
 package org.apache.activemq.broker;
 
 /**
- * This exception is thrown by the broker when you try to use it after it has been stopped.
- *  
+ * This exception is thrown by the broker when you try to use it after it has
+ * been stopped.
+ * 
  * @author chirino
  */
 public class BrokerStoppedException extends IllegalStateException {
 
-	private static final long serialVersionUID = -3435230276850902220L;
+    private static final long serialVersionUID = -3435230276850902220L;
 
-	public BrokerStoppedException() {
-		super();
-	}
+    public BrokerStoppedException() {
+        super();
+    }
 
-	public BrokerStoppedException(String message, Throwable cause) {
-		super(message);
-		initCause(cause);
-	}
+    public BrokerStoppedException(String message, Throwable cause) {
+        super(message);
+        initCause(cause);
+    }
 
-	public BrokerStoppedException(String s) {
-		super(s);
-	}
+    public BrokerStoppedException(String s) {
+        super(s);
+    }
 
-	public BrokerStoppedException(Throwable cause) {
-		initCause(cause);
-	}
+    public BrokerStoppedException(Throwable cause) {
+        initCause(cause);
+    }
 
 }

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/Connection.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/Connection.java?view=diff&rev=563982&r1=563981&r2=563982
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/Connection.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/Connection.java Wed Aug  8 11:56:59 2007
@@ -24,7 +24,6 @@
 import org.apache.activemq.command.Response;
 
 /**
- * 
  * @version $Revision: 1.5 $
  */
 public interface Connection extends Service {
@@ -37,8 +36,7 @@
     /**
      * Sends a message to the client.
      * 
-     * @param message
-     *            the message to send to the client.
+     * @param message the message to send to the client.
      */
     public void dispatchSync(Command message);
 
@@ -87,12 +85,12 @@
      * Returns the number of messages to be dispatched to this connection
      */
     public int getDispatchQueueSize();
-    
+
     /**
      * Returns the statistics for this connection
      */
     public ConnectionStatistics getStatistics();
-    
+
     /**
      * @return true if the Connection will process control commands
      */
@@ -101,10 +99,10 @@
     /**
      * @return the source address for this connection
      */
-	public String getRemoteAddress();
+    public String getRemoteAddress();
+
+    public void serviceExceptionAsync(IOException e);
 
-	public void serviceExceptionAsync(IOException e);
-	
-	public String getConnectionId();
+    public String getConnectionId();
 
 }



Mime
View raw message