Commit Graph

3844 Commits

Author SHA1 Message Date
Francesco Nigro 9f8a14440b ARTEMIS-1223 OutOfDirectMemoryError raised from TimedBuffer
Force allocation of direct ByteBuffer with Cleaner to help GC on tests.
2017-06-27 12:45:26 -04:00
Clebert Suconic 12e7465283 This closes #1373 2017-06-27 12:42:41 -04:00
Christopher L. Shannon (cshannon) a538b969c0 ARTEMIS-1258 - Add ServerSession as an argument to beforeSend and
afterSend
2017-06-27 12:42:40 -04:00
Clebert Suconic 437232b50e ARTEMIS-1253 Renaming NetworkReplicationTest to NetworkIsolationTest 2017-06-27 12:21:37 -04:00
Clebert Suconic 4d6956c291 This closes #1367 2017-06-27 12:19:38 -04:00
Clebert Suconic f407d86f0f ARTEMIS-1253 Fixing NetworkHealthCheck being shutdown after failures 2017-06-26 16:15:39 -04:00
Clebert Suconic 36110da9c8 ARTEMIS-1253 Refactoring renaming stop(boolean) to fail(boolean)
This method name would clash with ServiceComponent
As the real meaning here on this method is just to failover
So I've renamed the method to avoid the clash with my next commit

(I've done this on a separate commit as you may need to redo this
 commit from scratch again in other branches instead of lots of clashes on cherry-pick)
2017-06-26 16:15:39 -04:00
Clebert Suconic 4bae814908 ARTEMIS-1253 Adding testcase 2017-06-26 16:15:39 -04:00
Clebert Suconic 8a8023bf0b This closes #1364 2017-06-26 16:14:57 -04:00
Dmitrii Tikhomirov 027faa36d1 [ARTEMIS-1251] Log messages without prefixed id code in artemis-jms-server 2017-06-26 16:14:57 -04:00
Clebert Suconic 1888e2ca4f This closes #1351 2017-06-26 14:33:15 -04:00
Howard Gao 045021f7df ARTEMIS-1220 Diverted LargeMessage file corrupted during replication
When a large message is being diverted, a new copy of the original
message is created and replicated (if there is a backup) to the backup.

In LargeServerMessageImpl.copy(long) it reuse a byte array to copy
message body. It is possible that one block of date is read into
the byte array before the previous read has been replicated,
causing the replicated bytes to corrupt.

If we make a copy of the byte array before replication, the corruption
of data will be avoided.
2017-06-26 14:31:43 -04:00
Justin Bertram 583abcefba This closes #1368 2017-06-26 13:08:04 -05:00
Martyn Taylor 222275dd8d ARTEMIS-1254 New OrderedExecutor for JDBC LargeMsg 2017-06-26 18:43:50 +01:00
Martyn Taylor 604db9ee7e ARTEMIS-1204 Replace open sync with AtomicBoolean
The JDBCSequentialFile blocks on the writeLock when opening.  There is
no need to block here, in fact it may cause issues when opening and
syncing concurrently.  Instead an AtomicBoolean is enough to prevent the
file from being reloaded.
2017-06-26 18:41:21 +01:00
Clebert Suconic b50ae5a916 NO-JIRA Fixing a test 2017-06-23 14:44:23 -04:00
Clebert Suconic b640a62417 This closes #1361 2017-06-23 09:37:46 -04:00
Francesco Nigro 325f46e01f ARTEMIS-1248 Reduce garbage while Paging 2017-06-23 09:37:46 -04:00
Clebert Suconic d6191e31e2 This closes #1362 2017-06-23 08:56:40 -04:00
Erich Duda c5a25d3322 ARTEMIS-1250 ClusteredMessageCounterTest.testNonDurableMessageAddedWithPaging fails
Before sending of messages to server 0 begins, the test
should wait until consumer is registered at RemoteQueueBindingImpl
on server 0. Otherwise some messages may not be rebalanced
to server 1.
2017-06-23 13:39:25 +02:00
Clebert Suconic e709fc366d NO-JIRA: Fixing a test 2017-06-22 17:59:55 -04:00
Clebert Suconic 339fa20f2b NO-JIRA: Fixing JournalImplTestUnit
it doesn't really matter the number of files.. as long as the data is valid.
This type of assertion limits the implementation. it's mocking test with too much intrusion
over the implementation. Hence I'm removing these clauses that will fail eventually.
2017-06-22 17:49:43 -04:00
Christopher L. Shannon (cshannon) 35f6ebb2cb NO-JIRA: Minor documentation fix 2017-06-22 16:12:01 -04:00
Clebert Suconic 9f25013c54 This closes #1307 2017-06-22 12:41:48 -04:00
Guillaume Nodet b6dcff039f [ARTEMIS-1196] Fix missing JSON support 2017-06-22 12:16:25 -04:00
Clebert Suconic a970b41ebf This closes #1345 2017-06-22 12:13:11 -04:00
Michael Andre Pearce f63f130407 ARTEMIS-1235 delete queues when broker.xml changes
Add extra configuration to address-settings to be able to
control / enable address/queue deletion by pattern,
rather than a global toggle.

Add support in the reload logic to remove address
and/or queues if the address matches an address setting,
where it is enabled.
2017-06-22 12:12:12 -04:00
Clebert Suconic be8eb3ec9f This closes #1358 2017-06-22 12:01:41 -04:00
Jiri Danek 60fad35cfe ARTEMIS-1244 propagate retain flag of received message 2017-06-22 12:00:40 -04:00
Clebert Suconic c2ad9cab0d This closes #1357 2017-06-22 11:51:11 -04:00
Michal Tóth 2b80426153 ARTEMIS-1244 Retain flag code todo comment
Identified possible bug in MQTT receive of missing retained flag.
2017-06-22 11:51:11 -04:00
Michal Tóth e801df7974 ARTEMIS-607 New tests AMQP,MQTT,Stomp interceptor properties tests
Added tests for AMQP, MQTT and Stomp protocol for interceptors.
Tests are checking intercepted message properties.
Linked issue ARTEMIS-607
2017-06-22 11:51:11 -04:00
Clebert Suconic 902e0c49ab This closes #1359 2017-06-22 10:48:10 -04:00
Andy Taylor fbe27682a1 ARTEMIS-1237 - Hard coded timeout on Journal file open
Make timeout configurable

https://issues.apache.org/jira/browse/ARTEMIS-1237
2017-06-22 10:48:09 -04:00
Clebert Suconic 37d1d5ff7b ARTEMIS-1247 Allow tracing on ReplicatedJournal
This closes #1360
2017-06-22 10:22:36 -04:00
Clebert Suconic 85aeac99ab Revert "ARTEMIS-1227 Internal properties not removed from messages"
This reverts commit f465996444.

Following discussion on https://github.com/hornetq/hornetq/pull/2114
2017-06-22 09:49:45 -04:00
Clebert Suconic e78a902881 ARTEMIS-1224 fixing test 2017-06-21 20:00:13 -04:00
Clebert Suconic b89ad66c62 This closes #1324 2017-06-21 16:06:57 -04:00
Francesco Nigro cf68aab714 ARTEMIS-1214 Improve performance of read on Paging 2017-06-21 16:06:57 -04:00
Clebert Suconic ad4d3be203 This closes #1354 2017-06-21 11:22:59 -04:00
Howard Gao e258bdf188 ARTEMIS-1242 OpenWire Transactions never removed
Openwire doesn't remove the finished transactions
(committed or rolledback).
2017-06-21 11:22:59 -04:00
Clebert Suconic a8ecc9fa38 This closes #1353 2017-06-21 11:19:10 -04:00
Helge Waastad eaadc24729 ARTEMIS-1243 Release ReferenceCounted messages 2017-06-21 11:19:09 -04:00
Clebert Suconic 7583ff7172 This closes #1356 2017-06-21 11:16:30 -04:00
Jiri Danek 3d4e907a1b NO-JIRA fix typos 2017-06-21 11:16:29 -04:00
Clebert Suconic ae8fbbdef1 This closes #1350 2017-06-21 10:25:34 -04:00
Howard Gao 3d0896f87c ARTEMIS-1240 Disconnect at client side on decoding error
When a broken packet arrives at client side it causes decoding error.
Currently artemis doesn't handle it properly. It should catch such
errors and disconnect the underlying connection, logging a proper
warning message
2017-06-21 10:25:34 -04:00
Martyn Taylor 498a328635 This closes #1349 2017-06-20 10:09:26 +01:00
Michael Andre Pearce 1bfa1ad4fe ARTEMIS-1205: AMQP Shared Durable Subscriber - Document Update
Update documents for new configuration toggle for 'amqp-use-core-subscription-naming '
2017-06-19 23:05:10 +01:00
Martyn Taylor 7610dadaf3 This closes #1337 2017-06-19 12:44:13 +01:00