| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
|
| |
to be reduced between the various session closures. QPID-380
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@509216 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
| |
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
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@509178 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@509177 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@509176 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
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
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@509147 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
etc), allow other exchanges to be created through virtualhosts.xml
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@508942 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
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
|
| |
|
|
|
|
|
|
| |
Updated QueueBindHandler.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@508416 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Sorry Missed NoRouteException.java
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@508385 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
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
|
| |
|
|
|
|
|
|
| |
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-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
|
| |
|
|
|
|
| |
Updated AMQProtocolSession to have new methods to query and release a channel from the awaiting close-ok state. Once a channel has been signalled to be closed any further methods on that channel are ignored until a close-ok is sent.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@508366 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
writes by using the body.get[Channel|Connection]Exception() to throw a new exception to write out the frames.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@508351 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
persistence issues
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@508235 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@507939 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
should be removed
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@507938 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Adding test-classes for java management console
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@507894 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@507609 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@507596 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@507595 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@507584 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
added @Configured annotation to the maximumMessageSize attribute
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@507583 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@507559 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
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
|
| |
|
|
|
|
| |
retrotranslator required jars for verification.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@506542 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
distribution.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@506517 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
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
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@506405 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
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
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@505972 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@505892 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@505355 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
predelivery queues will also be cleared with moved messages. Messages will be moved to another queue and predelivery queues of subsribers of another queue will also be populated.
the features - removeMmessageFromTop and clearQueue is also modified by using the getNextMessage
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@505268 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@505256 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@505255 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@505242 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@504915 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@504868 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
repo. Using it. Also test classes now use test context properties so that test parameters are correctly printed out in the test results.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@504864 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
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
|
| |
|
|
|
|
| |
Management feature added - moving messages from one Queue to another
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@504507 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
mbean implementation, default virtual host is assigned to all mbeans
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@504112 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
error.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@504025 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
AMQQueueMBean updated with attribute MaximumMessageAge
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@503790 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Also the parameter selection of boolean type is made as check-boxes instead of a drop-down.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@503706 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
This local repository is no longer needed. JUnit-Toolkit snapshot repository is now hosted on sourceforge: http://junit-toolkit.svn.sourceforge.net/svnroot/junit-toolkit/. A release is also in progress to the central maven repository.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@503646 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Junit-toolkit has now fully migrated onto sourceforge. Snapshot repository location updated.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@503637 13f79535-47bb-0310-9956-ffa450edef68
|