Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-06 18:18:58 +00:00
Code Issues Packages Projects Releases Wiki Activity
2,908 Commits 22 Branches 100 Tags
Commit Graph

1898 Commits

Author SHA1 Message Date
James Strachan
f51ac13f85 a little bit of spring cleaning to remove some of the cruft 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384837 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-10 16:12:47 +00:00
James Strachan
8704338288 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


git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384826 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-10 15:53:21 +00:00
James Strachan
df26287181 minor refactorings to make it easier to derive from 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384755 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-10 10:21:07 +00:00
Robert Davies
c5f96e1db5 added some state to avoid npe when starting the connectorServer after stop has been called 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384738 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-10 09:11:56 +00:00
Adrian T. Co
5e8f85df32 Move MarshallingWithCachingTest from core module to soaktest module. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384690 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-10 03:05:38 +00:00
James Strachan
2f1dcea144 added test cases for UDP fragmentation 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384640 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-09 23:08:57 +00:00
James Strachan
3d7f76719f fix bug in fragmentation 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384638 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-09 22:57:13 +00:00
Hiram R. Chirino
7b69145159 Fix a 1.5 API dependency the slipped in. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384634 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-09 22:44:16 +00:00
Hiram R. Chirino
fd5ce05c1d Appling patch from Nathan Mittler. Thanks Nathan! http://jira.activemq.org/jira/browse/AMQ-620 
Improves c++ openwire support on linux



git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384616 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-09 21:11:16 +00:00
James Strachan
4446d55d30 added a working UDP server with test cases 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384603 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-09 20:26:47 +00:00
James Strachan
4f446eb025 initial spike of UDP server transport with some test cases (some of which are commented out as they are not quite working yet) 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384569 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-09 18:06:32 +00:00
James Strachan
22bb1bdd41 added helper method 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384568 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-09 18:02:47 +00:00
Robert Davies
6c0df67be6 tidied up subscription objectNames 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384492 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-09 11:22:26 +00:00
James Strachan
5371cf5e64 minor refactor of a property and exposed the selector as an MBean attribute. the selector can actually be updated in real time via JMX for non-durable topic subscriptions for AMQ-625 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384486 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-09 10:49:37 +00:00
James Strachan
b86da466e6 disabled some failing test cases until we can fix 'em 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384479 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-09 10:11:43 +00:00
James Strachan
346cdc5744 added test for copy() method 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384459 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-09 08:25:03 +00:00
Hiram R. Chirino
46ad8c2d71 Enabled CLS compliance again and fixed some of the comment positioning. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384457 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-09 08:19:01 +00:00
James Strachan
cedc2fb891 added an implementation of ActiveMQXAConnectionFactory for AMQ-624 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384454 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-09 07:42:26 +00:00
Hiram R. Chirino
c40f989966 Refactored the .NET client so that all the JMS references are NMS. Figured Sun would not be happy if we called this JMS. 
also tweeked the m2 poms a little




git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384452 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-09 07:11:37 +00:00
Hiram R. Chirino
c4e99fe48b - Fix NPE due to JMX problem 
- Made the maven setting a little more eclipse freindly.



git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384438 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-09 05:41:08 +00:00
Hiram R. Chirino
6583ef1821 I wish I could have commited this in smaller chunks 
- Added support for the openwire loose encoding to the .NET port
- Fixed the InactivityMonitor, it was timing out conections too often and testcase for it would fail intermitently
- Improved the wire format option negociation phase.  
   - We now gaurd to sending the WireformatInfo, so it's only sent once even if the start method is called multiple times.  
   - We now wait for the WireFormatInfo to be sent before reconfiguring the WireFormat with the new negociated options
   - Option negociation is now simpler to understand:
     - The WireFormatInfo is allways sent with all options turned off
     - Once WireFormatInfo's are exchanged, we enable the options on the WireFormat that both sides enabled.
 



git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384390 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-09 00:41:39 +00:00
Robert Davies
cbd5960e5a shorten subscription name 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384297 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-08 18:16:33 +00:00
James Strachan
6c0fae01de added working test case for the use of Broker, Queue, Topic MBeans 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384274 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-08 17:25:56 +00:00
James Strachan
138d9cfffa added MBean unit test case 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384256 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-08 16:27:25 +00:00
Hiram R. Chirino
5d9d499e66 Fix so that we can get the messages. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384255 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-08 16:27:16 +00:00
James Strachan
2cd143782a added a ReplayCommand to OpenWire for re-requesting dropped datagrams/commands and regenerated the openwire classes 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384231 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-08 15:15:11 +00:00
James Strachan
08f4639d5e added spike of a UDP server together with applying the transport refactorings to the UDP transport 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384225 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-08 14:44:35 +00:00
James Strachan
11c37a7be5 added fix for NPE when adding durable subscribers 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384223 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-08 14:36:35 +00:00
James Strachan
436fe42778 minor refactor to use "stopped" and "stopping" as properties on ServiceSupport and the transport classes. Also made the TransportListener getter visible and avoided the need for protected variables in the various TransportFilter implementations (due to inlining, often getter methods are faster in hotspot than access to protected fields, plus it simplifies the code & makes it less brittle) 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384220 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-08 14:10:27 +00:00
James Strachan
11be076ac9 refactor to move the useful code for dealing with start/stop lifecycles and the start, closed, closing properties into the base ServiceSupport class 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384208 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-08 13:09:17 +00:00
James Strachan
8568d6ee05 minor refactor to make it easier to override starting 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384193 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-08 12:09:49 +00:00
James Strachan
534ea690ff allow the transport to be closed before we try and send remove commands to it without generating an exception 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384189 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-08 11:47:09 +00:00
James Strachan
dba3ea8d0e enable JMX by default 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384187 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-08 11:44:45 +00:00
James Strachan
8d36b4c751 patch test case to explicitly disable JMX 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384186 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-08 11:44:28 +00:00
James Strachan
d47ce01a85 deal with mbeans being already unregistered gracefully 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384185 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-08 11:44:06 +00:00
James Strachan
8776a4154e added helper method to create non-persistent output streams together with added more javadoc 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384173 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-08 10:14:44 +00:00
Adrian T. Co
5628c2d94b Use the backport library to fix the compile error in Java 1.4. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384162 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-08 09:15:08 +00:00
Hiram R. Chirino
ead505da98 Fixed transport testcase so that it does not fail anymore. tcp transport was being stopped and then oneway was being called on it, and it was throwing an unexpected illegalstate exception witched to ioexception and all was better. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384001 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-07 20:33:02 +00:00
James Strachan
05b81ba8be Added test case for UDP 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@383984 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-07 19:52:50 +00:00
James Strachan
187f884b58 added test case demonstrating UDP transport working 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@383981 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-07 19:49:23 +00:00
James Strachan
f8e1c0ebe5 added helper methods for NIO/AIO/UDP based transports 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@383980 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-07 19:48:02 +00:00
Hiram R. Chirino
b2ad8fa833 Support naming all the connectors so that JMX object names are easier to view. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@383972 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-07 19:25:05 +00:00
Hiram R. Chirino
c977f7ddfc support destination options on a stream consumer. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@383971 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-07 19:24:15 +00:00
Hiram R. Chirino
5ff3487b2f renamed matched to pending. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@383969 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-07 19:18:28 +00:00
Hiram R. Chirino
3b0377cfaf Test case and fix for http://jira.activemq.org/jira/browse/AMQ-618 
Robert Newson, great job finding and putting together a test case for this.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@383957 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-07 18:59:41 +00:00
James Strachan
1c5ecb36d3 added a default implementation of BufferPool and a default replay strategy 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@383918 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-07 16:24:05 +00:00
James Strachan
fcd06b2077 add the data size to datagram headers 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@383894 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-07 14:12:11 +00:00
James Strachan
eba4c9cfa8 initial spike of a UDP based transport - completely untested so far :) 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@383893 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-07 14:06:59 +00:00
Robert Davies
560763a603 delete db messages on start-up 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@383853 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-07 11:49:28 +00:00
James Strachan
9c2185b826 set default timeout value of 30s 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@383832 13f79535-47bb-0310-9956-ffa450edef68
 2006-03-07 09:54:09 +00:00