summaryrefslogtreecommitdiff
path: root/java/client/src/org
Commit message (Collapse)AuthorAgeFilesLines
* TransactedTest.java - Added Logging around the setup.Martin Ritchie2006-11-071-0/+9
| | | | | | Added a sleep after VM Broker creation to allow broker to startup. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@472073 13f79535-47bb-0310-9956-ffa450edef68
* Added extra logging around InVM failuresMartin Ritchie2006-11-071-4/+14
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@472069 13f79535-47bb-0310-9956-ffa450edef68
* Added AMQQueueSessionAdaptor and AMQTopicSessionAdaptor and amended ↵Marnie McCormack2006-11-033-2/+360
| | | | | | AMQConnection create methods to use these adaptor classes as per QPID-66. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@470759 13f79535-47bb-0310-9956-ffa450edef68
* Changes to fix QueueReceiver ClassCastException being thrown by methods in ↵Marnie McCormack2006-11-033-8/+153
| | | | | | AMQSession which should return this interface. As per QPID-58. Added QueueReceiverAdaptor class now used in AMQSession. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@470742 13f79535-47bb-0310-9956-ffa450edef68
* generateQueueName now removes colons as well as semi-colonsMarnie McCormack2006-11-021-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@470380 13f79535-47bb-0310-9956-ffa450edef68
* Change to generateQueueName to remove non-conformant chars (/ and ;) as per ↵Marnie McCormack2006-11-021-15/+27
| | | | | | QPID-4. Other changes to allow test class inheritance for testing of this change. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@470336 13f79535-47bb-0310-9956-ffa450edef68
* Committed development version by mistake.Martin Ritchie2006-10-311-11/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@469436 13f79535-47bb-0310-9956-ffa450edef68
* Added additional logging to diagnose issues when unable to create an in VM ↵Martin Ritchie2006-10-311-3/+17
| | | | | | broker git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@469430 13f79535-47bb-0310-9956-ffa450edef68
* Modified to maintain a reference to the lastWriteFuture. This is then used ↵Martin Ritchie2006-10-201-1/+16
| | | | | | when closing the ProtocolSession to join on so that we can be sure all data has been written to the broker. A time out of 2 minutes ensures that the client doesn't hang for ever if the broker fails. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@466078 13f79535-47bb-0310-9956-ffa450edef68
* Resolution to QPID-23Martin Ritchie2006-10-205-0/+850
| | | | | | | | | | | Added Simple JNDI SPI Class that uses a PropertiesFile to create a ContextFactory for use with in JNDI. Added a unit test to test using properties file to get correct objects from JNDI lookup. Modifed AMQHeadersExchange.java to allow creation from a BindingURL. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@466076 13f79535-47bb-0310-9956-ffa450edef68
* QPID-36 Added high/low water mark to DUPS_OK_ACKNOWLEDGE.Martin Ritchie2006-10-183-21/+86
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@465166 13f79535-47bb-0310-9956-ffa450edef68
* Implemented Client side high/low water mark prefetching for NO_ACK.Martin Ritchie2006-10-175-107/+197
| | | | | | Use of single prefetch should be unaffected. Setting the high and low to be the same. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@464950 13f79535-47bb-0310-9956-ffa450edef68
* Fixed incorrect package on AMQVMBrokerCreationException (did not match ↵Robert Greig2006-10-122-26/+12
| | | | | | physical location). git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@463397 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2. JMSBytesMessage.readXXX methods now test the appropriate number of ↵Robert Greig2006-10-121-4/+50
| | | | | | bytes are available in the message and throw the appropriate exception if not. Unit test updated to check behaviour of readXXX methods. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@463363 13f79535-47bb-0310-9956-ffa450edef68
* Fixed ack.RecoverTest and ack.DisconnectAndRedeliverTest. These were failing ↵Gordon Sim2006-10-121-0/+6
| | | | | | | | | | | | | | | due to a race condition where the consumers queue was not bound by the time the publisher sent messages. This is a result of the use of nowait=true for the declare/bind/consume cycle for a BasicMessageConsumer. To work around this in tests like these that have two connections, one consuming & one publishing, I added a declareExchangeSynch() method to AMQSession which allows a thread to block until the session it invokes that method on has processed all the commands up to that point. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@463309 13f79535-47bb-0310-9956-ffa450edef68
* Added a little extra debug to the toString()Martin Ritchie2006-10-111-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@462840 13f79535-47bb-0310-9956-ffa450edef68
* Added extra debug output when failover fails.Martin Ritchie2006-10-111-4/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@462820 13f79535-47bb-0310-9956-ffa450edef68
* client/* - Only Create a Threshold Listener if if the acknowledgeMode is NO_ACKMartin Ritchie2006-10-032-6/+20
| | | | | | common/*/framing/* - White space changes from tabs to 4 spaces. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@452529 13f79535-47bb-0310-9956-ffa450edef68
* I somehow missed an import.Martin Ritchie2006-10-031-0/+1
| | | | | | | | | | | QPID-10 #QPID-10 JIRA QPID-10 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@452334 13f79535-47bb-0310-9956-ffa450edef68
* Fix for QPID-10. Problem was a memory leak of sorts on the client. A ↵Martin Ritchie2006-10-031-14/+29
| | | | | | temporary frame listener was never removed. Hence causing longer add times and lots of "live" objects. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@452326 13f79535-47bb-0310-9956-ffa450edef68
* AMQProtocolSession.java - white space changesMartin Ritchie2006-09-274-21/+23
| | | | | | | | | | | | BasicMessageProducer.java - white space changes BasicMessageConsumer.java - white space changes AMQSession.java - added a comment MemoryMessageStore.java - white space changes SubscriptionImpl.java AMQChannel.java - Removed race condition where two messages could get the same delivery tag and when using acks where messages can be added to the UnackMap out of sequence, Causing unknown message to ack exceptions. DestNameExchange.java - white space/style changes. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@450384 13f79535-47bb-0310-9956-ffa450edef68
* Combined.java - removed ApplicationRegistry ReferenceMartin Ritchie2006-09-252-2/+2
| | | | | | | | | | VmPipeTransportConnection.java - moved in to client package. TransportConnection.java - updated imports JNDIBindConnectionFactory.java - forced inclusion of url. Updated JNDI Setup git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@449675 13f79535-47bb-0310-9956-ffa450edef68
* AMQBrokerDetails.java - Changed default SSL value to use a static constantMartin Ritchie2006-09-2511-48/+454
| | | | | | | | | | | | | | AMQConnection.java - Fixed initial constructor connection, exception handling to check exception or cause for ConnectionExceptions and UnresolvedAddresses. AMQProtocolHandler.java - removed //todo as auth failure handling is now done. Added new transport exceptions AMQNoTransportForProtocolException.java and AMQTransportConnectionException.java as part of the TransportConnection changes. TransportConnection.java - Major changes to use the transport specified in the BrokerDetails object to dictate the type of Transport used for the connection. Currently only tcp and vm are supported. VmPipeTransportConnection.java - moved from test classes. Created vmbroker package for VMBrokerCreateException. Allows client to distinguish between a connection failure and a problem starting the broker to connect to it. BrokerDetails.java - Added default transport and set the current transport string values, 'tcp' and 'vm' FailoverMethod.java - Added singlebroker for completeness. FailoverPolicy.java - Allowed method type singlebroker to be created. Changed else if to else { if git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@449640 13f79535-47bb-0310-9956-ffa450edef68
* Closeable's checkNotClosed now throws a javax.jms.IllegalStateException ↵Steven Shaw2006-09-206-17/+16
| | | | | | rather than a java.lang.IllegalStateException. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@448211 13f79535-47bb-0310-9956-ffa450edef68
* No longer throw commons-lang's NotImplementedException. See ↵Steven Shaw2006-09-202-6/+34
| | | | | | http://issues.apache.org/jira/browse/QPID-1 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@448142 13f79535-47bb-0310-9956-ffa450edef68
* Import of qpid from etp:Rafael H. Schloming2006-09-1989-0/+12068
URL: https://etp.108.redhat.com/svn/etp/trunk/blaze Repository Root: https://etp.108.redhat.com/svn/etp Repository UUID: 06e15bec-b515-0410-bef0-cc27a458cf48 Revision: 608 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@447994 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status