You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by or...@apache.org on 2018/09/19 13:15:37 UTC
[2/2] qpid-broker-j git commit: QPID-8233: [Broker-J] Send
"connection-forced" error when virtual host is in the process of activating
QPID-8233: [Broker-J] Send "connection-forced" error when virtual host is in the process of activating
(cherry picked from commit 7ff50badfd0379e2ceb61308ca89f3890e70b7b0)
Project: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/commit/19624396
Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/19624396
Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/19624396
Branch: refs/heads/7.0.x
Commit: 19624396396fc09d0dbc55dbdbfe63b3dad130e0
Parents: 3cc87ee
Author: Alex Rudyy <or...@apache.org>
Authored: Sun Sep 9 23:11:18 2018 +0100
Committer: Alex Rudyy <or...@apache.org>
Committed: Wed Sep 19 13:50:16 2018 +0100
----------------------------------------------------------------------
.../apache/qpid/server/protocol/v1_0/AMQPConnection_1_0Impl.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/19624396/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0Impl.java
----------------------------------------------------------------------
diff --git a/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0Impl.java b/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0Impl.java
index 03954b4..02465a2 100644
--- a/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0Impl.java
+++ b/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/AMQPConnection_1_0Impl.java
@@ -912,7 +912,6 @@ public class AMQPConnection_1_0Impl extends AbstractAMQPConnection<AMQPConnectio
if (!addressSpace.isActive())
{
final Error err = new Error();
- err.setCondition(AmqpError.NOT_FOUND);
populateConnectionRedirect(addressSpace, err);
closeConnection(err);
}
@@ -1023,10 +1022,12 @@ public class AMQPConnection_1_0Impl extends AbstractAMQPConnection<AMQPConnectio
if(redirectHost == null)
{
+ err.setCondition(ConnectionError.CONNECTION_FORCED);
err.setDescription("Virtual host '" + _localHostname + "' is not active");
}
else
{
+ err.setCondition(ConnectionError.REDIRECT);
String networkHost;
int port;
if(redirectHost.matches("\\[[0-9a-f:]+\\](:[0-9]+)?"))
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org