summaryrefslogtreecommitdiff
path: root/java/common
Commit message (Collapse)AuthorAgeFilesLines
* 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
* changed method public void processed(Range range) for flushing when flush ↵Arnaud Simon2007-11-081-1/+1
| | | | | | is true git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593153 13f79535-47bb-0310-9956-ffa450edef68
* Fix for QPID-639: c++ now includes sizes for all structs (enabled the same ↵Gordon Sim2007-11-072-2/+2
| | | | | | in python & java) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@592895 13f79535-47bb-0310-9956-ffa450edef68
* Changed for synchronizing on results during close operationArnaud Simon2007-11-051-1/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@591953 13f79535-47bb-0310-9956-ffa450edef68
* cahnged for handling IO write errorsArnaud Simon2007-10-232-0/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@587476 13f79535-47bb-0310-9956-ffa450edef68
* changed to handle empty payload messagesArnaud Simon2007-10-181-0/+19
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@586027 13f79535-47bb-0310-9956-ffa450edef68
* deleted useless codeArnaud Simon2007-10-171-592/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@585467 13f79535-47bb-0310-9956-ffa450edef68
* Updated message selectorArnaud Simon2007-10-1711-2060/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@585461 13f79535-47bb-0310-9956-ffa450edef68
* Updated message selectorArnaud Simon2007-10-171-19/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@585458 13f79535-47bb-0310-9956-ffa450edef68
* Updated message selectorArnaud Simon2007-10-1710-61/+270
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@585457 13f79535-47bb-0310-9956-ffa450edef68
* added a bit of API around MinaHandlerRafael H. Schloming2007-10-172-34/+126
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@585453 13f79535-47bb-0310-9956-ffa450edef68
* work around MINA close issuesRafael H. Schloming2007-10-171-2/+20
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@585452 13f79535-47bb-0310-9956-ffa450edef68
* removed unused fieldsRafael H. Schloming2007-10-149-51/+20
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@584499 13f79535-47bb-0310-9956-ffa450edef68
* Enabled packed struct encoding in python, cpp, and java. Also fixed ↵Rafael H. Schloming2007-10-149-131/+340
| | | | | | computation of required byte credit in Message.cpp. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@584474 13f79535-47bb-0310-9956-ffa450edef68
* added Boolean to the default encoding mapRafael H. Schloming2007-10-121-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@584136 13f79535-47bb-0310-9956-ffa450edef68
* made the session usable from multiple threads (hopefully)Rafael H. Schloming2007-10-101-18/+31
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@583567 13f79535-47bb-0310-9956-ffa450edef68
* added support (currently disabled) for packed encodingRafael H. Schloming2007-10-109-85/+296
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@583468 13f79535-47bb-0310-9956-ffa450edef68
* Removed system.outs and replaced with log statementsRajith Muditha Attapattu2007-10-102-14/+20
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@583351 13f79535-47bb-0310-9956-ffa450edef68
* don't wait for results if the session is closed, also added missing ↵Rafael H. Schloming2007-10-051-13/+35
| | | | | | synchronization for flushProcessed(), and fixed a buggy log statement git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@582320 13f79535-47bb-0310-9956-ffa450edef68
* disabled MINA buffer poolingRafael H. Schloming2007-10-051-0/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@582269 13f79535-47bb-0310-9956-ffa450edef68
* replaced random printlns with strategically placed log statements, also ↵Rafael H. Schloming2007-10-0517-65/+360
| | | | | | added useful toString() for structs git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@582065 13f79535-47bb-0310-9956-ffa450edef68
* moved codec --> transport.codec to avoid conflicts with qpid namespaceRafael H. Schloming2007-10-0413-16/+16
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@581973 13f79535-47bb-0310-9956-ffa450edef68
* Changed to send message ack when requiredArnaud Simon2007-10-041-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@581912 13f79535-47bb-0310-9956-ffa450edef68
* Changed to use message.recover instead of message.releaseArnaud Simon2007-10-031-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@581589 13f79535-47bb-0310-9956-ffa450edef68
* applied patch from gsim to fix order of bit decodingRafael H. Schloming2007-10-031-4/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@581571 13f79535-47bb-0310-9956-ffa450edef68
* fixed encoding of b/e bits and handling of max frame sizeRafael H. Schloming2007-10-035-15/+23
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@581469 13f79535-47bb-0310-9956-ffa450edef68
* error checking for field table decode, actually close sessions on session ↵Rafael H. Schloming2007-10-013-4/+41
| | | | | | close, and maintain cummulative mark in session git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@581056 13f79535-47bb-0310-9956-ffa450edef68
* fixed codec of UUIDsRafael H. Schloming2007-09-272-4/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@579863 13f79535-47bb-0310-9956-ffa450edef68
* improved close handling, made session.sync() return on session closeRafael H. Schloming2007-09-253-1/+31
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@579040 13f79535-47bb-0310-9956-ffa450edef68
* switched to one byte for class/method idsRafael H. Schloming2007-09-242-3/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@578891 13f79535-47bb-0310-9956-ffa450edef68
* added a mapping for byte[]sRafael H. Schloming2007-09-242-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@578864 13f79535-47bb-0310-9956-ffa450edef68
* added field table encoding/decodingRafael H. Schloming2007-09-2415-107/+736
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@578827 13f79535-47bb-0310-9956-ffa450edef68
* rerun generate script when it is modifiedRafael H. Schloming2007-09-241-1/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@578826 13f79535-47bb-0310-9956-ffa450edef68
* added back access ticket to the encode/decode methodsRafael H. Schloming2007-09-201-4/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@577827 13f79535-47bb-0310-9956-ffa450edef68
* added frame-end constantRafael H. Schloming2007-09-202-2/+11
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@577785 13f79535-47bb-0310-9956-ffa450edef68
* merged the qpidity.url classes in to qpid.url and deleted qpidity.urlRajith Muditha Attapattu2007-09-196-271/+8
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@577464 13f79535-47bb-0310-9956-ffa450edef68
* added messageAcquire method Arnaud Simon2007-09-191-0/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@577330 13f79535-47bb-0310-9956-ffa450edef68
* forgot to dispatch non L4 methods inside SessionDelegateRafael H. Schloming2007-09-191-1/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@577323 13f79535-47bb-0310-9956-ffa450edef68
* * ProtocolEvent.Switch --> ProtocolDelegateRafael H. Schloming2007-09-1714-121/+121
| | | | | | | | | | * Delegate --> MethodDelegate * Added method dispatching as a separate delegation level to the hierarchy underneath ProtocolDelegate. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@576587 13f79535-47bb-0310-9956-ffa450edef68
* Took out the URL parsing logic from the AMQConnectionURL and moved in two ↵Rajith Muditha Attapattu2007-09-141-2/+3
| | | | | | | | | | | | | | | | | | Parser classes. The Connection Type (0-8 or 0-10) is decided based on the URL scheme if AMQConnection is created by passing a URL. In other cases it will be based on a jvm switch. Other constructors in AMQConnection internally constructs an 0-8 URL and call the constrcutor with a URL. In that case it is difficult to figure out the type of connection with out additional information. The additional information commes in the form of the following jvm arguments SwitchCon - enables this switch 0-10 - creates an 0-10 connection and the absence of it creates an 0-8 connection This was done to minimize any impact on the test code. currently only one code path can be tested at a given time. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@575789 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status