summaryrefslogtreecommitdiff
path: root/qpid/java/common
Commit message (Collapse)AuthorAgeFilesLines
...
* | QPID-3269Rajith Muditha Attapattu2011-07-084-18/+76
| | | | | | | | | | | | | | | | | | | | | | In order to verify the uniqueness of the client ID, a dummy session is created using client ID as it's name. This prevents any other connection from using same client ID as the session creation will fail. However this verification is switched off by default in order to preserve backwards compatibility. You need to use -Dqpid.verify_client_id=true switch verification on. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1144531 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3343: refactor test profiles to allow testing within the same JVM for ↵Robert Gemmell2011-07-0712-1922/+8
| | | | | | | | | | | | | | | | all protocols, remove vm:// transport support and associated forked Mina classes Applied patch by Keith Wall and myself git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1143874 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3342: transition TCP based Mina transport for 0-8/0-9/0-9-1 protocols ↵Robert Gemmell2011-07-0719-568/+919
| | | | | | | | | | | | | | | | over to new IO interface model Applied patch by Keith Wall and myself git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1143867 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3342: rationalise the existing 0-10 transport code and introduce new ↵Robert Gemmell2011-07-0714-273/+315
| | | | | | | | | | | | | | | | NetworkTransport + NetworkConnection abstraction. Decouple IoSender and IoReceiver, initiate their threads after the constructor completes. Applied patch by Keith Wall and myself git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1143866 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3341: remove unused/dead transport code and accompanying implementation ↵Robert Gemmell2011-07-0721-5140/+7
| | | | | | | | | | | | | | | | classes Applied patch by Keith Wall and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1143865 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3331: Update trunk versions to 0.13 for the next releaseJustin Ross2011-06-301-1/+1
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1141643 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3311 Committing a patch by Siddhesh PoyarekarRajith Muditha Attapattu2011-06-201-2/+8
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1137717 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-2158: add length validation into AMQShortString, remove dead code from ↵Robert Gemmell2011-06-076-38/+294
| | | | | | | | | | | | | | | | AMQDestinations, truncate exception messages with length over 255 before sending them over the wire in AMQChannelException and AMQConnectionException. Applied patch by Oleksandr Rudyy <orudyy@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1133037 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3261: decrease severity / improve clarity of log messages.Robert Gemmell2011-05-162-5/+5
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1103899 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3233Rajith Muditha Attapattu2011-05-031-1/+2
| | | | | | | | | | | | | | | | If the underlying AMQP session gets closed, the JMS session is now notified along with details that caused the session closure. The JMS Session will throw an exception (with an error code and details) when a user accesses the closed session. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1099288 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3205Rajith Muditha Attapattu2011-04-121-1/+29
| | | | | | | | | | | | | | Added the nessacery null checks to avoid a NPE due to missing delivery props or headers all together. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1091507 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3167: add a unit test of SimpleAMQQueue#processQueue to check delivery ↵Robert Gemmell2011-03-301-1/+11
| | | | | | | | | | | | when subscriptions with unique selectors are in use git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1087000 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3142: enable tests to run against a copy of an existing work directoryRobert Gemmell2011-03-151-1/+1
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1081858 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-2732Rajith Muditha Attapattu2011-03-081-1/+6
| | | | | | | | | | | | | | | | The reliability mode is now used on the producer side to determine replay. Any messages transfers sent to a destination marked unreliable will not be added to the replay buffer. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1079408 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-2985: Add producer configurable transaction timeoutsAndrew Donald Kennedy2011-03-081-0/+5
| | | | | | | | | | | | Port of QPID-2864 changes from 0.5.x-dev branch to trunk. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1079042 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3070: Do not send SessionCompleted with empty rangeAndrew Donald Kennedy2011-03-081-1/+4
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1079041 13f79535-47bb-0310-9956-ffa450edef68
* | NO-JIRA: increment version numbers from 0.9 to 0.11Robert Gemmell2011-03-071-1/+1
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1078729 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3098Rajith Muditha Attapattu2011-03-011-0/+1
| | | | | | | | | | | | | | | | This commit allows a MapMessage to accept an UUID object in it's setObject method. Added test cases for directly setting UUID objects or inside Maps and Lists that gets set into the MapMessage body. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1075961 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3029: Set channel and heatbeat max to correct valuesAndrew Donald Kennedy2011-02-181-5/+2
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1071972 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3065: Tidy up unused parts of DisassemblerAndrew Donald Kennedy2011-02-171-25/+5
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1071700 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3028: only hold the bytes for the cached string, instead of the entire ↵Robert Gemmell2011-02-172-1/+18
| | | | | | | | | | | | network read buffer array git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1071676 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3028: use a small array and companion HashMap to store the incomplete ↵Robert Gemmell2011-02-171-13/+42
| | | | | | | | | | | | Methods, rather than pre-allocating a 64000 entry array git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1071675 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3028: make assembler and disassembler use a static ThreadLocal for its ↵Robert Gemmell2011-02-173-7/+12
| | | | | | | | | | | | BBEncoder and BBDecoder, release buffer from BBDecoder when complete git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1071674 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3065: Send header and frame data as single bufferAndrew Donald Kennedy2011-02-171-10/+13
| | | | | | | | | | | | | | The Disassembler now fills a ByteBuffer with the entire frame contents before passing it to the Sender. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1071641 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3056: remove the unused SSL certificate, and then also the newly-empty ↵Robert Gemmell2011-02-141-0/+0
| | | | | | | | | | | | resources folder itself git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1070544 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3043Rajith Muditha Attapattu2011-02-111-1/+1
| | | | | | | | | | | | | | | | | | I had accidently marked the 'connectionLost' variable static. Removing the static identifier from the said variable. Thanks to Andrew Kennedy for spotting this. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1069858 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3043Rajith Muditha Attapattu2011-02-092-3/+23
| | | | | | | | | | | | | | Added the extra state 'RESUMING', to ensure that any new session creation is delayed until the connection is able to reattach all existing sessions. If a connection is reconnecting then it will first go to RESUMING state (instead of OPEN) in connection-open-ok. Once the 'resume' method in Connection.java is completed the state will be set to OPEN. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1069159 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-2994Rajith Muditha Attapattu2011-02-092-3/+16
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | The commit made in rev 1068661 will only close and throw an exception if the user tries to invoke an action (Ex sending a message or calling commit) on the transactional session while failover is in progress (i.e session in detached state). We also need to handle the case where the application is not doing anything during failover. But the application may still be in the middle of an uncommitted transaction. Therefore any session that is marked transactional should not be resumed. This commit removes tranactional sessions and close them inside the 'resume' method in Connection.java Any subsequent operation on this session will cause an exception being thrown, saying the session is closed. However the exception doesn't really contain the reason, other than to say the session is closed. The Java client in general needs a better error reporting scheme to convey more information to a client application. That will be handled under a separate JIRA. For the purpose of this JIRA the session being closed is good enough for the time being. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1069105 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3042Rajith Muditha Attapattu2011-02-091-0/+11
| | | | | | | | | | | | | | The createSession method in Connection.java now waits until the connection state == OPEN before it actually sends the session-attach on the wire. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1068696 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-2994Rajith Muditha Attapattu2011-02-081-1/+11
| | | | | | | | | | | | | | | | | | If the session is transactional, in the invoke method the session state is checked to see if it has dettached. If so the session is removed from the internal map maintained by the connection object. This prevents it from being resumed. An exception is also thrown notifying that failover may have happened in the middle of a transaction and the session is closed. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1068661 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3029: actually set and negotiate the supported max num channels per ↵Robert Gemmell2011-02-043-19/+61
| | | | | | | | | | | | connection during connection handshake. Enable/make the 0-10 client use channel numbers 0 to N-1 in line with the spec, rather than 1-N. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1067210 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3021: ensure the connection actor is used for connection control events ↵Robert Gemmell2011-02-044-0/+19
| | | | | | | | | | | | regardless of a particular sessions existence git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1067208 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-1670: Implement an UncaughtExceptionHandler to log exceptions causing ↵Robert Gemmell2011-02-046-34/+332
| | | | | | | | | | | | | | | | | | the permature termination of Qpid client threads. Applied patch from Keith Wall <keith.wall@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1067108 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3021: set the session/connection actor when the connection recieves new ↵Robert Gemmell2011-01-272-6/+2
| | | | | | | | | | | | events, ensure the correct thread logs close git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1064084 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-3010: ensure the SimpleByteBufferAllocator is always used and ↵Robert Gemmell2011-01-211-8/+8
| | | | | | | | | | | | non-direct ByteBuffers are the default, remove the old and now unused configuration methods from ServerConfiguration and update the example config.xml accordingly git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1061865 13f79535-47bb-0310-9956-ffa450edef68
* | While commiting a fix for QPID-2994 I accidently modified the timeout value.Rajith Muditha Attapattu2011-01-111-1/+1
| | | | | | | | | | | | | | I am restoring it to the original value. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1057927 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-2995Rajith Muditha Attapattu2011-01-111-0/+4
| | | | | | | | | | | | | | The redelivered flag is now set on messages that are restransmitted after failover. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1057462 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-2994Rajith Muditha Attapattu2011-01-111-3/+9
| | | | | | | | | | | | | | When the session is marked transactional, message transfers are not replayed. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1057460 13f79535-47bb-0310-9956-ffa450edef68
* | Increment version numbers from 0.7 to 0.8(docs) and 0.9(code)Robert Gemmell2010-11-071-1/+1
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1032374 13f79535-47bb-0310-9956-ffa450edef68
* | add ASF licence to various files in the java treeRobert Gemmell2010-10-311-0/+19
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1029523 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-2839 Add channel (CHN) Operational Loggin on 0-10Andrew Donald Kennedy2010-10-032-3/+3
| | | | | | | | | | | | Committed patch from SorinS <ssuciu@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1003985 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-2835 Implement CON Operational Logging on 0-10Andrew Donald Kennedy2010-10-033-14/+19
| | | | | | | | | | | | Committed patch from SorinS <ssuciu@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1003984 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-2857: Fix issue identified by running FindBugs across the codebase. ↵Robert Gemmell2010-10-011-4/+11
| | | | | | | | | | | | Close reader when it is no longer required git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1003479 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-2872: make the broker indicate a heartbeat max of 0sec to cause the ↵Robert Gemmell2010-09-261-1/+6
| | | | | | | | | | | | | | | | | | client disable heartbeating, as it otherwise enables the connection idle timeout by default and the broker cant generate them. Needed until QPID-2796 is undertaken to implement broker support for generating heartbeats. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1001544 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-2861Rajith Muditha Attapattu2010-09-211-1/+1
| | | | | | | | | | | | | | Adjusted the log message. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@999189 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-2876Rajith Muditha Attapattu2010-09-211-2/+2
| | | | | | | | | | | | | | Only message transfers are stored in the internal command array. This array is used for replaying after failover. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@999188 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-2781: move broker process name tagging default from the common qpid-run ↵Robert Gemmell2010-09-191-6/+0
| | | | | | | | | | | | used by multiple scripts, into the qpid-server script it is associated with git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@998696 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-2619: move echo of the broker PID from common qpid-run script used by ↵Robert Gemmell2010-09-191-1/+1
| | | | | | | | | | | | multiple scripts into qpid-server script. Change default pid filename to indicate association with qpid-server. Make filename configurable to allow choosing name e.g. for capturing pid of multiple servers" git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@998695 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-2861Rajith Muditha Attapattu2010-09-171-1/+11
| | | | | | | | | | | | | | | | Added a simple null check to eliminate acting on a result that is no longer valid. I am also adding a log message at "WARN" level if we receive a result for a command that is no longer in our map. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@997965 13f79535-47bb-0310-9956-ffa450edef68
* | QPID-2857 : Address issues found by running FindBugs against the Java codebaseRobert Godfrey2010-09-1223-73/+162
| | | | | | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@996393 13f79535-47bb-0310-9956-ffa450edef68