You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2007/08/08 20:58:13 UTC
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...
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();
}