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 2009/06/01 20:37:54 UTC
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...
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();
+
+}