Commit Graph

2167 Commits

Author SHA1 Message Date
Clebert Suconic 31055b6f0a Removing Marshalled property from Openwire 2016-04-20 23:00:57 -04:00
Clebert Suconic 1f586eaecb This closes #469 2016-04-20 12:33:02 -04:00
Howard Gao 3012447404 ARTEMIS-488 Fix OpenWire Test (Temp Queue removal and others)
Temp Queue not deleted when connection is closed.
Enable Stomp in openwire test because some test uses it.
Remove unused code in opwnwire
Wrong XA error code returned when xid is missing
(ActiveMQXAConnectionFactory.testRollbackXaErrorCode)
regression in ActiveMQSslConnectionFactoryTest (SSL related)
2016-04-20 12:33:01 -04:00
Martyn Taylor 0a719e08ed This closes #468 2016-04-20 15:29:25 +01:00
Bernd Gutjahr ec4cbf7b34 abstracted global client thread pools from ThreadPoolExecutor as implementation
Changed the ActiveMQClient interface to expose global thread pools as
ExecutorService and ScheduledExecutorService interface. This is necessary
to allow injecting thread pool implementations that are not based on
ThreadPoolExecutor or ScheduledThreadPoolExecutor.
2016-04-20 15:29:25 +01:00
Bernd Gutjahr 1b5396c033 Protected ActiveMQClient API against misuse.
1. Changed public fields in ActiveMQClient to private and added getters.

Exposing fields for thread pool sized allow to modify them in undesired ways.
I made these fields private and added corresponding getter methods.
In addition, I renamed the field 'globalThreadMaxPoolSize'
to 'globalThreadPoolSize' to be more consistent with the
'globalScheduledThreadPoolSize' field name.
I also adapted some tests to always call clearThreadPools after
the thread pool size configuration has been changed.

2. Protect against injecting null as thread pools

ActiveMQClient.injectPools allowed null as injected thread pools.
The effect was that internal threads pools were created,
but not shutdown correctly.
2016-04-20 15:29:25 +01:00
Bernd Gutjahr 2360fb4c9f ARTEMIS-485 Allow configuring an unbounded cached global client thread pool
Adapted code to handle -1 correctly to configure an unbounded thread pool.
In addition, I removed the capability to reconfigure the max pool size
of existing thread pools, because the global thread pool can either be
an unbounded cached pool, or a bounded fixed size pool.
These 2 kinds of pool also differ in the used blocking queue,
therefore cannot be converted into each other.
2016-04-20 15:29:25 +01:00
Martyn Taylor 725379920e This closes #477 2016-04-20 15:12:19 +01:00
Clebert Suconic b89faae458 ARTEMIS-490 Fixing new largeMessage copy 2016-04-20 10:08:29 -04:00
Martyn Taylor de0ac57aa4 This closes #474 2016-04-20 14:14:45 +01:00
Paul Gallagher a3ffa9aa34 Update to use one version of slf4j defined at the top level pom 2016-04-20 14:14:45 +01:00
Martyn Taylor cb8d3b78e6 This closes #475 2016-04-20 14:05:17 +01:00
Clebert Suconic bd3d0492fd ARTEMIS-482 testsuite fixes:
The new Executor operationr needs to be synchronized as a few tests are failing because of this
another fix on the test base class
2016-04-20 14:05:17 +01:00
Martyn Taylor d142c2b52c This closes #476 2016-04-20 13:55:23 +01:00
Andy Taylor f47bb6cc4b ARTEMIS-494 - implement filters correctly
took this code from ActiveMQ which was over hawled in this area

https://issues.apache.org/jira/browse/ARTEMIS-494
2016-04-20 12:14:04 +01:00
Clebert Suconic 17fe4707f4 This closes #473 2016-04-19 23:00:32 -04:00
jbertram 9d7a49b388 ARTEMIS-417 more broker-level JMX attrs 2016-04-19 23:00:32 -04:00
Clebert Suconic 03b2650990 ARTEMIS-482 fixing testsuite. Stopping Executor at the proper place
You have to stop the InVMExecutor after servers were stopped otherwise tests may hang
2016-04-19 17:35:29 -04:00
Andy Taylor 31e4e7d328 This closes #471 ARTEMIS-471 Fixing Divert on LargeMessages and Replication 2016-04-19 15:00:09 +01:00
Clebert Suconic e81fa5c359 ARTEMIS-490 Fixing LargeMessage copy through replication
this will fix cases like DLQ and Diverts
2016-04-19 15:00:09 +01:00
Clebert Suconic dcf651376f ARTEMIS-490 Adding test with LargeMessage.copy through replication
I'm keeping a commit just for the test so it would be easier to replicate the bug.
2016-04-19 15:00:09 +01:00
Clebert Suconic b4a6427d65 This closes #472 2016-04-19 09:49:59 -04:00
Andy Taylor 97f3fb241c ARTEMIS-493 - NullPointerException when trying a null connection remote properties are passed by client
adde a check and fixed a couple of other potential NPE's

https://issues.apache.org/jira/browse/ARTEMIS-493
2016-04-19 11:21:33 +01:00
Clebert Suconic bfa3b27cf7 This closes #459 2016-04-18 18:00:19 -04:00
Ingo Weiss e378e4f88f ARTEMIS-480 BridgeReconnectTest.testDeliveringCountOnBridgeConnectionFailure fails due to racing condition 2016-04-18 17:59:44 -04:00
Clebert Suconic 44c02be829 This closes #466 2016-04-18 17:52:22 -04:00
jbertram 2feda1d8f0 ARTEMIS-407 remove StompConnect references 2016-04-18 17:52:22 -04:00
Clebert Suconic 85f2af3812 This closes #467 2016-04-18 17:51:46 -04:00
jbertram 30907ffd8c ARTEMIS-400 allow SSL store reload 2016-04-18 17:51:46 -04:00
Clebert Suconic 1363d6eee3 This closes #470 2016-04-18 17:50:53 -04:00
jbertram afd1aeaf88 ARTEMIS-489 update examples doc 2016-04-18 17:50:53 -04:00
Clebert Suconic b4d6ae0f2c This closes #464 2016-04-18 17:50:09 -04:00
jbertram 5591bcabcc ARTEMIS-405 JMX attributes doc 2016-04-18 17:50:09 -04:00
Clebert Suconic 287ee86b3f ARTEMIS-465 - Fixing trace 2016-04-15 10:37:28 -04:00
Clebert Suconic b7118df7d0 ARTEMIS-482 Cleanup new ThreadPool on the testsuite to avoid leak report 2016-04-14 23:14:22 -04:00
Clebert Suconic ec73961f72 ARTEMIS-474 another fix on JChannelWrapper 2016-04-14 21:57:17 -04:00
Clebert Suconic a3ae2c4ad2 This closes #463 ARTEMIS-474 and ARTEMIS-484 2016-04-14 21:14:17 -04:00
Clebert Suconic 630db2d69c ARTEMIS-474 Clustering fails on certain topologies
Communication between nodes will fail under certain topologies
JGroups has something called JForkChannel that could be used on container systems.
And be injected into Artemis.
For some reason that channel cannot be reused for more than one channel per VM.
And it cannot ever be closed.

I am keeping the trace logs I used to debug this issue in case anything similar to this happens again.
2016-04-14 18:55:01 -04:00
Clebert Suconic d6c7e30594 ARTEMIS-484 Large Message Loss on Initial replication
https://issues.apache.org/jira/browse/ARTEMIS-484

The File copy after the initial synchronization on large messages was broken.
On this commit we fix how the buffer is cleaned up before each read since
a previously unfinished body read would make the buffer dirty.

I'm keeping also lots of Traces I have added to debug this issue, so they will
be useful if anything like this happens again.
2016-04-14 18:55:01 -04:00
Clebert Suconic 3ecd8b7c44 ARTEMIS-474 Avoiding one lock around the readyListener call tree and fixing ReplicationManager / NettyConnection deadlock 2016-04-14 18:55:01 -04:00
Clebert Suconic 2e894554ca ARTEMIS-474 fixing page.close() deadlock with replica 2016-04-14 18:55:01 -04:00
Clebert Suconic 86a81d315d ARTEMIS-465 Changing Byteman race on test 2016-04-14 18:55:01 -04:00
Clebert Suconic 914d93f636 This closes #462 2016-04-14 18:19:00 -04:00
Martyn Taylor fc8a1eff43 ARTEMIS-482 Assign dedicated ThreadPool for InVMTransport 2016-04-14 15:49:07 +01:00
Clebert Suconic 5678d1ad2b This closes #461 2016-04-13 21:29:59 -04:00
jbertram 7864577fbc ARTEMIS-420 user switch when broker is service 2016-04-13 21:29:59 -04:00
Clebert Suconic edc514196b This closes #460 2016-04-13 21:29:42 -04:00
jbertram c17f41dac7 ARTEMIS-476 example fixes/docs 2016-04-13 10:53:14 -05:00
Clebert Suconic 64ae8b0799 This closes #458 2016-04-12 17:26:51 -04:00
Howard Gao ee20248404 ARTEMIS-478 Improve Openwire SslBrokerServiceTest
Some of the SSL tests in openwire requires to pass in more options like
enabledCipherSuites. It needs to refactor the test util to allow passing
of those options to broker.
And some of the cipher suite is obsolete in recent jre. Meaning they
are disabled by default for security reasons
(e.g. SSL_RSA_WITH_RC4_128_SHA). This will cause SSL handshake failure.
It can be fixed by using a more secure (not disabled) one, like
TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256
2016-04-12 17:26:51 -04:00