Commit Graph

3642 Commits

Author SHA1 Message Date
Gary Tully 975fc55b2a https://issues.apache.org/jira/browse/AMQ-3332 - Make optimizeAckTimeout configurable to allow for different network latencies. Added attribute optimizeAcknowledgeTimeOut to ActiveMQConnectionFactory and ActiveMQConnection to make this configurble. A value of 0 disables, default stays at 300ms
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1125454 13f79535-47bb-0310-9956-ffa450edef68
2011-05-20 16:37:39 +00:00
Timothy A. Bish c1ebbc1465 Fix for: https://issues.apache.org/jira/browse/AMQ-3312
Replace usage of CopyOnWriteArraySet in the MBean methods that don't require a thread safe collection.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1125427 13f79535-47bb-0310-9956-ffa450edef68
2011-05-20 15:16:51 +00:00
Bosanac Dejan fd6c731690 https://issues.apache.org/jira/browse/AMQ-3135 - ConnectionInfo.clientIp - supporting duplex network case
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1124299 13f79535-47bb-0310-9956-ffa450edef68
2011-05-18 15:19:50 +00:00
Gary Tully 128a8f7a8e https://issues.apache.org/jira/browse/AMQ-3325 - PList temp store, chunk stream does not exist when broker under stress. Sync issue around temp store list creation for subs pending message cursor
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1104075 13f79535-47bb-0310-9956-ffa450edef68
2011-05-17 09:16:22 +00:00
Bosanac Dejan b5579ac1ca https://issues.apache.org/jira/browse/AMQ-3135 - add remote address to connection info advisory
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1103673 13f79535-47bb-0310-9956-ffa450edef68
2011-05-16 10:17:14 +00:00
Gary Tully 52d5189698 https://issues.apache.org/jira/browse/AMQ-3315 - Allow socket option soLinger to be enabled on TcpTransport. allow disable, soLinger == -1, disable, > -1 enable otherwise not set so system default
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1102232 13f79535-47bb-0310-9956-ffa450edef68
2011-05-12 10:22:20 +00:00
Gary Tully e8d45cb2d0 https://issues.apache.org/jira/browse/AMQ-3316 - Memory leak in ConnectionStateTracker with MessagePull objects. resolve typo
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1102023 13f79535-47bb-0310-9956-ffa450edef68
2011-05-11 19:01:04 +00:00
Gary Tully a1c19c5e49 https://issues.apache.org/jira/browse/AMQ-3316 - Memory leak in ConnectionStateTracker with MessagePull objects. Patch applied with thanks, good catch\!
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1102018 13f79535-47bb-0310-9956-ffa450edef68
2011-05-11 18:51:54 +00:00
Gary Tully 717bca1a40 https://issues.apache.org/jira/browse/AMQ-3272 - Handle RejectedExecutionException. In this case avoid the root cause, by allowing the semaphore to limit the enqueue tasks. Issue was in the cancel case locks were being release and the semaphore dropped while the executore queue still had the task pending, it needs to execute before the the samaphore can be released as it gates the task queue
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1102014 13f79535-47bb-0310-9956-ffa450edef68
2011-05-11 18:43:43 +00:00
Gary Tully 0aa5c2a889 https://issues.apache.org/jira/browse/AMQ-3315 - Allow socket option soLinger to be enabled on TcpTransport. url transport args ?soLinger=0 and ?transport.soLinger (for the broker accepted connectons) are now supported. a value > -1 enabled and sets the timeout to that value
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1101866 13f79535-47bb-0310-9956-ffa450edef68
2011-05-11 13:17:53 +00:00
Timothy A. Bish 3aaa1e73be fix for: https://issues.apache.org/jira/browse/AMQ-3306
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1101613 13f79535-47bb-0310-9956-ffa450edef68
2011-05-10 19:29:56 +00:00
Gary Tully 7e13a81851 https://issues.apache.org/jira/browse/AMQ-3314 - FilePendingMessageCursor isFull reports full in error when temp store is full, even if not needing the temp store. have cursor report full only if memory exhausted or temp usage exhausted and temp usage is needed
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1101544 13f79535-47bb-0310-9956-ffa450edef68
2011-05-10 17:15:02 +00:00
Gary Tully 842686a908 https://issues.apache.org/jira/browse/AMQ-2063 - JDBC persistence adapter improvements. make cleanup conditional on cleanupInterval > 0. Variants of the other improvements are already present on trunk
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1101109 13f79535-47bb-0310-9956-ffa450edef68
2011-05-09 16:55:51 +00:00
Gary Tully 0619a8757e https://issues.apache.org/jira/browse/AMQ-3310 - IOException PListStore "Could not locate data file" from FilePendingMessageCursor. Issue with reference counting and async location initialsation resulting in inuse data file removal and data file leaking. Pulled cleanup into task that periodically queries lists for references
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1101085 13f79535-47bb-0310-9956-ffa450edef68
2011-05-09 16:11:50 +00:00
Gary Tully d5813be360 https://issues.apache.org/jira/browse/AMQ-3305 - fix regression, only ask store for size while we are active, such that we don't get errors on stop
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1100959 13f79535-47bb-0310-9956-ffa450edef68
2011-05-09 11:08:14 +00:00
Gary Tully 1d242a2786 https://issues.apache.org/jira/browse/AMQ-3305 - add RecoveredTransaction JMX MBean to allow administrative heuristic completion of pending xa transactions. handy in the event of the transaction manager having trouble
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1100288 13f79535-47bb-0310-9956-ffa450edef68
2011-05-06 17:13:56 +00:00
Gary Tully 101e7110bc https://issues.apache.org/jira/browse/AMQ-3305 - Implement "exactly once" delivery with kahaDB and XA in the event of a failure post prepare.
Fixed up transaction broker recovery processing and kahadb store such that pending recovered
messages and acks wait for and respect the eventual xa transction outcome. Essentially
implementing exactly once delivery semantics on failure. Updated the camel jms to jdbc
test route to validate correct failure recovery processing with geronimo, test pulls in
xa wrappers from jencks and openejb such that NamedXAResources are registered with geronimo.
Additional unit tests added.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1100208 13f79535-47bb-0310-9956-ffa450edef68
2011-05-06 13:27:49 +00:00
Gary Tully ddca4cf590 null check in brokerSerice for jmx uri map and remove duplicated tests
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1100207 13f79535-47bb-0310-9956-ffa450edef68
2011-05-06 13:26:16 +00:00
Gary Tully 4fb190e444 verfication of discovered. params for static discovery
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1097793 13f79535-47bb-0310-9956-ffa450edef68
2011-04-29 12:40:27 +00:00
Gary Tully 12838c2811 https://issues.apache.org/jira/browse/AMQ-3300 - Add support for soWriteTimeout and soTimeout to ssl transport
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1097191 13f79535-47bb-0310-9956-ffa450edef68
2011-04-27 17:40:57 +00:00
Gary Tully c395917fa7 Ensure provided temp data store is started
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1097069 13f79535-47bb-0310-9956-ffa450edef68
2011-04-27 10:29:32 +00:00
Gary Tully adc45e8801 https://issues.apache.org/jira/browse/AMQ-3289 - ActiveMQ has problems storing >4K messages in Oracle - brought BlobAdapter up to speed and added @Override to other adapters to catch this sort of problem in the future
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1095376 13f79535-47bb-0310-9956-ffa450edef68
2011-04-20 11:52:50 +00:00
Gary Tully fe31092b54 https://issues.apache.org/jira/browse/AMQ-3288 - JDBC persistence adapter, intermittent performance degradation when a durable subscriber of priority messages falls behind. Store recovery was sometimes ignoring batch limit and would recover till memory limit was reached. Resolved issue with out or order delvery and immediatePriorityDelivery policy around memory limit boundaries. Resolved issue with over eager cleanup when priority and non priority destinations are mixed. Removed potential full table scan from cleanup. Resolved issue with null message ref (prefetch=0) and expiry. Added a bunch of corresponding tests
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1095352 13f79535-47bb-0310-9956-ffa450edef68
2011-04-20 10:39:25 +00:00
Timothy A. Bish 315b00fa14 fix for: https://issues.apache.org/jira/browse/AMQ-3278
fox for: https://issues.apache.org/jira/browse/AMQ-3271

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1094807 13f79535-47bb-0310-9956-ffa450edef68
2011-04-18 22:56:53 +00:00
Bosanac Dejan eb24079a93 https://issues.apache.org/jira/browse/AMQ-2774 - handling TransportDisposedIOException and making reconnection logic work in this case as well
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1094618 13f79535-47bb-0310-9956-ffa450edef68
2011-04-18 15:23:42 +00:00
Bosanac Dejan efcd57f60d https://issues.apache.org/jira/browse/AMQ-826 - ldap based authorization - add support for temp destinations
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1092098 13f79535-47bb-0310-9956-ffa450edef68
2011-04-14 10:27:59 +00:00
Bosanac Dejan 046130ef8e https://issues.apache.org/jira/browse/AMQ-826 - ldap based authorization - more fixes - support composite and easy advisory settings
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1091862 13f79535-47bb-0310-9956-ffa450edef68
2011-04-13 17:49:29 +00:00
Bosanac Dejan 26cf6a7f26 https://issues.apache.org/jira/browse/AMQ-826 - ldap based authorization - making tests work again, upgrading to apache ds 1.5.7, fixing ldif
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1091401 13f79535-47bb-0310-9956-ffa450edef68
2011-04-12 13:25:34 +00:00
Gary Tully 8a2892b9d0 https://issues.apache.org/jira/browse/AMQ-3276 - ConcurrentModificationException in embedded 5.5.0 broker. Rework https://issues.apache.org/jira/browse/AMQ-3219 - no need to set the context on thread creation as mdc impl uses an InheritableThreadLocal. This should avoid the concurrent mod, little test in mods to org.apache.activemq.bugs.AMQ2902Test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1090320 13f79535-47bb-0310-9956-ffa450edef68
2011-04-08 16:16:58 +00:00
Gary Tully 2c27e5edf2 add quick test variant to validate presence of mdc between threads
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1090318 13f79535-47bb-0310-9956-ffa450edef68
2011-04-08 16:16:27 +00:00
Bosanac Dejan 15de238fd6 https://issues.apache.org/jira/browse/AMQ-3272 - prevent RejectedExecutionException in kahadb
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1090186 13f79535-47bb-0310-9956-ffa450edef68
2011-04-08 10:22:40 +00:00
Bosanac Dejan 24ed4fe5ae https://issues.apache.org/jira/browse/AMQ-3275 - make udp protocol work
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1089864 13f79535-47bb-0310-9956-ffa450edef68
2011-04-07 12:59:24 +00:00
Bosanac Dejan 47833b7fb1 https://issues.apache.org/jira/browse/AMQ-3273 - file lock on win
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1089772 13f79535-47bb-0310-9956-ffa450edef68
2011-04-07 08:30:53 +00:00
Gary Tully 7fdd58e5b2 https://issues.apache.org/jira/browse/AMQ-3268 - Cannot use <SslContext> tag in blueprint configuration. Pull Resource from the api such that that string schema matches the java api. A resource is still used in the implementation such that a local or relative path or uri is supported
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1088944 13f79535-47bb-0310-9956-ffa450edef68
2011-04-05 09:47:19 +00:00
Gary Tully 951d87066c https://issues.apache.org/jira/browse/AMQ-3263 - ActiveMQ LoggingBrokerPlugin too verbose. add logSessionEvents attribute to split connection and session info. Patch applied with thanks
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1088631 13f79535-47bb-0310-9956-ffa450edef68
2011-04-04 14:09:30 +00:00
Bosanac Dejan 1760d1aefb https://issues.apache.org/jira/browse/AMQ-3262 - queue browser and message order
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1088593 13f79535-47bb-0310-9956-ffa450edef68
2011-04-04 12:27:11 +00:00
Gary Tully d55a3922c9 https://issues.apache.org/jira/browse/AMQ-3253 - Support Temporary Destinations in a network without advisories. Allow gc of regular destinations that have just network consumers, hub/spoke case with dynamic real reply destinations. policy entry: GcWithNetworkConsumers now applicable to all destinations. addition to https://issues.apache.org/jira/browse/AMQ-2571
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1088557 13f79535-47bb-0310-9956-ffa450edef68
2011-04-04 11:11:36 +00:00
Gary Tully 254d9209f5 https://issues.apache.org/jira/browse/AMQ-3253 - Support Temporary Destinations in a network without advisories. Support hub and spoke, such that two spokes can communicate. Revisit https://issues.apache.org/jira/browse/AMQ-2571 to make creating temp destinations on command configurable broker setAllowTempAutoCreationOnSend=true and allow temp destinations to be gced via gcInactiveDestinations policy
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1087912 13f79535-47bb-0310-9956-ffa450edef68
2011-04-01 21:56:34 +00:00
Gary Tully b9045dba98 https://issues.apache.org/jira/browse/AMQ-3253 - Support Temporary Destinations in a network without advisories. Allow the connection id generator prefix to be set via a connection factory such that temp identies can be configured such that they are suitable for inclusion in a network list of statically included destintions. Allow auto recreation of temp destinations by a new producer and tie lifecycle to the producers connection. This allows configurable support for request reply with temps in a network with advisory support disabled
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1087330 13f79535-47bb-0310-9956-ffa450edef68
2011-03-31 15:11:09 +00:00
Bosanac Dejan d8c142f1f4 https://issues.apache.org/jira/browse/AMQ-3249 - removing jaxb and stax from dependencies and distro
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1086566 13f79535-47bb-0310-9956-ffa450edef68
2011-03-29 12:32:34 +00:00
Gary Tully eb22a02563 https://issues.apache.org/jira/browse/AMQ-3236 - fix regression in MessageAckTest, ensure wireversion is used for marshaller test
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1086542 13f79535-47bb-0310-9956-ffa450edef68
2011-03-29 10:33:21 +00:00
Timothy A. Bish b0a38ff6c1 Update the test case so that its not dependent on port 61616
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1086378 13f79535-47bb-0310-9956-ffa450edef68
2011-03-28 20:10:41 +00:00
Gary Tully 442232514c [maven-release-plugin] prepare for next development iteration
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1086321 13f79535-47bb-0310-9956-ffa450edef68
2011-03-28 18:02:03 +00:00
Gary Tully c94de4230a [maven-release-plugin] prepare release activemq-5.5.0
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1086315 13f79535-47bb-0310-9956-ffa450edef68
2011-03-28 17:52:07 +00:00
Gary Tully 69ac6cc55e add missing license text
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1086294 13f79535-47bb-0310-9956-ffa450edef68
2011-03-28 16:30:46 +00:00
Bosanac Dejan 625f5e38a5 ExpiredMessagesWithNoConsumerTest failure on slow machines
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1086280 13f79535-47bb-0310-9956-ffa450edef68
2011-03-28 15:43:51 +00:00
Gary Tully 8443bd188a https://issues.apache.org/jira/browse/AMQ-3236 - preserve store compatability with new ack attribute. Only use version 7 openwire on the wire, persist using version 6 format. New ack cause attribute does not need to persist as it gets set in a DLQ message property. resolve regression - org.apache.activemq.store.amq.reader.AMQReaderTest.testIterateArchive
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1086277 13f79535-47bb-0310-9956-ffa450edef68
2011-03-28 15:41:18 +00:00
Gary Tully 41506505f4 https://issues.apache.org/jira/browse/AMQ-1780 - ActiveMQ broker does not automatically reconnect if the connection to the database is lost - extend the DefaultIOExceptionHandler http://activemq.apache.org/configurable-ioexception-handling.html to be aware of sql exceptions and provide a connector stop/resume option. This is now called in the event of a failure to get a jdbc connection, the default behaviour is to stop as before, but new iptions to ignore some sql exceptions or to stop/resume connectors are supported which allow a db restart to be recovered without restarting the broker
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1086182 13f79535-47bb-0310-9956-ffa450edef68
2011-03-28 11:00:06 +00:00
Timothy A. Bish 53f789b475 fix for: https://issues.apache.org/jira/browse/AMQ-3241
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1085773 13f79535-47bb-0310-9956-ffa450edef68
2011-03-26 17:24:27 +00:00
Timothy A. Bish bbd4b33646 On really slow machine this test can take a bit longer than the current timeout.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1085539 13f79535-47bb-0310-9956-ffa450edef68
2011-03-25 19:48:32 +00:00