| Commit message (Collapse) | Author | Age | Files | Lines |
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-2519@1187375 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-2519@1187150 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-2519@1186990 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1071972 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1071700 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
network read buffer array
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@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/qpid@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/qpid@1071674 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@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/qpid@1071641 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@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/qpid@1071620 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1071465 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1071462 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
resources folder itself
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@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/qpid@1070519 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@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/qpid@1067210 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
regardless of a particular sessions existence
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@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/qpid@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/qpid@1064629 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1064437 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
into consideration
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@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/qpid@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/qpid@1064085 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
events, ensure the correct thread logs close
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1064084 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
creation, dont put the created Sub actor onto the stack as the SubFlushRunner does this already when required
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1063328 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
| |
The createMessageProducer method now throws a JMSException.
The MessageProducer constructors now throw an AMQException allowing any exceptions caught during destination validation to be propogated back to the createMessageProducer method.
Fixed the exception handling for the 0-10 code path where all exceptions are chained properly. This allows the user to get all the relavent information by examing the stack trace.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1063123 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
put on the CurrentActor stack for the open messages
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1062722 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
resolves this issue
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1061866 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
non-direct ByteBuffers are the default, remove the old and now unused configuration methods from ServerConfiguration and update the example config.xml accordingly
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1061865 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
the test proceeds, as these may be processor-count dependant and throw the final result off
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1061863 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
of 1000
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1061862 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
| |
Commiting a fix as per the solution outlined in the above JIRA.
A null check is added in the generateDestination method in AbstractAMQMessageDelegate.java where an ExchangeInfo object is created with just the exchange name to allow the destination to be created. The correct information will be querried when a consumer or producer is created with that destination.
If a replyTo address is available then the exchange info for that is querried and updated within the updateExchangeTypeMapping method in AMQMessageDelegate_0_10.java
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1061577 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
I am restoring it to the original value.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1057927 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1057578 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
The redelivered flag is now set on messages that are restransmitted after failover.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1057462 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
When the session is marked transactional, message transfers are not replayed.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1057460 13f79535-47bb-0310-9956-ffa450edef68
|