| Commit message (Collapse) | Author | Age | Files | Lines |
| ... | |
| |
|
|
|
|
| |
align with unquoted names used elsewhere in the console
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1077869 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Only UNRELIABLE and AT_LEAST_ONCE is supported.
Currently the reliability mode is used only for determining the accept-mode.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1076800 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
The isQueueExist method is modified to handle the exception when a queue has been deleted.
Both the Message producer and consumer now delete the queue if the delete option is selected and will not check if the queue is empty or if there are any subscribers on it.
Also added test cases.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1076670 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
- Change error checks so that don't throw an incorrect exception in getters
when the queue is null. This should only happen when sending.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1076642 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
| |
The getPropertyNames method will filter out any property names whose values are not allowed as per the JMS spec.
I could have used the ALLOWED map to check if a value is a valid type.
But unfortunately that map contains byte[] as a valid type, which is not correct as per the JMS spec.
I did not want to modify that map or the behaviour of the setObjectProperty or getObjectProperty methods as there might be applications out there that is depending on it.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1076532 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Instead of checking if it's an instance of AMQQueue, the code the now checks if it's an instance of AMQDestination and javax.jms.Queue to cover the AMQAnyDestination case. The same check is done for topics. Added test cases for QueueReceivers, TopicSubscribers and DurableTopicSubscribers using the new addressing scheme.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1076516 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1076329 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
Added logic to look for the 'host' in the authority field if getHost returns null.
Looking at the code that follows, you could definitely make more improvements.
However since we are close to the 0.10 release I'd leave things as it is for the time being.
I have also added test cases to cover the issues highlighted by the respective JIRA.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1076011 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
This commit allows a MapMessage to accept an UUID object in it's setObject method.
Added test cases for directly setting UUID objects or inside Maps and Lists that gets set into the MapMessage body.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1075961 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
available plugins for 0-10 codepath.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1075871 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1075756 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
ObjectName key values
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1075745 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Connections, Exchanges, and VirtualHosts instead of just remapping characters.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1075744 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1073038 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1072179 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1071972 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1071700 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
network read buffer array
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1071676 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Methods, rather than pre-allocating a 64000 entry array
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1071675 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
BBEncoder and BBDecoder, release buffer from BBDecoder when complete
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1071674 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1071642 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
The Disassembler now fills a ByteBuffer with the entire frame contents before
passing it to the Sender.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1071641 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1071631 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
Refactor test and fix 0-10 client session to flush acks
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1071620 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1071465 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1071462 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
resources folder itself
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1070544 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
| |
As the first step added system properties for host, port and address and got rid of the jndi lookup.
There is also a system property for URL which allows a user to specify a fully fledged URL with various connection options like SSL etc..
If the host & port is specified the URL property is ignored.
I also added some documentation in the perf_report.sh suggesting recommended settings for performance testing.
These are guidelines only and a prospective user needs to experiment with their environment to fine tune the settings.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1070519 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1070497 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Modified the code to use the correct system property name.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1069998 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
I had accidently marked the 'connectionLost' variable static.
Removing the static identifier from the said variable.
Thanks to Andrew Kennedy for spotting this.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1069858 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Added the extra state 'RESUMING', to ensure that any new session creation is delayed until the connection is able to reattach all existing sessions. If a connection is reconnecting then it will first go to RESUMING state (instead of OPEN) in connection-open-ok. Once the 'resume' method in Connection.java is completed the state will be set to OPEN.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1069159 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
The commit made in rev 1068661 will only close and throw an exception if the user tries to invoke an action (Ex sending a message or calling commit) on the transactional session while failover is in progress (i.e session in detached state).
We also need to handle the case where the application is not doing anything during failover. But the application may still be in the middle of an uncommitted transaction. Therefore any session that is marked transactional should not be resumed.
This commit removes tranactional sessions and close them inside the 'resume' method in Connection.java
Any subsequent operation on this session will cause an exception being thrown, saying the session is closed.
However the exception doesn't really contain the reason, other than to say the session is closed.
The Java client in general needs a better error reporting scheme to convey more information to a client application.
That will be handled under a separate JIRA.
For the purpose of this JIRA the session being closed is good enough for the time being.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1069105 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
The createSession method in Connection.java now waits until the connection state == OPEN before it actually sends the session-attach on the wire.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1068696 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
If the session is transactional, in the invoke method the session state is checked to see if it has dettached.
If so the session is removed from the internal map maintained by the connection object. This prevents it from being resumed.
An exception is also thrown notifying that failover may have happened in the middle of a transaction and the session is closed.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1068661 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
with maven.local.repo), generate poms into the scratch dir, make the artifacts a SNAPSHOT version by default (configurable with maven.snapshot), and tweak the SNAPSHOT output version naming not to be unique (configurable with maven.unique.version)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1068445 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
atomic QueueContext._releasedEntry. Race was between thread SubFlushRunner (or QueueRunner) executing method SimpleAMQQueue.setLastSeenEntry and the thread executing the MessageRelase command executing method SimpleAMQQueue.updateSubRequeueEntry. Bolstered the unit tests surrounding the area of change to reduce risk of regression. Overrode TestableMemoryMessageStore#close() to avoid a NPE during tearDown silently cluttering some unit test logs (including SimpleAMQQueueTest).
Applied patch from Keith Wall <keith.wall@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1068315 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
generated POMs, specify 'qpid' prefix to ensure correctly named poms + artifacts + dependencies, add project url to generated POM.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1068180 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
full POMs. Update the SLF4J, Derby, Felix dep info to match the jars currently in use.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1068179 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
modules during the release process
Applied patches from Emmanuel Bourg <ebourg@apache.org>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1068178 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
class files, as the defaults can differ depending on the used compiler
Applied patch from Rajika Kumarasiri <rajika@wso2.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1067667 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
connection during connection handshake. Enable/make the 0-10 client use channel numbers 0 to N-1 in line with the spec, rather than 1-N.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1067210 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
regardless of a particular sessions existence
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1067208 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
the permature termination of Qpid client threads.
Applied patch from Keith Wall <keith.wall@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1067108 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
logging, add unit tests
Applied patches from Keith Wall
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1064629 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1064437 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
into consideration
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1064108 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
minor differences between 0-10 and 0-9 behaviour
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1064086 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
leveraging an internal broker (via IBBC) to load the vhost config required for the tests
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1064085 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
events, ensure the correct thread logs close
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1064084 13f79535-47bb-0310-9956-ffa450edef68
|