summaryrefslogtreecommitdiff
path: root/java/client
Commit message (Collapse)AuthorAgeFilesLines
* QPID-379 Bounced Messages do not appear in connection exception listener. Martin Ritchie2007-02-196-93/+226
| | | | | | | | | | | | The previous commit that started the Dispatcher was wrong and caused a lot of failures. This will address that problem by providing a thread pool on the client connection object to deliver bounced messages to the exception handler. Tidied up MessageListenerTests so all the asserts are in the given test. Renamed TestChannelCloseMethodHandlerNoCloseOk as surefire picks it up as a test case. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@509202 13f79535-47bb-0310-9956-ffa450edef68
* QPID-376 Renamed Test case StateManagerMartin Ritchie2007-02-191-3/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@509178 13f79535-47bb-0310-9956-ffa450edef68
* QPID-376 Renamed Test case StateManagerMartin Ritchie2007-02-191-0/+108
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@509177 13f79535-47bb-0310-9956-ffa450edef68
* Badly named file annoyed surefireMartin Ritchie2007-02-191-108/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@509176 13f79535-47bb-0310-9956-ffa450edef68
* QPID-372, QPID-376 Broker now ignores all frames for closing channels. Martin Ritchie2007-02-197-100/+723
| | | | | | | | | | | | | | | | | | | When a close-ok is received the channel can be reopened and used All uses of getChannel check the return type is not null and throw a NOT_FOUND AMQException. If the channel is not found during a method handler then the Channel will be closed. ChannelCloseHandler - Now throws a connection exception if trying to close a a non exisitant channel. AMQMinaProtocolSession - Added pre-check for closing channels to ignore all but Close-OK methods - Updated ChannelException method to close connection if the CE was a result of not having a valid channel. - Changed state to CLOSING when writing out a connection close frame. AMQConnection - Wrapped all _logging calls , Updated comment formatting AMQSession - called startDispatcherIfRequired when receiving a message as without it a producer will not get a returned message. This is because there is no consumer setup to consume. ConnectionCloseMethodHandler - Wrapped code in try finally so that the protocol session would always be closed correctly. AMQStateManager - Added state to the logging values Modified AMQTimeoutException to include a new constant value to identify the failure reason. AMQConstant - Added 408 REQUEST_TIMEOUT fixed error with NOT_ALLOWED value was 530 should be 507. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@509172 13f79535-47bb-0310-9956-ffa450edef68
* QPID-375 : Default Exchange fixesRobert Godfrey2007-02-191-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@509147 13f79535-47bb-0310-9956-ffa450edef68
* QPID-375 : remove assumptions on standard exchanges (amq.direct, amq.topic, ↵Robert Godfrey2007-02-1659-205/+527
| | | | | | etc), allow other exchanges to be created through virtualhosts.xml git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@508649 13f79535-47bb-0310-9956-ffa450edef68
* QPID-373 Queue|Exchange}{Bind|Declare} should be synchronous to correctly ↵Martin Ritchie2007-02-161-1/+1
| | | | | | | | receive/handle error Updated AMQSession to be synchronous. With the build error fixed!! git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@508384 13f79535-47bb-0310-9956-ffa450edef68
* QPID-373 Queue|Exchange}{Bind|Declare} should be synchronous to correctly ↵Martin Ritchie2007-02-161-89/+92
| | | | | | | | receive/handle error Updated AMQSession to be synchronous git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@508382 13f79535-47bb-0310-9956-ffa450edef68
* QPID-11 remove protocol literals from code. Martin Ritchie2007-02-169-17/+26
| | | | | | | | | | | | | | | | | | | | | QPID-376 use of getChannel() does not correct handle error cases when null is returned. Updated AMQMethodBody - to have a convenience method getChannelNotFoundException to be used for QPID-376 when channel is null. This allows the replyCode NOT_FOUND=404 to be changed to changed easily if required. QPID-376 - Updated All Handlers to throw channel exception when channel is null. QPID-11 Updated all handlers to use AMQConstant values rather than hardcoded literals. - Updated AMQException to use AMQConstant values rather than int to ensure that no more literal values creep back in to the code base. Replaced all usages of int above framing to store replycode with AMQConstant to prevent creep. Had to create new constants for literals used in code base but not yet part of spec. 405=Already Exists 406=In Use 323=Invalid Routing Key Remove non spec constant 500=Unknown_Exchange_Name replaced with generic NOT_FOUND git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@508381 13f79535-47bb-0310-9956-ffa450edef68
* QPID-366 : Reference counting not being decremented correctly and other ↵Robert Godfrey2007-02-154-14/+15
| | | | | | persistence issues git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@508235 13f79535-47bb-0310-9956-ffa450edef68
* virtual host testpath replaced with testBhupendra Bhusman Bhardwaj2007-02-152-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@507939 13f79535-47bb-0310-9956-ffa450edef68
* Reset log level from error to info.Martin Ritchie2007-02-141-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@507609 13f79535-47bb-0310-9956-ffa450edef68
* Applied QPID-162 patches from Kevin SmithMartin Ritchie2007-02-14132-648/+1058
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@507595 13f79535-47bb-0310-9956-ffa450edef68
* Applied QPID-6 SSL Options patch from Kevin SmithMartin Ritchie2007-02-148-74/+191
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@507584 13f79535-47bb-0310-9956-ffa450edef68
* QPID-368 Revised. Had the wrong logging level set on an log statementMartin Ritchie2007-02-141-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@507559 13f79535-47bb-0310-9956-ffa450edef68
* QPID-368 Added the first data body to the list when creating it. included ↵Martin Ritchie2007-02-142-0/+189
| | | | | | | | | | | | | | | | | test case. Test case tests sending 9 messages - 64k-1 - 64k - 64k+1 - 128k-1 - 128k - 128+1 - 128k - 512k - 1024k git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@507557 13f79535-47bb-0310-9956-ffa450edef68
* (Patch submitted by Rupert Smith) Qpid-365, sets dummy values for ↵Robert Greig2007-02-121-4/+0
| | | | | | retrotranslator required jars for verification. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@506542 13f79535-47bb-0310-9956-ffa450edef68
* (Patch submitted by Rupert Smith) Qpid-360 fixes.Robert Greig2007-02-123-176/+195
| | | | | | | Message type defaults to ByteMessage when not specified. Unknown destination type is used as default when not specified. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@506439 13f79535-47bb-0310-9956-ffa450edef68
* (Path Qpid-337 submitted by Rupert Smith)Robert Greig2007-02-124-42/+190
| | | | | | Does 1.4 retrotranslation as part of the maven build. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@506401 13f79535-47bb-0310-9956-ffa450edef68
* QPID-359 : Allow for rudimentary use of access ticketsRobert Godfrey2007-02-116-12/+94
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@505972 13f79535-47bb-0310-9956-ffa450edef68
* QPID-353 : Amend type of JMS destination type from byte to intRobert Greig2007-02-083-6/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@504915 13f79535-47bb-0310-9956-ffa450edef68
* Improved version of the "accept the broker version" fix.Robert Greig2007-02-081-34/+32
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@504868 13f79535-47bb-0310-9956-ffa450edef68
* Added a system property qpid.accept.broker.version to allow the client to ↵Robert Greig2007-02-071-8/+17
| | | | | | accept whatever version the broker offers on connection negotiation. Useful when testing different broker implementations that may not be in sync with Qpid versioning. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@504736 13f79535-47bb-0310-9956-ffa450edef68
* Fixed bug in stop(). If a connection is opened not start()ed then closed a ↵Martin Ritchie2007-02-051-1/+5
| | | | | | NullPointerException will be thrown as the Dispatcher has not been created. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@503593 13f79535-47bb-0310-9956-ffa450edef68
* QPID-84Bhupendra Bhusman Bhardwaj2007-02-025-695/+3
| | | | | | tests for FSContextFactory deleted.fscontext.jar is not part of apache svn. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@502610 13f79535-47bb-0310-9956-ffa450edef68
* QPID-341 When using Queues and Topics defined via JNDI settings are not ↵Martin Ritchie2007-02-011-3/+3
| | | | | | | | preserved. Removed extraction of destination/queue name and used BindingURL directly to create Destination. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@502271 13f79535-47bb-0310-9956-ffa450edef68
* Increased logging on a failure to attain stateMartin Ritchie2007-02-011-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@502268 13f79535-47bb-0310-9956-ffa450edef68
* QPID-339 DispatcherTest.java was broker now it actually tests correctly.Martin Ritchie2007-02-013-8/+288
| | | | | | Added test to Check changing message listeners git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@502261 13f79535-47bb-0310-9956-ffa450edef68
* QPID-339 Java client hangs when starting up (intermittently)Martin Ritchie2007-02-013-74/+348
| | | | | | | | | | | | | | Patched the problem where the dispatcher would hang. The previous logic was flawed. Patch worked on by Robert Godfrey and Martin Ritchie. Added test to ensure that the connection is not automatically started. (Only added the test last time by mistake. This is the actual fix) With a test for the DispatcherTest git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@502253 13f79535-47bb-0310-9956-ffa450edef68
* QPID-330 Clients occasionally fail to notice connectMartin Ritchie2007-02-011-31/+18
| | | | | | The AMQConnection.java constructor now deals with the full connection process. The failover thread should not be started. This allows the connection method to be simplified and not Thread.sleep waiting for the connection. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@502249 13f79535-47bb-0310-9956-ffa450edef68
* QPID-339 Java client hangs when starting up (intermittently)Martin Ritchie2007-02-011-0/+165
| | | | | | | | | | Patched the problem where the dispatcher would hang. The previous logic was flawed. Patch worked on by Robert Godfrey and Martin Ritchie. Added test to ensure that the connection is not automatically started. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@502248 13f79535-47bb-0310-9956-ffa450edef68
* QPID-333 Committed test class rename to stop it being picked up by SurefireMartin Ritchie2007-02-014-11/+12
| | | | | | AMQTopic.java - whitespace git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@502172 13f79535-47bb-0310-9956-ffa450edef68
* QPID-333 Message Properties on non Qpid Messages are not preservedMartin Ritchie2007-01-315-47/+493
| | | | | | | | | | Updated MessageConverter to have a constructor that takes a Message type. Updated MessageConverterTest to use the new NonQpidMessage to test it out. JMSHeaderAdapter.java - whitespace changes and comment noting that null return is required. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@501917 13f79535-47bb-0310-9956-ffa450edef68
* QPID-327 : Patch supplied by Rob Godfrey - [race condition] PoolingFilter : ↵Robert Greig2007-01-295-7/+30
| | | | | | Possible race condition when completing a Job git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@501096 13f79535-47bb-0310-9956-ffa450edef68
* QPID-313 : Patch supplied by Rob Godfrey - Call to attainState in ↵Robert Greig2007-01-291-33/+28
| | | | | | makeBrokerConnection can miss the notification of state change. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@501011 13f79535-47bb-0310-9956-ffa450edef68
* QPID-324 : Patch supplied by Rob Godfrey - Only send byte indicating topic / ↵Robert Greig2007-01-291-3/+8
| | | | | | queue / other in properties field table, not whole destination git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@501008 13f79535-47bb-0310-9956-ffa450edef68
* QPID-322 : Patch supplied by Rob Godfrey - Tests may hang instead of fail if ↵Robert Greig2007-01-2913-46/+133
| | | | | | message does not get through git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@501007 13f79535-47bb-0310-9956-ffa450edef68
* QPID-324 : Patch supplied by Rob Godfrey - Only send byte indicating topic / ↵Robert Greig2007-01-2927-115/+339
| | | | | | queue / other in properties field table, not whole destination git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@501005 13f79535-47bb-0310-9956-ffa450edef68
* QPID-320 : Patch supplied by Rob Godfrey - Simplify logic to deal with ↵Robert Greig2007-01-292-176/+62
| | | | | | setting MessageListener only after connection start has been called git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@501004 13f79535-47bb-0310-9956-ffa450edef68
* [Patch supplied by Jonathan Anstey] Solve probelm in which TransactedTest ↵Kim van der Riet2007-01-261-1/+1
| | | | | | causes a failure in RecoverTest owing to messages sticking around. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@500310 13f79535-47bb-0310-9956-ffa450edef68
* Change to TransactedTest which prevents the intermittent error ↵Kim van der Riet2007-01-261-1/+2
| | | | | | junit.framework.ComparisonFailure: expected:<B> but was:<C> (or similar) from occurring on either the commit or rollback portion of the test. The error occurs when the test consumer testConsumer1 bind frames arrive at the server before the message bodies with A,B,C and cause queue 1 to start a round-robin distribution for these messages when they finally do arrive. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@500264 13f79535-47bb-0310-9956-ffa450edef68
* QPID-315Marnie McCormack2007-01-253-0/+440
| | | | | | Test classes to reproduce problem with missing correlation id on incoming messages from non-Qpid broker git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@499979 13f79535-47bb-0310-9956-ffa450edef68
* QPID-315Marnie McCormack2007-01-253-99/+12
| | | | | | | Moved message conversion logic from BasicMessageProducer to MessageConverter Added correlation id to AbstractJMSMessage.toString() git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@499975 13f79535-47bb-0310-9956-ffa450edef68
* QPID-318 : Patch supplied by Rob Godfrey - remove hard-coding of protocol valuesRobert Greig2007-01-255-26/+23
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@499851 13f79535-47bb-0310-9956-ffa450edef68
* QPID-318 : Patch supplied by Rob Godfrey - Remove hard-coding of protocol ↵Robert Greig2007-01-257-164/+218
| | | | | | version number. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@499628 13f79535-47bb-0310-9956-ffa450edef68
* QPID-317 : Patch supplied by Rob Godfrey - Remove dependency on JMS from ↵Robert Greig2007-01-246-69/+590
| | | | | | common / broker. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@499563 13f79535-47bb-0310-9956-ffa450edef68
* QPID-315Marnie McCormack2007-01-241-10/+14
| | | | | | Updated and tidied class prior to addition of tests git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@499532 13f79535-47bb-0310-9956-ffa450edef68
* QPID-50 : Patch supplied by Rob Godfrey - Virtual Host implementationRobert Greig2007-01-244-20/+30
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@499490 13f79535-47bb-0310-9956-ffa450edef68
* QPID-50 : Patch supplied by Rob Godfrey - Virtual Host implementationRobert Greig2007-01-2434-86/+90
| | | | git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@499446 13f79535-47bb-0310-9956-ffa450edef68