400 Commits

Author SHA1 Message Date
Christopher L. Shannon (cshannon)
594c79e531 [maven-release-plugin] prepare release activemq-5.14.1 2016-09-27 13:06:12 -04:00
Clebert Suconic
195046c503 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-27 12:16:16 -04:00
gtully
8e6fe414ad 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-27 12:16:05 -04:00
gtully
ebbb7ab437 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-27 12:15:50 -04:00
Timothy Bish
0bb76c7fb4 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-27 12:15:40 -04:00
Timothy Bish
9211661244 NO-JIRA: Small test client fix to close threads out faster. 2016-09-27 12:15:30 -04:00
Timothy Bish
12ee866a6e 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-27 12:15:18 -04:00
Timothy Bish
fa5514985d 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-27 12:15:06 -04:00
Timothy Bish
14c5c5276c https://issues.apache.org/jira/browse/AMQ-6422
Adds a split consumer test that uses presettled receivers.
2016-09-27 12:14:55 -04:00
Timothy Bish
566e82614a 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-27 12:14:43 -04:00
Timothy Bish
ca11674f37 https://issues.apache.org/jira/browse/AMQ-6422
Add test for credit grants but no settles for a single receiver.
2016-09-27 12:14:31 -04:00
Timothy Bish
a5a4262b54 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.  
Conflicts:
	activemq-amqp/src/test/resources/log4j.properties
2016-09-27 12:14:08 -04:00
Timothy Bish
b77b3c428b Add a test case for anonymous sender links using simple test client. 2016-09-27 12:13:04 -04:00
Timothy Bish
cc0e78790f 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-27 12:12:43 -04:00
gtully
94ffb1bf81 AMQ-6422 - include the inflight count in the prefetch for positive remote credit flows. Fix and test 2016-09-27 12:12:33 -04:00
Christopher L. Shannon (cshannon)
02d53a0d9f Revert "[maven-release-plugin] prepare release activemq-5.14.1"
This reverts commit 422b231c25bbf1af4695939468e80b9a2dbaa98b.
2016-09-27 11:57:35 -04:00
Christopher L. Shannon (cshannon)
354142adf1 Revert "[maven-release-plugin] prepare for next development iteration"
This reverts commit 47a652ef2a9bb876b324da65285a7de4fab25317.
2016-09-27 11:57:25 -04:00
Christopher L. Shannon (cshannon)
47a652ef2a [maven-release-plugin] prepare for next development iteration 2016-09-27 08:58:13 -04:00
Christopher L. Shannon (cshannon)
422b231c25 [maven-release-plugin] prepare release activemq-5.14.1 2016-09-27 08:57:19 -04:00
Christopher L. Shannon (cshannon)
c99eb1d600 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

(cherry picked from commit 98c5866c7534c1f26d2e41edbdb372fe21387fe4)
2016-09-06 10:19:20 -04:00
Christopher L. Shannon (cshannon)
679f0cfd31 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.

(cherry picked from commit ed0e786b6002633411037923fb28a075489e442b)
2016-09-06 10:19:20 -04:00
Timothy Bish
f15c0e8e0a https://issues.apache.org/jira/browse/AMQ-6410
Advertise that the connection supported delayed message delivery.
(cherry picked from commit 4a1f2f7ca73fc3cf8d650a4d1b884bc6a0750e59)
2016-08-30 15:02:03 -04:00
Timothy Bish
680d082a17 https://issues.apache.org/jira/browse/AMQ-6404
Add check for unmarshalled text body and handle that case.
(cherry picked from commit 1030fb184216d00e3fd43a416931acd3b2fc6794)
2016-08-23 10:07:14 -04:00
Christopher L. Shannon (cshannon)
a35371d880 NO-JIRA : creating 5.14.x branch 2016-08-02 09:30:31 -04:00
Christopher L. Shannon (cshannon)
71cbc65283 [maven-release-plugin] prepare release activemq-5.14.0 2016-08-02 09:02:54 -04:00
Timothy Bish
d54e21b2ff https://issues.apache.org/jira/browse/AMQ-6374
Refactor transformer to better map AMQP messages to JMS message types
and better preserve the original encoding of stored messages so that
they can be sent back to an AMQP client with expected content types.
Adds additional interoperability tests.
2016-07-25 18:15:53 -04:00
Timothy Bish
4b018b4206 https://issues.apache.org/jira/browse/AMQ-6339
Clean up the transport implementation and reduce duplication.
2016-07-18 16:54:37 -04:00
Timothy Bish
a35e8dc8a2 https://issues.apache.org/jira/browse/AMQ-6359
Allow a receiver link to enable consumer options on the subscription
such as exclusive and retroactive using options encoded on the address
2016-07-14 16:08:34 -04:00
Timothy Bish
16c487a7b9 https://issues.apache.org/jira/browse/AMQ-6353
Fix and test for encoding the correlation Id value to the ActiveMQ
message object's string value
2016-07-12 14:19:01 -04:00
Timothy Bish
c9c05eb866 NO-JIRA Update this test to test across all transformers. 2016-07-12 10:57:07 -04:00
Timothy Bish
31c55f7510 https://issues.apache.org/jira/browse/AMQ-6339
Add support for AMQP client to connect using WebSockets.
2016-06-30 14:52:40 -04:00
Timothy Bish
83827f2770 https://issues.apache.org/jira/browse/AMQ-6341
Wait on broker response for async broker commands.
2016-06-29 20:13:34 -04:00
Timothy Bish
4e23adfcc9 https://issues.apache.org/jira/browse/AMQ-6340
combine the lists in the correct order for later redispatch.
2016-06-29 12:57:30 -04:00
Timothy Bish
e02c1a17f8 https://issues.apache.org/jira/browse/AMQ-6286
Create a follow on test showing AMQP respects order.
2016-06-24 09:39:48 -04:00
Timothy Bish
d563e9019d Test for message property handling cross protocols.
Add a test that validates that message properties are propagated between
OpenWire and AMQP.
2016-06-22 18:05:39 -04:00
Timothy Bish
94ca7039b1 Add a rollback test that rolls back repeatedly using new connections. 2016-06-22 13:02:14 -04:00
Timothy Bish
a95d6fd4eb Adds a start of message interoperability test for OpenWire <-> Qpid JMS 2016-06-21 13:01:19 -04:00
Timothy Bish
27d955501f Add some additional tests for dynamic sender / receiver links 2016-06-16 15:59:56 -04:00
Timothy Bish
f595f3c20d Handle the case where the remote doesn't set any properties resulting in
a null instance being returned from the properties getter.
2016-06-15 18:55:13 -04:00
Timothy Bish
dbed28e625 https://issues.apache.org/jira/browse/AMQ-6320
Turn off support for non SASL connections by default, can be enabled on
the TransportConnector URI if needed.
2016-06-10 17:55:28 -04:00
Timothy Bish
c5998444cf https://issues.apache.org/jira/browse/AMQ-6319
Additional fixes and tests for disable of non-SASL client connects.
2016-06-10 17:11:44 -04:00
Timothy Bish
534dbee447 NO-JIRA: Add test to show behavior of non-prefixed addresses that
default to Queue.
2016-06-10 09:50:59 -04:00
Timothy Bish
c49db029ab https://issues.apache.org/jira/browse/AMQ-6319
Improve configuration for disabling non-SASL connections.
2016-06-09 17:32:41 -04:00
Timothy Bish
28e7cb0b21 https://issues.apache.org/jira/browse/AMQ-6309
Fix some minor issues shown by static code analysis
2016-06-03 18:05:40 -04:00
Timothy Bish
db71b43b19 https://issues.apache.org/jira/browse/AMQ-6305
Lower prefetch on settlement of allow for dispatch of the full amount of
granted credit.  Adds additional tests.
2016-06-03 17:05:00 -04:00
Timothy Bish
76b70545f2 https://issues.apache.org/jira/browse/AMQ-6304
Ensure that the broker send a container ID using its assigned Broker
name value.
2016-06-01 18:38:41 -04:00
Timothy Bish
8448cf1cb8 https://issues.apache.org/jira/browse/AMQ-6305
Refactor credit handling and drain state tracking to ensure we stay in
sync with the remote state and always answer drain requests.  Start
adding some more tests around drain to the interop suite.
2016-06-01 18:30:31 -04:00
Timothy Bish
6ae169e275 https://issues.apache.org/jira/browse/AMQ-6305
Add test and supporting enhancements to the JUnit module to allow for
easy repetition of tests that don't always fail reliably
2016-05-26 18:02:59 -04:00
Timothy Bish
08f266d762 Remove unused import. 2016-05-26 16:52:18 -04:00
Timothy Bish
4d6f4d7475 https://issues.apache.org/jira/browse/AMQ-6263
Encode the incoming messageId value into a string using type prefixes
and decode them on the way out to ensure that we preserve the original
AMQP MessageId type and value.
2016-04-26 18:08:11 -04:00