| Commit message (Collapse) | Author | Age | Files | Lines |
... | |
|
|
|
|
|
|
| |
Committing patch from SorinS <ssuciu@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1001804 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
| |
Subscription/ServerConnection/ServerSession Objects
Committed patch from Sorins <ssuciu@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1001779 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
| |
client disable heartbeating, as it otherwise enables the connection idle timeout by default and the broker cant generate them.
Needed until QPID-2796 is undertaken to implement broker support for generating heartbeats.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1001544 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1001543 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1001542 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
Patch from SorinS <ssuciu@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1001537 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
Patch from SorinS <ssuciu@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1001536 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
| |
Converts the argument Map to a FieldTable and add as an argument to messageSubscribe
Patch from <sorins@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1000407 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Modified the address helper class to check for the durable property in the node props for the target node and link props for the subscription queue.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@999718 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
When a topic based destination is used in creating a consumer, the code looks to see if the address is already resolved.
If it is then it could mean two things.
1. A consumer is being recreated after failover.
2. This destination was used previously to create a consumer or a producer. In this case we assume it was used for a consumer.
For case #1, we need to preserve the queue name. The reason being if it was either a durable subscription or if it was a named queue (name property specified in link) then we need to maintain the same name.
For case #2 we need to ensure that each consumer gets it's own queue,hence we clone the destination object and the queue name is set to null
so name is auto-generated.
I have removed the incorrect logic (in BasicMessageConsumer_0_10) of looking at the durable property as one factor in deciding if it's case #1.
A durable subscription does use a named queue, therefore it is not nessacery to look at the durable property in order to identify it as case #1.
I have made modifications to createDurableTopic method in AMQTopic to set the queue name in the link properties.
The above changes enable a user to create more than one consumer (each with it's own unique queue) when using the same destination created off an addressing string that has durable set to true.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@999704 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
Added logic to the AMQTopic class to handle the creation of the durable subscription topics using an addressing string.
Modified the subscription queue creation to handle durable subscriptions.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@999196 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Adjusted the log message.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@999189 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Only message transfers are stored in the internal command array. This array is used for replaying after failover.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@999188 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
| |
Implementation of review changes.
Patch from <sorins@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@998891 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
across the Java codebase
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@998700 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@998699 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@998697 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
used by multiple scripts, into the qpid-server script it is associated with
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@998696 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
multiple scripts into qpid-server script. Change default pid filename to indicate association with qpid-server. Make filename configurable to allow choosing name e.g. for capturing pid of multiple servers"
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@998695 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@998548 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@998547 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
from direct/topic exchanges
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@998546 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
queue deletion process to prevent an unauthorised attempt from barring all future deletion attempts
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@998545 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
logging during binding recovery to guard against NPEs, and check for exchange presence to prevent the BindingFactory incorrectly binding to the default exchange
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@998544 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Incorporates changes for QPID-2597 from 0.5.x-dev branch revisions 943240, 943534, 943576, and 943845.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@998543 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
statement. Correct exception message.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@998542 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@998162 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
| |
Only the selector property should be copied to the FilterManager FieldTable.
Patch from <sorins@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@998154 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
finding potential issues
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@998152 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Applying patch from <sorins@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@998126 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Applying patch from <sorins@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@998125 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
Added a simple null check to eliminate acting on a result that is no longer valid.
I am also adding a log message at "WARN" level if we receive a result for a command that is no longer in our map.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@997965 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
prompted by the RMI runtime dont stop the world
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@996855 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@996393 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
not-allowed
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@996308 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
confirmation
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@996303 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@996300 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@995575 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
patch :)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@995430 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
failing as part of the suite
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@995352 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
messages from the test output
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@995103 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
| |
default
Applied patch from Sorin Suciu <ssuciu@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@995102 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@995065 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@994963 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@992995 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@992988 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
| |
can be safely removed
Applied patch from Sorin Suciu <ssuciu@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@992903 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Applied patch from Sorin Suciu <ssuciu@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@992902 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
| |
removed
Applied patch from Sorin Suciu <ssuciu@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@992901 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Applied patch from Sorin Suciu <ssuciu@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@992900 13f79535-47bb-0310-9956-ffa450edef68
|