Commit Graph

10244 Commits

Author SHA1 Message Date
Timothy Bish 63d62a71f5 https://issues.apache.org/jira/browse/AMQ-6438
JMS Transformer performance improvements and bug fixes

Trim unnecessary code and improve overall performance of the JMS
Transformer codecs.  Remove legacy Qpid JMS client related code from the
transformer as these are no longer supported.  Fix outgoing message that
do not match the structure of the incoming message that created them such
as message with had only a body being sent out with Headers and message
Properties.
2016-09-26 18:43:06 -04:00
Timothy Bish 5702ec8d7c https://issues.apache.org/jira/browse/AMQ-6438
Add additional test for larger more complex AMQP message
2016-09-26 17:19:42 -04:00
Christopher L. Shannon (cshannon) a82c95cd29 https://issues.apache.org/jira/browse/AMQ-6436
The temporary store will now delete the old temp directory on start up
if lazyInit is true instead of waiting for the store to initialize to
clear up space.  This prevents space on the disk from being wasted with
old data if the temp store isn't initialized
2016-09-23 15:47:27 -04:00
Christopher L. Shannon (cshannon) 09456480b8 https://issues.apache.org/jira/browse/AMQ-6431
Fixing BitArrayBin to not overflow in certain cases with numbers larger
than Int max
2016-09-23 14:30:37 -04:00
Christopher L. Shannon (cshannon) 18571ce09b https://issues.apache.org/jira/browse/AMQ-6430
Modifying patch so that only stores that persist the noLocal flag will
check if this flag has changed to prevent a subscription from being
deleted by mistake
2016-09-23 10:59:32 -04:00
Christopher L. Shannon (cshannon) 2b99ffcc22 https://issues.apache.org/jira/browse/AMQ-6433
Generating a new equals method in TypeConversionSupport so the proper
null checks exist
2016-09-23 08:02:22 -04:00
Christopher L. Shannon (cshannon) f25e7ab47f https://issues.apache.org/jira/browse/AMQ-6434
Rewriting logic in finally block of PooledTaskRunner to avoid using a
return statement
2016-09-23 07:51:11 -04:00
Timothy Bish d4c7cce7d7 https://issues.apache.org/jira/browse/AMQ-6438
Makes some improvements to the profiling test for the transformers.
2016-09-21 18:18:41 -04:00
Clebert Suconic 35e8a52888 NO-JIRA: Adding an extra test on AmqpTransactionTest
The test I'm adding was back ported from Artemis.
It will validate if the ACKs are nacked in case of a connection.close();
To avoid a situation where the TX would sit on a Transaction Resource Manager somewhere like an XID.
2016-09-21 16:13:57 -04:00
Christopher L. Shannon (cshannon) 7c293b661f https://issues.apache.org/jira/browse/AMQ-6430
When a nolocal durable consumer reconnects the new connectionId is properly captured for
the NoLocal expression so that nolocal works on reconnect.  Also fixed
the detection of the nolocal value changing on consumer connect.
2016-09-21 09:34:46 -04:00
gtully 6c01b641b1 https://issues.apache.org/jira/browse/AMQ-6422 - move delivery tracking to pumpoutbound and additional test that shows how the presettle case breaks. Thanks to Robbie Gemmell for the feedback 2016-09-21 13:59:45 +01:00
gtully ffee8b442f https://issues.apache.org/jira/browse/AMQ-6422 - match proton sender view credit to prefetchExtension - tracking credit to dispatch delta to track additional flow requests. Proton sender layer is distinct from the transport layer - they mirror each other 2016-09-21 10:33:20 +01:00
gtully 5d9f1cd3d5 https://issues.apache.org/jira/browse/AMQ-6435 - use lesser guava dep to match leveldb java 2016-09-21 10:26:06 +01:00
Timothy Bish 5d53aa2d11 NO-JIRA: Add some more variants of the .NET transaction tests
Adds ability to not settle accepted messages on the client to enable
creation of tests that are equivalent to the AmqpNetLite client's
transaction tests which hold settlement and expect the resource to
handle it on successful discharge.
2016-09-19 17:36:58 -04:00
Timothy Bish 9f812a2103 NO-JIRA: Additional test on JobSchedulerStoreImpl
Pushes on the journal log GC logic to ensure that cleanup is occurring
when the redelivery plugin is scheduling more resends on TX rollback.
2016-09-19 10:53:50 -04:00
Dejan Bosanac 6630e81379 https://issues.apache.org/jira/browse/AMQ-6435 - destination mbean query api 2016-09-19 16:22:44 +02:00
Timothy Bish a35d23dff7 NO-JIRA: Small test client fix to close threads out faster. 2016-09-15 16:28:16 -04:00
Timothy Bish 4516c8df3f NO-JIRA: Add some additional tests ported from the .NET AMQP client
Adds some transaction tests ported from AMQP .NET client with some
variances based on the way the test client works and limitations in the
brokers handling of Transacted sends.
2016-09-15 13:26:06 -04:00
Timothy Bish b4ab0e1af9 NO-JIRA AMQP Test updates
Adds support for doing sends and receives that are enrolled in a
transaction created in a session other than the session that created the
sender or receiver.  Adds some tests that show this in action.
2016-09-14 18:23:52 -04:00
Timothy Bish da9fedead4 https://issues.apache.org/jira/browse/AMQ-6422
Adds a split consumer test that uses presettled receivers.
2016-09-09 18:34:03 -04:00
Timothy Bish 2fdc2600ac https://issues.apache.org/jira/browse/AMQ-6422
Small fix to test and check for zero inflight on successive send to
destination that should have no credit on the registered receiver.
2016-09-09 13:02:04 -04:00
Timothy Bish 640289868e https://issues.apache.org/jira/browse/AMQ-6422
Add test for credit grants but no settles for a single receiver.
2016-09-09 12:52:48 -04:00
Timothy Bish 5de9bdac08 https://issues.apache.org/jira/browse/AMQ-6427
Move to Qpid JMS 0.11.0
2016-09-09 11:17:08 -04:00
Timothy Bish 84cd815500 Allow the AMQP test client to also be configure to trace frames
The test client can allow for quick tracing of the frame traffic via a
call to setTraceFrames on the client or connection instance before
connection to the remote.  This allows for tests to easily switch on /
off tracing.  The log4j.properties is also updated to output frame
tracing with the URI option is put on the AMQP transport or the client
value is enabled.
2016-09-08 16:19:37 -04:00
Christopher L. Shannon (cshannon) a038655605 https://issues.apache.org/jira/browse/AMQ-6423
Fixing durable sync over a network bridge so that network subscriptions
that are no longer permissible are also cleaned up
2016-09-08 08:28:26 -04:00
Timothy Bish 0050f22b97 Add a test case for anonymous sender links using simple test client. 2016-09-07 17:27:31 -04:00
Timothy Bish ee271afe90 https://issues.apache.org/jira/browse/AMQ-6422
I've made a few minor test changes and added a couple more cases.  Under
heavy CPU load I'm able to get test,
testReceiveMessageAndRefillCreditBeforeAcceptOnQueue to fail on the
second receive call where it should get the second message since it
granted credit.
2016-09-07 14:05:21 -04:00
gtully 88daeec28f AMQ-6422 - include the inflight count in the prefetch for positive remote credit flows. Fix and test 2016-09-07 17:28:35 +01:00
Christopher L. Shannon (cshannon) 88af1c70d9 https://issues.apache.org/jira/browse/AMQ-6418
Fixing mqtt link stealing default setting for auto transport
2016-09-07 08:17:34 -04:00
Christopher L. Shannon (cshannon) 9ab94883a8 https://issues.apache.org/jira/browse/AMQ-6420
Properly copying wire format options map before applying to the
transport when using auto transports so that the options do not get
cleared and will be used for all future connections
2016-09-07 07:42:13 -04:00
Christopher L. Shannon (cshannon) 98c5866c75 https://issues.apache.org/jira/browse/AMQ-6418
Properly setting the transport properties on the
AutoNIOSSLTransportServer and fixing the Stomp protocol to set the peer
certs when using auto+ssl
2016-09-06 10:17:05 -04:00
gtully a3f1aa0bda TrapMessageInJDBCStoreTest - intermittent ci failure. Avoid contention on datasource, use long lived connection for assertions 2016-09-02 11:27:12 +01:00
gtully 508df5359c sanity check on provider url params for connection factory 2016-09-02 10:38:26 +01:00
Timothy Bish bb8d32c04a https://issues.apache.org/jira/browse/AMQ-6387
Fix up the Memory Store such that it removes the references it adds to
messages when they are placed into the memory durable topic subscription
store.
2016-09-01 16:26:03 -04:00
gtully a0d05f8ea3 AMQ-2910 fix timing on test timeout - ensure consumer connection is started 2016-09-01 16:54:50 +01:00
gtully a9c7f7122b AMQ-6411 - tidy up latch between runs. Have not seen repeat of npe yet 2016-09-01 16:53:02 +01:00
gtully f8bc19b96d AMQ-6413 - ensure audit update on skipped store add for kahadb concurrentStoreAndDispatch. Fix and test 2016-09-01 16:46:21 +01:00
Christopher L. Shannon (cshannon) ed0e786b60 https://issues.apache.org/jira/browse/AMQ-6414
Changing the nio+ssl transports to trigger a serviceRead after start up
to prevent blocking. The prevents the channels from not reading in
certain cases, most notably with the auto+nio+ssl transport when used
for a network bridge.  Also added a couple tests and changed a network
bridge test to test out auto+nio+ssl.
2016-09-01 11:39:46 -04:00
Christopher L. Shannon (cshannon) e57de54410 NO-JIRA: Fixing OpenWireConnectionTimeoutTest failure 2016-09-01 10:10:52 -04:00
Timothy Bish 4a1f2f7ca7 https://issues.apache.org/jira/browse/AMQ-6410
Advertise that the connection supported delayed message delivery.
2016-08-30 15:00:23 -04:00
Timothy Bish a4cd4dc674 https://issues.apache.org/jira/browse/AMQ-6409
Update Netty to 4.0.41.Final
2016-08-30 11:04:43 -04:00
Timothy Bish 1595912bbf https://issues.apache.org/jira/browse/AMQ-6408
Update to latest proton-j 0.14.0
2016-08-30 11:00:53 -04:00
gtully bf5b1fcfce address npe in intermittent failure in ci 2016-08-30 15:39:49 +01:00
Timothy Bish de4f4e406f Fix NPE case so a meaningful error is reported on failure. 2016-08-29 17:05:21 -04:00
Christopher L. Shannon (cshannon) b9fad53fc6 https://issues.apache.org/jira/browse/AMQ-6067
The JDBCMessageStore now checks hasSpace() when running a message
recovery listener to prevent going past the max configured page size
2016-08-26 13:46:42 -04:00
gtully 2b1cda1964 AMQ-6406 - ensure duplicates trapped by the cursor-add or queue-page-in are removed from the message store 2016-08-25 15:01:19 +01:00
gtully 5a874816b7 AMQ-6403 - add indexDirectory attribute to kahadb plist impl - settable via broker service tempDataStore 2016-08-24 11:39:22 +01:00
Timothy Bish 1030fb1842 https://issues.apache.org/jira/browse/AMQ-6404
Add check for unmarshalled text body and handle that case.
2016-08-23 09:58:05 -04:00
Claus Ibsen 8447e1af2d AMQ-6402: Fixed potential NPE in OriginalDestinationPropagateStrategy 2016-08-20 12:13:55 +02:00
gtully b37b9eb5af fix up cancelledTaskModMetric reporting in kahadb 2016-08-19 11:48:42 +01:00