summaryrefslogtreecommitdiff
path: root/qpid/java/client
Commit message (Collapse)AuthorAgeFilesLines
...
* QPID-2347 broke some java tests; I believe these make incorrect assumptions ↵Gordon Sim2010-01-221-0/+1
| | | | | | about durable subscriptions and have changed them accordingly. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@902231 13f79535-47bb-0310-9956-ffa450edef68
* The commit contains fixes for QPID-2351, QPID-2350 and some ground work for ↵Rajith Muditha Attapattu2010-01-218-48/+95
| | | | | | | | | | | | | | QPID-2352 - Modified Connection.java to add more than one ConnectionListener. This was done to facilitate the SASL encryption patch - QPID-2352. - Changed the access modifier for getSaslClient method to "public" to allow the SaslClient to be retrieved by the SASL encryption code -QPID-2352. - Introduced ConnectionSettings object to hold all the configuration options. Previous constructor methods remains unchanged. - Modified the ClientDelegate to handle heartbeat and idelTimeout value properly. - Added support to specify config options via the connection URL - QPID-2351 - Added support to handle the heartbeat/idle_timeout options properly in the 0-10 code - QPID-2350. However once QPID-2343 is completed, the code will be further simplified. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901506 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2349 : Fixed Protocol Version negotiation. The Negotiated protocol ↵Martin Ritchie2010-01-203-2/+14
| | | | | | | | | version was not given to the ProtocolSession. Once this is done the correct delegate is enabled on connection. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901341 13f79535-47bb-0310-9956-ffa450edef68
* Added detailed instructions for running the individual examples. ↵Jonathan Robie2010-01-201-1/+272
| | | | | | Instructions are taken from the MRG Messaging Tutorial. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901241 13f79535-47bb-0310-9956-ffa450edef68
* Changed the setIdleTimeout method to take an int instead of a long.Rajith Muditha Attapattu2010-01-191-1/+1
| | | | | | | | The socket interface takes the so_timeout as an int and also the AMQP heartbeat interval is taken as an int. This change will help simplify the code that handles heartbeats. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@901000 13f79535-47bb-0310-9956-ffa450edef68
* This is a first step towards QPID-2343Rajith Muditha Attapattu2010-01-183-115/+2
| | | | | | | | The common module also contains code for the client, and therefore contains configuration required for the client to be accessible from within the common module. Therefore the ClientProperties.java is best be placed inside the common module. The goal is to have a place holder for all configuration properties. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@900595 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2340 : Fix ProducerFlowControlTest to call a synchronous operation ↵Robert Godfrey2010-01-141-0/+4
| | | | | | between sends (merged from 0.5-dev) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@899301 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2340 : Fix ProducerFlowControlTest to call a synchronous operation ↵Robert Godfrey2010-01-143-0/+12
| | | | | | between sends (merged from 0.5-dev) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@899296 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-2174Rajith Muditha Attapattu2010-01-122-5/+6
| | | | | | | | I couldn't find any straight forward way to grab the proper ID from the SASL client. Therefore I had to use the java GSSAPI classes to create a security context to grab the ID. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@898505 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-2336Rajith Muditha Attapattu2010-01-112-2/+10
| | | | | | | The fix allows an idle_timeout of zero to be set as the heartbeat interval with a warning message to say heartbeats are disabled. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@897922 13f79535-47bb-0310-9956-ffa450edef68
* Upped qpid version to 0.7 for next development cycleAndrew Stitcher2010-01-041-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@895789 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2273 : Fix Protocol NegotiationRobert Godfrey2009-12-187-13/+52
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@892301 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-1830Rajith Muditha Attapattu2009-12-171-3/+10
| | | | | | | | | I have removed the checkReadable() method from the toBodyString() This will enable the toString() method to be used any time on message. I have also modified the Functions.str() to take in an additional parameter to denote to the starting position of the buffer. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@891805 13f79535-47bb-0310-9956-ffa450edef68
* Update OSGI/Eclipse bundle versions and filenames for the 0.6 releaseRobert Gemmell2009-12-101-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@889271 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2258 : AMQP0-9-1 Compliance fixesRobert Godfrey2009-12-092-8/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@889022 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2242 : Update to 0-8 producer to set the JMS_QPID_DESTTYPE when sending ↵Martin Ritchie2009-12-081-1/+21
| | | | | | | | | | | messages. This update required a change to the FieldTable to clear any _encodedBuffer when setting a new value Provided test in JMSDestintationTest. This test requires a broker that supports both 0-8/9 and 0-10 as we must first use a 0-10 connection to send a message, which does not set JMS_QPID_DESTTYPE, then receive the message on 0-8/9. This allows us to validate that messages recieved without JMS_QPID_DESTTYPE set will can correctly set the value without a BufferOverflow Exception when simply forwarding the message. Excluded test from all cpp and InVM runs as test requires a 0-8/9 and 0-10 capable broker. Can reinstate to InVM when multiprotocol testing is capable. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@888345 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2242 : Update to the 0-8/9 code path to use the 0-10 static lookup ↵Martin Ritchie2009-12-074-109/+211
| | | | | | tables for the Destination type when JMS_QPID_DESTTYPE has not been set. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@887994 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2242 : Removed unused AMQMessagseDelegate_0_10 constructorMartin Ritchie2009-12-071-12/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@887951 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2242 : Fixed 0-10 code path's getJMSDestination() updated ↵Martin Ritchie2009-12-072-1/+6
| | | | | | | | | | | | JMSDestinationTest to cover more test cases: - Recieving a msg via Queue,Topic - Recieving a msg via Queue with a MessageListener - Recieving a msg on a queue that was sent to a topic, requires JMX interface to perform message move. Excluded test from 0-8 profile until the problem has been resolved git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@887948 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2192: restore erroneously removed setLinkedException()Aidan Skinner2009-12-031-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@886890 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2192: remove extraneous printStackTrace()sAidan Skinner2009-12-026-8/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@886031 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1849: actually pass through parameterAidan Skinner2009-11-111-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@835135 13f79535-47bb-0310-9956-ffa450edef68
* ensure only passive declares of amq.* exchangesRafael H. Schloming2009-11-011-3/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@831671 13f79535-47bb-0310-9956-ffa450edef68
* Reverted removal of client log4j.xml from 828019Martin Ritchie2009-10-271-0/+36
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@830102 13f79535-47bb-0310-9956-ffa450edef68
* Added AMQP 0-9-1 supportRobert Godfrey2009-10-266-2/+214
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@829944 13f79535-47bb-0310-9956-ffa450edef68
* Merged from java-broker-0-10 branchRobert Godfrey2009-10-259-67/+80
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@829675 13f79535-47bb-0310-9956-ffa450edef68
* Extension of publisher class for TopicsMarnie McCormack2009-10-231-0/+59
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@829106 13f79535-47bb-0310-9956-ffa450edef68
* Fix for large files in FileMessageFactory, changes to Publisher to make ↵Marnie McCormack2009-10-233-13/+181
| | | | | | topic publication easier, added MultiMessageDispatcher class to allow parameterised sending of messages to a queue or a topic git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@829102 13f79535-47bb-0310-9956-ffa450edef68
* Update PropertiesFileInitialContextFactory to give more details on error.Martin Ritchie2009-10-212-37/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@828019 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1859 - Converted System.out.println to _logger.info.Martin Ritchie2009-10-191-5/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@826646 13f79535-47bb-0310-9956-ffa450edef68
* Remove Java 1.6 @Overrides on interface implmentationsMartin Ritchie2009-10-191-5/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@826639 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1816 : When client fails over due to an error, that error is still held ↵Martin Ritchie2009-10-192-0/+22
| | | | | | bt the StateManager and will prvent the connection from working. During failover check and see if the Connection had been marked closed if so remove any set exception. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@826638 13f79535-47bb-0310-9956-ffa450edef68
* Merge java-network-refactor branchAidan Skinner2009-10-1511-567/+285
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@825362 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1950 : Simplified the connection by using the default URL and ↵Martin Ritchie2009-10-131-2/+10
| | | | | | | | configuring retry rather than using the default failover URL that has multiple brokers defined. Whilst this may not stop the test failing it will make the log files simpler. Updated FailoverHandler to ensure that any pending write is sync'd if possible. Also updated Test to perform a synchronous operation after the ack to ensure it arrives at the broker, QPID-2138 highlights that it doesn't get there due to what appears to be Mina propagating the exception ahead of the data. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@824704 13f79535-47bb-0310-9956-ffa450edef68
* Fix compiler compliance levels, not allowed @Override on interfaces in 1.5Aidan Skinner2009-10-113-3/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@824129 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1440 : Code review changes from QPID-1289. All actioned except adding ↵Martin Ritchie2009-10-087-24/+53
| | | | | | new createConsumer() method. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@823149 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1950 : Problem is that the thrown exception whilst an IOException does ↵Martin Ritchie2009-10-081-0/+11
| | | | | | not signify that the socket has closed. So the broker had two open connections to send messages on. Change was to ensure that the previous Socket/IOSession has been closed before failover starts. Also added protected to ChannelOpenHandler to guard against out of order frames causing a NPE. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@823087 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1816 : Add Acknowledge tests and QuickAcking manual test helper.Martin Ritchie2009-10-051-1/+12
| | | | | | Updated AcknowldegeAfterFailoverTest to correctly cover the failure cases. Sending messages on a dirty transaction and Receiveing messagges on a dirty session. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@821824 13f79535-47bb-0310-9956-ffa450edef68
* Fix for dirty sessions, start to test that sessions are dirty when required.Martin Ritchie2009-10-051-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@821823 13f79535-47bb-0310-9956-ffa450edef68
* Updated BlockingWaiter to provided more details when a new exception arrives ↵Martin Ritchie2009-10-051-1/+1
| | | | | | and the old one has not been consumed git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@821817 13f79535-47bb-0310-9956-ffa450edef68
* QPID-942 : Add Simplistic Producer Flow Control to the java Broker / java ↵Robert Godfrey2009-10-012-7/+37
| | | | | | 0-8/0-9 client git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@820739 13f79535-47bb-0310-9956-ffa450edef68
* Improve error reporting when commit failedMartin Ritchie2009-09-281-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@819592 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1871 : Updated RollbackOrderTest to include an onMessage test. Fixed ↵Martin Ritchie2009-09-283-19/+58
| | | | | | | | deadlock issue with 0-10 rollback method and onMessage usage. Moved 0-10 rollback strategy to the abstract AMQSession and updated 0-8 to use that approach. 0-8 Still excluded from test runs as the race condition is not that the dispatcher would hold a message and reject after the TxRollback. The problem is the Java Broker sends a message out after the FlowOk message so the Dispatcher then sits on it, see QPID-2116. This exact problem was hidden due to the way the Dispatcher is stopped. This problem has not been addressed. The request to stop the dispatcher can only actually stop the dispatcher whilst it is in the middle of processing a message. The stop needs to interrupt the _queue.take() and hold the dispatcher AFTER the processing of any message that it needs to do: see QPID-2117. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@819590 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1956Rajith Muditha Attapattu2009-09-221-5/+5
| | | | | | | I had missed this bit when I committed last night. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@817867 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-1956Rajith Muditha Attapattu2009-09-221-2/+11
| | | | | | | | Added a check in the getNextBrokerDetails method to return null when the current broker equals the only remaining broker in the list A test case for this will be added once I finalized the test case for the failover exchange method git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@817487 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-2114 Rajith Muditha Attapattu2009-09-221-1/+1
| | | | | | | I have also added a simple check for the default message priority in an existing test in JMSPropertiesTest git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@817478 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-2113Rajith Muditha Attapattu2009-09-221-0/+36
| | | | | | | | | | | I didn't meddle with the existing log4j.properties file present in the common module as it maybe used in the broker. However a cursory glance at the etc directory revealed that the the broker too has a log4j.xml file. So perhaps the log4j.properties files in the common module is not really needed. (The settings given i the log4j.xml under the client module could be overriden by explicitly specifying a log4.xml file using -Dlog.configuration property) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@817457 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1809, QPID-2081 : Corrected ChannelClose logic. Removed an unnecessary ↵Martin Ritchie2009-09-072-57/+63
| | | | | | sync on the failoverMutex in AMQSession that was causing the notification of the close to be blocked until a TimeOutException occured. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@812153 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2081, QPID-155 : Updated AMQSession to allow queue/exchange decare to ↵Martin Ritchie2009-09-061-2/+2
| | | | | | be set on a per session basis git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@811748 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2081, QPID-155 : Provide a test for Dynamic Queue/Exchange toggling and ↵Martin Ritchie2009-09-041-2/+16
| | | | | | fixed the issue with ChannelCloseExceptions by closing the channel and not sending the ChannelClose when the Channel has already been closed by the broker. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@811472 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status