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/10 00:11:10 UTC
[4/6] 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
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/7ff50bad
Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/7ff50bad
Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/7ff50bad
Branch: refs/heads/master
Commit: 7ff50badfd0379e2ceb61308ca89f3890e70b7b0
Parents: 367b080
Author: Alex Rudyy <or...@apache.org>
Authored: Sun Sep 9 23:11:18 2018 +0100
Committer: Alex Rudyy <or...@apache.org>
Committed: Mon Sep 10 01:10:54 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/7ff50bad/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