| Commit message (Collapse) | Author | Age | Files | Lines |
... | |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
In order to verify the uniqueness of the client ID, a dummy session is
created using client ID as it's name. This prevents any other connection
from using same client ID as the session creation will fail. However
this verification is switched off by default in order to preserve
backwards compatibility. You need to use -Dqpid.verify_client_id=true
switch verification on.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1144531 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| |
| |
| | |
all protocols, remove vm:// transport support and associated forked Mina classes
Applied patch by Keith Wall and myself
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1143874 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| |
| |
| | |
over to new IO interface model
Applied patch by Keith Wall and myself
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1143867 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| |
| |
| | |
NetworkTransport + NetworkConnection abstraction. Decouple IoSender and IoReceiver, initiate their threads after the constructor completes.
Applied patch by Keith Wall and myself
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1143866 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| |
| |
| | |
classes
Applied patch by Keith Wall and myself.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1143865 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1141643 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1137717 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| |
| |
| | |
AMQDestinations, truncate exception messages with length over 255 before sending them over the wire in AMQChannelException and AMQConnectionException.
Applied patch by Oleksandr Rudyy <orudyy@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1133037 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1103899 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| |
| |
| | |
If the underlying AMQP session gets closed, the JMS session is now notified along with details that caused the session closure.
The JMS Session will throw an exception (with an error code and details) when a user accesses the closed session.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1099288 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| |
| | |
Added the nessacery null checks to avoid a NPE due to missing delivery props or headers all together.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1091507 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| | |
when subscriptions with unique selectors are in use
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1087000 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1081858 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| |
| |
| | |
The reliability mode is now used on the producer side to determine replay.
Any messages transfers sent to a destination marked unreliable will not be added to the replay buffer.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1079408 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| | |
Port of QPID-2864 changes from 0.5.x-dev branch to trunk.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1079042 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1079041 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1078729 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
|
| |
| |
| |
| | |
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
|
| |
| |
| |
| |
| |
| |
| | |
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
|
| |
| |
| |
| |
| |
| | |
resources folder itself
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@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@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
|
| |
| |
| |
| |
| |
| | |
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
|
| |
| |
| |
| |
| |
| | |
events, ensure the correct thread logs close
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@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@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@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@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@1057460 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1032374 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1029523 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| | |
Committed patch from SorinS <ssuciu@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1003985 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| | |
Committed patch from SorinS <ssuciu@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@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@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@1001544 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| |
| |
| |
| | |
Adjusted the log message.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@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@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@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@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@997965 13f79535-47bb-0310-9956-ffa450edef68
|
| |
| |
| |
| | |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@996393 13f79535-47bb-0310-9956-ffa450edef68
|