/[Apache-SVN]
ViewVC logotype

Revision 384826


Jump to revision: Previous Next
Author: jstrachan
Date: Fri Mar 10 15:53:21 2006 UTC (18 years, 8 months ago)
Changed paths: 109 (showing only 100; show all)
Log Message:
refactored the UDP transport to push most of the code and logic back into the transport layer itself.

* Command how has transient from & to properties which can be used with transports like UDP/multicast to indicate which endpoint (typically broker) actually sent the commands
* used int for commandId 
* support for PartialCommand support; allowing large commands (such as big messages) to be split up into smaller chunks
* added a CommandJoiner for joining partial commands together into complete commands
* ReliableTransport which re-orders and can re-request missed commands


Changed paths

Path Details
Directoryincubator/activemq/trunk/activemq-core/project.xml modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/gram/java/org/apache/activemq/openwire/tool/OpenWireJavaMarshallingScript.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/AbstractConnection.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterConnector.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BaseCommand.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/BaseEndpoint.java added
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Command.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/CommandTypes.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Endpoint.java added
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/KeepAliveInfo.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/LastPartialCommand.java added
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/PartialCommand.java added
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ReplayCommand.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Response.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/WireFormatInfo.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/CommandIdComparator.java added
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/OpenWireFormat.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/BaseCommandMarshaller.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/LastPartialCommandMarshaller.java added
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/MarshallerFactory.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/PartialCommandMarshaller.java added
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ReplayCommandMarshaller.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/ResponseMarshaller.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/CommandJoiner.java added
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/ReliableTransport.java added
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/ResponseCorrelator.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportLogger.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/multicast/ added
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/multicast/MulticastDatagramHeaderMarshaller.java added
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/multicast/MulticastTransport.java added
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/multicast/MulticastTransportFactory.java added
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/multicast/package.html added
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/replay/ added
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/replay/ExceptionIfDroppedReplayStrategy.java added
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/replay/ReplayStrategy.java added
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/CommandChannel.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/CommandProcessor.java deleted
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/CommandReadBuffer.java deleted
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/DatagramEndpoint.java added
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/DatagramHeader.java deleted
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/DatagramHeaderMarshaller.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/DatagramReadBuffer.java deleted
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransport.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportFactory.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportServer.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/replay/ deleted
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/ServiceSupport.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTestSupport.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/RecoveryBrokerTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/StubConnection.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQBytesMessageTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQDestinationTestSupport.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQMapMessageTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQMessageTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQObjectMessageTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQQueueTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQStreamMessageTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTempDestinationTestSupport.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTempQueueTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTempTopicTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTextMessageTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ActiveMQTopicTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/BaseCommandTestSupport.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/BrokerIdTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/BrokerInfoTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConnectionErrorTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConnectionIdTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConnectionInfoTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConsumerIdTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ConsumerInfoTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ControlCommandTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/DataArrayResponseTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/DataResponseTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/DestinationInfoTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/DiscoveryEventTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ExceptionResponseTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/FlushCommandTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/IntegerResponseTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/JournalQueueAckTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/JournalTopicAckTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/JournalTraceTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/JournalTransactionTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/KeepAliveInfoTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/LastPartialCommandTest.java added
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/LocalTransactionIdTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/MessageAckTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/MessageDispatchNotificationTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/MessageDispatchTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/MessageIdTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/MessageTestSupport.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/PartialCommandTest.java added
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ProducerIdTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ProducerInfoTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/RemoveInfoTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/RemoveSubscriptionInfoTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ReplayCommandTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/ResponseTest.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v1/SessionIdTest.java modified , text changed
[...]

infrastructure at apache.org
ViewVC Help
Powered by ViewVC 1.1.26