From commits-return-6806-apmail-activemq-commits-archive=activemq.apache.org@activemq.apache.org Wed Aug 08 18:59:44 2007 Return-Path: Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: (qmail 48807 invoked from network); 8 Aug 2007 18:59:43 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 8 Aug 2007 18:59:43 -0000 Received: (qmail 66519 invoked by uid 500); 8 Aug 2007 18:59:42 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 66471 invoked by uid 500); 8 Aug 2007 18:59:42 -0000 Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list commits@activemq.apache.org Received: (qmail 66462 invoked by uid 99); 8 Aug 2007 18:59:42 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 08 Aug 2007 11:59:42 -0700 X-ASF-Spam-Status: No, hits=-100.0 required=10.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.3] (HELO eris.apache.org) (140.211.11.3) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 08 Aug 2007 18:59:39 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id 5B7521A981A; Wed, 8 Aug 2007 11:59:19 -0700 (PDT) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit 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 -0000 To: commits@activemq.apache.org From: chirino@apache.org X-Mailer: svnmailer-1.1.0 Message-Id: <20070808185919.5B7521A981A@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org 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 QueueReceiver object to receive messages that - * have been delivered to a queue. - *

+ * have been delivered to a queue.

*

* Although it is possible to have multiple QueueReceiver s for * the same queue, the JMS API does not define how messages are distributed - * between the QueueReceivers. - *

+ * between the QueueReceivers.

*

* If a QueueReceiver 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 * QueueReceiver s without a message selector will read messages - * in message producer order. - *

+ * in message producer order.

*

* Creating a MessageConsumer provides the same features as * creating a QueueReceiver. A MessageConsumer * object is recommended for creating new code. The QueueReceiver - * is provided to support existing 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 Queue associated with this queue receiver. - * + * * @return this receiver's Queue - * @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 QueueSender object to send messages to a - * queue. - *

+ * queue.

*

* Normally, the Queue is specified when a QueueSender - * is created. In this case, an attempt to use the send - * methods for an unidentified QueueSender will throw a + * + * is created. In this case, an attempt to use the send methods + * for an unidentified QueueSender will throw a * java.lang.UnsupportedOperationException. *

*

* If the QueueSender is created with an unidentified - * Queue, an attempt to use the send methods that - * assume that the Queue has been identified will throw a + * Queue, + * an attempt to use the send methods that assume that the + * Queue has been identified will throw a * java.lang.UnsupportedOperationException. *

*

- * During the execution of its send method, a message must not - * be changed by other threads within the client. If the message is modified, - * the result of the send is undefined. - *

+ * During the execution of its send method, a message must not be + * changed by other threads within the client. If the message is modified, the + * result of the send is undefined.

*

* 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. - *

+ * times.

*

- * The following message headers are set as part of sending a message: JMSDestination, - * JMSDeliveryMode,JMSExpiration,JMSPriority, + * The following message headers are set as part of sending a message: + * JMSDestination, JMSDeliveryMode,JMSExpiration,JMSPriority, * JMSMessageID and JMSTimeStamp. When the * message is sent, the values of these headers are ignored. After the - * completion of the send, the headers hold the values - * specified by the method sending the message. It is possible for the send + * completion of the send, the headers hold the values specified + * by the method sending the message. It is possible for the send * method not to set JMSMessageID and JMSTimeStamp - * if the setting of these headers is explicitly disabled by the MessageProducer.setDisableMessageID - * or MessageProducer.setDisableMessageTimestamp method. - *

+ * if the setting of these headers is explicitly disabled by the + * MessageProducer.setDisableMessageID or + * MessageProducer.setDisableMessageTimestamp method.

*

* Creating a MessageProducer provides the same features as * creating a QueueSender. A MessageProducer * object is recommended when creating new code. The QueueSender * 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 QueueSender. - * + * * @return this sender's queue * @throws JMSException if the JMS provider fails to get the queue for this - * QueueSender due to some internal error. + * QueueSender 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 QueueSender's default delivery mode, priority, and - * time to live. - *

+ * Sends a message to a queue for an unidentified message producer. Uses the + * QueueSender's default delivery mode, priority, and time + * to live.

*

* 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. - *

+ * specifying delivery mode, priority and time to live.

*

* 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. - *

- * 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. + *

+ * 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. *

@@ -55,17 +59,16 @@ * subscriber by its provider. *

* It is erroneous for a client to delete a durable subscription while there - * is an active MessageConsumer or TopicSubscriber - * 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 MessageConsumer or + * TopicSubscriber 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 - * here + * A helper class to create a fully configured broker service using a URI. The + * list of currently supported URI syntaxes is described here * * @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(); }