summaryrefslogtreecommitdiff
path: root/java/common
Commit message (Collapse)AuthorAgeFilesLines
...
* QPID-1006 and QPID-1007: -QPID-1006:use same socket buffer size and frame ↵Arnaud Simon2008-05-051-4/+64
| | | | | | size -QPID-1007: added io write handler into MINA chain git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@653354 13f79535-47bb-0310-9956-ffa450edef68
* QPID-988 and QPID-989: fixes to framing for final 0-10 specGordon Sim2008-04-304-2/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@652386 13f79535-47bb-0310-9956-ffa450edef68
* QPID-984: override MINA's IoServiceListenerSupport class in order to fix ↵Rafael H. Schloming2008-04-291-0/+351
| | | | | | infinite loop git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@652170 13f79535-47bb-0310-9956-ffa450edef68
* QPID-832 : Fix eol-styleRobert Godfrey2008-04-2438-5810/+5810
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@651325 13f79535-47bb-0310-9956-ffa450edef68
* QPID-832 nuke some obsolete stuffAidan Skinner2008-04-241-125/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@651134 13f79535-47bb-0310-9956-ffa450edef68
* QPID-832 merge M2.xAidan Skinner2008-04-2474-1261/+8921
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@651133 13f79535-47bb-0310-9956-ffa450edef68
* QPID-901: update pom to work with new codegenRafael H. Schloming2008-04-183-6/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@649648 13f79535-47bb-0310-9956-ffa450edef68
* QPID-901: updates to the java client to use the 0-10 final spec instead of ↵Rafael H. Schloming2008-04-1642-1044/+1493
| | | | | | the 0-10 preview spec; this includes improvements to the codegen process as well as some modifications to the shared code path in the client to not lose per message state when consumers are closed. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@648692 13f79535-47bb-0310-9956-ffa450edef68
* This is a fix for QPID-911.Rajith Muditha Attapattu2008-04-091-0/+2
| | | | | | | When the message id is set, _hasBeenUpdated will be set to true. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@646519 13f79535-47bb-0310-9956-ffa450edef68
* QPID-829 Remove 0.10 specific URL. The code path is now selected based on ↵Arnaud Simon2008-04-027-4/+116
| | | | | | broker response. We first try the highest protocol version and update the handler if the broker replies with a different protocol version. NOTE that we need to update the current java broker and 0.8 client for handling protocol headers. This should happen with the M2.1 merge. For the moment we only support an in VM 0.8 broker. Moreover, we'll need to migrate to a 0.10 vs 99.0 protocol version. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@643822 13f79535-47bb-0310-9956-ffa450edef68
* Changed construtor serialbits type, was double should be long (ref qpid-861)Arnaud Simon2008-03-261-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@641304 13f79535-47bb-0310-9956-ffa450edef68
* Qpid-861: Java RFC 1982 implementation + Junit testsArnaud Simon2008-03-263-0/+275
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@641212 13f79535-47bb-0310-9956-ffa450edef68
* make build.xml files backward-compatible with ant 1.6.5, by replacing ant ↵Nuno Santos2008-03-241-5/+5
| | | | | | 1.7 specific tasks/extensions git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@640503 13f79535-47bb-0310-9956-ffa450edef68
* Revision 636791 says: "Added constant to represent the AMQP versions, as ↵Arnaud Simon2008-03-181-1/+1
| | | | | | previously it was hard-coded." Those constants must be used when the connection is established. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@638344 13f79535-47bb-0310-9956-ffa450edef68
* Added constant to represent the AMQP versions, as previously it was hard-coded.Rajith Muditha Attapattu2008-03-132-1/+8
| | | | | | | | Modified the ConnectionDelegate to use the Constants for AMQP version. Also the version cosntants were changed to 99-0 to work with the c++ broker until the 0-10 framing gets completed. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@636791 13f79535-47bb-0310-9956-ffa450edef68
* Changed host name to localhost so the test can run on Windows (see QPID-836)Arnaud Simon2008-03-071-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@634673 13f79535-47bb-0310-9956-ffa450edef68
* Correct the constant OPTION_BINDING_KEY that resulted in a test case failureRajith Muditha Attapattu2008-02-273-15/+24
| | | | | | | | | Modified the AMQBindingURL to fix an error in the toString method Added more test cases to the main method in the BindingURLParser for quick testing, these cases are also present as unit tests. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@631695 13f79535-47bb-0310-9956-ffa450edef68
* Added a new parser for the BindingURL.Rajith Muditha Attapattu2008-02-273-132/+506
| | | | | | | | | This allows adding multiple binding keys, using # and * in the URLs. This is tracked via QPID-814 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@631489 13f79535-47bb-0310-9956-ffa450edef68
* combined test cases and eliminated race conditionRafael H. Schloming2008-02-211-12/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@629991 13f79535-47bb-0310-9956-ffa450edef68
* added flag for tagging header without a payloadArnaud Simon2008-02-213-5/+13
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@629747 13f79535-47bb-0310-9956-ffa450edef68
* fixed logging of message DataRafael H. Schloming2008-02-131-1/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@627607 13f79535-47bb-0310-9956-ffa450edef68
* synchronize access to lastWrite futureRafael H. Schloming2008-02-121-4/+11
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@627154 13f79535-47bb-0310-9956-ffa450edef68
* fixed computation of ranged acks, fix needed for failing RecoverTestRafael H. Schloming2008-02-111-5/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@620584 13f79535-47bb-0310-9956-ffa450edef68
* added test for exception listener; fixed NPERafael H. Schloming2008-02-072-21/+52
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@619538 13f79535-47bb-0310-9956-ffa450edef68
* Added code to pass in the throwable to the closedListener so that it can be ↵Rajith Muditha Attapattu2008-02-061-1/+1
| | | | | | included in the JMS Exception thrown via the ExceptionListener git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@619189 13f79535-47bb-0310-9956-ffa450edef68
* added close notificationRafael H. Schloming2008-02-066-16/+78
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@619182 13f79535-47bb-0310-9956-ffa450edef68
* Added code to connect the network error exceptions to the JMS Exception ↵Rajith Muditha Attapattu2008-02-051-1/+2
| | | | | | listener. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@618519 13f79535-47bb-0310-9956-ffa450edef68
* added a TransportExceptionRafael H. Schloming2008-02-043-1/+132
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@618462 13f79535-47bb-0310-9956-ffa450edef68
* added exception callback to ConnectonDelegateRafael H. Schloming2008-02-0411-2/+43
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@618437 13f79535-47bb-0310-9956-ffa450edef68
* ant build systemRafael H. Schloming2008-02-012-0/+106
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@617320 13f79535-47bb-0310-9956-ffa450edef68
* fixed svn:executable and svn:eol-styleRafael H. Schloming2008-01-311-0/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@617303 13f79535-47bb-0310-9956-ffa450edef68
* changed default port value for tcpArnaud Simon2008-01-301-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@616715 13f79535-47bb-0310-9956-ffa450edef68
* added support to notify connection.close to the JMSExceptionListenerRajith Muditha Attapattu2008-01-291-13/+12
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@616542 13f79535-47bb-0310-9956-ffa450edef68
* Changed version to M3 to avoid confusion with old M2 snapshotsRajith Muditha Attapattu2008-01-251-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@615264 13f79535-47bb-0310-9956-ffa450edef68
* replaced printlns with debug statementsArnaud Simon2008-01-181-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@613166 13f79535-47bb-0310-9956-ffa450edef68
* Please refer JIRA's 739,740 and 741 for more information about the issues.Rajith Muditha Attapattu2008-01-161-1/+8
| | | | | | | | | | | | | | | | | | | | AMQDestination Renamed the destinationName to routingKey as it is incorrectly used. Also modified it to recognize fannout exchange AMQQueue Modified to return the proper routing key to support situations where the queue name and the routing key is different. BasicMessageProducer_0_10.java Added a temp hack to interoperate with python. The bug is in python and it needs to be fixed. Basically python relies on the content length to pass the content frames properly. So I added a line to calculate the content length and sets it in the message properties. The rest was modified to reflect the change done in AMQDestination. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@612581 13f79535-47bb-0310-9956-ffa450edef68
* removed an empty java fileRafael H. Schloming2008-01-091-0/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@610614 13f79535-47bb-0310-9956-ffa450edef68
* chshed headers: see QPID-720Arnaud Simon2008-01-047-20/+60
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@608838 13f79535-47bb-0310-9956-ffa450edef68
* I noticed that the asString() method will rebuild the string from scratch ↵Rajith Muditha Attapattu2008-01-021-6/+16
| | | | | | each time. So I cached the String and the char[] after it builds the first time. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@608147 13f79535-47bb-0310-9956-ffa450edef68
* changed MINA threading modelArnaud Simon2007-12-041-7/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@600861 13f79535-47bb-0310-9956-ffa450edef68
* removed useless lockArnaud Simon2007-12-041-14/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@600860 13f79535-47bb-0310-9956-ffa450edef68
* fixed the error in receivingRajith Muditha Attapattu2007-12-031-3/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@600599 13f79535-47bb-0310-9956-ffa450edef68
* merged the three writes in a single oneArnaud Simon2007-12-031-10/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@600501 13f79535-47bb-0310-9956-ffa450edef68
* Added a very basic plain nio transport. You could flip between the ↵Rajith Muditha Attapattu2007-11-303-0/+225
| | | | | | | | | transports using -Dtransport="nio". By default it's the MINA transport. You can also turn on batching for the nio transport by using -Dbatch="true". This option has no effect on MINA. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@599856 13f79535-47bb-0310-9956-ffa450edef68
* Modified the code to not keep the command in the map if ↵Rajith Muditha Attapattu2007-11-281-17/+13
| | | | | | | | | | | | | | | | "enable_command_replay" is false. However we still need to keep the command_id to implement sync properly. By default "enable_command_replay" is false. The earlier implementation completely avoided incrementing the command count and putting it in the map. This causes a problem as it will break the contract for sync. When the client code calls sync we need to only return when the broker has sent the EM that is at or above that command_id. So we need to keep that around. Keeping track of command_ids is different from keeping commands around. We keep commands around for reply, but we need to keep track of command_id's to implement the execution layer properly. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@599144 13f79535-47bb-0310-9956-ffa450edef68
* Changed the MINA version to 1.1.5.Rajith Muditha Attapattu2007-11-281-2/+2
| | | | | | | | Now the Broker module does not compile as it seem to depend on an obselete package. So I haev commented the broker module in the build. We can move the broker code to work with the new MINA version during the f2f. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@599116 13f79535-47bb-0310-9956-ffa450edef68
* added enable_replay optionArnaud Simon2007-11-281-4/+20
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@599030 13f79535-47bb-0310-9956-ffa450edef68
* optimized message creationArnaud Simon2007-11-271-5/+38
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@598559 13f79535-47bb-0310-9956-ffa450edef68
* optimized message creationArnaud Simon2007-11-271-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@598556 13f79535-47bb-0310-9956-ffa450edef68
* changed for setting offset when buffers are fragmentedArnaud Simon2007-11-141-1/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594881 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status