summaryrefslogtreecommitdiff
path: root/java/common/src
Commit message (Collapse)AuthorAgeFilesLines
* 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
* Appologies for the sudden checkin without notice, close to the release cycle.Rajith Muditha Attapattu2008-11-216-135/+16
| | | | | | | Reverting the changes back. Will attach a patch and commit after the release. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@719657 13f79535-47bb-0310-9956-ffa450edef68
* This is related to QPID-1479.Rajith Muditha Attapattu2008-11-216-16/+135
| | | | | | | | | | | | | | | For starters I have changed the IoSender.java IoReceiver.java and AMQSession.java#Dispatcher to use the Thread factory to create the threads they require. The ThreadFactory has two implimentations, the default being the java.lang.Threads. The other is the RealtimeThreadFactory which uses reflection to create threads with a specific priority. -Dqpid.thread_factory=<thread_factory_class> will decide which thread factory should be loaded. -Dqpid.rt_thread_priority=<int> specifies the gloabl real time thread priority and defaults to 20. You could also set individual thread priorities by adding the nessacery config+code changes. I have also changed the Testkit and QpidBench to use the Thread factory so you could use them for testing/benchmarking work on RT JVMs. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@719628 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1463: Andrea's patchesArnaud Simon2008-11-197-224/+606
| | | | | | | | | | | | | - Added read / write methods on org.apache.qpid.transport.codec.Encoder / org.apache.qpid.transport.codec.Decoder; - Added the corresponding implementation on org.apache.qpid.transport.codec.BBEncoder / org.apache.qpid.transport.codec.BBDecoder - Added comments on org.apache.qpid.transport.codec.Encoder / org.apache.qpid.transport.codec.Decoder; - Removed org.apache.qpid.transport.codec.ManagementEncoder / org.apache.qpid.transport.codec.ManagementDecoder. - Added 6 data types (Int8, Int16, Int32, Int64, Double and Float); - Added type mappings with the data types above according to management specifications; - Removed all references to ManagementEncoder / Decoder classes; Now Qman is using (whenever is possible) Decoder / Encoder and when some specific method is needed then the BBDecoder / BBEncoder is used. - Some test case adjustment; git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@718949 13f79535-47bb-0310-9956-ffa450edef68
* updated version numbers and release notes for M4Rafael H. Schloming2008-11-151-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@714267 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1434 : Changed rethrow() name based on feedback from RobMartin Ritchie2008-11-062-45/+22
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@711848 13f79535-47bb-0310-9956-ffa450edef68
* QPID-1434 : Add ability to rethrow AMQExceptionsMartin Ritchie2008-11-061-0/+128
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@711820 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status