Skip to content

Commit

Permalink
Revert "ARTEMIS-2100 address routing-type overridden on attaching AMQ…
Browse files Browse the repository at this point in the history
…P sender"

There are too many failures because of the semantic change here.

This reverts commit 1c17a4d.

(cherry picked from commit 2f52e3c)
  • Loading branch information
clebertsuconic committed Nov 1, 2018
1 parent 8e8b02a commit b427087
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 127 deletions.
Expand Up @@ -19,13 +19,11 @@
import java.util.Arrays;
import java.util.List;

import org.apache.activemq.artemis.api.config.ActiveMQDefaultConfiguration;
import org.apache.activemq.artemis.api.core.ActiveMQSecurityException;
import org.apache.activemq.artemis.api.core.RoutingType;
import org.apache.activemq.artemis.api.core.SimpleString;
import org.apache.activemq.artemis.core.security.CheckType;
import org.apache.activemq.artemis.core.security.SecurityAuth;
import org.apache.activemq.artemis.core.server.impl.AddressInfo;
import org.apache.activemq.artemis.core.transaction.Transaction;
import org.apache.activemq.artemis.protocol.amqp.broker.AMQPSessionCallback;
import org.apache.activemq.artemis.protocol.amqp.exceptions.ActiveMQAMQPException;
Expand Down Expand Up @@ -231,15 +229,8 @@ private RoutingType getRoutingType(Symbol[] symbols, SimpleString address) {
}
}
}
final AddressInfo addressInfo = sessionSPI.getAddress(address);
if (addressInfo != null && !addressInfo.getRoutingTypes().isEmpty()) {
if (addressInfo.getRoutingTypes().size() == 1) {
return addressInfo.getRoutingType();
}
}
RoutingType defaultRoutingType = sessionSPI.getDefaultRoutingType(address);
defaultRoutingType = defaultRoutingType == null ? ActiveMQDefaultConfiguration.getDefaultRoutingType() : defaultRoutingType;
return defaultRoutingType;

return sessionSPI.getDefaultRoutingType(address);
}

/*
Expand Down

This file was deleted.

0 comments on commit b427087

Please sign in to comment.