Commit Graph

663 Commits

Author SHA1 Message Date
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
Adrian T. Co 1d6fb63a95 Possible bug in computation of BooleanStream size.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382252 13f79535-47bb-0310-9956-ffa450edef68
2006-03-02 02:56:39 +00:00
James Strachan 9efa4e6e68 Applied modified generated code using Mats latest patch for the generator
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382103 13f79535-47bb-0310-9956-ffa450edef68
2006-03-01 17:52:38 +00:00
James Strachan 283549bae6 Applied Mats latest patches to get the openwire-cpp code compiling
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382102 13f79535-47bb-0310-9956-ffa450edef68
2006-03-01 17:51:13 +00:00
James Strachan cc7678ee9b Added latest generated C++ commands and marshalling code
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382091 13f79535-47bb-0310-9956-ffa450edef68
2006-03-01 17:34:23 +00:00
Hiram R. Chirino 60c65ba7ff Adding csproj and cln files created with x-develop as I was having touble with the vs.net generated ones.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382087 13f79535-47bb-0310-9956-ffa450edef68
2006-03-01 17:21:49 +00:00
James Strachan 2f6054959a added test case and fix for JMSType header
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382086 13f79535-47bb-0310-9956-ffa450edef68
2006-03-01 17:19:28 +00:00
James Strachan b5bba09207 test case and patch to ensure that the JMSXGroupID can be specified in Stomp together with testing for the use of correlation-id
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382083 13f79535-47bb-0310-9956-ffa450edef68
2006-03-01 17:05:17 +00:00
James Strachan 7f1b4644af minor refactor to avoid strange eclipse compile error message
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382082 13f79535-47bb-0310-9956-ffa450edef68
2006-03-01 17:04:16 +00:00