| 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
|
|
|
|
|
|
|
| |
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
|
|
|
|
|
|
| |
resources folder itself
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1070544 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
|
|
|
|
|
|
| |
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
|
|
|
|
|
|
| |
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
|
|
|
|
|
|
| |
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
|
|
|
|
|
|
|
| |
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
|
|
|
|
|
|
|
| |
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
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1032374 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1029523 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
Committed patch from SorinS <ssuciu@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1003985 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
Committed patch from SorinS <ssuciu@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1003984 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
Close reader when it is no longer required
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1003479 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
|
|
|
|
|
|
|
| |
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
|
|
|
|
|
|
| |
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
|
|
|
|
|
|
|
|
| |
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
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@996393 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
confirmation
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@996303 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
|
|
|
|
|
|
|
|
|
|
| |
AMQSession_0_10 is modified to contain a pair of get/set methods for the current
exception, using the set method to post the exception to the listener. The sync
method will now throw an exception if one has occurred and all other methods
that used to call sync()/getCurrentException() can just call sync(0 and get the
expected behaviour.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@985262 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@985261 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@985260 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@985259 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@985202 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@985199 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
| |
inherit from it, allowing exclusions to be applied.
Add ability to gather the class name of the message store associated with the test profile in use.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@982986 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
this time)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@982517 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@981269 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
properties
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@981231 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@981106 13f79535-47bb-0310-9956-ffa450edef68
|