summaryrefslogtreecommitdiff
path: root/qpid/java
Commit message (Collapse)AuthorAgeFilesLines
* added isolated test cases for interop with c++ brokerRajith Muditha Attapattu2007-09-211-0/+126
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@577963 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@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@577785 13f79535-47bb-0310-9956-ffa450edef68
* merged the qpidity.url classes in to qpid.url and deleted qpidity.urlRajith Muditha Attapattu2007-09-1915-317/+54
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@577464 13f79535-47bb-0310-9956-ffa450edef68
* changed method messageAcquire to test if the acquire range set is nullArnaud Simon2007-09-191-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@577331 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@577330 13f79535-47bb-0310-9956-ffa450edef68
* updated for using jms message for filtering incoming messagesArnaud Simon2007-09-191-42/+54
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@577326 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@577323 13f79535-47bb-0310-9956-ffa450edef68
* renamed qpidity.jms to qpidity.njms and qpidity.client to qpidity.nclientArnaud Simon2007-09-1959-0/+13674
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@577253 13f79535-47bb-0310-9956-ffa450edef68
* deleted qpidity.jms and qpidity.clientArnaud Simon2007-09-1959-13674/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@577231 13f79535-47bb-0310-9956-ffa450edef68
* renamed qpidity.jms to qpidity.njms and qpidity.client to qpidity.nclientArnaud Simon2007-09-191-3/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@577229 13f79535-47bb-0310-9956-ffa450edef68
* renamed qpidity.jms to qpidity.njms and qpidity.client to qpidity.nclientArnaud Simon2007-09-199-30/+28
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@577227 13f79535-47bb-0310-9956-ffa450edef68
* added njmsArnaud Simon2007-09-1942-122/+114
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@577226 13f79535-47bb-0310-9956-ffa450edef68
* added nclientArnaud Simon2007-09-1917-45/+44
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@577223 13f79535-47bb-0310-9956-ffa450edef68
* added message selector evaluation (for 0_10 only) Arnaud Simon2007-09-184-30/+223
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@577011 13f79535-47bb-0310-9956-ffa450edef68
* Added XA support (for 0_10 only)Arnaud Simon2007-09-1810-36/+930
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@576933 13f79535-47bb-0310-9956-ffa450edef68
* added 0_10 replyTo supportArnaud Simon2007-09-186-14/+46
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@576853 13f79535-47bb-0310-9956-ffa450edef68
* added support querying an exchange and implemented dtx Session Arnaud Simon2007-09-183-12/+24
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@576799 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@576587 13f79535-47bb-0310-9956-ffa450edef68
* fixed several bugs after running samples against 0_10 Arnaud Simon2007-09-177-21/+50
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@576491 13f79535-47bb-0310-9956-ffa450edef68
* changed qpid session propagationArnaud Simon2007-09-172-11/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@576396 13f79535-47bb-0310-9956-ffa450edef68
* 0_10 implementationArnaud Simon2007-09-171-8/+70
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@576388 13f79535-47bb-0310-9956-ffa450edef68
* Updated ConnectionURLArnaud Simon2007-09-175-5/+47
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@576378 13f79535-47bb-0310-9956-ffa450edef68
* Took out the URL parsing logic from the AMQConnectionURL and moved in two ↵Rajith Muditha Attapattu2007-09-1412-252/+807
| | | | | | | | | | | | | | | | | | 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@575789 13f79535-47bb-0310-9956-ffa450edef68
* * moved most of the classes in the org.apache.qpidity package toRafael H. Schloming2007-09-1384-1639/+1511
| | | | | | | | | | | | | | | | | | | | org.apache.qpidity.transport * factored out the network specific pieces into org.apache.qpidity.transport * moved the mina specific code to org.apache.qpidity.transport.network.mina * replaced the handler chain with Sender/Receiver chains that can deal with close request/closed notifications * moved from an anonymous struct[] to a real Header class * removed an excess copy from message data transmit git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@575474 13f79535-47bb-0310-9956-ffa450edef68
* updated message hierarchy for using 0_10 messagesArnaud Simon2007-09-1320-197/+317
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@575289 13f79535-47bb-0310-9956-ffa450edef68
* QPID-572 Applied test patch supplied by Aidan Skinner along with change to ↵Martin Ritchie2007-09-122-1/+159
| | | | | | ConcurrentSelectorDeliveryManager that resolves the ordering problem. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574982 13f79535-47bb-0310-9956-ffa450edef68
* This is the first pass at refactoring the Connection stuff.Rajith Muditha Attapattu2007-09-114-231/+426
| | | | | | | | | | | | | | The AMQConnection was not made abstract to preserve the widely usd AMQConsutructor in test cases. Instead 0-8,0-10 specific functionality was delegated to a version specific delegate. The version is selected via a JVM argument (and based on the URL format) Currently this mean that we can test only a single code path (o-8 or 0-10) at a time. Next Step is to refactor the URL stuff. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574582 13f79535-47bb-0310-9956-ffa450edef68
* added message flow mode window Arnaud Simon2007-09-101-2/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574255 13f79535-47bb-0310-9956-ffa450edef68
* added 0_10 factoryArnaud Simon2007-09-101-1/+21
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574227 13f79535-47bb-0310-9956-ffa450edef68
* updated recoverArnaud Simon2007-09-101-8/+11
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574226 13f79535-47bb-0310-9956-ffa450edef68
* git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574225 ↵Arnaud Simon2007-09-102-17/+2
| | | | 13f79535-47bb-0310-9956-ffa450edef68
* added AbstractJMSMessage createJMSMessageFromUnprocessedMessageArnaud Simon2007-09-101-3/+12
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574223 13f79535-47bb-0310-9956-ffa450edef68
* removed AbstractJMSMessage createJMSMessageFromUnprocessedMessageArnaud Simon2007-09-101-9/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574222 13f79535-47bb-0310-9956-ffa450edef68
* git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574221 ↵Arnaud Simon2007-09-103-0/+707
| | | | 13f79535-47bb-0310-9956-ffa450edef68
* Unprocessed message was made abstract and a 0-8 and 0-10 implementation is ↵Rajith Muditha Attapattu2007-09-0610-173/+336
| | | | | | | | | | provided. The return message extends unprocessed_msg_0_8 as return message is only a 0-8 feature. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@573282 13f79535-47bb-0310-9956-ffa450edef68
* Separated 0-8 functionality from the AMQSession,/BasicMessageProducer and ↵Rajith Muditha Attapattu2007-09-057-433/+765
| | | | | | BasicMessageConsumer and made them abstract git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@573039 13f79535-47bb-0310-9956-ffa450edef68
* fixed a race condition in rollback() that leads to intermittant failures of ↵Rafael H. Schloming2007-09-042-28/+37
| | | | | | TransactedTest, also modified TransactedTest to be slightly more robust git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@572751 13f79535-47bb-0310-9956-ffa450edef68
* added debugging utility methodRafael H. Schloming2007-09-041-0/+13
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@572750 13f79535-47bb-0310-9956-ffa450edef68
* added byteBuffer to Stream converter Arnaud Simon2007-09-046-99/+386
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@572656 13f79535-47bb-0310-9956-ffa450edef68
* QPID-554 Patch submitted by Jia Jia to add viewing of binary content in ↵Martin Ritchie2007-08-318-154/+502
| | | | | | messages. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@571491 13f79535-47bb-0310-9956-ffa450edef68
* fixed a race condition in ConnectionStartTestRafael H. Schloming2007-08-311-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@571367 13f79535-47bb-0310-9956-ffa450edef68
* fixed a race condition causing intermittant test failures in ↵Rafael H. Schloming2007-08-301-40/+49
| | | | | | AMQBrokerManagerMBeanTest git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@571277 13f79535-47bb-0310-9956-ffa450edef68
* Remerge of M2. All tests pass locallyMartin Ritchie2007-08-30198-6815/+17361
| | | | | | | | | | | | | | | | Testing done in Intelij and mvn command line via windows/cygwin. Python tests removed from auto build pending Jython-siztion. Tested running broker in intelij and python run-tests from cygwin. All tests pass. (CombinedTest still exhibts a race condition. but that has always been so.) Additional Race condition identified (around MsgReject/AutoDeleteQueues) during testing patch to follow. systests are inconsistent Some use TestableMemoryMessageStore some use MemoryMessgaeStore. Lets not roll back this change if issues are discovered. Lets work together to go forward and address any issues. I have spent a lot of time ensuring the tests work for me so I hope that they work for you. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@571129 13f79535-47bb-0310-9956-ffa450edef68
* Added a temp fix to overcome the ByteBuffer.array() problemRajith Muditha Attapattu2007-08-251-0/+13
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@569695 13f79535-47bb-0310-9956-ffa450edef68
* Corrected logic to check message listenerRajith Muditha Attapattu2007-08-251-40/+41
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@569691 13f79535-47bb-0310-9956-ffa450edef68
* added bouncerArnaud Simon2007-08-252-3/+395
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@569689 13f79535-47bb-0310-9956-ffa450edef68
* I provided a fixed to the deadlock issue in MessageConsumerImpl.Rajith Muditha Attapattu2007-08-254-356/+205
| | | | | | | | | | | | | | | | | | Here is the deadlock issue --------------------------- The internal receive thread acquires the _incomingMessageLock and blocks on sync() The MINA thread gets on to onMessage() and blocks while trying to acquire the incomingMessageLock Since the MINA thread doesn't return it can't process the execution.complete() sent by the broker. Since the execution.complete doesn't get processed, the sync() doesn't return. Hence the deadlock. Solution ---------- I rewrote the receive logic using a LinkedBlockingQueue and leveraging the application thread that calls receive methods git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@569688 13f79535-47bb-0310-9956-ffa450edef68
* Added basic test case to test JMSRajith Muditha Attapattu2007-08-2411-59/+170
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@569547 13f79535-47bb-0310-9956-ffa450edef68
* Fixed compilation errors related to PingPongBouncer.Rajith Muditha Attapattu2007-08-241-3/+3
| | | | | | | It looks like this file was accidently deleted. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@569480 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status