Commit Graph

983 Commits

Author SHA1 Message Date
James Strachan f3ef1a9a31 refactored LastPartialCommand so that it is-a PartialCommand so can contain data and should marshal just the same as the PartialCommand; this solves the double-datagram issue when closing a partial command stream
also refactored the reliable transport some more so that it is close to working; should have test cases working soon...

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@387385 13f79535-47bb-0310-9956-ffa450edef68
2006-03-21 02:49:00 +00:00
Adrian T. Co 9c6169748d - Minor correction in xml config
- Enabled failing test cases

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@387060 13f79535-47bb-0310-9956-ffa450edef68
2006-03-19 23:20:46 +00:00
Adrian T. Co 27ec68d22d - Added checking for NPE
- Added newline in maven.xml

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386960 13f79535-47bb-0310-9956-ffa450edef68
2006-03-19 12:48:32 +00:00
Adrian T. Co 774cdcf8b5 Added maven goal to ignore test failures.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386953 13f79535-47bb-0310-9956-ffa450edef68
2006-03-19 10:56:48 +00:00
Hiram R. Chirino d5b3b819ba Created a STOMP PHP client.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386940 13f79535-47bb-0310-9956-ffa450edef68
2006-03-19 09:22:40 +00:00
Darwin G. Flores b182afbe46 git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386808 13f79535-47bb-0310-9956-ffa450edef68 2006-03-18 04:31:17 +00:00
Adrian T. Co 351decc105 - Corrected the path to the keystores.
- Enabled SslTransportBrokerTest

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386772 13f79535-47bb-0310-9956-ffa450edef68
2006-03-18 00:25:27 +00:00
Adrian T. Co 4f7235d964 - Setup keystores for ssl used by ConfigTest.java
- Prevented NullPointerException in MemoryPersistenceAdapter

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386769 13f79535-47bb-0310-9956-ffa450edef68
2006-03-18 00:13:56 +00:00
Adrian T. Co 9920d70580 - Send the ConnectionInfo first before sending the BrokerInfo in the DemandForwardingBridge, so it would work in http.
- Enabled the TwoBrokerTopicSendReceiveUsingHttpTest.
- Added a sleep to the test to give jetty enough time to setup before sending messages.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386738 13f79535-47bb-0310-9956-ffa450edef68
2006-03-17 22:09:11 +00:00
Hiram R. Chirino 8b3fb9b928 - Enhanced the NMS test support class so that it creates the connection lazily.
- You can now get a DestinationType from a destination in case you want to know what type of destination you are working with.



git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386712 13f79535-47bb-0310-9956-ffa450edef68
2006-03-17 20:58:24 +00:00
Hiram R. Chirino 9224eeb0a2 Fixed the primitive map marhsalling problem that was breaking the tests.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386703 13f79535-47bb-0310-9956-ffa450edef68
2006-03-17 20:11:02 +00:00
Hiram R. Chirino 257f16a0bb The default should be failover=false. We can't assume that normal configurations will use broker nodes that never fail.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386670 13f79535-47bb-0310-9956-ffa450edef68
2006-03-17 16:43:21 +00:00
James Strachan 27a677f459 added the ability to configure the redelivery policy on the activation spec
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386654 13f79535-47bb-0310-9956-ffa450edef68
2006-03-17 15:19:56 +00:00
James Strachan c559a8093f fix for AMQ-600 to detect IOExceptions as being transport exceptions, not service exceptions (which are normally things like JMSException or security exceptions etc) and then disposing the connection eagerly - to free up the clientID so that the client can reconnect
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386610 13f79535-47bb-0310-9956-ffa450edef68
2006-03-17 11:19:12 +00:00
James Strachan 2bc9a83508 patch for AMQ-600 to catch IOException caused by attempts to dispatch synchronously to a connection on a dead socket and treat them as a transport exception (rather than service exception), disposing the connection so that clientID's can be reused
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386608 13f79535-47bb-0310-9956-ffa450edef68
2006-03-17 11:14:11 +00:00
Adrian T. Co 635e6e7445 - Perform the actual setup of the connectors when it is actually started.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386603 13f79535-47bb-0310-9956-ffa450edef68
2006-03-17 10:38:02 +00:00
James Strachan a876eb3789 latest generated openwire
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386589 13f79535-47bb-0310-9956-ffa450edef68
2006-03-17 09:19:33 +00:00
James Strachan cfbb3c852a fix for AMQ-627 to always catch and deal with interupted exceptions
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386586 13f79535-47bb-0310-9956-ffa450edef68
2006-03-17 09:15:38 +00:00
James Strachan 15550b812a latest generated openwire
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386585 13f79535-47bb-0310-9956-ffa450edef68
2006-03-17 09:15:15 +00:00
James Strachan 3d07b93074 enforce loop back mode false
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386583 13f79535-47bb-0310-9956-ffa450edef68
2006-03-17 09:13:31 +00:00
James Strachan 0ae30b3e87 added a few more properties to the multicast transport
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386581 13f79535-47bb-0310-9956-ffa450edef68
2006-03-17 09:10:23 +00:00
Hiram R. Chirino 13adb80274 http://jira.activemq.org/jira/browse/AMQ-631
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386546 13f79535-47bb-0310-9956-ffa450edef68
2006-03-17 05:38:30 +00:00
Hiram R. Chirino b4c362bf25 adding more ignores.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386508 13f79535-47bb-0310-9956-ffa450edef68
2006-03-17 02:26:59 +00:00
Hiram R. Chirino 47853d3584 Fix for http://jira.activemq.org/jira/browse/AMQ-639
The NetworkConnector was not removing the old bridge for the map of bridges that he was mantinaing,
so when the remote broker came back up, then the bridge was not restarted.

Also add a new ConnectionFilter interface which allows the broker to avoid establishing loopback connections.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386507 13f79535-47bb-0310-9956-ffa450edef68
2006-03-17 02:24:29 +00:00
Hiram R. Chirino d77e665ed7 Deliver the events to the DiscoveryListener async to the mutlicast/heartbeating thread so that that if the
DiscoveryListener blocks for while (like if he is being debuged) then we don't erroniously assume that memebrs
int the group have timed out. 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386506 13f79535-47bb-0310-9956-ffa450edef68
2006-03-17 02:22:04 +00:00
Hiram R. Chirino 24235a99e4 limit the child when the parent is limited.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386504 13f79535-47bb-0310-9956-ffa450edef68
2006-03-17 02:11:34 +00:00
Adrian T. Co 2edfb2864c Add the jetty jars to the distribution.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386484 13f79535-47bb-0310-9956-ffa450edef68
2006-03-16 23:37:24 +00:00
Adrian T. Co 89ac08c57f - Added activemq-optional.jar to the assembly module dependency.
- Corrected broker name in config files.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386480 13f79535-47bb-0310-9956-ffa450edef68
2006-03-16 23:15:30 +00:00
James Strachan 2b1a0f0c94 updated to use the class name "BaseDataStructure" so that generated code mimicks the class structure of the Java code to avoid getting confused
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386442 13f79535-47bb-0310-9956-ffa450edef68
2006-03-16 19:48:46 +00:00
James Strachan 68a542a097 removed some old cruft
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386441 13f79535-47bb-0310-9956-ffa450edef68
2006-03-16 19:47:30 +00:00
James Strachan f21fe895a2 updated the C# client to get it compiling and most of the tests working with the latest generated OpenWire code; particularly after the change of Command.CommandId from short to int
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386440 13f79535-47bb-0310-9956-ffa450edef68
2006-03-16 19:45:13 +00:00
James Strachan 05ea5d4795 added test case for closing just the session
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386382 13f79535-47bb-0310-9956-ffa450edef68
2006-03-16 17:06:09 +00:00
Hiram R. Chirino baab4b209e Also set the dispatchAsync when using connection consumers (use in MDB dispatching).
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386335 13f79535-47bb-0310-9956-ffa450edef68
2006-03-16 14:11:00 +00:00
Frederick G. Oconer 85cc87a5a5 Commented out HttpsTransportBrokerTest.java because it hangs.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386303 13f79535-47bb-0310-9956-ffa450edef68
2006-03-16 10:05:52 +00:00
Hiram R. Chirino 4e15e1b177 fixed spelling.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386274 13f79535-47bb-0310-9956-ffa450edef68
2006-03-16 06:17:01 +00:00
Hiram R. Chirino ea94429a2f - server should set a error code if no clientID was specified.
- client should avoid doing a GET until the clientID is specified.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386272 13f79535-47bb-0310-9956-ffa450edef68
2006-03-16 06:11:37 +00:00
Darwin G. Flores 2133fb7c91 git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386271 13f79535-47bb-0310-9956-ffa450edef68 2006-03-16 05:52:15 +00:00
Darwin G. Flores 4b1af8e029 git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386269 13f79535-47bb-0310-9956-ffa450edef68 2006-03-16 05:41:06 +00:00
Hiram R. Chirino 38f7b126d6 Made the peer test a little more reliable by using consumer advisory messages to know when the peers have fully connected in the cluster.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386258 13f79535-47bb-0310-9956-ffa450edef68
2006-03-16 04:47:34 +00:00
James Strachan 70f9d61313 fixed bug which was exposed by the Stomp Ruby client. (We could really do with a maven integration build project that runs the C, C++, C# and Ruby code against a running broker)
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386215 13f79535-47bb-0310-9956-ffa450edef68
2006-03-15 23:29:39 +00:00
James Strachan de74d7ac72 added a stomp connector to the little debug broker program
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386209 13f79535-47bb-0310-9956-ffa450edef68
2006-03-15 23:19:02 +00:00
James Strachan 09de5a2481 switched default stomp port back to 61613 (thanks for the suggestion brian :) to avoid causing surprises for folks using stomp on 3.x or using the existing ruby stomp client. See AMQ-634 for more details
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386208 13f79535-47bb-0310-9956-ffa450edef68
2006-03-15 23:18:24 +00:00
Hiram R. Chirino 36722d8774 Applied patch in http://jira.activemq.org/jira/browse/AMQ-633
Thanks Brian Diesenhaus!

Also exposed the memory limits and usage via JMX and allowed the limit to be configured via a destination policy.



git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386199 13f79535-47bb-0310-9956-ffa450edef68
2006-03-15 22:45:38 +00:00
James Strachan 8d589ec6fa added a replay buffer to the ReliableTransport so that nodes with missing messages can re-request stuff
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386198 13f79535-47bb-0310-9956-ffa450edef68
2006-03-15 22:43:40 +00:00
James Strachan 3dd6d8afcb cache around endpoints so that they are reused - so that networks using brokerIds & brokerInfos can store the state on the endpoint
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386196 13f79535-47bb-0310-9956-ffa450edef68
2006-03-15 22:41:53 +00:00
Hiram R. Chirino 6a89f08c4f disable the use of range acks with network connectors since that could cause the broker to block waiting for messages to be consumed (in the case of big messages being sent).
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386132 13f79535-47bb-0310-9956-ffa450edef68
2006-03-15 19:04:32 +00:00
Hiram R. Chirino 6994361f80 Get the connonical path so that we we debug, when know the explicit path to the data files.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386129 13f79535-47bb-0310-9956-ffa450edef68
2006-03-15 18:54:34 +00:00
James Strachan 400b1fca09 refactor of the DemandForwardingBridge so that a multicast-based network can be created (or any other multiplexing transport can be used to create a netowrk)
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386100 13f79535-47bb-0310-9956-ffa450edef68
2006-03-15 16:03:34 +00:00
James Strachan 1629774d27 added logging if we can't properly cast things when closing things down
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386099 13f79535-47bb-0310-9956-ffa450edef68
2006-03-15 16:02:20 +00:00
Hiram R. Chirino 3c09f0cba5 Be more carefull about how long we wait for the test to timeout
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386092 13f79535-47bb-0310-9956-ffa450edef68
2006-03-15 15:15:29 +00:00