6f851c8cce
Wait for the queue consumers to connect before sending the messages.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@643461 13f79535-47bb-0310-9956-ffa450edef68
2008-04-01 16:02:19 +00:00
bcacddfaad
Adding a little more delay so it works with slower machines.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@643460 13f79535-47bb-0310-9956-ffa450edef68
2008-04-01 16:01:20 +00:00
53756f3c19
fixed failing camel tests; made the CamelEndpointLoader dependent on the EnhancedConnection interface so it works with a naked ActiveMQConnection or a PooledConnection. Also changed the defaults to use a PooledConnectionFactory by default when using the ActiveMQ camel component
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@643458 13f79535-47bb-0310-9956-ffa450edef68
2008-04-01 15:58:14 +00:00
80722e4c9d
fix for failing test case
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@643439 13f79535-47bb-0310-9956-ffa450edef68
2008-04-01 15:21:13 +00:00
a818270040
Making the MultiBrokersMultiClientsTest less timing dependent. Using advisories to know when the subscriptions have been setup so
...
that we can start the publishing at the right time.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@643407 13f79535-47bb-0310-9956-ffa450edef68
2008-04-01 14:05:51 +00:00
2a328ed27c
When pulling a message, iterate the destinations first to make sure that it has pushed all available messages to
...
the sub. This should fix the ZeroPrefetchTest that was intermitently failing on slower machines.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@643390 13f79535-47bb-0310-9956-ffa450edef68
2008-04-01 13:22:48 +00:00
3eb6aed961
If a transport error occurs, there is no point in trying to cleanup with the broker since transport has failed.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@643206 13f79535-47bb-0310-9956-ffa450edef68
2008-03-31 23:16:55 +00:00
431478a8f5
do best effort to drain the queues.. and error should not interrupt the connection and broker shutdown.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@643205 13f79535-47bb-0310-9956-ffa450edef68
2008-03-31 23:15:45 +00:00
c20b10bed8
This method override seems like it's causing out of order dispatch in the JmsTempDestinationTest disabling for now until we can research this further.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@643148 13f79535-47bb-0310-9956-ffa450edef68
2008-03-31 21:00:33 +00:00
8e98b13c87
Fixing DLQ tests.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@643108 13f79535-47bb-0310-9956-ffa450edef68
2008-03-31 19:26:19 +00:00
53c9bab824
added a fix for http://issues.apache.org/activemq/browse/AMQ-1636 to avoid creating unnecessary connections when sending messages from Camel
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@642166 13f79535-47bb-0310-9956-ffa450edef68
2008-03-28 09:42:40 +00:00
76ac7588e8
- Fixing out of order dispatch.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@642067 13f79535-47bb-0310-9956-ffa450edef68
2008-03-28 02:22:39 +00:00
b5df4babc0
Fixed the JmsTempDestinationTest test. Async send was causing the temp destination to get recreated after the temp connection was closed.
...
Fixed - Was sending duplicate temp destination created advisories.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@641938 13f79535-47bb-0310-9956-ffa450edef68
2008-03-27 18:45:04 +00:00
14b8957713
Shutdown all connections opened in the testcase so that the broker shutdown between cases. Fixes failures that happened ocasionally
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@641890 13f79535-47bb-0310-9956-ffa450edef68
2008-03-27 16:55:09 +00:00
e35c115e03
added a little test program showing how to browse ActiveMQ queues using Camel BrowsableEndpoints http://activemq.apache.org/camel/browsableendpoint.html
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@641756 13f79535-47bb-0310-9956-ffa450edef68
2008-03-27 09:47:45 +00:00
3cbee72a9c
added test case and patch that shows adding producers & sending messages didn't trigger advisories
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@641548 13f79535-47bb-0310-9956-ffa450edef68
2008-03-26 20:23:26 +00:00
cdfb3c0691
increased the sleep to ensure test case works
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@641545 13f79535-47bb-0310-9956-ffa450edef68
2008-03-26 20:19:29 +00:00
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
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
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
1987cfa234
Only unlock a service lock if we managed to lock it
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@637454 13f79535-47bb-0310-9956-ffa450edef68
2008-03-15 18:59:49 +00:00
ceb7e1a86c
Don't check connection splits for temporary destinations
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@637046 13f79535-47bb-0310-9956-ffa450edef68
2008-03-14 10:44:52 +00:00
5dc188eb32
monitor connection splits is now on by default
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636930 13f79535-47bb-0310-9956-ffa450edef68
2008-03-14 00:04:32 +00:00
ba3e913daf
tidied up detection of stale subscriptions across a network
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636897 13f79535-47bb-0310-9956-ffa450edef68
2008-03-13 21:18:35 +00:00
320f80263e
too many advisories flying about
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636868 13f79535-47bb-0310-9956-ffa450edef68
2008-03-13 20:31:32 +00:00
5fd3229c0b
default back to straight through for network vm transport
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636796 13f79535-47bb-0310-9956-ffa450edef68
2008-03-13 16:21:36 +00:00
4a136864f1
remove unused method
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636733 13f79535-47bb-0310-9956-ffa450edef68
2008-03-13 11:56:41 +00:00
5288e0d2e7
remove unused imports
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636732 13f79535-47bb-0310-9956-ffa450edef68
2008-03-13 11:55:47 +00:00
c451951148
Added properties for caching of temp destinations
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636724 13f79535-47bb-0310-9956-ffa450edef68
2008-03-13 11:36:43 +00:00
e4621e3aa7
Added properties for caching of temp destinations
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636722 13f79535-47bb-0310-9956-ffa450edef68
2008-03-13 11:35:57 +00:00
a785cb75dd
expose internal maps to help debugging
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636720 13f79535-47bb-0310-9956-ffa450edef68
2008-03-13 11:35:20 +00:00
1096564117
Allow the region broker implemenation to get changed by subclasses of BrokerService.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636609 13f79535-47bb-0310-9956-ffa450edef68
2008-03-13 03:09:48 +00:00
93ccb9ca3b
try and allow for zero pretech consumers with lazy dispatch
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636507 13f79535-47bb-0310-9956-ffa450edef68
2008-03-12 20:59:54 +00:00
290ce2a6bf
ensure network connections use async dispatch
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636454 13f79535-47bb-0310-9956-ffa450edef68
2008-03-12 19:00:25 +00:00
8fd41894ca
Add network consumer id to a DemandSubscription
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636428 13f79535-47bb-0310-9956-ffa450edef68
2008-03-12 17:12:35 +00:00
f9cc04e5db
Add network consumer id to a DemandSubscription
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636426 13f79535-47bb-0310-9956-ffa450edef68
2008-03-12 17:11:51 +00:00
cb65470569
use a separate mutex for building backups
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636425 13f79535-47bb-0310-9956-ffa450edef68
2008-03-12 17:10:17 +00:00
712254d5d2
support a list of ConsumerId's from the network
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636424 13f79535-47bb-0310-9956-ffa450edef68
2008-03-12 17:08:48 +00:00
22565e4176
don't throw an exception if removing an invalid subscription -
...
it could happen from the ConnectionSplitBroker
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636422 13f79535-47bb-0310-9956-ffa450edef68
2008-03-12 17:07:46 +00:00
58cf400836
Check for old network Subscriptions as well as connections
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636420 13f79535-47bb-0310-9956-ffa450edef68
2008-03-12 17:06:07 +00:00
f67415d879
don't wait for ever when stopping the connection on a blocked write
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636419 13f79535-47bb-0310-9956-ffa450edef68
2008-03-12 17:04:44 +00:00
84792bafed
If pageIn is forced - don't do lazyDispatch
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636411 13f79535-47bb-0310-9956-ffa450edef68
2008-03-12 16:48:22 +00:00
a9ccf5623d
check for null message in MessageDispatch
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636281 13f79535-47bb-0310-9956-ffa450edef68
2008-03-12 11:16:05 +00:00
c6b88f1ecc
Made the ReconnectTest a little more robust.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636106 13f79535-47bb-0310-9956-ffa450edef68
2008-03-11 21:17:51 +00:00
2185cdb6e0
Fix supplied by Pete Schwamb for corrupted DiskIndexLinkedList
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636078 13f79535-47bb-0310-9956-ffa450edef68
2008-03-11 19:46:58 +00:00
7d70fec53a
make lazy dispatch the default for queues
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636067 13f79535-47bb-0310-9956-ffa450edef68
2008-03-11 19:13:50 +00:00
4fcacf7772
A client should connect to the same broker for it's sending and receiving so that the broker does the forwarding
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636064 13f79535-47bb-0310-9956-ffa450edef68
2008-03-11 19:11:51 +00:00
67d38fafd1
Fix for the failing QueueMasterSlaveTestUsingSharedFileTest on windows. The lock on the AsyncDataManager was not being retried.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636037 13f79535-47bb-0310-9956-ffa450edef68
2008-03-11 17:59:24 +00:00
75d43c027f
This test is very taxing.. if you didn't have a good machine it could produce false negatives.. lowering requirements a bit to reduce false negatives.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@635971 13f79535-47bb-0310-9956-ffa450edef68
2008-03-11 15:20:31 +00:00
512b0c7e67
Don't use FilePendingMessageCursor if persitence is off
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@635932 13f79535-47bb-0310-9956-ffa450edef68
2008-03-11 14:05:20 +00:00
0c45ad5778
exclude NetworkFailoverTest
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@635755 13f79535-47bb-0310-9956-ffa450edef68
2008-03-10 23:11:55 +00:00
8f1505ff55
tidy up imports
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@635753 13f79535-47bb-0310-9956-ffa450edef68
2008-03-10 23:10:46 +00:00
7ee534ff26
monitor connection splits
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@635747 13f79535-47bb-0310-9956-ffa450edef68
2008-03-10 23:05:50 +00:00
29cfdedb12
take out System println messages
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@635688 13f79535-47bb-0310-9956-ffa450edef68
2008-03-10 20:54:54 +00:00
044c07d9a5
Added a lazy dispatch option for queues
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@635682 13f79535-47bb-0310-9956-ffa450edef68
2008-03-10 20:35:34 +00:00
98b4923918
Simple Request/Reply test using temp queues over a network - with
...
a failure on every send
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@635681 13f79535-47bb-0310-9956-ffa450edef68
2008-03-10 20:33:24 +00:00
c42c5ff976
Fix problem in message state tracker that will result on OME
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@635565 13f79535-47bb-0310-9956-ffa450edef68
2008-03-10 14:16:49 +00:00
5e747b070d
Improvements to removing stale connections
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@634797 13f79535-47bb-0310-9956-ffa450edef68
2008-03-07 20:09:07 +00:00
c803f531e3
Ignore invalid commands to the AdvisoryConsumer- can happen due
...
to the use of wildcards across a network
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@634775 13f79535-47bb-0310-9956-ffa450edef68
2008-03-07 18:43:51 +00:00
26eedea5fb
added support to be able to auto-expose ActiveMQ Queues into a CamelContext so that they are browsable by any Camel based tooling
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@634686 13f79535-47bb-0310-9956-ffa450edef68
2008-03-07 14:17:01 +00:00
1a01d13731
Detect clients fail over - that haven't removed themselves from
...
a brokee
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@634589 13f79535-47bb-0310-9956-ffa450edef68
2008-03-07 09:06:30 +00:00
3f9d6e2ef8
re-introduce optimize dispatch for queues
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@634588 13f79535-47bb-0310-9956-ffa450edef68
2008-03-07 09:02:37 +00:00
4c481ec6a9
Added a ReentrantReadWriteLock to guard against a service call executing while a connection is being shutdown.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@634505 13f79535-47bb-0310-9956-ffa450edef68
2008-03-07 02:33:32 +00:00
bb763f5f7a
dump an index
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@634490 13f79535-47bb-0310-9956-ffa450edef68
2008-03-07 01:01:18 +00:00
88fbb05af5
Add foundation for monitoring split brokers from a clients view point
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@634488 13f79535-47bb-0310-9956-ffa450edef68
2008-03-07 00:59:02 +00:00
cf55702288
resolve concurrent modification
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@634487 13f79535-47bb-0310-9956-ffa450edef68
2008-03-07 00:57:55 +00:00
f4ca650108
Fix concurrent modification of pagedInMessages
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@634472 13f79535-47bb-0310-9956-ffa450edef68
2008-03-07 00:10:20 +00:00
9cc2d3776e
open up to more Configuration
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@634421 13f79535-47bb-0310-9956-ffa450edef68
2008-03-06 21:29:22 +00:00
4ae43a36b5
reduce contention around stats on connection - thx for spotting this Hiram!
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@634420 13f79535-47bb-0310-9956-ffa450edef68
2008-03-06 21:26:53 +00:00
d56371fd69
fix current modification of linked list
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@634415 13f79535-47bb-0310-9956-ffa450edef68
2008-03-06 21:02:50 +00:00
c0b74f0562
Fix for: https://issues.apache.org/activemq/browse/AMQ-1613
...
Avoid deadlocking with the thread calling oneway() when we are cleaning up the connection due to an Inactivity error.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@634411 13f79535-47bb-0310-9956-ffa450edef68
2008-03-06 20:45:02 +00:00
fb0e159499
added a helper class for auto-exposing ActiveMQ Queues into the CamelContext
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@634377 13f79535-47bb-0310-9956-ffa450edef68
2008-03-06 18:22:20 +00:00
5e897d6c38
updated the test case for http://issues.apache.org/activemq/browse/AMQ-1199 to make it a better test
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@634281 13f79535-47bb-0310-9956-ffa450edef68
2008-03-06 14:40:14 +00:00
f6efc5660d
added support for http://issues.apache.org/activemq/browse/AMQ-1199 so that its easy to browse the available queues & topics in a broker
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@634277 13f79535-47bb-0310-9956-ffa450edef68
2008-03-06 14:35:26 +00:00
cd54a162f6
Define specific region classes for TempQueue and TempTopic
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@633976 13f79535-47bb-0310-9956-ffa450edef68
2008-03-05 18:59:58 +00:00
e7316df001
synchronize around the messagesWaitingForSpace
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@633808 13f79535-47bb-0310-9956-ffa450edef68
2008-03-05 10:17:43 +00:00
f6fd249d8c
remove unused import
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@633806 13f79535-47bb-0310-9956-ffa450edef68
2008-03-05 10:12:20 +00:00
3b0afd6b71
Added NonCachedMessageContext
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@633800 13f79535-47bb-0310-9956-ffa450edef68
2008-03-05 09:35:31 +00:00
26aeb46493
Added non persistent queue network test
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@633799 13f79535-47bb-0310-9956-ffa450edef68
2008-03-05 09:32:45 +00:00
a9b841af61
The AsyncDataManager now supports doing a callback notification for when a write
...
has been secured to disk.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@633603 13f79535-47bb-0310-9956-ffa450edef68
2008-03-04 19:36:58 +00:00
747b2ddc4a
Fixing edge case that does not normally occur. When marshalling a null object and size prefixing is disabled, we
...
were still prefixing the size of the data.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@633571 13f79535-47bb-0310-9956-ffa450edef68
2008-03-04 17:55:01 +00:00
c84e58a948
Reduce contention by using an Atomic Reference.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@633570 13f79535-47bb-0310-9956-ffa450edef68
2008-03-04 17:52:14 +00:00
1c8cfd9cfe
The testWildcardConsume has 1 consumer subscribe to 2 destiantions and made an assumption
...
that messages would delivered in the order published to the 2 different destinations. This is not correct
as the messages could queue up and get dispatched at different times. Updated the code so that this assumption
is no longer relied on.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@633554 13f79535-47bb-0310-9956-ffa450edef68
2008-03-04 17:28:53 +00:00
3d18d59904
Protect the messagesWaitingForSpace variable against concurrent modification.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@633210 13f79535-47bb-0310-9956-ffa450edef68
2008-03-03 18:03:21 +00:00
e376456111
Compress HashIndex on startup - only way to ensure the index
...
pages are loaded in correct order without changing the wire format
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@632964 13f79535-47bb-0310-9956-ffa450edef68
2008-03-03 07:18:00 +00:00
b67f61df98
Don't use default container name for loader test
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@632963 13f79535-47bb-0310-9956-ffa450edef68
2008-03-03 07:16:34 +00:00
18e1a6bfc1
HashTest expanded to load/unload/load indexes through testing
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@632962 13f79535-47bb-0310-9956-ffa450edef68
2008-03-03 07:15:45 +00:00
d8b407bb63
Added copy file method
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@632961 13f79535-47bb-0310-9956-ffa450edef68
2008-03-03 07:14:39 +00:00
c427689dad
make splitting consumers/producers memory limit optional and off
...
by default
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@632666 13f79535-47bb-0310-9956-ffa450edef68
2008-03-01 22:31:26 +00:00
767b548715
fix for inaccurate page calculation in bin overflow
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@632651 13f79535-47bb-0310-9956-ffa450edef68
2008-03-01 19:59:49 +00:00
32dc290eb7
reset defaults
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@632560 13f79535-47bb-0310-9956-ffa450edef68
2008-03-01 07:30:03 +00:00
13829eff1d
The Producer MemoryLimit can lead to network deadlock when spooling is disabled.
...
So we now disable using it when sooling is used on a queue.
see:
https://issues.apache.org/activemq/browse/AMQ-1606
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@632455 13f79535-47bb-0310-9956-ffa450edef68
2008-02-29 21:59:33 +00:00
c0b00b2d28
set track messages off by default
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@632333 13f79535-47bb-0310-9956-ffa450edef68
2008-02-29 14:55:10 +00:00
710db267a9
Move back to using DEfaultThreadPools for reconnect tasks - as
...
for very bad connections, DedicatedTaskRunner could get swamped with
reconnect tasks
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@632269 13f79535-47bb-0310-9956-ffa450edef68
2008-02-29 09:22:02 +00:00
014f82a1e0
remove println() - oops
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@632051 13f79535-47bb-0310-9956-ffa450edef68
2008-02-28 16:45:17 +00:00
03ecdb00ee
changed free list implementation
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@632050 13f79535-47bb-0310-9956-ffa450edef68
2008-02-28 16:42:30 +00:00
e31ca80546
added size to toString() method
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@632047 13f79535-47bb-0310-9956-ffa450edef68
2008-02-28 16:38:34 +00:00
571a253df7
added toString()
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@632046 13f79535-47bb-0310-9956-ffa450edef68
2008-02-28 16:36:56 +00:00
a36426d202
keep alive should get a response
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@631965 13f79535-47bb-0310-9956-ffa450edef68
2008-02-28 13:29:35 +00:00
dd35ef43e5
Upgraded jettison to 1.0
...
https://issues.apache.org/activemq/browse/AMQ-1597
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@631871 13f79535-47bb-0310-9956-ffa450edef68
2008-02-28 06:45:52 +00:00
a6e227dcdc
Tweak the logging a bit. Didn't like the idea of different log messages depending on log level.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@631866 13f79535-47bb-0310-9956-ffa450edef68
2008-02-28 06:24:17 +00:00
da6c2d61f1
Changing logging to log stacktraces to debug only
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@631864 13f79535-47bb-0310-9956-ffa450edef68
2008-02-28 06:20:12 +00:00
bf20d76622
https://issues.apache.org/activemq/browse/AMQ-1598
...
Remove extraneous Thread.dumpStack call
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@631848 13f79535-47bb-0310-9956-ffa450edef68
2008-02-28 05:12:44 +00:00
e60828c077
Better qos options on the producer of this test.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@631665 13f79535-47bb-0310-9956-ffa450edef68
2008-02-27 18:07:46 +00:00
b01374e05f
Added better weighted sleeps to make sure everything is going before we start sampling.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@631662 13f79535-47bb-0310-9956-ffa450edef68
2008-02-27 17:44:07 +00:00
a9120b1b12
Adding a test does a load test across multiple network connections.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@631658 13f79535-47bb-0310-9956-ffa450edef68
2008-02-27 17:20:03 +00:00
00893abe27
recycle hash pages
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@631537 13f79535-47bb-0310-9956-ffa450edef68
2008-02-27 10:21:27 +00:00
5075fb9dea
added a test case showing how to set a property using a Processor http://www.nabble.com/setting-JMSXGroupId-property-from-within-a-processor-tp15706825s22882p15706825.html
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@631509 13f79535-47bb-0310-9956-ffa450edef68
2008-02-27 07:56:33 +00:00
e225ba622c
optionally replay messages on the fault tolerant transport
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@631244 13f79535-47bb-0310-9956-ffa450edef68
2008-02-26 15:00:37 +00:00
25b6812daa
Added network and fault tolerant flags to ConnectionContext
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@631241 13f79535-47bb-0310-9956-ffa450edef68
2008-02-26 14:56:31 +00:00
33724ec1c3
removed tmp destination tests - the check is done client side now
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@631240 13f79535-47bb-0310-9956-ffa450edef68
2008-02-26 14:55:45 +00:00
cd24f8099f
Introduced AbstractTempRegion - to cater for temp destination
...
usage on failover
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@631237 13f79535-47bb-0310-9956-ffa450edef68
2008-02-26 14:50:43 +00:00
16b4009348
added additional logging around ClassNotFoundException
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@631227 13f79535-47bb-0310-9956-ffa450edef68
2008-02-26 14:34:40 +00:00
230255a479
https://issues.apache.org/activemq/browse/AMQ-1595
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@630253 13f79535-47bb-0310-9956-ffa450edef68
2008-02-22 17:03:39 +00:00
b34f730231
expose some methods to make it easier to test
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@630136 13f79535-47bb-0310-9956-ffa450edef68
2008-02-22 10:05:33 +00:00
3d33c0e51a
Fixing bug with qdox.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@630050 13f79535-47bb-0310-9956-ffa450edef68
2008-02-21 23:42:00 +00:00
b141d21dce
Gaurd against too many read checks happening back to back.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@629859 13f79535-47bb-0310-9956-ffa450edef68
2008-02-21 16:39:16 +00:00
204f6d8385
have backup off by default
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@629725 13f79535-47bb-0310-9956-ffa450edef68
2008-02-21 09:10:27 +00:00
2a153b085f
Fix for https://issues.apache.org/activemq/browse/AMQ-1560
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@629713 13f79535-47bb-0310-9956-ffa450edef68
2008-02-21 08:13:08 +00:00
60c260582d
Fix for https://issues.apache.org/activemq/browse/AMQ-1591
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@629639 13f79535-47bb-0310-9956-ffa450edef68
2008-02-20 22:24:18 +00:00
34c530c39b
removed unused imports
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@629636 13f79535-47bb-0310-9956-ffa450edef68
2008-02-20 22:19:31 +00:00
e0bdc012c1
Fix for https://issues.apache.org/activemq/browse/AMQ-1591
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@629631 13f79535-47bb-0310-9956-ffa450edef68
2008-02-20 22:05:02 +00:00
bca91bb068
check for null byte passed as parameter
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@629623 13f79535-47bb-0310-9956-ffa450edef68
2008-02-20 21:47:18 +00:00
13af1e36fb
- Fix for https://issues.apache.org/activemq/browse/AMQ-1576 (behavior is that if a jms property is null, it will not be converted, but will still be added to the default list of properties)
...
- Fix a spelling typo
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@629060 13f79535-47bb-0310-9956-ffa450edef68
2008-02-19 10:46:13 +00:00
8768a04e63
doDispatch():
...
only apply message to least loaded if target subscription not
already found
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@629007 13f79535-47bb-0310-9956-ffa450edef68
2008-02-19 07:21:50 +00:00
40950bc4b8
https://issues.apache.org/activemq/browse/AMQ-1580
...
- Check for 0 length buffer when receiving byte messages
- Don't send an empty byte message if there is no data to flush
- Added test case from AMQQ-1580
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@628988 13f79535-47bb-0310-9956-ffa450edef68
2008-02-19 04:37:55 +00:00
900c9af498
When recovering durable subscriptions - ensure they are recovered only once
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@628778 13f79535-47bb-0310-9956-ffa450edef68
2008-02-18 15:13:12 +00:00
4a8ade0fae
Fix typo: https://issues.apache.org/activemq/browse/AMQ-1565
...
Added explicit version for maven-antrun-plugin
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@628764 13f79535-47bb-0310-9956-ffa450edef68
2008-02-18 14:52:56 +00:00
213c3ae379
Apply patch for https://issues.apache.org/activemq/browse/AMQ-1584
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@628710 13f79535-47bb-0310-9956-ffa450edef68
2008-02-18 12:55:51 +00:00
2747573f66
Fix for https://issues.apache.org/activemq/browse/AMQ-1583
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@628708 13f79535-47bb-0310-9956-ffa450edef68
2008-02-18 12:50:38 +00:00
d4382e483b
Change Queue dispatch model to reduce contention for lots of
...
consumers
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@628667 13f79535-47bb-0310-9956-ffa450edef68
2008-02-18 09:38:10 +00:00
edd35d4b13
Added a TaksRunner that always executes iterate - even if its already running
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@628665 13f79535-47bb-0310-9956-ffa450edef68
2008-02-18 09:36:39 +00:00
8250a3c4b2
Fix some timing issues with test cases
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@628664 13f79535-47bb-0310-9956-ffa450edef68
2008-02-18 09:35:37 +00:00
7882eb7968
Fix some timing issues with test cases
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@628663 13f79535-47bb-0310-9956-ffa450edef68
2008-02-18 09:32:57 +00:00
da46fffc54
removed unused property
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@620760 13f79535-47bb-0310-9956-ffa450edef68
2008-02-12 11:11:05 +00:00
be6376373f
Utility class for messages
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@620738 13f79535-47bb-0310-9956-ffa450edef68
2008-02-12 10:04:36 +00:00
f94406aae6
calculate message size even if the minimumMessageSize == 0
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@620500 13f79535-47bb-0310-9956-ffa450edef68
2008-02-11 14:59:56 +00:00
5460b7bb47
remove patch comment
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@619789 13f79535-47bb-0310-9956-ffa450edef68
2008-02-08 07:24:26 +00:00
24fea9368c
iterate() now returns false after every run to prevent spinning
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@619652 13f79535-47bb-0310-9956-ffa450edef68
2008-02-07 21:42:56 +00:00
939a3160f3
Handle the OverlappingFileLockException that could occur.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@619511 13f79535-47bb-0310-9956-ffa450edef68
2008-02-07 17:13:03 +00:00
52ca2de3f0
remove shutdown hook
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@619391 13f79535-47bb-0310-9956-ffa450edef68
2008-02-07 12:58:46 +00:00
6f66aa0eea
can't determine order messages will arrive in for separate queues
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@619390 13f79535-47bb-0310-9956-ffa450edef68
2008-02-07 12:57:52 +00:00
ac0a88f44d
slave deletes all messages on startup now
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@619388 13f79535-47bb-0310-9956-ffa450edef68
2008-02-07 12:56:12 +00:00
6d0c552c8a
cursor fixes
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@619387 13f79535-47bb-0310-9956-ffa450edef68
2008-02-07 12:55:02 +00:00
1a6cbfa651
fix for https://issues.apache.org/activemq/browse/AMQ-1446
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@619347 13f79535-47bb-0310-9956-ffa450edef68
2008-02-07 10:15:54 +00:00
6c52d28985
Fix for:
...
https://issues.apache.org/activemq/browse/AMQ-1116
https://issues.apache.org/activemq/browse/AMQ-1575
https://issues.apache.org/activemq/browse/AMQ-1577
https://issues.apache.org/activemq/browse/AMQ-1581
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@619336 13f79535-47bb-0310-9956-ffa450edef68
2008-02-07 09:51:19 +00:00
527bd15a5a
- Clients do not shutdown due to non-daemon threads hanging around.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@619004 13f79535-47bb-0310-9956-ffa450edef68
2008-02-06 14:48:42 +00:00
149428b5bc
Reduce contention on the AMQ Store
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@618981 13f79535-47bb-0310-9956-ffa450edef68
2008-02-06 12:23:41 +00:00
65beee6895
comment out send first then consume
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@618817 13f79535-47bb-0310-9956-ffa450edef68
2008-02-05 23:08:01 +00:00
f81d0d59d3
lock dispatching (again) whilst adding a consumer
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@618689 13f79535-47bb-0310-9956-ffa450edef68
2008-02-05 16:20:11 +00:00
ecc87ea672
add isConnected() flag to a Transport
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@618656 13f79535-47bb-0310-9956-ffa450edef68
2008-02-05 14:06:43 +00:00
c128634fa6
copy message before resend
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@618655 13f79535-47bb-0310-9956-ffa450edef68
2008-02-05 14:05:46 +00:00
d0f3d4dce9
Make maximum page size for queues configurable
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@618654 13f79535-47bb-0310-9956-ffa450edef68
2008-02-05 14:04:39 +00:00
071b4b109e
refactored cursors to improve re-use
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@618621 13f79535-47bb-0310-9956-ffa450edef68
2008-02-05 12:14:49 +00:00
4188ed0b9a
increase the length of the wait for messages
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@618620 13f79535-47bb-0310-9956-ffa450edef68
2008-02-05 12:11:09 +00:00
ad3799cbae
removed test waiting for space
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@618619 13f79535-47bb-0310-9956-ffa450edef68
2008-02-05 12:07:32 +00:00
c99f05529f
Updated the performance tests
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@618617 13f79535-47bb-0310-9956-ffa450edef68
2008-02-05 12:05:52 +00:00
c24574c801
don't set memory limit
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@618615 13f79535-47bb-0310-9956-ffa450edef68
2008-02-05 12:01:19 +00:00
0c1279009c
remove unused imports
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@618612 13f79535-47bb-0310-9956-ffa450edef68
2008-02-05 11:45:26 +00:00
ef0e1bac6e
Adding a ReadOnlyAsyncDataManager so that you can access a set of data files in a read only way.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@618082 13f79535-47bb-0310-9956-ffa450edef68
2008-02-03 20:43:17 +00:00
3ac0537e3e
added isDisposed to Transport interface
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@617015 13f79535-47bb-0310-9956-ffa450edef68
2008-01-31 06:34:12 +00:00
5f83e62d66
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@616811 13f79535-47bb-0310-9956-ffa450edef68
2008-01-30 16:42:39 +00:00
a55149cad0
Further enhancement for https://issues.apache.org/activemq/browse/AMQ-1572
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@616735 13f79535-47bb-0310-9956-ffa450edef68
2008-01-30 12:14:12 +00:00
418823a7e1
Further enhancement for https://issues.apache.org/activemq/browse/AMQ-1572
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@616733 13f79535-47bb-0310-9956-ffa450edef68
2008-01-30 12:10:22 +00:00
e210657db2
Fix for https://issues.apache.org/activemq/browse/AMQ-1572
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@616506 13f79535-47bb-0310-9956-ffa450edef68
2008-01-29 20:06:47 +00:00
3249682bda
disable caching of messages for the Queue Cursor
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@615341 13f79535-47bb-0310-9956-ffa450edef68
2008-01-25 21:06:43 +00:00
e16bcf2f48
turn cache off by default
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@615297 13f79535-47bb-0310-9956-ffa450edef68
2008-01-25 18:25:04 +00:00
b8674d4006
disable optimized dispatch
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@615288 13f79535-47bb-0310-9956-ffa450edef68
2008-01-25 17:56:06 +00:00
cce756605f
use task runner to dispatch messages - improve concurrency
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@615287 13f79535-47bb-0310-9956-ffa450edef68
2008-01-25 17:52:54 +00:00
55810b3155
resolution for https://issues.apache.org/activemq/browse/AMQ-1566
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@614645 13f79535-47bb-0310-9956-ffa450edef68
2008-01-23 20:08:27 +00:00
23cda2d6bb
Fix for https://issues.apache.org/activemq/browse/AMQ-1562
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@614206 13f79535-47bb-0310-9956-ffa450edef68
2008-01-22 14:28:10 +00:00
17e22cff6f
Fix for https://issues.apache.org/activemq/browse/AMQ-1475
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@613899 13f79535-47bb-0310-9956-ffa450edef68
2008-01-21 14:22:58 +00:00
01cef910db
Fix for https://issues.apache.org/activemq/browse/AMQ-1560
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@613874 13f79535-47bb-0310-9956-ffa450edef68
2008-01-21 13:09:38 +00:00
1f2804a76a
Fix for https://issues.apache.org/activemq/browse/AMQ-1559
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@613832 13f79535-47bb-0310-9956-ffa450edef68
2008-01-21 10:33:55 +00:00
83c3dca9e5
Fix for https://issues.apache.org/activemq/browse/AMQ-1510
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@613830 13f79535-47bb-0310-9956-ffa450edef68
2008-01-21 10:31:22 +00:00
caf7a7c7c2
Fix for https://issues.apache.org/activemq/browse/AMQ-1556
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@613829 13f79535-47bb-0310-9956-ffa450edef68
2008-01-21 10:28:59 +00:00
8f190f188b
increase the amount of time to receive messages - to try prevent intermittent failure
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@613244 13f79535-47bb-0310-9956-ffa450edef68
2008-01-18 19:49:56 +00:00
8d11f07a96
Fix for https://issues.apache.org/activemq/browse/AMQ-1553
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@613230 13f79535-47bb-0310-9956-ffa450edef68
2008-01-18 19:16:15 +00:00
671ed4916e
resources for the sharedFileMaster tests
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@612910 13f79535-47bb-0310-9956-ffa450edef68
2008-01-17 18:18:44 +00:00
a28ccae9fb
added a test case and fix for AMQ-775 along with a useful base class for testing ActiveMQ using Camel
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@612828 13f79535-47bb-0310-9956-ffa450edef68
2008-01-17 14:31:03 +00:00
5361df13dc
added a little helper factory bean for https://issues.apache.org/activemq/browse/AMQ-1552 to allow easy failover configuration without explicit URI magic
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@612824 13f79535-47bb-0310-9956-ffa450edef68
2008-01-17 14:20:35 +00:00
10eae9d6e7
fixed the schema location
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@612823 13f79535-47bb-0310-9956-ffa450edef68
2008-01-17 14:19:15 +00:00
c4d8d86715
Applying https://issues.apache.org/activemq/browse/AMQ-1361
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@612661 13f79535-47bb-0310-9956-ffa450edef68
2008-01-17 00:48:02 +00:00
2b5608f761
Applying patch at https://issues.apache.org/activemq/browse/AMQ-943
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@612544 13f79535-47bb-0310-9956-ffa450edef68
2008-01-16 19:15:50 +00:00
634da7a88e
Add producers to DestinationStatistics
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@612542 13f79535-47bb-0310-9956-ffa450edef68
2008-01-16 19:03:02 +00:00
5f4db41d2d
set correct consumer count on consumer advisories
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@612459 13f79535-47bb-0310-9956-ffa450edef68
2008-01-16 13:56:24 +00:00
e7245768b3
Fixing the build. Backing down the xbean version until the qdox parser problem is resolved.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@611918 13f79535-47bb-0310-9956-ffa450edef68
2008-01-14 20:29:18 +00:00
b39430ab17
Upgrade to xbean 3.3-SNAPSHOT to pull in the fix for:
...
http://issues.apache.org/jira/browse/XBEAN-101
PropertyPlaceholderConfigurer can not be used to resolve values assigned to xbean properties that have a custom PropertyEditor
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@610502 13f79535-47bb-0310-9956-ffa450edef68
2008-01-09 18:44:34 +00:00
3163d48eb1
applied patch for https://issues.apache.org/activemq/browse/AMQ-1542
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@610432 13f79535-47bb-0310-9956-ffa450edef68
2008-01-09 16:16:05 +00:00
3d10accb46
fixes for load testing
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@609606 13f79535-47bb-0310-9956-ffa450edef68
2008-01-07 13:51:06 +00:00
0640cb703a
Added basic load test for queues
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@608902 13f79535-47bb-0310-9956-ffa450edef68
2008-01-04 16:07:18 +00:00
9899dff93d
nake inflight message count a little more explicit
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@608414 13f79535-47bb-0310-9956-ffa450edef68
2008-01-03 10:03:19 +00:00
082bbf0f06
Add some duplex property for network connector view
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@608356 13f79535-47bb-0310-9956-ffa450edef68
2008-01-03 06:34:40 +00:00
a0b3e3211e
Fix for https://issues.apache.org/activemq/browse/AMQ-1533
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@608034 13f79535-47bb-0310-9956-ffa450edef68
2008-01-02 08:16:25 +00:00
409902c394
Tweaking for Queue performance and concurrency
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@607317 13f79535-47bb-0310-9956-ffa450edef68
2007-12-28 19:52:24 +00:00
c493b87f0a
This test could get stuck - now only wait 2 seconds for a message
...
and use Memory Message Store
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@607186 13f79535-47bb-0310-9956-ffa450edef68
2007-12-28 08:11:14 +00:00
2a538388fc
Adding missing resource file.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@607074 13f79535-47bb-0310-9956-ffa450edef68
2007-12-27 14:36:27 +00:00
2db7df72d6
Reduce contention around Queues
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@607038 13f79535-47bb-0310-9956-ffa450edef68
2007-12-27 11:06:50 +00:00
ea0cd012b1
fix for http://issues.apache.org/activemq/browse/AMQ-1157
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@607037 13f79535-47bb-0310-9956-ffa450edef68
2007-12-27 11:03:41 +00:00
069a5676f1
multiple paths try to re-start the broker with vm:// trapnsport -
...
changed URI to tcp://
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@606682 13f79535-47bb-0310-9956-ffa450edef68
2007-12-24 09:42:25 +00:00
8179df80f1
don't wait for ever for worker to stop
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@606260 13f79535-47bb-0310-9956-ffa450edef68
2007-12-21 17:56:03 +00:00
34378e8ec1
Only wait 1 second for connections to stop. When killing a stale
...
connection - if stop doesn't complete - it hangs the broker.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@606241 13f79535-47bb-0310-9956-ffa450edef68
2007-12-21 16:45:21 +00:00
9f94b6c509
Fix for https://issues.apache.org/activemq/browse/AMQ-1528
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@606022 13f79535-47bb-0310-9956-ffa450edef68
2007-12-20 20:42:43 +00:00
01215e240d
Updated version number now that 5.0.0 is out the door
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@605972 13f79535-47bb-0310-9956-ffa450edef68
2007-12-20 16:23:16 +00:00
471ea33051
Applied Dejan's patch on AMQ-1272 with some small tweaks.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@605944 13f79535-47bb-0310-9956-ffa450edef68
2007-12-20 14:37:41 +00:00
Hiram R. Chirino
James Strachan
Guillaume Nodet
Robert Davies
Adrian T. Co