a9ba595748
When messages expire take them out of the paged in list so that we can dispatch more messages to other consumers.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@641525 13f79535-47bb-0310-9956-ffa450edef68
2008-03-26 19:56:29 +00:00
0b6cd58fb7
fixed some failing tests - with much better tests that test headers move across camel routing steps and that we can invoke a request/reply explicitly using JMS headers
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@641380 13f79535-47bb-0310-9956-ffa450edef68
2008-03-26 16:26:07 +00:00
401937a115
Added full hamcrest dependency for testing
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@641364 13f79535-47bb-0310-9956-ffa450edef68
2008-03-26 16:07:36 +00:00
b02c06fb31
Decrement the message reference when the messages are removed from the vm pending cursor.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@641027 13f79535-47bb-0310-9956-ffa450edef68
2008-03-25 21:51:37 +00:00
54280bcfec
Added central repo to try fix issue with ibiblio and the build
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@640898 13f79535-47bb-0310-9956-ffa450edef68
2008-03-25 17:03:57 +00:00
ae7de6c236
In the queue case, when a consumer was closed it was not properly re-delivering messages to other available consumers. This was causing message to look like they got dropped.
...
- When we shut a queue sub down we now get it's pending+dispatched list and re-dispatch that to the other available subscriptions.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@640890 13f79535-47bb-0310-9956-ffa450edef68
2008-03-25 16:45:00 +00:00
f9585fd6ab
It's possible the prefered wireformat could be null
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@640684 13f79535-47bb-0310-9956-ffa450edef68
2008-03-25 03:36:07 +00:00
c04d8c548d
Better failover error handling and now we pass on the max initial inactivity timeout to the timeout used by the intial wire format negociation.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@640641 13f79535-47bb-0310-9956-ffa450edef68
2008-03-24 23:19:50 +00:00
0a4c8064e4
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@639667 13f79535-47bb-0310-9956-ffa450edef68
2008-03-21 15:29:55 +00:00
f6856a893c
Improve OSGi manifest attributes wrt xbean-spring
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@639592 13f79535-47bb-0310-9956-ffa450edef68
2008-03-21 10:30:19 +00:00
9e13dc67fa
Disable lazy dispatch. Was causing queue browser tests to fail.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@639539 13f79535-47bb-0310-9956-ffa450edef68
2008-03-21 04:26:33 +00:00
299a98d48f
removing a bad reference increment
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@639532 13f79535-47bb-0310-9956-ffa450edef68
2008-03-21 03:30:45 +00:00
0302ffded7
avoid deadlock on stop()
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@639531 13f79535-47bb-0310-9956-ffa450edef68
2008-03-21 03:29:33 +00:00
47183aeeaa
set new expiration time
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@639499 13f79535-47bb-0310-9956-ffa450edef68
2008-03-20 23:56:18 +00:00
f4971bf2dc
Avoid local consumer starvation. We were not properly keeping the list sorted.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@639422 13f79535-47bb-0310-9956-ffa450edef68
2008-03-20 19:31:36 +00:00
01ab56f7d0
Better memory usage reference counting for the persistent message case.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@639388 13f79535-47bb-0310-9956-ffa450edef68
2008-03-20 17:49:45 +00:00
198dd34a9e
Stop the to connection first to avoid hanging on error.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@639332 13f79535-47bb-0310-9956-ffa450edef68
2008-03-20 16:00:25 +00:00
c9c11074a8
Fix queue reference counting.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@639315 13f79535-47bb-0310-9956-ffa450edef68
2008-03-20 15:31:34 +00:00
b3931192fc
added a soak test for a separate local broker
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@639282 13f79535-47bb-0310-9956-ffa450edef68
2008-03-20 13:20:59 +00:00
5d485843b6
If a connection is close() make sure we error out any outstanding requests it may be doing so that it can properly shutdown.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@639111 13f79535-47bb-0310-9956-ffa450edef68
2008-03-20 01:59:39 +00:00
ff7033fa14
set default max page size to 100
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@639030 13f79535-47bb-0310-9956-ffa450edef68
2008-03-19 21:52:31 +00:00
31a87ac778
allow blocked connections to unblock so we can get in and stop them.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638969 13f79535-47bb-0310-9956-ffa450edef68
2008-03-19 18:45:08 +00:00
2f1822bf2c
Fix for inactivity exceptions not getting generated due to previous change.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638942 13f79535-47bb-0310-9956-ffa450edef68
2008-03-19 17:19:32 +00:00
5269519536
Do the inital recovery dispatch in the iterate() thread so that the addSubscription() operation on the Queue executes quickly.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638924 13f79535-47bb-0310-9956-ffa450edef68
2008-03-19 16:29:26 +00:00
aa2c8965eb
use compareAndSet() in onException
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638922 13f79535-47bb-0310-9956-ffa450edef68
2008-03-19 16:26:53 +00:00
f55923619d
Added separately configurable initial delay for timeout tasks on InactivityMonitor
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638910 13f79535-47bb-0310-9956-ffa450edef68
2008-03-19 16:07:54 +00:00
c18b583020
Don't timeout a stop since that can lead to a failover connection not being able to reconnect correctly.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638891 13f79535-47bb-0310-9956-ffa450edef68
2008-03-19 15:52:36 +00:00
1656e1dd52
Avoid generating additional exception after the first one reported.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638886 13f79535-47bb-0310-9956-ffa450edef68
2008-03-19 15:48:41 +00:00
38d433a34a
Fix NPE
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638870 13f79535-47bb-0310-9956-ffa450edef68
2008-03-19 15:26:18 +00:00
2f9fdea41f
changed some defaults
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638844 13f79535-47bb-0310-9956-ffa450edef68
2008-03-19 14:35:32 +00:00
dd57e40758
synchronize oneway()
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638814 13f79535-47bb-0310-9956-ffa450edef68
2008-03-19 12:34:40 +00:00
8de8d0b37e
opps had my logic backwards..
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638603 13f79535-47bb-0310-9956-ffa450edef68
2008-03-18 22:00:16 +00:00
6b33749b17
access to the writeThread was not safe.. Plus interrupting another thread is not recommended anyways.
...
also fail new oneway() operations once inactivity is detected.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638596 13f79535-47bb-0310-9956-ffa450edef68
2008-03-18 21:43:42 +00:00
dc4f2993cc
change reference count boundaries around messages - so they
...
are around acks
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638385 13f79535-47bb-0310-9956-ffa450edef68
2008-03-18 14:32:41 +00:00
3c4d09d749
Don't use port 6001 since that conflicts with X servers on windows.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638359 13f79535-47bb-0310-9956-ffa450edef68
2008-03-18 13:33:10 +00:00
eccb337303
Don't send the ShutdownInfo when stopping the transport. This should make it faster to shutdown a failed connection.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638358 13f79535-47bb-0310-9956-ffa450edef68
2008-03-18 13:18:22 +00:00
e58dfee8cc
Disable by default the status detector - InactivityMonitor does the same thing
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638260 13f79535-47bb-0310-9956-ffa450edef68
2008-03-18 08:26:43 +00:00
3957eb0f6d
removed unused executor
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638246 13f79535-47bb-0310-9956-ffa450edef68
2008-03-18 07:15:45 +00:00
e41be74339
Use ThreadPool for stopping services
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638238 13f79535-47bb-0310-9956-ffa450edef68
2008-03-18 06:45:25 +00:00
44e6f7d0cd
Use ThreadPool for stopping services
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638235 13f79535-47bb-0310-9956-ffa450edef68
2008-03-18 06:38:18 +00:00
ec15e1c05a
Use ThreadPool for starting local services
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638234 13f79535-47bb-0310-9956-ffa450edef68
2008-03-18 06:30:00 +00:00
859397c18b
Use ThreadPool for starting remote services
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@638233 13f79535-47bb-0310-9956-ffa450edef68
2008-03-18 06:24:37 +00:00
cdd2108dd1
Just making it a little more thread safe.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@637965 13f79535-47bb-0310-9956-ffa450edef68
2008-03-17 16:42:09 +00:00
4bce5c810a
Don't timeout trying to aquire the service write lock. Timing out can cause to improper shutdown.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@637962 13f79535-47bb-0310-9956-ffa450edef68
2008-03-17 16:34:34 +00:00
70511a6929
don't want errors from old transport after its failed
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@637883 13f79535-47bb-0310-9956-ffa450edef68
2008-03-17 13:34:11 +00:00
4032a01c17
Interrupt the writing thread on failure
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@637881 13f79535-47bb-0310-9956-ffa450edef68
2008-03-17 13:32:31 +00:00
5e03394423
send shutdown to transports asynchronously - as they may be blocked
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@637879 13f79535-47bb-0310-9956-ffa450edef68
2008-03-17 13:30:38 +00:00
372f69aba9
tightened synchronization around dispatchQueue
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@637878 13f79535-47bb-0310-9956-ffa450edef68
2008-03-17 13:28:06 +00:00
0ff0ee3766
use defaults for VMTransport in network connections
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@637877 13f79535-47bb-0310-9956-ffa450edef68
2008-03-17 13:27:11 +00:00
b32ff4dd5c
Ensure we detect Connection splits for any type of network
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@637609 13f79535-47bb-0310-9956-ffa450edef68
2008-03-16 16:30:55 +00:00
Hiram R. Chirino
James Strachan
Guillaume Nodet
Robert Davies