a5a6a2a5d1
Added more synchronization
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@603348 13f79535-47bb-0310-9956-ffa450edef68
2007-12-11 20:19:46 +00:00
27c87d20f3
Applied patch in AMQ-1515 Thx David.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@602565 13f79535-47bb-0310-9956-ffa450edef68
2007-12-08 21:45:55 +00:00
6f0dcac677
Added a little more debug logging to the InactivityMonitor because I suspect that
...
the schedular might not be triggering the read and write checks at the right time.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@602553 13f79535-47bb-0310-9956-ffa450edef68
2007-12-08 21:31:14 +00:00
2984963912
If you have a multi-threaded client which share 1 connection to the broker it is possible you may have seen errors like:
...
2007-12-05 14:14:52,606 [VMTransport] ERROR - org.apache.activemq.broker.TransportConnection.Service - Async error occurred: java.lang.IllegalStateException: Cannot lookup a connection that had not been registered: ID:bubba-38184-1196882086290-2:1
java.lang.IllegalStateException: Cannot lookup a connection that had not been registered: ID:bubba-38184-1196882086290-2:1
at org.apache.activemq.broker.SingleTransportConnectionStateRegister.lookupConnectionState(SingleTransportConnectionStateRegister.java:113)
at org.apache.activemq.broker.TransportConnection.lookupConnectionState(TransportConnection.java:1313)
at org.apache.activemq.broker.TransportConnection.processRemoveConsumer(TransportConnection.java:538)
at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:64)
at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:281)
at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:178)
at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:100)
at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
at org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:202)
at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:118)
at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:42)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:885)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:907)
at java.lang.Thread.run(Thread.java:619)
root cause is that the client side has multiple threads calling close() on consumer/session and the connection objects. If the timing of those concurrent calls was just right, it is possible for the client to send the connection close message followed by a session or consumer close message which is invalid and would result in IllegalStateException reported by the broker.
- Simplified the ActiveMQConnection and TransportConnection shutdown so that this does does not happen.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@602529 13f79535-47bb-0310-9956-ffa450edef68
2007-12-08 18:56:11 +00:00
8c541377bd
Fix for excessive memory usage for durable consumers -
...
see https://issues.apache.org/activemq/browse/AMQ-1490
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@602440 13f79535-47bb-0310-9956-ffa450edef68
2007-12-08 10:03:26 +00:00
5628b3e4ba
Added synchronization to prevent concurrent modification
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@602260 13f79535-47bb-0310-9956-ffa450edef68
2007-12-07 22:47:10 +00:00
ddff5e5c16
Fix for https://issues.apache.org/activemq/browse/AMQ-1512
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@601011 13f79535-47bb-0310-9956-ffa450edef68
2007-12-04 17:21:54 +00:00
f472000467
Changes to address memory usage for large transactions for:
...
https://issues.apache.org/activemq/browse/AMQ-1490
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@600891 13f79535-47bb-0310-9956-ffa450edef68
2007-12-04 11:27:58 +00:00
2913fb8ada
Using wrong class to initialize the log
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@600671 13f79535-47bb-0310-9956-ffa450edef68
2007-12-03 20:33:34 +00:00
1ba3532365
handle the inactivity actions in an async thread so that the schedular thread does not get blocked.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@599993 13f79535-47bb-0310-9956-ffa450edef68
2007-11-30 22:39:26 +00:00
d83969f6a8
Allow a blocked thread to unwind if it's connection is getting terminated.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@599835 13f79535-47bb-0310-9956-ffa450edef68
2007-11-30 14:42:53 +00:00
d59fd98daa
updated so that we can use delete the db on start-up
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@599470 13f79535-47bb-0310-9956-ffa450edef68
2007-11-29 15:03:29 +00:00
9dd11cb71f
Fix for https://issues.apache.org/activemq/browse/AMQ-1490
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@599129 13f79535-47bb-0310-9956-ffa450edef68
2007-11-28 20:19:27 +00:00
987ad27449
removed System.out logging
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@599122 13f79535-47bb-0310-9956-ffa450edef68
2007-11-28 20:02:16 +00:00
ca4c58b564
Camel should be optional
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@598942 13f79535-47bb-0310-9956-ffa450edef68
2007-11-28 10:26:00 +00:00
bbe26eddc2
Fix for https://issues.apache.org/activemq/browse/AMQ-1502
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@598330 13f79535-47bb-0310-9956-ffa450edef68
2007-11-26 16:15:12 +00:00
fd2c95e9bc
Fix for https://issues.apache.org/activemq/browse/AMQ-1491
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@597582 13f79535-47bb-0310-9956-ffa450edef68
2007-11-23 07:51:02 +00:00
ba8b248788
Fix for https://issues.apache.org/activemq/browse/AMQ-1500
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@597581 13f79535-47bb-0310-9956-ffa450edef68
2007-11-23 07:40:51 +00:00
1aab7d3597
Adding missing headers
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@594172 13f79535-47bb-0310-9956-ffa450edef68
2007-11-12 15:11:44 +00:00
5e3aa21375
Scale back this test a little bit. It was storing 1.6 GIG is message contents. Which took a long time to store and also
...
will fail on machines that don't have the much free space. If we want to run BIG tests like that they should go into a
system testing module. Scaled it back so that only 160 Megs of data are generated by the test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@593585 13f79535-47bb-0310-9956-ffa450edef68
2007-11-09 16:30:07 +00:00
2edad74ca9
The VMTransport now let's it's peer know when it's being stopped so that the Peer can give its' transport listener a peer disconnected exception. Otherwise a VM transport client could disconnect without the server side knowing it disconnected and the server side would not terminate it's side of the connection. This could be seen as a memory leak on when the static network config is setup and one of the static brokers is not up.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@593204 13f79535-47bb-0310-9956-ffa450edef68
2007-11-08 15:39:51 +00:00
04a637916e
Added better temp destination support. We now properly create temp destinations that the client can subscribe to
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@592531 13f79535-47bb-0310-9956-ffa450edef68
2007-11-06 19:44:58 +00:00
ada47fbc50
- memory leak fix: TransportConnection would leak memory if an error occured while start()ing the connection. Most visible when you create a network connector pointing at a remote broker that was down since this loops through creating TransportConnectors every few seconds.
...
- Deadlock fix VMTransport could dead lock if during start() an error occured and stop was recusively called.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@592114 13f79535-47bb-0310-9956-ffa450edef68
2007-11-05 18:47:16 +00:00
62890b3fbb
- Reduced verbosity of logging in TransportConnector so that exceptions should only be in DEBUG messages.
...
- Added more logging to SimpleDiscoveryAgent so that we can see what it's doing in regards to reconnect handling and
enabled exponential backoff by default.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@592090 13f79535-47bb-0310-9956-ffa450edef68
2007-11-05 17:07:38 +00:00
770642a8a1
Further enhancement to https://issues.apache.org/activemq/browse/AMQ-1246
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@591442 13f79535-47bb-0310-9956-ffa450edef68
2007-11-02 20:09:57 +00:00
229ca6afd7
Fix for https://issues.apache.org/activemq/browse/AMQ-1246
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@591160 13f79535-47bb-0310-9956-ffa450edef68
2007-11-01 22:42:33 +00:00
b2544046c5
Fix for https://issues.apache.org/activemq/browse/AMQ-1486
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@591148 13f79535-47bb-0310-9956-ffa450edef68
2007-11-01 21:49:13 +00:00
9a491bbc76
Fix for https://issues.apache.org/activemq/browse/AMQ-1485
...
Fix npe for above
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@591145 13f79535-47bb-0310-9956-ffa450edef68
2007-11-01 21:23:44 +00:00
30fe17834c
Fix for https://issues.apache.org/activemq/browse/AMQ-1485
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@591142 13f79535-47bb-0310-9956-ffa450edef68
2007-11-01 20:26:50 +00:00
28296e689c
Fix for https://issues.apache.org/activemq/browse/AMQ-1485
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@591113 13f79535-47bb-0310-9956-ffa450edef68
2007-11-01 18:37:28 +00:00
26387143e8
updated properties
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@590623 13f79535-47bb-0310-9956-ffa450edef68
2007-10-31 11:09:03 +00:00
b2969d05a9
tidy up comments
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@589330 13f79535-47bb-0310-9956-ffa450edef68
2007-10-28 10:54:35 +00:00
c8761c7e0f
Fix for https://issues.apache.org/activemq/browse/AMQ-1479
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@589314 13f79535-47bb-0310-9956-ffa450edef68
2007-10-28 09:39:12 +00:00
9352c9fcdc
Test case for: https://issues.apache.org/activemq/browse/AMQ-1479
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@589048 13f79535-47bb-0310-9956-ffa450edef68
2007-10-27 04:14:35 +00:00
582f3401fa
The caching of the prepared statement for updating the last ack was wrong.
...
Reported at http://www.nabble.com/Is-this-a-bug-in-DefaultJDBCAdapter.java--tf1890445s2354.html#a5170127
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@588767 13f79535-47bb-0310-9956-ffa450edef68
2007-10-26 20:20:25 +00:00
0e7162509d
fix bad cast
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@588731 13f79535-47bb-0310-9956-ffa450edef68
2007-10-26 18:16:17 +00:00
3a4a360d3f
Avoid deleting datafiles that are in-use.. timing issue was making this possible
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@588725 13f79535-47bb-0310-9956-ffa450edef68
2007-10-26 18:00:14 +00:00
6084b6061b
MarshallingSupport.unmarshalPrimitive is throwing "Unknown primitive type: 0" when nested map contains a null
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@588718 13f79535-47bb-0310-9956-ffa450edef68
2007-10-26 17:32:19 +00:00
ceec57aa0d
Removed synchronizations on all the processXXX() methods to avoid getting into situations where deadlocks occur.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@588260 13f79535-47bb-0310-9956-ffa450edef68
2007-10-25 15:43:34 +00:00
43b808d158
Cleanup the leaky abstraction of the DiscoveryAgent. see:
...
https://issues.apache.org/activemq/browse/AMQ-1477
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@587927 13f79535-47bb-0310-9956-ffa450edef68
2007-10-24 16:53:46 +00:00
1c1ed4d953
allow any setter to be called
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@587618 13f79535-47bb-0310-9956-ffa450edef68
2007-10-23 19:11:34 +00:00
230a57b155
https://issues.apache.org/activemq/browse/AMQ-1268
...
Test case regression was fixed.. enabling test again
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@587509 13f79535-47bb-0310-9956-ffa450edef68
2007-10-23 13:58:59 +00:00
82d1c91b3f
Fix for https://issues.apache.org/activemq/browse/AMQ-796
...
- The threads associated with the session are now setup to be non-daemon so that if you
setup a MessageListener and let the main thread exit, your program will not terminate
if there are no active transport threads which is the case when the failover transport
is in the middle of reconnecting to a broker.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@587504 13f79535-47bb-0310-9956-ffa450edef68
2007-10-23 13:36:15 +00:00
569e5ca78c
synchronize doMessageSend() to ensure messages are stored and dispatched
...
in the right order
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@587396 13f79535-47bb-0310-9956-ffa450edef68
2007-10-23 05:38:36 +00:00
d3d58fe41d
Test case and Fix for https://issues.apache.org/activemq/browse/AMQ-777
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@587216 13f79535-47bb-0310-9956-ffa450edef68
2007-10-22 19:37:01 +00:00
6bb7fba3c5
Avoid deadlock described at: https://issues.apache.org/activemq/browse/AMQ-1468
...
Synchronization not really required once the transport errors out..
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@587198 13f79535-47bb-0310-9956-ffa450edef68
2007-10-22 19:01:16 +00:00
328229b42b
Fixed the test cases in FanoutTransportBrokerTest also added a fanOutQueues property to enabled fanning out on
...
Queues. See issue: https://issues.apache.org/activemq/browse/AMQ-1464
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@587188 13f79535-47bb-0310-9956-ffa450edef68
2007-10-22 18:39:57 +00:00
565588c13d
check for message order
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@587091 13f79535-47bb-0310-9956-ffa450edef68
2007-10-22 13:45:12 +00:00
13fc99769f
remove System messages
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@587051 13f79535-47bb-0310-9956-ffa450edef68
2007-10-22 10:10:40 +00:00
36486fe5b4
Fix for https://issues.apache.org/activemq/browse/AMQ-1449
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@587033 13f79535-47bb-0310-9956-ffa450edef68
2007-10-22 08:38:22 +00:00
99966f58e7
fix for https://issues.apache.org/activemq/browse/AMQ-1467
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@586581 13f79535-47bb-0310-9956-ffa450edef68
2007-10-19 19:07:19 +00:00
1ee00173d6
Fix for https://issues.apache.org/activemq/browse/AMQ-1452 and
...
https://issues.apache.org/activemq/browse/AMQ-729
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@586580 13f79535-47bb-0310-9956-ffa450edef68
2007-10-19 19:01:10 +00:00
4f8a1e6d6b
Reduced the amount of time that the synchronizations are held to avoid deadlocks
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@586460 13f79535-47bb-0310-9956-ffa450edef68
2007-10-19 13:56:37 +00:00
1ea24bff37
applied patch for AMQ-1440 and AMQ-1439
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@586251 13f79535-47bb-0310-9956-ffa450edef68
2007-10-19 03:54:45 +00:00
fe8bc3317c
The VM transport could deadlock between the iterate() method and the oneway() method when the async message buffer used by the transport fills up. Change the synchronization logic to make use the a Valve to avoid needing to lock mutexes for so long.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@586185 13f79535-47bb-0310-9956-ffa450edef68
2007-10-19 00:00:45 +00:00
49325b60cd
Check for duplicates
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@586025 13f79535-47bb-0310-9956-ffa450edef68
2007-10-18 16:22:07 +00:00
2cb2119814
fix for https://issues.apache.org/activemq/browse/AMQ-1467
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@585967 13f79535-47bb-0310-9956-ffa450edef68
2007-10-18 14:08:44 +00:00
393a861e89
updated for https://issues.apache.org/activemq/browse/AMQ-1251
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@585853 13f79535-47bb-0310-9956-ffa450edef68
2007-10-18 04:10:37 +00:00
64bec6b133
Test case for https://issues.apache.org/activemq/browse/AMQ-1202
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@585843 13f79535-47bb-0310-9956-ffa450edef68
2007-10-18 03:53:45 +00:00
89f793efb0
updates for https://issues.apache.org/activemq/browse/AMQ-1311
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@585413 13f79535-47bb-0310-9956-ffa450edef68
2007-10-17 08:47:38 +00:00
0da68b4cb3
Make producerFlowControl configurable per Destination
...
default=true
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@585375 13f79535-47bb-0310-9956-ffa450edef68
2007-10-17 05:05:50 +00:00
4c137cd2bc
don't wait for ever to stop
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@585215 13f79535-47bb-0310-9956-ffa450edef68
2007-10-16 18:25:17 +00:00
9da7e31a33
Updated the flow control logic for the Topic case to match what we are using for the Queue case
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@585187 13f79535-47bb-0310-9956-ffa450edef68
2007-10-16 16:22:08 +00:00
8931aac98e
no need to call force() on commit as the reference store gets rebuilt on failure
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@585109 13f79535-47bb-0310-9956-ffa450edef68
2007-10-16 10:53:51 +00:00
cb234b32d3
change number of messages -was hanging waiting space
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@585047 13f79535-47bb-0310-9956-ffa450edef68
2007-10-16 05:46:18 +00:00
fe9bd4f594
fix for npe
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@584929 13f79535-47bb-0310-9956-ffa450edef68
2007-10-15 21:36:37 +00:00
1722001748
fix data logs not being correctly removed
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@584863 13f79535-47bb-0310-9956-ffa450edef68
2007-10-15 19:31:22 +00:00
487e694152
Fix for a failover transport deadlock that could occur if the transport is stopped at the same time a failure occurs.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@584800 13f79535-47bb-0310-9956-ffa450edef68
2007-10-15 14:50:09 +00:00
67e5952dd1
Applied patch associated with:
...
https://issues.apache.org/activemq/browse/AMQ-358
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@584047 13f79535-47bb-0310-9956-ffa450edef68
2007-10-12 05:27:03 +00:00
cdf35dfe12
Expose properties for configuring the asyncDataManager
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@583949 13f79535-47bb-0310-9956-ffa450edef68
2007-10-11 20:58:25 +00:00
a9119eca19
Fix for NPE in duplex network connection
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@583595 13f79535-47bb-0310-9956-ffa450edef68
2007-10-10 19:53:07 +00:00
5ac6f3a890
removed System.out
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@583571 13f79535-47bb-0310-9956-ffa450edef68
2007-10-10 18:28:53 +00:00
b2f7ba79db
add some more useful methods
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@583237 13f79535-47bb-0310-9956-ffa450edef68
2007-10-09 17:45:54 +00:00
5dcf9cf6b9
added a plugin to support invocation of MessageListener classes as a bean in Camel; for more information see: http://cwiki.apache.org/CAMEL/activemq.html
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@583185 13f79535-47bb-0310-9956-ffa450edef68
2007-10-09 14:44:50 +00:00
810375af5f
added a plugin to support invocation of MessageListener classes as a bean in Camel; for more information see: http://cwiki.apache.org/CAMEL/activemq.html
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@583184 13f79535-47bb-0310-9956-ffa450edef68
2007-10-09 14:44:20 +00:00
48e8c053fc
updated javadoc link
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@583163 13f79535-47bb-0310-9956-ffa450edef68
2007-10-09 13:35:57 +00:00
27a6c0a301
updated the javadoc to be more clear about the camel support
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@583114 13f79535-47bb-0310-9956-ffa450edef68
2007-10-09 11:28:38 +00:00
b9d0972596
quick fix for npe
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@582910 13f79535-47bb-0310-9956-ffa450edef68
2007-10-08 17:47:47 +00:00
22fbb80daf
make persistentIndex true by default
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@582839 13f79535-47bb-0310-9956-ffa450edef68
2007-10-08 15:10:19 +00:00
edb50cb4de
set options on the discovery agent correctly from the URI
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@582810 13f79535-47bb-0310-9956-ffa450edef68
2007-10-08 12:54:35 +00:00
d1eb18af70
Add properties to the AMQPersistenceAdaptorFactory
...
to set syncOnWrite(default=false) and persistentIndex(default=true) properties
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@582801 13f79535-47bb-0310-9956-ffa450edef68
2007-10-08 12:39:48 +00:00
1d487896b4
refresh entry for prev as well as next
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@582575 13f79535-47bb-0310-9956-ffa450edef68
2007-10-07 05:10:28 +00:00
84a116d2c7
Fix for https://issues.apache.org/activemq/browse/AMQ-1445
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@582574 13f79535-47bb-0310-9956-ffa450edef68
2007-10-07 04:42:24 +00:00
e2ef8b8165
patch http://issues.apache.org/activemq/browse/AMQ-1444
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@582086 13f79535-47bb-0310-9956-ffa450edef68
2007-10-05 06:02:46 +00:00
f3d633c2a9
Test case for sending single messages per connection - was blowing memory - now fixed
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581885 13f79535-47bb-0310-9956-ffa450edef68
2007-10-04 13:01:25 +00:00
805a0cc506
the MESSAGE_SIZE_OVERHEAD was too low - increased it to a more realistic size
...
Please note - this is related to the overhead in broker memory - not
the on-the-wire size - which is small
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581882 13f79535-47bb-0310-9956-ffa450edef68
2007-10-04 12:49:37 +00:00
5f8c101973
By default, use no subscription recovery policy for temporary or advisory topics
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581881 13f79535-47bb-0310-9956-ffa450edef68
2007-10-04 12:48:02 +00:00
fc69b29343
handle errors from recovery check gracefully
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581792 13f79535-47bb-0310-9956-ffa450edef68
2007-10-04 08:00:39 +00:00
3c1a8474f9
FilePendingMessageCursor was being added twice to the MemoryUsage
...
which resulted in a memory leak
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581784 13f79535-47bb-0310-9956-ffa450edef68
2007-10-04 06:18:49 +00:00
c256dcf9e8
Fix for https://issues.apache.org/activemq/browse/AMQ-1038
...
We now send REDELIVERY acks to the broker when a message is redelivered. This allows the broker to update the message with the number of times redelivery has occured so that if the message is delivered to another consumer it can DQL the message when max redeliveries have occured across consumers.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581747 13f79535-47bb-0310-9956-ffa450edef68
2007-10-03 23:32:29 +00:00
1401e69956
after canceling a TimerTask - purge from the Timer list - fix memory leak
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581736 13f79535-47bb-0310-9956-ffa450edef68
2007-10-03 21:55:40 +00:00
7b1fd3484e
Fix for http://issues.apache.org/activemq/browse/AMQ-1250
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581715 13f79535-47bb-0310-9956-ffa450edef68
2007-10-03 20:24:27 +00:00
08841bbde3
fix memory leak in ActiveMQConnection - with asyncConnectionThread not being shutdown on a close
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581683 13f79535-47bb-0310-9956-ffa450edef68
2007-10-03 18:50:03 +00:00
5bd3bf6e24
Ignore NULL references when checking isEmpty
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581568 13f79535-47bb-0310-9956-ffa450edef68
2007-10-03 11:24:38 +00:00
69a5e00843
be conservative allocating objects up-front
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581321 13f79535-47bb-0310-9956-ffa450edef68
2007-10-02 17:58:11 +00:00
595d95b3da
Have the TransactionContext per connection
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581242 13f79535-47bb-0310-9956-ffa450edef68
2007-10-02 13:58:22 +00:00
6aa4bcad5b
some unnecessary memory allocations removed
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581167 13f79535-47bb-0310-9956-ffa450edef68
2007-10-02 09:25:39 +00:00
53c4e125f6
Fix for AMQ-1095:
...
- Added contributed test cases
- We now filter out non-matching messages as they are loaded into the TopicStorePrefetch
- Changed the TopicStorePrefetch and StoreDurableSubscriberCursor so that they don't depend
on the pending message counter since some stores cannot give an accurate count for it.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581053 13f79535-47bb-0310-9956-ffa450edef68
2007-10-01 20:02:18 +00:00
7bd8fb6754
Fix failing test cases.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@580475 13f79535-47bb-0310-9956-ffa450edef68
2007-09-28 20:16:08 +00:00
3d024d6b4f
Make amq 5.x compatible again with 4.x clients
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@580382 13f79535-47bb-0310-9956-ffa450edef68
2007-09-28 15:09:33 +00:00
Robert Davies
Hiram R. Chirino
Guillaume Nodet
Jonas B. Lim
James Strachan