activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r780773 [1/31] - in /activemq/sandbox/activemq-flow: activemq-client/ activemq-client/src/main/java/org/ activemq-client/src/main/java/org/apache/ activemq-client/src/main/java/org/apache/activemq/ activemq-client/src/main/java/org/apache/a...
Date Mon, 01 Jun 2009 18:37:54 GMT
Author: chirino
Date: Mon Jun  1 18:37:41 2009
New Revision: 780773

URL: http://svn.apache.org/viewvc?rev=780773&view=rev
Log:
Bringing in more 5.x classes to remove dep on the 5.x module.

Added:
    activemq/sandbox/activemq-flow/activemq-client/src/main/java/org/
    activemq/sandbox/activemq-flow/activemq-client/src/main/java/org/apache/
    activemq/sandbox/activemq-flow/activemq-client/src/main/java/org/apache/activemq/
    activemq/sandbox/activemq-flow/activemq-client/src/main/java/org/apache/activemq/jndi/
    activemq/sandbox/activemq-flow/activemq-client/src/main/java/org/apache/activemq/jndi/ActiveMQInitialContextFactory.java   (with props)
    activemq/sandbox/activemq-flow/activemq-client/src/main/java/org/apache/activemq/jndi/ActiveMQWASInitialContextFactory.java
    activemq/sandbox/activemq-flow/activemq-client/src/main/java/org/apache/activemq/jndi/package.html   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/BlobMessage.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/IConnection.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/Message.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/advisory/
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/advisory/AdvisorySupport.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/advisory/package.html   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/blob/
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/blob/BlobTransferPolicy.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/blob/BlobUploadStrategy.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/blob/BlobUploader.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/blob/DefaultBlobUploadStrategy.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/blob/package.html
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/broker/region/
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/broker/region/Destination.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/broker/region/MessageReference.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ActiveMQBlobMessage.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ActiveMQBytesMessage.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ActiveMQDestination.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ActiveMQMapMessage.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ActiveMQMessage.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ActiveMQObjectMessage.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ActiveMQQueue.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ActiveMQStreamMessage.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ActiveMQTempDestination.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ActiveMQTempQueue.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ActiveMQTempTopic.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ActiveMQTopic.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/BaseCommand.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/BaseEndpoint.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/BrokerId.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/BrokerInfo.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/Command.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/CommandTypes.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ConnectionControl.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ConnectionError.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ConnectionId.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ConnectionInfo.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ConsumerControl.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ConsumerId.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ConsumerInfo.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ControlCommand.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/DataArrayResponse.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/DataResponse.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/DataStructure.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/DestinationInfo.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/DiscoveryEvent.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/Endpoint.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ExceptionResponse.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/FlushCommand.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/IntegerResponse.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/JournalQueueAck.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/JournalTopicAck.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/JournalTrace.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/JournalTransaction.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/KeepAliveInfo.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/LastPartialCommand.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/LocalTransactionId.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/MarshallAware.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/Message.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/MessageAck.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/MessageDispatch.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/MessageDispatchNotification.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/MessageId.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/MessagePull.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/NetworkBridgeFilter.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/PartialCommand.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ProducerAck.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ProducerId.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ProducerInfo.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/RemoveInfo.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/RemoveSubscriptionInfo.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ReplayCommand.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/Response.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/SessionId.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/SessionInfo.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/ShutdownInfo.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/SubscriptionInfo.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/TransactionId.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/TransactionInfo.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/WireFormatInfo.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/XATransactionId.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/command/package.html   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/filter/
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/filter/NoLocalExpression.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/BooleanStream.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/CommandIdComparator.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/DataStreamMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/OpenWireFormat.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/OpenWireFormatFactory.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ActiveMQBytesMessageMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ActiveMQDestinationMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ActiveMQMapMessageMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ActiveMQMessageMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ActiveMQObjectMessageMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ActiveMQQueueMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ActiveMQStreamMessageMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ActiveMQTempDestinationMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ActiveMQTempQueueMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ActiveMQTempTopicMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ActiveMQTextMessageMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ActiveMQTopicMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/BaseCommandMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/BaseDataStreamMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/BrokerIdMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/BrokerInfoMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ConnectionControlMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ConnectionErrorMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ConnectionIdMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ConnectionInfoMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ConsumerControlMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ConsumerIdMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ConsumerInfoMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ControlCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/DataArrayResponseMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/DataResponseMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/DataStructureSupportMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/DestinationInfoMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/DiscoveryEventMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ExceptionResponseMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/FlushCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/IntegerResponseMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/JournalQueueAckMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/JournalTopicAckMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/JournalTraceMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/JournalTransactionMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/KeepAliveInfoMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/LastPartialCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/LocalTransactionIdMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/MarshallerFactory.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/MessageAckMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/MessageDispatchMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/MessageDispatchNotificationMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/MessageIdMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/MessageMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/NetworkBridgeFilterMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/PartialCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ProducerIdMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ProducerInfoMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/RemoveInfoMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/RemoveSubscriptionInfoMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ReplayCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ResponseMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/SessionIdMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/SessionInfoMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/ShutdownInfoMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/SubscriptionInfoMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/TransactionIdMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/TransactionInfoMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/WireFormatInfoMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v1/XATransactionIdMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ActiveMQBytesMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ActiveMQDestinationMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ActiveMQMapMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ActiveMQMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ActiveMQObjectMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ActiveMQQueueMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ActiveMQStreamMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ActiveMQTempDestinationMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ActiveMQTempQueueMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ActiveMQTempTopicMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ActiveMQTextMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ActiveMQTopicMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/BaseCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/BaseDataStreamMarshaller.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/BrokerIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/BrokerInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ConnectionControlMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ConnectionErrorMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ConnectionIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ConnectionInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ConsumerControlMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ConsumerIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ConsumerInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ControlCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/DataArrayResponseMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/DataResponseMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/DestinationInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/DiscoveryEventMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ExceptionResponseMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/FlushCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/IntegerResponseMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/JournalQueueAckMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/JournalTopicAckMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/JournalTraceMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/JournalTransactionMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/KeepAliveInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/LastPartialCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/LocalTransactionIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/MarshallerFactory.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/MessageAckMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/MessageDispatchMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/MessageDispatchNotificationMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/MessageIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/MessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/MessagePullMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/NetworkBridgeFilterMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/PartialCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ProducerIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ProducerInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/RemoveInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/RemoveSubscriptionInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ReplayCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ResponseMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/SessionIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/SessionInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/ShutdownInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/SubscriptionInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/TransactionIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/TransactionInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/WireFormatInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v2/XATransactionIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ActiveMQBlobMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ActiveMQBytesMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ActiveMQDestinationMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ActiveMQMapMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ActiveMQMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ActiveMQObjectMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ActiveMQQueueMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ActiveMQStreamMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ActiveMQTempDestinationMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ActiveMQTempQueueMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ActiveMQTempTopicMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ActiveMQTextMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ActiveMQTopicMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/BaseCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/BaseDataStreamMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/BrokerIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/BrokerInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ConnectionControlMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ConnectionErrorMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ConnectionIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ConnectionInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ConsumerControlMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ConsumerIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ConsumerInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ControlCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/DataArrayResponseMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/DataResponseMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/DestinationInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/DiscoveryEventMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ExceptionResponseMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/FlushCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/IntegerResponseMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/JournalQueueAckMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/JournalTopicAckMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/JournalTraceMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/JournalTransactionMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/KeepAliveInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/LastPartialCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/LocalTransactionIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/MarshallerFactory.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/MessageAckMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/MessageDispatchMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/MessageDispatchNotificationMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/MessageIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/MessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/MessagePullMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/NetworkBridgeFilterMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/PartialCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ProducerAckMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ProducerIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ProducerInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/RemoveInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/RemoveSubscriptionInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ReplayCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ResponseMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/SessionIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/SessionInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/ShutdownInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/SubscriptionInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/TransactionIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/TransactionInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/WireFormatInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v3/XATransactionIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ActiveMQBlobMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ActiveMQBytesMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ActiveMQDestinationMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ActiveMQMapMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ActiveMQMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ActiveMQObjectMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ActiveMQQueueMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ActiveMQStreamMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ActiveMQTempDestinationMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ActiveMQTempQueueMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ActiveMQTempTopicMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ActiveMQTextMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ActiveMQTopicMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/BaseCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/BaseDataStreamMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/BrokerIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/BrokerInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ConnectionControlMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ConnectionErrorMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ConnectionIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ConnectionInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ConsumerControlMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ConsumerIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ConsumerInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ControlCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/DataArrayResponseMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/DataResponseMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/DestinationInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/DiscoveryEventMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ExceptionResponseMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/FlushCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/IntegerResponseMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/JournalQueueAckMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/JournalTopicAckMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/JournalTraceMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/JournalTransactionMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/KeepAliveInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/LastPartialCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/LocalTransactionIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/MarshallerFactory.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/MessageAckMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/MessageDispatchMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/MessageDispatchNotificationMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/MessageIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/MessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/MessagePullMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/NetworkBridgeFilterMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/PartialCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ProducerAckMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ProducerIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ProducerInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/RemoveInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/RemoveSubscriptionInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ReplayCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ResponseMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/SessionIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/SessionInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/ShutdownInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/SubscriptionInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/TransactionIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/TransactionInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/WireFormatInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v4/XATransactionIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ActiveMQBlobMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ActiveMQBytesMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ActiveMQDestinationMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ActiveMQMapMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ActiveMQMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ActiveMQObjectMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ActiveMQQueueMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ActiveMQStreamMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ActiveMQTempDestinationMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ActiveMQTempQueueMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ActiveMQTempTopicMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ActiveMQTextMessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ActiveMQTopicMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/BaseCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/BaseDataStreamMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/BrokerIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/BrokerInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ConnectionControlMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ConnectionErrorMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ConnectionIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ConnectionInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ConsumerControlMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ConsumerIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ConsumerInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ControlCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/DataArrayResponseMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/DataResponseMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/DestinationInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/DiscoveryEventMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ExceptionResponseMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/FlushCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/IntegerResponseMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/JournalQueueAckMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/JournalTopicAckMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/JournalTraceMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/JournalTransactionMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/KeepAliveInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/LastPartialCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/LocalTransactionIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/MarshallerFactory.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/MessageAckMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/MessageDispatchMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/MessageDispatchNotificationMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/MessageIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/MessageMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/MessagePullMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/NetworkBridgeFilterMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/PartialCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ProducerAckMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ProducerIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ProducerInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/RemoveInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/RemoveSubscriptionInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ReplayCommandMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ResponseMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/SessionIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/SessionInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/ShutdownInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/SubscriptionInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/TransactionIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/TransactionInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/WireFormatInfoMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/openwire/v5/XATransactionIdMarshaller.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/state/
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/state/CommandVisitor.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/state/CommandVisitorAdapter.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/state/ConnectionState.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/state/ConsumerState.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/state/ProducerState.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/state/SessionState.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/state/Tracked.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/state/TransactionState.java
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/transport/
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/transport/WireFormatNegotiator.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/usage/
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/usage/DefaultUsageCapacity.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/usage/MemoryUsage.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/usage/Usage.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/usage/UsageCapacity.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/usage/UsageListener.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/util/
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/util/MarshallingSupport.java   (with props)
    activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/util/TypeConversionSupport.java   (with props)
    activemq/sandbox/activemq-flow/activemq-util/src/main/java/org/apache/activemq/jndi/
    activemq/sandbox/activemq-flow/activemq-util/src/main/java/org/apache/activemq/jndi/JNDIBaseStorable.java
    activemq/sandbox/activemq-flow/activemq-util/src/main/java/org/apache/activemq/jndi/JNDIReferenceFactory.java
    activemq/sandbox/activemq-flow/activemq-util/src/main/java/org/apache/activemq/jndi/JNDIStorableInterface.java
    activemq/sandbox/activemq-flow/activemq-util/src/main/java/org/apache/activemq/jndi/LazyCreateContext.java   (with props)
    activemq/sandbox/activemq-flow/activemq-util/src/main/java/org/apache/activemq/jndi/NameParserImpl.java   (with props)
    activemq/sandbox/activemq-flow/activemq-util/src/main/java/org/apache/activemq/jndi/ReadOnlyContext.java   (with props)
    activemq/sandbox/activemq-flow/activemq-util/src/main/java/org/apache/activemq/jndi/package.html   (with props)
    activemq/sandbox/activemq-flow/activemq-util/src/main/java/org/apache/activemq/util/HexSupport.java   (with props)
    activemq/sandbox/activemq-flow/activemq-util/src/main/java/org/apache/activemq/util/JMSExceptionSupport.java   (with props)
Modified:
    activemq/sandbox/activemq-flow/activemq-client/pom.xml
    activemq/sandbox/activemq-flow/activemq-openwire/pom.xml
    activemq/sandbox/activemq-flow/activemq-selector/src/main/java/org/apache/activemq/filter/MessageEvaluationContext.java
    activemq/sandbox/activemq-flow/activemq-stomp/pom.xml
    activemq/sandbox/activemq-flow/activemq-util/pom.xml

Modified: activemq/sandbox/activemq-flow/activemq-client/pom.xml
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-client/pom.xml?rev=780773&r1=780772&r2=780773&view=diff
==============================================================================
--- activemq/sandbox/activemq-flow/activemq-client/pom.xml (original)
+++ activemq/sandbox/activemq-flow/activemq-client/pom.xml Mon Jun  1 18:37:41 2009
@@ -39,15 +39,13 @@
     </dependency>
     <dependency>
       <groupId>org.apache.activemq</groupId>
-      <artifactId>activemq-dispatcher</artifactId>
-    </dependency>
-    <dependency>
-      <groupId>org.apache.activemq</groupId>
-      <artifactId>activemq-flow</artifactId>
+      <artifactId>activemq-openwire</artifactId>
     </dependency>
+
     <dependency>
       <groupId>org.apache.activemq</groupId>
-      <artifactId>activemq-transport</artifactId>
+      <artifactId>activemq-core</artifactId>
+      <version>5.3-SNAPSHOT</version>
     </dependency>
 
     <!-- Testing Dependencies -->    

Added: activemq/sandbox/activemq-flow/activemq-client/src/main/java/org/apache/activemq/jndi/ActiveMQInitialContextFactory.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-client/src/main/java/org/apache/activemq/jndi/ActiveMQInitialContextFactory.java?rev=780773&view=auto
==============================================================================
--- activemq/sandbox/activemq-flow/activemq-client/src/main/java/org/apache/activemq/jndi/ActiveMQInitialContextFactory.java (added)
+++ activemq/sandbox/activemq-flow/activemq-client/src/main/java/org/apache/activemq/jndi/ActiveMQInitialContextFactory.java Mon Jun  1 18:37:41 2009
@@ -0,0 +1,216 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.jndi;
+
+import java.net.URISyntaxException;
+import java.util.ArrayList;
+import java.util.Hashtable;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import java.util.Properties;
+import java.util.StringTokenizer;
+import java.util.concurrent.ConcurrentHashMap;
+
+import javax.jms.Queue;
+import javax.jms.Topic;
+import javax.naming.Context;
+import javax.naming.NamingException;
+import javax.naming.spi.InitialContextFactory;
+
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.command.ActiveMQQueue;
+import org.apache.activemq.command.ActiveMQTopic;
+
+/**
+ * A factory of the ActiveMQ InitialContext which contains
+ * {@link ConnectionFactory} instances as well as a child context called
+ * <i>destinations</i> which contain all of the current active destinations, in
+ * child context depending on the QoS such as transient or durable and queue or
+ * topic.
+ * 
+ * @version $Revision: 1.2 $
+ */
+public class ActiveMQInitialContextFactory implements InitialContextFactory {
+
+    private static final String[] DEFAULT_CONNECTION_FACTORY_NAMES = {"ConnectionFactory", "QueueConnectionFactory", "TopicConnectionFactory"};
+
+    private String connectionPrefix = "connection.";
+    private String queuePrefix = "queue.";
+    private String topicPrefix = "topic.";
+
+    public Context getInitialContext(Hashtable environment) throws NamingException {
+        // lets create a factory
+        Map<String, Object> data = new ConcurrentHashMap<String, Object>();
+        String[] names = getConnectionFactoryNames(environment);
+        for (int i = 0; i < names.length; i++) {
+            ActiveMQConnectionFactory factory = null;
+            String name = names[i];
+
+            try {
+                factory = createConnectionFactory(name, environment);
+            } catch (Exception e) {
+                throw new NamingException("Invalid broker URL");
+
+            }
+            /*
+             * if( broker==null ) { try { broker = factory.getEmbeddedBroker(); }
+             * catch (JMSException e) { log.warn("Failed to get embedded
+             * broker", e); } }
+             */
+            data.put(name, factory);
+        }
+
+        createQueues(data, environment);
+        createTopics(data, environment);
+        /*
+         * if (broker != null) { data.put("destinations",
+         * broker.getDestinationContext(environment)); }
+         */
+        data.put("dynamicQueues", new LazyCreateContext() {
+            private static final long serialVersionUID = 6503881346214855588L;
+
+            protected Object createEntry(String name) {
+                return new ActiveMQQueue(name);
+            }
+        });
+        data.put("dynamicTopics", new LazyCreateContext() {
+            private static final long serialVersionUID = 2019166796234979615L;
+
+            protected Object createEntry(String name) {
+                return new ActiveMQTopic(name);
+            }
+        });
+
+        return createContext(environment, data);
+    }
+
+    // Properties
+    // -------------------------------------------------------------------------
+    public String getTopicPrefix() {
+        return topicPrefix;
+    }
+
+    public void setTopicPrefix(String topicPrefix) {
+        this.topicPrefix = topicPrefix;
+    }
+
+    public String getQueuePrefix() {
+        return queuePrefix;
+    }
+
+    public void setQueuePrefix(String queuePrefix) {
+        this.queuePrefix = queuePrefix;
+    }
+
+    // Implementation methods
+    // -------------------------------------------------------------------------
+
+    protected ReadOnlyContext createContext(Hashtable environment, Map<String, Object> data) {
+        return new ReadOnlyContext(environment, data);
+    }
+
+    protected ActiveMQConnectionFactory createConnectionFactory(String name, Hashtable environment) throws URISyntaxException {
+        Hashtable temp = new Hashtable(environment);
+        String prefix = connectionPrefix + name + ".";
+        for (Iterator iter = environment.entrySet().iterator(); iter.hasNext();) {
+            Map.Entry entry = (Map.Entry)iter.next();
+            String key = (String)entry.getKey();
+            if (key.startsWith(prefix)) {
+                // Rename the key...
+                temp.remove(key);
+                key = key.substring(prefix.length());
+                temp.put(key, entry.getValue());
+            }
+        }
+        return createConnectionFactory(temp);
+    }
+
+    protected String[] getConnectionFactoryNames(Map environment) {
+        String factoryNames = (String)environment.get("connectionFactoryNames");
+        if (factoryNames != null) {
+            List<String> list = new ArrayList<String>();
+            for (StringTokenizer enumeration = new StringTokenizer(factoryNames, ","); enumeration.hasMoreTokens();) {
+                list.add(enumeration.nextToken().trim());
+            }
+            int size = list.size();
+            if (size > 0) {
+                String[] answer = new String[size];
+                list.toArray(answer);
+                return answer;
+            }
+        }
+        return DEFAULT_CONNECTION_FACTORY_NAMES;
+    }
+
+    protected void createQueues(Map<String, Object> data, Hashtable environment) {
+        for (Iterator iter = environment.entrySet().iterator(); iter.hasNext();) {
+            Map.Entry entry = (Map.Entry)iter.next();
+            String key = entry.getKey().toString();
+            if (key.startsWith(queuePrefix)) {
+                String jndiName = key.substring(queuePrefix.length());
+                data.put(jndiName, createQueue(entry.getValue().toString()));
+            }
+        }
+    }
+
+    protected void createTopics(Map<String, Object> data, Hashtable environment) {
+        for (Iterator iter = environment.entrySet().iterator(); iter.hasNext();) {
+            Map.Entry entry = (Map.Entry)iter.next();
+            String key = entry.getKey().toString();
+            if (key.startsWith(topicPrefix)) {
+                String jndiName = key.substring(topicPrefix.length());
+                data.put(jndiName, createTopic(entry.getValue().toString()));
+            }
+        }
+    }
+
+    /**
+     * Factory method to create new Queue instances
+     */
+    protected Queue createQueue(String name) {
+        return new ActiveMQQueue(name);
+    }
+
+    /**
+     * Factory method to create new Topic instances
+     */
+    protected Topic createTopic(String name) {
+        return new ActiveMQTopic(name);
+    }
+
+    /**
+     * Factory method to create a new connection factory from the given
+     * environment
+     */
+    protected ActiveMQConnectionFactory createConnectionFactory(Hashtable environment) throws URISyntaxException {
+        ActiveMQConnectionFactory answer = new ActiveMQConnectionFactory();
+        Properties properties = new Properties();
+        properties.putAll(environment);
+        answer.setProperties(properties);
+        return answer;
+    }
+
+    public String getConnectionPrefix() {
+        return connectionPrefix;
+    }
+
+    public void setConnectionPrefix(String connectionPrefix) {
+        this.connectionPrefix = connectionPrefix;
+    }
+
+}

Propchange: activemq/sandbox/activemq-flow/activemq-client/src/main/java/org/apache/activemq/jndi/ActiveMQInitialContextFactory.java
------------------------------------------------------------------------------
    svn:executable = *

Added: activemq/sandbox/activemq-flow/activemq-client/src/main/java/org/apache/activemq/jndi/ActiveMQWASInitialContextFactory.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-client/src/main/java/org/apache/activemq/jndi/ActiveMQWASInitialContextFactory.java?rev=780773&view=auto
==============================================================================
--- activemq/sandbox/activemq-flow/activemq-client/src/main/java/org/apache/activemq/jndi/ActiveMQWASInitialContextFactory.java (added)
+++ activemq/sandbox/activemq-flow/activemq-client/src/main/java/org/apache/activemq/jndi/ActiveMQWASInitialContextFactory.java Mon Jun  1 18:37:41 2009
@@ -0,0 +1,99 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.jndi;
+
+import java.util.Hashtable;
+import java.util.Iterator;
+import java.util.Map;
+
+import javax.naming.Context;
+import javax.naming.NamingException;
+
+/**
+ * This implementation of <CODE>InitialContextFactory</CODE> should be used
+ * when ActiveMQ is used as WebSphere Generic JMS Provider. It is proved that it
+ * works on WebSphere 5.1. The reason for using this class is that custom
+ * property defined for Generic JMS Provider are passed to InitialContextFactory
+ * only if it begins with java.naming or javax.naming prefix. Additionaly
+ * provider url for the JMS provider can not contain ',' character that is
+ * necessary when the list of nodes is provided. So the role of this class is to
+ * transform properties before passing it to
+ * <CODE>ActiveMQInitialContextFactory</CODE>.
+ * 
+ * @author Pawel Tucholski
+ */
+public class ActiveMQWASInitialContextFactory extends ActiveMQInitialContextFactory {
+
+    /**
+     * @see javax.naming.spi.InitialContextFactory#getInitialContext(java.util.Hashtable)
+     */
+    public Context getInitialContext(Hashtable environment) throws NamingException {
+
+        return super.getInitialContext(transformEnvironment(environment));
+    }
+
+    /**
+     * Performs following transformation of properties:
+     * <ul>
+     * <li>(java.naming.queue.xxx.yyy,value)=>(queue.xxx/yyy,value)
+     * <li>(java.naming.topic.xxx.yyy,value)=>(topic.xxx/yyy,value)
+     * <li>(java.naming.connectionFactoryNames,value)=>(connectionFactoryNames,value)
+     * <li>(java.naming.provider.url,url1;url2)=>java.naming.provider.url,url1,url1)
+     * <ul>
+     * 
+     * @param environment properties for transformation
+     * @return environment after transformation
+     */
+    protected Hashtable transformEnvironment(Hashtable environment) {
+
+        Hashtable environment1 = new Hashtable();
+
+        Iterator it = environment.entrySet().iterator();
+
+        while (it.hasNext()) {
+            Map.Entry entry = (Map.Entry)it.next();
+            String key = (String)entry.getKey();
+            String value = (String)entry.getValue();
+
+            if (key.startsWith("java.naming.queue")) {
+                String key1 = key.substring("java.naming.queue.".length());
+                key1 = key1.replace('.', '/');
+                environment1.put("queue." + key1, value);
+            } else if (key.startsWith("java.naming.topic")) {
+                String key1 = key.substring("java.naming.topic.".length());
+                key1 = key1.replace('.', '/');
+                environment1.put("topic." + key1, value);
+            } else if (key.startsWith("java.naming.connectionFactoryNames")) {
+                String key1 = key.substring("java.naming.".length());
+                environment1.put(key1, value);
+            } else if (key.startsWith("java.naming.connection")) {
+                String key1 = key.substring("java.naming.".length());
+                environment1.put(key1, value);
+            } else if (key.startsWith(Context.PROVIDER_URL)) {
+                // websphere administration console does not exept , character
+                // in provider url, so ; must be used
+                // all ; to ,
+                value = value.replace(';', ',');
+                environment1.put(Context.PROVIDER_URL, value);
+            } else {
+                environment1.put(key, value);
+            }
+        }
+
+        return environment1;
+    }
+}

Added: activemq/sandbox/activemq-flow/activemq-client/src/main/java/org/apache/activemq/jndi/package.html
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-client/src/main/java/org/apache/activemq/jndi/package.html?rev=780773&view=auto
==============================================================================
--- activemq/sandbox/activemq-flow/activemq-client/src/main/java/org/apache/activemq/jndi/package.html (added)
+++ activemq/sandbox/activemq-flow/activemq-client/src/main/java/org/apache/activemq/jndi/package.html Mon Jun  1 18:37:41 2009
@@ -0,0 +1,25 @@
+<!--
+    Licensed to the Apache Software Foundation (ASF) under one or more
+    contributor license agreements.  See the NOTICE file distributed with
+    this work for additional information regarding copyright ownership.
+    The ASF licenses this file to You under the Apache License, Version 2.0
+    (the "License"); you may not use this file except in compliance with
+    the License.  You may obtain a copy of the License at
+   
+    http://www.apache.org/licenses/LICENSE-2.0
+   
+    Unless required by applicable law or agreed to in writing, software
+    distributed under the License is distributed on an "AS IS" BASIS,
+    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+    See the License for the specific language governing permissions and
+    limitations under the License.
+-->
+<html>
+<head>
+</head>
+<body>
+
+JNDI support classes
+
+</body>
+</html>

Propchange: activemq/sandbox/activemq-flow/activemq-client/src/main/java/org/apache/activemq/jndi/package.html
------------------------------------------------------------------------------
    svn:executable = *

Modified: activemq/sandbox/activemq-flow/activemq-openwire/pom.xml
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-openwire/pom.xml?rev=780773&r1=780772&r2=780773&view=diff
==============================================================================
--- activemq/sandbox/activemq-flow/activemq-openwire/pom.xml (original)
+++ activemq/sandbox/activemq-flow/activemq-openwire/pom.xml Mon Jun  1 18:37:41 2009
@@ -37,12 +37,13 @@
       <groupId>org.apache.activemq</groupId>
       <artifactId>activemq-broker</artifactId>
     </dependency>
-
-    <!-- TODO: remove this dependency -->
     <dependency>
       <groupId>org.apache.activemq</groupId>
-      <artifactId>activemq-core</artifactId>
-      <version>5.3-SNAPSHOT</version>
+      <artifactId>activemq-transport</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.geronimo.specs</groupId>
+      <artifactId>geronimo-jms_1.1_spec</artifactId>
     </dependency>
 
     <!-- Testing Dependencies -->

Added: activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/BlobMessage.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/BlobMessage.java?rev=780773&view=auto
==============================================================================
--- activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/BlobMessage.java (added)
+++ activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/BlobMessage.java Mon Jun  1 18:37:41 2009
@@ -0,0 +1,64 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.MalformedURLException;
+import java.net.URL;
+
+import javax.jms.JMSException;
+
+/**
+ * Represents a message which has a typically out of band Binary Large Object
+ * (BLOB)
+ * 
+ * @version $Revision: $
+ */
+public interface BlobMessage extends Message {
+
+    /**
+     * Return the input stream to process the BLOB
+     */
+    InputStream getInputStream() throws IOException, JMSException;
+
+    /**
+     * Returns the URL for the blob if its available as an external URL (such as file, http, ftp etc)
+     * or null if there is no URL available
+     */
+    URL getURL() throws MalformedURLException, JMSException;
+
+
+    /**
+     * The MIME type of the BLOB which can be used to apply different content types to messages.
+     */
+    String getMimeType();
+
+    /**
+     * Sets the MIME type of the BLOB so that a consumer can process things nicely with a Java Activation Framework
+     * DataHandler
+     */
+    void setMimeType(String mimeType);
+
+
+    String getName();
+
+    /**
+     * The name of the attachment which can be useful information if transmitting files over ActiveMQ
+     */
+    void setName(String name);
+}

Added: activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/IConnection.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/IConnection.java?rev=780773&view=auto
==============================================================================
--- activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/IConnection.java (added)
+++ activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/IConnection.java Mon Jun  1 18:37:41 2009
@@ -0,0 +1,31 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq;
+
+import org.apache.activemq.command.ActiveMQTempDestination;
+
+
+public interface IConnection {
+
+    boolean isUseCompression();
+
+    boolean isNestedMapAndListEnabled();
+
+    boolean isObjectMessageSerializationDefered();
+
+    void deleteTempDestination(ActiveMQTempDestination activeMQTempDestination);
+}

Propchange: activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/IConnection.java
------------------------------------------------------------------------------
    svn:executable = *

Added: activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/Message.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/Message.java?rev=780773&view=auto
==============================================================================
--- activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/Message.java (added)
+++ activemq/sandbox/activemq-flow/activemq-openwire/src/main/java/org/apache/activemq/Message.java Mon Jun  1 18:37:41 2009
@@ -0,0 +1,33 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq;
+
+/**
+ * Represents the JMS extension methods in Apache ActiveMQ
+ *
+ * @version $Revision: $
+ */
+public interface Message extends javax.jms.Message {
+
+    /**
+     * Returns the MIME type of this mesage. This can be used in selectors to filter on
+     * the MIME types of the different JMS messages, or in the case of {@link org.apache.activemq.BlobMessage}
+     * it allows you to create a selector on the MIME type of the BLOB body
+     */
+    String getJMSXMimeType();
+
+}



Mime
View raw message