Commit Graph

821 Commits

Author SHA1 Message Date
Hiram R. Chirino b858350da4 back ported the BooleanStream class and it's associated test case
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@383051 13f79535-47bb-0310-9956-ffa450edef68
2006-03-04 06:23:01 +00:00
Hiram R. Chirino 477984fd4f simplified a little.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@383040 13f79535-47bb-0310-9956-ffa450edef68
2006-03-04 05:27:32 +00:00
Hiram R. Chirino f6393f602f fix pom so that it builds
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@383034 13f79535-47bb-0310-9956-ffa450edef68
2006-03-04 04:33:58 +00:00
Hiram R. Chirino 0bba31190e organized imports.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@383015 13f79535-47bb-0310-9956-ffa450edef68
2006-03-04 03:42:22 +00:00
Hiram R. Chirino c60ac2ff62 Fixing up http://jira.activemq.org/jira/browse/AMQ-615
- We now close the consumers created by a pooled session when the session is closed.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@383014 13f79535-47bb-0310-9956-ffa450edef68
2006-03-04 03:41:51 +00:00
Adrian T. Co 7027fe66d7 Initial fix for http. Its still failing for some other reasons though (sync problems I think).
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382998 13f79535-47bb-0310-9956-ffa450edef68
2006-03-04 01:32:44 +00:00
Hiram R. Chirino da26ccbd32 added another option that allows you to basically drain a destination for while messages are being produced.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382964 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 23:21:37 +00:00
Hiram R. Chirino 7f9f040835 No need to clean up connection if it's being closed.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382960 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 23:16:53 +00:00
Hiram R. Chirino 375469bac7 disabled the inactivity monitor by default for now.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382954 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 22:54:52 +00:00
Hiram R. Chirino 1882e545a5 fix testcase
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382936 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 21:28:41 +00:00
Hiram R. Chirino 202b3efb96 http://jira.activemq.org/jira/browse/AMQ-612
http://jira.activemq.org/jira/browse/AMQ-613

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382934 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 21:24:33 +00:00
Hiram R. Chirino 44b00e9309 - Improved the delete and purge operations on a queue.
- Messages now removed from the message list: fixes message count < 0 problem
  - Messages are now locked before they are deleted, if messages are in flight to a consumer, we don't want to delete them.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382919 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 20:07:07 +00:00
Robert Davies 9c5680c9f6 don't remove connection info from broker if the transport has failed
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382913 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 19:24:16 +00:00
Robert Davies 62c28d1b77 Added methods to create/destroy durable subscriber
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382890 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 17:20:19 +00:00
James Strachan dc168c055b fixed NPE
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382888 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 17:08:40 +00:00
James Strachan 4759540e6e fixed bug if the connection factory already has a clientId configured
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382886 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 16:57:49 +00:00
Hiram R. Chirino 7f5213ba99 Standardize on throwing Exception instead of Throwable, we were using both forms throught the API
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382869 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 15:36:38 +00:00
James Strachan 99c1a67a28 refactor of the TcpTransport so that the timeout and buffer size can be configured via properties before the socket is used after the start() method is called.
this also fixes AMQ-610


git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382846 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 15:02:54 +00:00
James Strachan 178515aa32 added an alternative eviction strategy
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382830 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 14:18:34 +00:00
Hiram R. Chirino 9c1a5fa6a2 bad testcase, transport was never started.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382824 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 13:59:11 +00:00
James Strachan fa430aaae0 minor refactor to make it easier to add extra startup features
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382821 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 13:58:06 +00:00
James Strachan 062dc5681c added better MBeans for topic subscriptions so that they can see the discarded and matched statistics. Also added a configurable MessageEvictionStrategy
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382816 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 13:56:29 +00:00
James Strachan 4dad3fc833 removed old comment
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382754 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 10:36:32 +00:00
James Strachan bed10aac1e allowed the maximum pending message count to be specified on the ActiveMQPrefetchPolicy or the ConsumerInfo
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382753 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 10:34:33 +00:00
Robert Davies 6d003a89e2 tidied up some of the synchronization
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382746 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 10:06:41 +00:00
Hiram R. Chirino c916749e78 Don't use the inactivity monitor when the stomp protocol is in use.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382741 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 09:49:07 +00:00
James Strachan e87f4c9106 reset the logging level
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382738 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 09:40:29 +00:00
James Strachan 4e28bcea8f added example of setting the pendingMessageLimitStrategy
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382708 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 07:39:59 +00:00
Robert Davies 2867249482 log when discarding messages - and ensure we don't get npe
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382692 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 06:50:38 +00:00
Hiram R. Chirino 057cde18f9 updated groovy code genertors so that the .hpp suffix is included in the include statements.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382591 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 00:41:35 +00:00
Hiram R. Chirino 5aec42f155 Added xcode project files and modifed includes so that they would work for me on OS X,
still getting some compile errors tho.


git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382590 13f79535-47bb-0310-9956-ffa450edef68
2006-03-03 00:40:41 +00:00
Hiram R. Chirino 6272ddc88f spelling fix.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382547 13f79535-47bb-0310-9956-ffa450edef68
2006-03-02 23:08:05 +00:00
Hiram R. Chirino 981cef5f84 Added test case to verify that the group id could be set using STOMP, in reference to:
http://forums.activemq.org/posts/list/442.page

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382544 13f79535-47bb-0310-9956-ffa450edef68
2006-03-02 22:59:55 +00:00
Hiram R. Chirino ed5d43b04f Added more operations to the JMX beans.
- broker view can now create and destroy destinations
 - queue view can now copy messages to other destinations.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382532 13f79535-47bb-0310-9956-ffa450edef68
2006-03-02 22:11:25 +00:00
Hiram R. Chirino 1229c23bc4 - Implemented transpor inactivity monitoring for the tcp transport
- The properties set on the tcp transport can now be set on the transport sever, and the sever will configure the transports it creates with those properties.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382503 13f79535-47bb-0310-9956-ffa450edef68
2006-03-02 20:25:19 +00:00
Hiram R. Chirino 3bdf883d04 BSDish lic. we can redistribut this code.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382462 13f79535-47bb-0310-9956-ffa450edef68
2006-03-02 18:29:33 +00:00
James Strachan 95d0dec008 Patch for AMQ-606 to allow slow consumers to have their old messages discarded. For background to the issue see http://docs.codehaus.org/display/ACTIVEMQ/Slow+Consumers
Provides a way to set a limit on the pending messages to be dispatched to a subscription so that if that limit is reached, old messages are discarded. This will avoid the non-durable topics from getting blocked due to slow consumers


git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382459 13f79535-47bb-0310-9956-ffa450edef68
2006-03-02 17:56:21 +00:00
Hiram R. Chirino 4a65a33af0 Fix for http://jira.activemq.org/jira/browse/AMQ-525
BooleanStream now can handle more than 64*8 bits.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382454 13f79535-47bb-0310-9956-ffa450edef68
2006-03-02 17:27:25 +00:00
Hiram R. Chirino acce91b74e Fix for http://jira.activemq.org/jira/browse/AMQ-578
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382439 13f79535-47bb-0310-9956-ffa450edef68
2006-03-02 16:36:42 +00:00
James Strachan d8c086274a updated the comments
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382434 13f79535-47bb-0310-9956-ffa450edef68
2006-03-02 16:15:58 +00:00
James Strachan c874b21ef8 added test case for the BooleanStream together with the patch from Dave Gynn
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382428 13f79535-47bb-0310-9956-ffa450edef68
2006-03-02 16:03:17 +00:00
James Strachan 0d5de13537 added the ability to discard old messages for non-durable topics if a maximum number of pending messages is reached
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382421 13f79535-47bb-0310-9956-ffa450edef68
2006-03-02 15:56:30 +00:00
James Strachan f1e4459644 added test case and patch for marshalling of long values which result in negative int / short values being unmarshalled
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382395 13f79535-47bb-0310-9956-ffa450edef68
2006-03-02 14:33:45 +00:00
Robert Davies c717221cf8 added support fro browsing messages for a durable subscriber
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382393 13f79535-47bb-0310-9956-ffa450edef68
2006-03-02 14:31:05 +00:00
Robert Davies 3182029ef4 Make it easier for ActiveCluster to be used by other JMS implementations -
added patches supplied by Ben Kibler

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382378 13f79535-47bb-0310-9956-ffa450edef68
2006-03-02 13:24:46 +00:00
James Strachan 5fbce8982c disabled test due to AMQ-583
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382359 13f79535-47bb-0310-9956-ffa450edef68
2006-03-02 11:54:59 +00:00
Robert Davies 2eae0548d8 Fixed some npe I'd just introduced
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382353 13f79535-47bb-0310-9956-ffa450edef68
2006-03-02 11:28:40 +00:00
Robert Davies c82f6f3309 Added support for view inactive durable consumers
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382344 13f79535-47bb-0310-9956-ffa450edef68
2006-03-02 10:31:23 +00:00
Frederick G. Oconer 4ddb76fe4d updated package and dependencies.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382341 13f79535-47bb-0310-9956-ffa450edef68
2006-03-02 10:05:16 +00:00
Frederick G. Oconer 0d3c8fd61d Updated dependency version.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382340 13f79535-47bb-0310-9956-ffa450edef68
2006-03-02 10:04:26 +00:00