summaryrefslogtreecommitdiff
path: root/qpid/java/client/src/main
Commit message (Collapse)AuthorAgeFilesLines
* QPID-6481: Move java source tree to top levelAlex Rudyy2015-04-15191-39760/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1673693 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6466: [Java Client] Avoid possibilty that the dispatcher and IO thread ↵Keith Wall2015-03-262-59/+68
| | | | | | can reject/release the same message during consumer close git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1669472 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6460, QPID-6460: [Java Client] Make task pool used for exception ↵Keith Wall2015-03-201-47/+24
| | | | | | | | | | reporting duties exactly one thread to serialise the callbacks Also, * name the task pool thread (for diagnostic purposes) * no longer forcedily shutdown the pool on close as an unexpected InterruptedException may corrupt an application's state git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1668000 13f79535-47bb-0310-9956-ffa450edef68
* QPID-6458: [Java Client] Prevent the client sending channel.flow (or ↵Keith Wall2015-03-181-1/+4
| | | | | | message.stop) after the session has been closed by the client git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667578 13f79535-47bb-0310-9956-ffa450edef68
* merge from trunkKeith Wall2015-03-0313-69/+259
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1663717 13f79535-47bb-0310-9956-ffa450edef68
* merged from trunkKeith Wall2015-02-139-46/+140
|\ | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1659606 13f79535-47bb-0310-9956-ffa450edef68
| * QPID-6374: [Java Broker] 0-10 Failover: the thread performing the failover ↵Keith Wall2015-02-139-46/+140
| | | | | | | | | | | | prep now syncs the dispatch queue (avoids possibility of app level dead lock) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1659605 13f79535-47bb-0310-9956-ffa450edef68
| * QPID-6374 : avoid taking a lock when not modifying a valueRobert Godfrey2015-02-121-12/+15
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1659341 13f79535-47bb-0310-9956-ffa450edef68
| * QPID-6387: [Java Client] Remove array optimisation from session/consumer mapsKeith Wall2015-02-115-173/+27
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1659103 13f79535-47bb-0310-9956-ffa450edef68
| * QPID-6347: Remove the now obsolete queue_event_generation option; this is a ↵Justin Ross2015-02-111-13/+0
| | | | | | | | | | | | patch from Irina Boverman git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1659063 13f79535-47bb-0310-9956-ffa450edef68
* | merged from trunk r1659391Robert Godfrey2015-02-126-198/+42
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1659392 13f79535-47bb-0310-9956-ffa450edef68
* | merge from trunkKeith Wall2015-02-105-178/+241
|\ \ | |/ | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1658748 13f79535-47bb-0310-9956-ffa450edef68
| * QPID-6374 : tidyup calls to connection task poolRobert Godfrey2015-02-102-44/+67
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1658714 13f79535-47bb-0310-9956-ffa450edef68
| * QPID-6374 : Always call exception listener from connection task pool, rather ↵Robert Godfrey2015-02-102-14/+31
| | | | | | | | | | | | than from within the failover mutex git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1658689 13f79535-47bb-0310-9956-ffa450edef68
| * QPID-6374 : Reorder ock aquisition and remove synchronization where it is ↵Robert Godfrey2015-02-103-128/+133
| | | | | | | | | | | | not desired to reduce deadlocks git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1658652 13f79535-47bb-0310-9956-ffa450edef68
| * QPID-6371: [Java Broker/Java Common] Prevent log4j warning during Broker startupKeith Wall2015-02-071-0/+6
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1658098 13f79535-47bb-0310-9956-ffa450edef68
| * QPID-6363: [Java Client] Register SASL mechanisms earlyKeith Wall2015-02-051-0/+12
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1657555 13f79535-47bb-0310-9956-ffa450edef68
* | Separate Byte and ProtocolEvent sender/receivers, add server specific 0-10 ↵Robert Godfrey2015-01-314-16/+13
| | | | | | | | | | | | encoder git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1656248 13f79535-47bb-0310-9956-ffa450edef68
| |
| \
*-. \ Merge from trunkKeith Wall2015-01-275-21/+147
|\ \ \ | | |/ | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1655057 13f79535-47bb-0310-9956-ffa450edef68
| | * QPID-6336: [Java Broker] Change 0-8..0-91 path to await the receiver being ↵Keith Wall2015-01-272-2/+80
| | | | | | | | | | | | | | | | | | | | | | | | closed before continuing with the next connection attempt Based on work by Oleksandr Rudyy <orudyy@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1655034 13f79535-47bb-0310-9956-ffa450edef68
| | * QPID-6294 : Fix issue whereby AUTO ACK receive consumer would only ever ↵Robert Godfrey2015-01-201-2/+5
| | | | | | | | | | | | | | | | | | receive one message since _currentPrefetch would never be zeroed git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1653293 13f79535-47bb-0310-9956-ffa450edef68
| | * QPID-6294 : [Java Client] Allow use of 0 prefetch in AMQP 0-8/9/9-1Robert Godfrey2015-01-022-18/+57
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1648987 13f79535-47bb-0310-9956-ffa450edef68
| | * QPID-5099 : [Java Client] release pre-acquired messages after explicit ↵Robert Godfrey2014-12-161-0/+6
| | | | | | | | | | | | | | | | | | consumer close git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1646009 13f79535-47bb-0310-9956-ffa450edef68
| * | Merge from trunkAidan Skinner2009-10-1117-62/+216
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@824198 13f79535-47bb-0310-9956-ffa450edef68
| * | QPID-2104 AMQProtocolHandler: hand the actual write off to a seperate threadAidan Skinner2009-09-181-2/+9
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@816612 13f79535-47bb-0310-9956-ffa450edef68
| * | QPID-2024 QPID-2105: Remove now unnecessary classes like Event, PoolingFilter, Aidan Skinner2009-09-174-61/+35
| | | | | | | | | | | | | | | | | | | | | | | | | | | ReadWriteThreadModel. Move the couple of necessary methods to Job. Fix imports. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@816232 13f79535-47bb-0310-9956-ffa450edef68
| * | QPID-2015: Remove AMQIoTransportProtocolSession. Release the executor ↵Aidan Skinner2009-09-162-146/+1
| | | | | | | | | | | | | | | | | | service in the same class as it's acquired git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@815729 13f79535-47bb-0310-9956-ffa450edef68
| * | QPID-2105: Make NetworkDriver.open use a SSLContextFactory, not an SSLEngine.Aidan Skinner2009-09-167-329/+248
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Allow an existing SocketConnector to be passed into a MINANetworkDriver, for use with the ExistingSocket bit of TransportConnection. Move the ExistingSocket stuff to one place, use MINANetworkDriver in TransportConnection and make AMQProtocolHandler implement ProtocolEngine. Remove MINA specific gubbins from AMQProtocolHandler and AMQProtocolSession. Move fireAsynchEvent to Job Add getLocalAddress to AMQProtocolEngine Move TestNetworkDriver to common Use correct class for logger in AMQProtocolEngine Check the exception is thrown properly in SimpleACLTest, make it a little less prone to obscure race conditions. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@815704 13f79535-47bb-0310-9956-ffa450edef68
| * | Merge from trunk Aidan Skinner2009-09-0911-114/+156
| | | | | | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@812936 13f79535-47bb-0310-9956-ffa450edef68
| * | QPID-2025: Add a AMQProtocolEngine from the de-MINAfied ↵Aidan Skinner2009-09-012-5/+9
| | | | | | | | | | | | | | | | | | AMQMinaProtocolSession. Remove various now-unused classes and update references. Add tests for AMQDecoder. Net -1500 lines, +25% performance on transient messaging. Nice. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@810110 13f79535-47bb-0310-9956-ffa450edef68
| * | QPID-2024: Add ProtocolEngine and NetworkDriver interfaces and a ↵Aidan Skinner2009-08-182-22/+1
| | | | | | | | | | | | | | | | | | NetworkDriver implementation that uses MINA. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@805477 13f79535-47bb-0310-9956-ffa450edef68
* | | Allow the transport to inform the model that encryption is being usedRobert Godfrey2014-12-111-0/+5
| |/ |/| | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644586 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-6205 : [Java Client] 0.8/0.9.x JMS client leaks transport threads and ↵Robert Godfrey2014-11-021-19/+26
| | | | | | | | | | | | sockets if connection cannot be established to the broker git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1636104 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-6206 : [Java Client] create new AMQDecoder for every reconnection attemptRobert Godfrey2014-10-312-2/+9
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1635855 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-6179 - [Java Client] Connection establishment can send invalid frame ↵Robert Godfrey2014-10-231-0/+3
| | | | | | | | | | | | sequence when retrying git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1633728 13f79535-47bb-0310-9956-ffa450edef68
* | NO-JIRA : removed unused constant which historically related to the use of ↵Robert Godfrey2014-10-211-1/+0
| | | | | | | | | | | | MINA as a transport git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1633425 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-6164 : Add synchronous publish capability to 0-8/9/9-1Robert Godfrey2014-10-177-25/+176
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1632585 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-6125 : [Java Broker] AMQP 0-8/9/9-1 protocol handler refactoringRobert Godfrey2014-10-178-415/+113
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1632583 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-6152: [Java Client] Allow connection/session close time to be ↵Keith Wall2014-10-141-47/+33
| | | | | | | | | | | | | | | | | | | | overridden by system property. Change implementation so that the timeout is applied individually to each session close, the connection and the shutdown of the task pool. Also moved the shutdown of the task pool to a finally, so that it occurs even if one or more sessions fail to close. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1631810 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-6088 : only reset the credit window if the credit window has been expandedRobert Godfrey2014-10-141-1/+4
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1631712 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3678 : [Java Client] Add support for setting link capacity to zero in ↵Robert Godfrey2014-09-233-17/+83
| | | | | | | | | | | | ADDR addresses git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1626995 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-6088 : [Java Client] AMQP 0-8/8/9-1 prefetch should auto expand when ↵Robert Godfrey2014-09-084-67/+151
| | | | | | | | | | | | receive is called in a situation where the prefetch buffer is full git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1623422 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-6066: [Java Client] 0-8..0-9-1 only - Add system property to allow ↵Keith Wall2014-09-031-1/+6
| | | | | | | | | | | | | | | | | | call to exchange.bound during AMQSession#getQueueDepth to be omitted This prevents interoperabiliy problem with older Java Brokers, and gives users a change to restore old behaviour (AMQChannelException in the event that the queue does not exist) if desired. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1622176 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-6052 : Address review comments from Robbie GemmellRobert Godfrey2014-09-014-270/+167
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1621826 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-6055 : [Java Broker] Ensure max frame size is always less than ↵Robert Godfrey2014-08-301-1/+1
| | | | | | | | | | | | Integer.MAX_VALUE git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1621498 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-6058 : [Java Client] The client does not fail with a sensible error ↵Robert Godfrey2014-08-301-0/+8
| | | | | | | | | | | | message if it tries to send a message header that is larger than the max frame size git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1621426 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-6052 : Use ADDR addresses for JMSDestination on incoming messages in ↵Robert Godfrey2014-08-2817-132/+252
| | | | | | | | | | | | 0-9-1 when the address mode is ADDR git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1621143 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-6040 : [Java Broker] [Java Client] add the ability to create a single ↵Robert Godfrey2014-08-265-32/+59
| | | | | | | | | | | | consumer that is consuming across a collection of queues git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1620659 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-6037 : [Java Client] Enhance experimental support for ADDR addressing ↵Robert Godfrey2014-08-2411-111/+399
| | | | | | | | | | | | to the 0-8/9/9-1 client git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1620147 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-6037 : [Java Client] Add experimental support for ADDR addressing to ↵Robert Godfrey2014-08-238-248/+653
| | | | | | | | | | | | the 0-8/9/9-1 client git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1620036 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status