summaryrefslogtreecommitdiff
path: root/java/common/src
Commit message (Collapse)AuthorAgeFilesLines
...
* 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
* 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
* 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-046-18/+57
| | | | 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
* 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-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-148-89/+315
| | | | | | 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-108-18/+165
| | | | 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-0516-63/+335
| | | | | | 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-0412-13/+13
| | | | 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