Commit Graph

3650 Commits

Author SHA1 Message Date
Bernd Gutjahr 5a31e70353 ARTEMIS-1078 Improving ActiveMQThreadPoolExecutor
This is now considering only threads waiting for the queue to get new tasks as idle.

The thread pool maintained a counter of active threads, but that counter was increased
too late in the beforeExecute method. Submitting a task created a new thread.
If now a second task was submitter before the new thread had started to execute it's task,
the second task was queued without creating a 2nd thread. So the second task was only
executed after the first task had been completed - even if the thread pool's
maximum number of thread had not been reached.

This fix now maintains the delta between the number those threads that are currently waiting
in the queue's poll or take methods as idle threads, and the number of queued tasks.
It creates new threads unless there are enough idle threads to pick up all queued tasks.

This closes #1144
2017-03-31 19:01:54 -04:00
Clebert Suconic 05ca44d901 This closes #1166 2017-03-31 17:52:14 -04:00
Martyn Taylor 8760b3ddfd ARTEMIS-1087 Make InVM buffer pooling configurable 2017-03-31 18:56:07 +01:00
Clebert Suconic 848090fad2 This closes #1165 2017-03-31 10:56:15 -04:00
Martyn Taylor 120b8aa7ad ARTEMIS-1085 Perform storelineup on appendRecord 2017-03-31 15:50:02 +01:00
Martyn Taylor 33fff52651 This closes #1164 2017-03-31 15:24:50 +01:00
Clebert Suconic 1ca1b4baf9 ARTEMIS-1042 Commenting out test 2017-03-30 22:23:20 -04:00
Clebert Suconic d779afe874 NO-JIRA: Fixing test hunging on OpenWire 2017-03-30 21:56:46 -04:00
Clebert Suconic 690b8d24d7 This closes #1160 2017-03-30 21:20:37 -04:00
Justin Bertram 6cf9a98c49 ARTEMIS-1065 fix broken test 2017-03-30 21:20:37 -04:00
Clebert Suconic 5f79610fd3 This closes #1161 2017-03-30 21:20:14 -04:00
Justin Bertram 81b5563a52 ARTEMIS-992 NPE on startup 2017-03-30 21:20:14 -04:00
Clebert Suconic fd0513e4f5 This closes #1162 2017-03-30 21:19:44 -04:00
Timothy Bish 62cb9b22de ARTEMIS-1086 Proper conversion of SimpleString to String
When adding boolean value keyed by SimpleString the key needs to be
converted to a String type to be valid AMQP.
2017-03-30 21:19:43 -04:00
Clebert Suconic 44a946c8e3 This closes #1163 2017-03-30 21:18:50 -04:00
Justin Bertram 5a93aa9b76 ARTEMIS-1083 fix errant WARN message 2017-03-30 18:34:21 -05:00
Clebert Suconic 86779195fa NO-JIRA: Removing duplciate code 2017-03-30 11:15:09 -04:00
Martyn Taylor 6cacdd9e32 This closes #1130 2017-03-30 10:15:51 +01:00
Otavio Rodolfo Piske 20c67baa5a ARTEMIS-607 Added an example/verification for calling an interceptor when using MQTT protocol 2017-03-30 10:15:50 +01:00
Martyn Taylor 07597ba959 This closes #1158 2017-03-30 09:54:26 +01:00
Clebert Suconic 9bef242b74 ARTEMIS-1056 Adjusting Acceptor values
I have been doing tests with quiver at large message sizes
the tests would work really slowly without these fixes
2017-03-30 09:54:26 +01:00
Clebert Suconic 5ca514a2a8 NO-JIRA: one test script to ignore checkstyle 2017-03-30 09:54:26 +01:00
Martyn Taylor 266b1f31bf This closes #1159 2017-03-30 09:52:20 +01:00
Bennet Schulz 6790686059 Update examples.md 2017-03-30 10:36:42 +02:00
Clebert Suconic aafb2087fa Revert "NO-JIRA upgrade maven-surefire-plugin to 2.19.1"
This reverts commit 63054a0706.
2017-03-29 21:43:06 -04:00
Clebert Suconic 2a63b3ef8f This closes #1157 2017-03-29 16:05:47 -04:00
Justin Bertram 98aa1891a5 ARTEMIS-1076 fix broken doc links 2017-03-29 16:05:47 -04:00
Clebert Suconic 0e17666ded This closes #1156 2017-03-29 16:00:26 -04:00
Justin Bertram 0f468fe07c ARTEMIS-1079 don't ask for role, address-full-policy, or global-max-size on CLI 2017-03-29 16:00:26 -04:00
Justin Bertram 6ddcda55db NO-JIRA server control test update 2017-03-29 16:00:26 -04:00
Justin Bertram 30ec72bfcb This closes #1155 2017-03-29 11:49:16 -05:00
Martyn Taylor 42bf845edb ARTEMIS-1084 Throw RunTime on bad Oracle table size 2017-03-29 14:59:12 +01:00
Clebert Suconic 3271cd971c This closes #1145 2017-03-29 09:46:03 -04:00
Justin Bertram 6e56d2b336 ARTEMIS-1079 CLI option for paging/blocking 2017-03-29 09:46:03 -04:00
Clebert Suconic 057b3b856e This closes #1151 2017-03-29 09:27:27 -04:00
Jiri Danek 63054a0706 NO-JIRA upgrade maven-surefire-plugin to 2.19.1 2017-03-29 09:27:27 -04:00
Clebert Suconic 3597605a60 This closes #1134 2017-03-29 09:19:52 -04:00
Howard Gao 82c720bdfb ARTEMIS-1071 Invalid Type exception handling improvements
If broker fails to decode any packets from buffer, it should
treat it as a critical bug and disconnect immediately.
Currently broker only logs an error message.
2017-03-29 09:19:52 -04:00
Clebert Suconic 9df74f347b This closes #1149 2017-03-29 09:18:16 -04:00
Justin Bertram ce3adf6fa8 ARTEMIS-1065 get queue names by routing type 2017-03-29 09:18:16 -04:00
Clebert Suconic 9b11914c21 This closes #1153 2017-03-29 09:09:55 -04:00
Martyn Taylor 955af96fe9 ARTEMIS-1082 Catch Create Queue race in OpenWire 2017-03-29 13:49:01 +01:00
Justin Bertram 056a88dfca This closes #1147 2017-03-28 20:32:28 -05:00
Clebert Suconic 1f4473e8d7 ARTEMIS-1081 Implementing AMQP UndeliverableHere 2017-03-28 20:32:28 -05:00
Clebert Suconic 746220e11e ARTEMIS-1080 Implementing AMQP::reject 2017-03-28 20:32:28 -05:00
Clebert Suconic 13a272b37b ARTEMIS-1056 fixing tests
When I added flow control, some tests that were using reflection started to fail.
Also as a precaution I'm using <= on the flow control low credit check
2017-03-28 20:32:28 -05:00
Clebert Suconic facc9dbc94 This closes #1146 2017-03-28 18:33:16 -04:00
Justin Bertram b7e11f92b6 ARTEMIS-1064 AddressControl routingType fix 2017-03-28 15:30:52 -05:00
Justin Bertram e3a23cda73 This closes #1139 2017-03-28 15:10:33 -05:00
Armand Roelens 3ceb332866 ARTEMIS-1074 Acceptors/Connectors now start up when configured to use SSL and a password codec 2017-03-28 15:10:33 -05:00