summaryrefslogtreecommitdiff
path: root/java/common/src
Commit message (Collapse)AuthorAgeFilesLines
...
* fixed session memory leak exposed by SessionCreateTestRafael H. Schloming2009-07-251-2/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@797705 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1992 : Addition of new Broker Logging FrameworkMartin Ritchie2009-07-222-78/+184
| | | | | | | | | | | | | | | | | | | | | | | | | | | Provided static CurrentActor for accessing ThreadLocal. Included Test to validate setting of ThreadLocals. Added Test for AMQPActor Added getRootMessageLogger() to IApplicationRegistry Adjusted *ProtocolSessions to start counting at 0. Allowed Setting of Vhost on the MockProtocolSession Created a fixed Principle in MockProtocolSession Changes to MockProtocolSession, prevent NPEs when the AMQPActor creates its log string. Converted CurrentActor to use a Stack allowing a variety of actors to take their turn on a thread. Improved package structure Added testing for Actors Moved FileMonitorTools functionality to FileUtils and provided a Test Converted Log4jMessageLoggerTest to a proper UnitTest Moved Test cases to test package Updated other broker tests to set the authenticated user before setting the virtualhost, Whilst the logging could output null as the username it would be better if the tests correctly set the authorizedID. Update to include tests for disabled logging Fully tested LogSubjects Updated MockAMQQueue to be able to take a Virtualhost as per a normal Queue. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@796650 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1797: update bundle version format and output filenames, modify ant ↵Robert Gemmell2009-07-111-2/+2
| | | | | | | | | bundle task only to run for required modules git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@793184 13f79535-47bb-0310-9956-ffa450edef68
* fixed hang in SSL client, ssl profile still fails due to port conflicts, but ↵Rafael H. Schloming2009-07-012-14/+24
| | | | | | it should no longer hang git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@790161 13f79535-47bb-0310-9956-ffa450edef68
* cleaned up extraneous whitespaceRafael H. Schloming2009-06-302-83/+83
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@789887 13f79535-47bb-0310-9956-ffa450edef68
* made test ports configurable; this required adding variable expansion to ↵Rafael H. Schloming2009-06-181-0/+144
| | | | | | PropertiesFileInitialContextFactory git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@786269 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1893: echo back a heartbeat when we receive oneRafael H. Schloming2009-06-081-0/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@782633 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1875Rajith Muditha Attapattu2009-05-281-1/+1
| | | | | | | | The BindingURLParser is updated to grab the clientID and subscription to form the queue name. I also added a test case to cover this. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@779651 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1854Rajith Muditha Attapattu2009-05-141-1/+8
| | | | | | | | | The sender.close is now surrounded with a try catch to handle the exception thrown by the IoSender.close(). The ideal situation would have been to pass false to the IoSender.close(boolean reportException) method which will then not throw the exception up the stack. But that method is not exposed in the Sender interface. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@774817 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1853. Since the socket is being closed inside the ↵Rajith Muditha Attapattu2009-05-141-1/+0
| | | | | | finnaly block we can remove the socket.close after the while loop inside the run method. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@774812 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-1857Rajith Muditha Attapattu2009-05-131-0/+2
| | | | | | | We now create a new session id, instead of reusing the same when it tries to attach the session after failover. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@774452 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-1854Rajith Muditha Attapattu2009-05-131-0/+1
| | | | | | | | I have added a sender.close() inside the closed() method in the Connection.java This ensures the sender is closed and the IoSender thread is shutdown gracefully. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@774305 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-1853. We now close the socket in the finnally block.Rajith Muditha Attapattu2009-05-131-0/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@774297 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1839Rajith Muditha Attapattu2009-05-041-2/+12
| | | | | | | | | I added a timeout (that could be configured via qpid.ssl_timeout if needed) to notify the application, 1) if the broker fails to respond in a timely manner 2) if there was an error and the broker has already closed the connection. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@771470 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1803 : Fixed potential NPE in FileUtils.deleteMartin Ritchie2009-04-101-2/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@764076 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1798: Update AMQQueueMBean to use new constant value of DeliveryMode, ↵Robert Gemmell2009-04-101-0/+4
| | | | | | replacing previously incorrect literal value used in conditional statement and thus preventing the reversal of delivery mode status. Also update other broker classes making similar comparisons using a literal value to use a constant git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@764026 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-1773Rajith Muditha Attapattu2009-03-241-1/+14
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@758017 13f79535-47bb-0310-9956-ffa450edef68
* This is to correct a mistake pointed out in the dev listRajith Muditha Attapattu2009-03-241-1/+1
| | | | | | | | The method connect(host, port, vhost, username, password, false,"PLAIN"); is using the hardcoded value false for the ssl paramter. This commit modified the code to use ssl as the parameter instead. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@757640 13f79535-47bb-0310-9956-ffa450edef68
* Fix for QPID-1761 and QPID-1762: made BBEncoder.grow() flip the buffer ↵Rafael H. Schloming2009-03-202-0/+58
| | | | | | before copying; added a BBEncoder test; made unrecognized mime types default to BytesMessage; added logging of exception root cause to AMQSession; fixed miscelaneous test failures git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@756328 13f79535-47bb-0310-9956-ffa450edef68
* These classes are not used in any meaningful way.Rajith Muditha Attapattu2009-03-191-200/+0
| | | | | | | I am removing them to avoid any confusion they may cause. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@756231 13f79535-47bb-0310-9956-ffa450edef68
* Removed false positive return from FU.delete(). Delete mirrors functionality ↵Martin Ritchie2009-03-092-8/+16
| | | | | | provided by java.io. Attempting to delete an non-existent file returns false. The caller must handle this correctly. If client provides a null value then the call will throw a NPE which is a valid java response. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@751720 13f79535-47bb-0310-9956-ffa450edef68
* FileUtils would report a failure to delete a non-existent fileMartin Ritchie2009-03-092-2/+12
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@751636 13f79535-47bb-0310-9956-ffa450edef68
* FileUtils : Was not correctly handling the case where a File object became ↵Martin Ritchie2009-03-061-7/+8
| | | | | | null, it would previously have thrown a NPE which was erroneously caught this and declared the delete to have failed. If there is nothing to delete (signified by the Null File object) then the delete should pass. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@750946 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1708: go into CLOSED instead of DETACHED state when there is an ↵Rafael H. Schloming2009-03-032-3/+60
| | | | | | execution exception git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@749740 13f79535-47bb-0310-9956-ffa450edef68
* Added check for when file reference becomes null, occurs if the file is ↵Martin Ritchie2009-03-021-3/+8
| | | | | | externally deleted. Also noted success return value was never propogated correctly, Updated : Test needed. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@749330 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1701: fixed potential deadlock on connection closeRafael H. Schloming2009-02-272-3/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748594 13f79535-47bb-0310-9956-ffa450edef68
* don't block unreliable commands during resumeRafael H. Schloming2009-02-261-1/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@748119 13f79535-47bb-0310-9956-ffa450edef68
* Made the various receive variants check that the server queue is empty ↵Rafael H. Schloming2009-02-256-10/+43
| | | | | | before returning null. Also modified AMQQueueBrowser to use receiveNoWait() when browsing queues using 0-10. These changes uncovered numerous second order bugs, mostly in failover. These are also fixed. This fixes QPID-1642 and QPID-1643. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747963 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1665: add a timer to ensure message acking is never delayed more than ↵Rafael H. Schloming2009-02-192-1/+25
| | | | | | 1000 ms by default, this is configurable by qpid.session.max_ack_delay git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@745892 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1658: added a byte limit for the number of commands in the session ↵Rafael H. Schloming2009-02-112-3/+25
| | | | | | replay buffer, and made the buffer length configurable git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@743455 13f79535-47bb-0310-9956-ffa450edef68
* Merge branch 'QPID-1583'Aidan Skinner2009-02-111-2/+1
| | | | | | | Conflicts: qpid/java/common/src/main/java/org/apache/qpid/util/NetMatcher.java git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@743304 13f79535-47bb-0310-9956-ffa450edef68
* Change package, remove dependency on Java DNS serverAidan Skinner2009-02-101-5/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@743029 13f79535-47bb-0310-9956-ffa450edef68
* Borrow NetMatcher from JAMES. Should probably be moved to commons-net at ↵Aidan Skinner2009-02-101-0/+264
| | | | | | some point. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@743015 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1652 : Created MessagePublishInfoImpl and Unit Test, removed the ↵Martin Ritchie2009-02-094-89/+187
| | | | | | several annoynmous classes that did all the same work. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@742496 13f79535-47bb-0310-9956-ffa450edef68
* Missed the modifications to FailoverRoundRobinServers.java during the commit ↵Rajith Muditha Attapattu2009-02-091-2/+0
| | | | | | | | | for QPID-1649 Missed the modifications to ServerDelegate during the cleanup done in rev 742269 git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@742278 13f79535-47bb-0310-9956-ffa450edef68
* Removing unused classes from the great refactoring period.Rajith Muditha Attapattu2009-02-098-858/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@742269 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1645Rajith Muditha Attapattu2009-02-092-5/+19
| | | | | | | | | Added support to specify the sasl_mechs as a space separated list in the connection URL. By default it will use PLAIN. You could provide a list of mechs to support or force to use one GASSAPI or CRAM-MD5 by specifying only that in the connection URL. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@742267 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1646: implemented handlers for producer flow control signalsRafael H. Schloming2009-02-053-4/+92
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@741024 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1609.Rajith Muditha Attapattu2009-01-2310-37/+112
| | | | | | | | Currently we only check idle state on the incomming side. In the future we plan to add code to send a heartbeat when we reach the idle state on the outgoing side. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@737125 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1605: added an assertion to catch acknowledgments of message-ids ↵Rafael H. Schloming2009-01-211-0/+7
| | | | | | outside the range permitted on a session; added code to pause failover until messages from old sessions have been cleared out of the dispatcher queue git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736316 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1603: ignore incoming heartbeat controlsRafael H. Schloming2009-01-202-0/+14
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736109 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1479Rajith Muditha Attapattu2009-01-137-16/+184
| | | | | | | This commit contains the core classes for adding the thread abstraction patch git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734205 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-1571Rajith Muditha Attapattu2009-01-131-3/+41
| | | | | | | | After M4 release we should probably revisit the SSL close logic. The current fix was done with causing as less impact as possible on the tested code paths. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734160 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1557: fixed the cpp.cluster test profileRafael H. Schloming2009-01-062-2/+11
| | | | | | | | | | | | | | | | | | | | | | - pulled out the XA excludes into a separate excludes file - made the cluster profile exclude the XA tests - made the build system automatically set all system properties that start with profile - added a profile.clustered property that defaults to false - made the cpp.cluster test profile set the profile.clustered property to true - modified the failover tests to exclude some erroneous asserts if the broker is clustered - modified the java client to not advertize a non-zero timeout git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@731810 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1549: don't throw not implemented when we get a flush with the expected ↵Rafael H. Schloming2008-12-233-2/+35
| | | | | | bit set git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@729118 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1547: ignore socket closed exceptions if shutdownInput is brokenRafael H. Schloming2008-12-231-3/+12
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@729021 13f79535-47bb-0310-9956-ffa450edef68
* Added the ASF license header to the following files.Rajith Muditha Attapattu2008-12-162-0/+39
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@726943 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1499 : Modification to IoAcceptor so ConnectionTest can close the open ↵Martin Ritchie2008-12-022-6/+21
| | | | | | SocketServer. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@722669 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1487: remove dead files, make BindingURLParser use the right class for ↵Aidan Skinner2008-11-265-832/+1
| | | | | | logging since it was using one that is being removed. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@720920 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1251 : Applied patch from JIRA (With correct code style). Augemented ↵Martin Ritchie2008-11-242-13/+87
| | | | | | ConnectionTest to correctly test for the special os.name = windows case. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@720200 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status