Commit Graph

9898 Commits

Author SHA1 Message Date
Claus Ibsen 50243106c2 Upgrade Camel to 2.20.1 2017-11-15 10:46:24 +01:00
Christopher L. Shannon (cshannon) 3ca439cada AMQ-6858 - Allow configuration of the client Id token in network bridge
The client id token that is used to separate parts of a generated local
client id in a network bridge should be configurable so bridge names and
broker names can contain underscores if desired
2017-11-14 15:23:26 -05:00
Christopher L. Shannon 41211c78d1 AMQ-6858 - reworking durable subscription propagation fix
Significantly reworking previous fix so that the client id is properly
changed when tracking network proxy subscriptions. This makes it so
removal is done properly
2017-11-13 11:07:43 -05:00
Dejan Bosanac a0a23b99cc [AMQ-6859] MQTT - topic name of the message 2017-11-10 15:26:48 +01:00
Christopher L. Shannon (cshannon) 96ce14b278 AMQ-6858 - Fix several durable subscription bridge propagation issues
Durable network proxy subs will now be properly created across multiple
bridges when 3 or more brokers are used.  Demand will be properly synced
and removed.
2017-11-09 11:21:18 -05:00
Timothy Bish 7dad09a9cd AMQ-6856 Update Qpid-JMS and Proton-J
Update to latest release of Qpid-JMS 0.27.0
Update to latest release of Proton-J 0.23.0 to match the Qpid-JMS dep
2017-11-06 11:35:10 -05:00
gtully b29ccf3488 [AMQ-6854] log warn if page in is blocked on usage preventing dispatch. Reuse blockedProducerWarningInterval to tweak reporting 2017-11-02 16:04:30 +00:00
gtully 03b19b9da4 [AMQ-6847] limit the retry loop to one iteration overa all pending messages such that new additions are not replayed to avoid duplicates 2017-11-01 11:26:36 +00:00
gtully 2ea5d1420b [AMQ-6847] pause dispatch for message move to avoid redelivery with pending ack/remove/audit rollback 2017-10-27 11:40:06 +01:00
gtully 005403e94b [no jira] more lenient for ci builds - intermittetnt failure 2017-10-27 11:37:04 +01:00
gtully 8e576be1d9 [AMQ-6849] - fix sendFailIfNoSpaceAfterTimeout policy entry default value 2017-10-26 11:36:03 +01:00
gtully 6da08b245e [AMQ-6849] provide a virtualTopic dropOnResourceLimit attribute, default to false.
Enabling will allow dispatch to continue even when end to some consumer queues
fail due to resource constraints.
The existing systemUsage sendFailIfNoSpace and sendFailIfNoSpaceAfterTimeout are
promoted to destination policy options allowing selective destinations to fail a
send with an exception. The global system usage options are still in place.
When dropOnResourceLimit=true dispatch will continue in the event that any
subscription queue throws a resource limit exception on send failure.
2017-10-25 14:53:20 +01:00
gtully be6f4b69c1 [no jira] calm this test a bit due to oom in ci builds 2017-10-25 13:08:00 +01:00
Timothy Bish 489cdc624c This closes #262 2017-10-18 14:54:26 -04:00
James Sears cc6cb74c74 AMQ-6828 Improvement to python AMQP example.
Migrate example python code to proton reactor API.
2017-10-18 11:06:19 +01:00
Christopher L. Shannon (cshannon) b3f41cb44b NO-JIRA: Adding 5.15.2 schema mapping 2017-10-17 09:59:54 -04:00
Christopher L. Shannon (cshannon) 0c396a23e7 AMQ-6834 - Adding back in spring schemas for camel 2017-10-16 09:21:59 -04:00
Claus Ibsen 98a5e55a96 AMQ-6834: activemq-osgi should not include camel namespace in spring as they have been removed from Camel. Only blueprint is supported 2017-10-15 10:21:06 +02:00
Claus Ibsen 3cfa5cf7e2 Upgrade Spring 2017-10-15 10:02:56 +02:00
Claus Ibsen 02cd02e981 Upgrade Apache Camel to 2.20.0 2017-10-15 09:57:40 +02:00
gtully e793260573 [AMQ-6831, AMQ-6771] trigger eofexception on read -1 - AMQ6522Test 2017-10-11 00:20:44 +01:00
Timothy Bish ada50f74f9 AMQ-6830 Update main netty dep to 4.1.16.Final
Update the main netty dep used in the tests to latest
2017-10-10 12:51:14 -04:00
gtully f989992278 [AMQ-6831, AMQ-6771] fix up recovery check to ensure full batch is available in memory, regression from AMQ-6771 2017-10-10 17:24:09 +01:00
Timothy Bish 0e6fc19cff AMQ-6830 Update Qpid JMS and Netty
Update to latest Qpid JMS 0.26.0 and Netty 4.1.16.Final
2017-10-06 15:40:38 -04:00
gtully 044699c00c [AMQ-6829] add inflight count to dstat queue output 2017-10-06 16:21:15 +01:00
Claus Ibsen 25ef84a3a0 Upgrade Spring 2017-10-06 12:48:01 +02:00
Claus Ibsen 77fc96b07b Upgrade Camel 2017-10-06 12:23:01 +02:00
gtully 578eacab45 [AMQ-6824] remove time dependency in test assertion 2017-09-28 11:36:11 +01:00
Robbie Gemmell e5b7c9fba4 AMQ-6821, AMQ-6790: add the ActiveMQAMQPBrokerFeatureTest to the smoke/sanity test profile 2017-09-27 15:07:00 +01:00
gtully 33b52b5914 [AMQ-6790] add netty kqueue osgi dependency to the activemq-amqp-client feature 2017-09-27 12:43:38 +01:00
gtully 41a100766c [AMQ-6824] - fix up prefetchExtension growth on transaction completion and delivered ack and tie in boolean usePrefetchExtension 2017-09-26 11:30:18 +01:00
Timothy Bish a21dd40527 AMQ-6823 Ensure that MessagePull is works across HTTP transport
The MessagePull command needs to have the transients initialized such
that the pull operation works across transports that use XStream or
other marshaling that doesn't performs custom serialization.
2017-09-25 13:26:18 -04:00
Christopher L. Shannon (cshannon) 62ce852659 NO-JIRA: Exclude logo.svg from apache-rat check 2017-09-25 08:47:04 -04:00
Christopher L. Shannon (cshannon) 76cc779668 NO-JIRA: Adding schema definition for 5.15.1 2017-09-25 08:43:04 -04:00
Robbie Gemmell e50e1661bf AMQ-6821: update to qpid-jms 0.25.0 2017-09-22 17:02:43 +01:00
Robbie Gemmell 66d9d86fdf NO-JIRA: remove script, moved into dist dev repo to simplify use, now under https://dist.apache.org/repos/dist/dev/activemq/activemq 2017-09-21 17:35:58 +01:00
Robbie Gemmell c513bd7ba8 NO-JIRA: tweak script to default to a version-named dir, allow specifying alternative, and exit if it already exists 2017-09-21 16:16:31 +01:00
Christopher L. Shannon (cshannon) 6e33507bf2 AMQ-6820 - Properly handle ClosedChannelException
When a ClosedChannelException occurs inside SelectorSelection properly
call the transport listener onError() method to handle cleanup and
logging.
2017-09-21 08:14:19 -04:00
Timothy Bish 61d3231d36 AMQ-6809 Fix issue where stream message getBytes returned wrong value
StreamMessage implementation should return zero when the full value of a
written byte array has been consumed before then returning -1 on the
next read.  Ands fix and additional testing of ActiveMQStreamMessage
2017-09-20 15:50:09 -04:00
gtully 5b4fb8aa2b [no jira] test to exercise pool setBlockIfSessionPoolIsFull false 2017-09-20 15:37:43 +01:00
Timothy Bish 0f21cf7145 Adds a script used to prepare a release for vote
Script used to download the release from a staged repo and validate the
checkums and signature and create a new .sha512 hash for the release
bits
2017-09-19 15:48:25 -04:00
gtully 8c3ef6cadb [AMQ-6815] have checkpoint validate status of async writes to avoid stale metadata and validate location size on read to avoid potential oom on restart 2017-09-19 16:51:00 +01: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
Robbie Gemmell 9326ccabac AMQ-6812: update to proton-j 0.22.0 2017-09-15 17:53:00 +01:00
Christopher L. Shannon (cshannon) 6b27708ae1 AMQ-6811 - moving ActiveMQMessageIsMarshalled test to src/test/java 2017-09-15 12:20:44 -04:00
Christopher L. Shannon (cshannon) f82993d9c2 AMQ-6811 - fix reduceMemoryFootprint when no message body
ReduceMemoryFootprint will now properly detect that a message is
marshalled even if there is no message body so the headers can be
cleared out after message send
2017-09-15 10:11:46 -04:00
Timothy Bish 31f507001a This closes #259 2017-09-15 09:02:48 -04:00
Erik Wramner c691124d32 AMQ-6808 preserve destination for browsed scheduled messages 2017-09-15 09:02:36 -04:00
gtully a359d8152c [AMQ-6277] take account of producer audit not being updatated on recovery check, avoid unnecessary partial journal replay 2017-09-15 13:48:03 +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