Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-08 19:15:20 +00:00
Code Issues Packages Projects Releases Wiki Activity
1,138 Commits 22 Branches 100 Tags
Commit Graph

659 Commits

Author SHA1 Message Date
Hiram R. Chirino
b022a9d835 Set instance variables to null so that we don't OOM exceptions when using m2 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@398076 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-29 03:22:23 +00:00
Hiram R. Chirino
794e8d7880 Ignore log messages from other software packages by default. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@398018 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-28 21:26:22 +00:00
Hiram R. Chirino
653a7791f7 Disable optimizeAcknowledge for now. It is still not threadsafe. Tests fail on on 2 core windows box when this is enabled. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@398016 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-28 21:25:43 +00:00
Hiram R. Chirino
807e18f9f9 - Gaurd access to dispatched list ( a sync was missing). 
- Added better exception messages to know what happened when a slave subscription gets out of sync with the master.
- Implemented a simpler isFull()

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@398015 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-28 21:24:06 +00:00
Hiram R. Chirino
d65ba8034b Gaurd access to the pending list better. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397985 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-28 19:13:54 +00:00
Hiram R. Chirino
f5f1366e4b Include the prefetch size in the JMX stats of a subscription 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397982 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-28 19:02:01 +00:00
Hiram R. Chirino
f1a0614066 Added a 'noRangeAcks' flag to the ConsumerInfo command 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397960 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-28 17:26:59 +00:00
Hiram R. Chirino
4009fda30c Organized imports 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397941 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-28 16:20:26 +00:00
Hiram R. Chirino
f25e2ca23e Applyed Rodrigo S de Castro's latest unit test patch and fixed the redelivery problem. Redelivery was not being delayed when rollback was called from the message listener. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397915 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-28 15:11:39 +00:00
Hiram R. Chirino
03de4c2d8b Added testcase by Rodrigo S de Castro. Thanks Rodrigo! 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397908 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-28 14:07:27 +00:00
Hiram R. Chirino
e2aad41e6a Since some OS/JVM combinations handle threads more efficiently than others, using a thread pool to run our async tasks may not 
be the most optimal solution.  Modified the TaskRunnerFactory so that it uses a system property to choose between the 
PooledTaskRunner or the DedicatedTaskRunner which now keeps a dedicated thread per task.

The default is still set to use the PooledTaskRunner, but we may change this if performance benchmarks indicate that DedicatedTaskRunner should be the default.

Also make the thread names a little more uniform so that when you use a debugger you can easily tell what each thread is doing.




git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397774 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-28 05:54:54 +00:00
Hiram R. Chirino
cb1d21f0a3 Fix for http://issues.apache.org/activemq/browse/AMQ-695 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397613 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-27 19:11:38 +00:00
Robert Davies
a17b95182f close local transport if remote transport fails (and supports failover), and re-establish local transport on a successful re-connect 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397589 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-27 16:59:18 +00:00
Robert Davies
40b96b1b8f Fix for Queues getting full in the broker 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397420 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-27 05:47:28 +00:00
Hiram R. Chirino
93dc39b130 changed a bunch of System.out.println() to log.info() 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397249 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-26 17:25:42 +00:00
James Strachan
d680ba1291 added some helper methods to make it easier to access management information without having to use explicit JMX APIs 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397198 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-26 13:54:11 +00:00
James Strachan
4e65119cff disabled test case that has a timing issue 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397193 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-26 13:22:48 +00:00
James Strachan
35f915f3b9 updated the javadoc to be more explicit about the limitations of the pool package 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397168 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-26 10:49:02 +00:00
Hiram R. Chirino
535e16a3e4 It was possible to return a marshalled command before previously added pending commands. And have the commands run out of order. For examples, an unsubscribe could be executed before all it's ack were run. This fix forces commands to allways be run in enqueued order. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@396957 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-25 19:22:29 +00:00
James Strachan
8ad6fd36a1 added a helper method to make it easier to work with the admin view together with fixed some NPEs I was getting when redeploying ActiveMQ when using mvn jetty6:run 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@396892 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-25 14:06:52 +00:00
James Strachan
73f0e97531 added helper classes for comparing messages 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@396891 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-25 14:05:03 +00:00
Hiram R. Chirino
53454ccb36 Don't open data files again if the store has been closed.. on windows tests were failing since the open data files could not be deleted. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@396583 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-24 15:41:59 +00:00
Hiram R. Chirino
75c9b638be Close data files when the store is closed 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@396040 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-22 00:58:16 +00:00
Robert Davies
065c46f19d put back support for request/reply across networks 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@395810 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-21 08:02:19 +00:00
Robert Davies
a16b869fd8 more tuning - and ensure data files have more meaningful names 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@395689 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-20 20:07:32 +00:00
Hiram R. Chirino
9cf5f45cf6 If we get an async exception, report it to all blocked sync requests. 
https://issues.apache.org/activemq/browse/AMQ-691


git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@395641 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-20 16:58:58 +00:00
Hiram R. Chirino
2ee58ca235 Support "transport." properties when creating a tranport server 
Support "socket." properties when creating a transport.


git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@395640 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-20 16:57:56 +00:00
Robert Davies
fa8b889906 finese tuning 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@395611 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-20 14:58:50 +00:00
Robert Davies
6575f2d22d tuning around kaha persistence 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@395597 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-20 14:15:30 +00:00
Robert Davies
2c64bf99d9 fine tuning 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@395256 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-19 14:46:25 +00:00
Robert Davies
5c7f4b626b messages not getting acked 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@395254 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-19 14:39:49 +00:00
Hiram R. Chirino
b708fd32c3 Properly handle a rollback() when call from an onMessaqge() 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394851 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-18 05:50:40 +00:00
Hiram R. Chirino
535c30c3e8 handle sync send timeouts better. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394811 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-17 23:49:01 +00:00
Guillaume Nodet
1e6c45fb2e Fix dependencies scopes for m2 build... 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394797 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-17 22:39:14 +00:00
Hiram R. Chirino
dcf7dea53f An async error could cause a deadlock when using the VM transport since all it's operations are sync. The error handling is now done in an async thread to avoid the deadlock. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394729 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-17 17:04:59 +00:00
Hiram R. Chirino
178f34bd9b Missing synchronization would cause acks to not be delivered to the broker. After enough acks were missed, 
the consumer would stop receiving messages due to the broker thinking the consumers prefetch is full.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394710 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-17 15:36:04 +00:00
Hiram R. Chirino
c46562ba7c If a topic consumer was hung up, it would eventually stop the producers since the broker memory limit would be reached. 
The problem was if the consumer was killed, the broker memory would not get freed up and so the producer would remain blocked.
When a subscription is removed, the memory of the pending messages are now released.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394707 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-17 15:32:28 +00:00
Hiram R. Chirino
91720daee7 On consumer close, wait for it's async threads to finish before returning. Was getting errors when async acks were sent and the subscription was allready closed. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394705 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-17 15:29:43 +00:00
Guillaume Nodet
bfa4b9bb68 Fix m2 build: the distribution is nearly identical to the m1 dist. 
Remaining problems: missing STATUS file, and activemq.rar is way too big

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394399 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-15 23:33:05 +00:00
Hiram R. Chirino
5c03c7df96 frame builder was not adding all the properties (they were not all String values). 
Connect should also use the\0\n convention that the frame builder uses.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394269 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-15 08:26:30 +00:00
Hiram R. Chirino
e73fa1201a Get bytes messages to work right with pub sub. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394242 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-15 02:05:04 +00:00
Hiram R. Chirino
5706bed79d ah.. onMesage was causing the bytes messages content to be nulled.. setting the readOnly properties manually. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394145 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-14 17:22:41 +00:00
Hiram R. Chirino
51d3c8260c message.onSend() was not being called causing the readOnly fields to not be properly initialized. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394142 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-14 17:12:59 +00:00
Robert Davies
6eaea6f336 For optimized acknowledge, eagerly get acknowledgements from consumers 
when the dispatched list gets too big.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394050 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-14 08:38:50 +00:00
Robert Davies
6d366dcc85 fine tuning, client control commands etc. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@393913 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-13 20:16:24 +00:00
Robert Davies
ef0734bccf fine tuning, client control commands etc. 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@393912 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-13 20:15:35 +00:00
Robert Davies
52ee976ec8 added support for clearing messages in-flight 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@393495 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-12 16:18:36 +00:00
Robert Davies
00d054a6c2 more tuning 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@393490 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-12 15:52:06 +00:00
Robert Davies
28647f1790 added changes from http://jira.activemq.org/jira//browse/AMQ-660 
to allow destination conversation on outbound messages with replyTo destinations



git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@393383 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-12 04:46:22 +00:00
Robert Davies
d964145532 extra peformance tuning parameters 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@393294 13f79535-47bb-0310-9956-ffa450edef68
 2006-04-11 19:09:11 +00:00