Commit Graph

434 Commits

Author SHA1 Message Date
Lucas Tétreault e0a37a5c30 Fix serialization of RemoveInfo advisory message for AMQP consumers 2022-10-12 19:06:44 -07:00
Matt Pavlovich 680717cb95
[AMQ-8976] Add maxConnectionExceededCount metric for connectors (#850) 2022-07-18 16:20:25 -05:00
Jean-Baptiste Onofré 239ddc05b1 [AMQ-8583] Move AMQP ResponseHandler interface into protocol package 2022-04-19 17:26:48 +02:00
Jean-Baptiste Onofré e597017200
Merge pull request #662 from jbonofre/AMQ-7426
[AMQ-7426] Upgrade to log4j2
2022-02-27 13:23:53 +01:00
Matt Pavlovich e522feaad8
[AMQ-8511] Minor fix for amqp unit tests to help w/ CI build consistency (#780) 2022-02-24 08:45:25 -06:00
jbonofre 472dcf8497 [AMQ-7426] Upgrade to log4j2 2022-02-24 15:20:51 +01:00
Matt Pavlovich 2cc17a2fa0 [AMQ-8279] Compiler warning cleanups
- Remove unsused imports (exept for generated classes)
 - Convert to T.valueOf on boxed primitives from new T()
2021-05-25 09:34:35 -05:00
Robbie Gemmell 45a400b37d NO-JIRA: refresh test keystores, fix failures on new OS/JDK combos where the old signature algs fail updated constraints 2020-11-26 13:45:29 +00:00
Benjamin Graf a2e718f259 AMQ-8055 - rename posion to correct poison 2020-10-23 09:50:18 +02:00
Pascal Schumacher 67e06c82f7 Fix some javadoc warnings releated to non-existing parameter names. 2020-05-17 11:38:05 +02:00
Daniel Trebbien b020cba744 Fix some incorrect SLF4J logger calls
In some cases, there were an inconsistent number of formatting anchors.

In other cases, formatting anchors were used, but because the
trace/debug/info/warn/error(String, Throwable) variant was used, the
string is a message string rather than a format string.

These issues were found by SLF4J Helper for NetBeans IDE:
http://plugins.netbeans.org/plugin/72557/
2020-02-19 08:26:36 +00:00
Jean-Baptiste Onofré 4ecdd5a2a8
Merge pull request #448 from PascalSchumacher/fix_unused_format_arguments_in_log_messages
Fix unused format arguments in log messages.
2020-02-13 07:53:32 +01:00
Pascal Schumacher 6764511fa1 Fix unused format arguments in log messages. 2020-02-12 17:52:28 +01:00
jbonofre 097506a458 [AMQ-7399] org.apache.activemq.SERIALIZABLE_PACKAGES doesn't include java* by default 2020-02-12 13:43:03 +01:00
Johannes Bäurle 6f338aa281 [AMQ-7068] Advisory messages are empty when received with a AMQP subscription (#312) 2019-11-17 17:40:15 +01:00
Timothy Bish 122745b5b8 AMQ-7274 Update proton-j and fix footer key type on outbound transform
Footer annotations maps should be using Symbol keys not strings.
2019-08-13 15:05:00 -04:00
Robbie Gemmell aff9413cdb AMQ-7189: ensure messages with defauled durable field are internally classed non-persistent by the 'native' transformer 2019-04-26 12:55:14 +01:00
gtully 4dee173962 AMQ-7077 AMQ-6421 - tie queue consumer slow flag detection to abort slow consumer policy, fire advisory when set. 2018-10-17 11:04:47 +01:00
Timothy Bish ac1e709dc4 AMQ-7065 Update to Qpid JMS v0.37.0
Update to latest client release, adds some tests for split framed
message send / receive
2018-10-02 15:20:11 -04:00
Christopher L. Shannon (cshannon) 1e31df9800 AMQ-7047 - Switch default for hostname verification to be false for
server

For the client it makes sense to have it true by default but for the
server it makes sense to have it false by default
2018-08-31 13:04:14 -04:00
Christopher L. Shannon (cshannon) 69fad2a135 Add support for hostname verification 2018-08-31 06:39:49 -04:00
Timothy Bish ba7934e91a AMQ-7001 Remove now unnecessary check for UTF8Buffer type
Remove the now unneeded checks for UTF8Buffer on the outbound converter
as the Codec now can encode those to the correct string AMQP types
without need for any help.
2018-08-01 18:34:09 -04:00
Timothy Bish 9ec6ee43b1 AMQ-7001 Resolve issues with encode failures on copied messages
Ensure that messages are copied to avoid contention on message content
when concurrent store and dispatch is enabled and better handle the AMQP
message type value.  Adds an AMQP Encoder for UTF8Buffer to encode down
to AMQP String encodings to allow for encoded OpenWire messages such as
MapMessage which can contain UTF8Buffer instances for String keys and
values.
2018-08-01 18:13:37 -04:00
gtully ed8860000f AMQ-7001 - amqp jms transformer - always copy message if properties need to be modified, fix and long running test that is disabled 2018-06-26 15:25:52 +01:00
Timothy Bish b8cfab97db AMQ-6958 Configure the AMQP Max Frame Size by default
Configure a value of 128KB for AMQP max frame size by default to improve
overall performance and provide a limit on delivery size before chunking
begins.
2018-05-10 13:16:13 -04:00
Timothy Bish b29d2ea342 AMQ-6909 Update Qpid JMS, proton-j and Netty to latest.
Use latest releases of AMQP deps
2018-05-08 17:44:55 -04:00
Timothy Bish 36a2871301 AMQ-6872 Use correct type casts on ApplicationProperties Map
Fix missing cast on value out of current proton release.
2017-12-08 11:40:34 -05:00
Timothy Bish e7bce023de AMQ-6872 Use correct type casts on ApplicationProperties Map
Use the spec defined values when casting the Map from the
ApplicationProperties section.
2017-12-07 14:54:42 -05:00
Robbie Gemmell f82eccd2f5 AMQ-6813: update tick deadline handling to account for potential to be negative due to using nanoTime derived values, plus other edge case protections 2017-09-15 17:53:00 +01:00
Timothy Bish ed395d1a85 AMQ-6804 Improve Transfer tag generation and pooling
Reduce GC overhead and improve tag generation for faster tag creation.
2017-09-06 13:28:26 -04:00
Timothy Bish ce551cf97d NO-JIRA update the AMQP tests to use the client close timeout
Use the client built in close timeout instead of the executor which can
leave threads running and causes the tests to take much longer than
needed.
2017-06-15 17:13:32 -04:00
Timothy Bish 0eb11bf0a1 https://issues.apache.org/jira/browse/AMQ-6676
Handle continuation frames on the test client WS transport.
2017-05-16 10:53:23 -04:00
Timothy Bish 88efa01e11 AMQ-6675 AMQP Test client can't accept bigger frames on WS
Need to configure the WS Handshaker in the test client's netty transport
with the same value given to the proton connection via setMaxFrameSize
so that incoming frames larger than the default 65535 over WS don't
trigger netty to fail the connection.
2017-05-11 18:33:38 -04:00
Timothy Bish 4f7c9ec811 AMQ-6674 Ensure timely shutdown of the connection executor
Don't wait for next idle check or other scheduled tasks to run before
shutdown can proceed.
2017-05-11 15:59:08 -04:00
Timothy Bish 154ff81eee AMQ-6673 Add some fixes and improvements to the AMQP test client
Adds some thread safety fixes and Netty usage fixes to the transport as
well as adding a traceBytes option to trace the bytes sent / received
during testing.
2017-05-11 15:01:16 -04:00
Timothy Bish fddbac2b8a AMQ-6672 Use a dynamic proxy to create unmodifiable types
Use a dynamic proxy instead of hand-crafted wrappers around proton
types to prevent access to mutating methods in tests that could
inadvertantly change the state outside the connection thread.
2017-05-11 13:14:39 -04:00
Robert Gemmell 73e70299e6 AMQ-6623: update to proton-j 0.19.0 2017-05-08 12:42:51 +01:00
Timothy Bish 2e2d5ddd3d https://issues.apache.org/jira/browse/AMQ-6669
Respect the wireFormat.maxFrameSize option on WS and WSS transports
allowing binary content larger than 65535
2017-05-04 16:37:53 -04:00
Timothy Bish 381a1ae206 https://issues.apache.org/jira/browse/AMQ-6659
Honor the sender settle mode from the client and ensure we always set
receiver mode to FIRST to reflect we don't support SECOND.  Adds tests
coverage and needed test client changes for this.
2017-04-21 10:51:35 -04:00
Timothy Bish 1fd2450544 NO-JIRA Make the version string indicate that the value is unknown
The default version string is out of date and doesn't indicate that a
proper value couldn't be found, return something that makes that a bit
more clear.
2017-04-11 13:13:30 -04:00
Timothy Bish 0752d840b9 https://issues.apache.org/jira/browse/AMQ-6638
Adds some additional logging to the connection validation code, adds
some additional tests as well.
2017-04-05 16:20:28 -04:00
Timothy Bish 0196be1d27 https://issues.apache.org/jira/browse/AMQ-6630
Update to latest Qpid JMS release 0.21.0 and match the netty 4.1.8.Final
dependency up with it.
2017-03-15 12:41:25 -04:00
Robert Gemmell 0707031334 AMQ-6623: update to proton-j 0.18.0 2017-03-10 15:31:17 +00:00
Timothy Bish 8a34ca0ec7 Clean up connection resources on failed connect. 2016-12-21 17:19:05 -05:00
Timothy Bish 4a1c05b628 https://issues.apache.org/jira/browse/AMQ-6536
Add support for the receiver side of a sender link which carries a
desired capabilities array which can request to know if we support
delayed delivery, answer with an offered capability in that case.
2016-12-13 12:36:59 -05:00
Timothy Bish e050519ff6 https://issues.apache.org/jira/browse/AMQ-6500
Better handle prefetch extension and pull consumers over Topics to avoid
the remote not receiving all the messages available based on the credit
it has issued.
2016-11-18 11:59:01 -05:00
Timothy Bish 980162233f https://issues.apache.org/jira/browse/AMQ-6504
Round the start time value not truncate to ensure delay falls on the
correct side of the scheduling block.
2016-11-11 14:48:49 -05:00
Timothy Bish 097c0e7eae NO-JIRA Add some additional validation. 2016-11-10 12:45:37 -05:00
Timothy Bish 7cf7fba7aa https://issues.apache.org/jira/browse/AMQ-6498
Include the already received backlog when deciding to grant additional
credit to avoid excessive backlogs of messages during producer flow
control.
2016-11-04 11:55:12 -04:00
Hadrian Zbarcea be24a133ef This closes #88 (merged as a65ac586). More file permissions fixes. 2016-11-03 14:26:34 -04:00