Skip to content

Commit 8e108df

Browse files
committed
Fix merge conflicts
1 parent 6312f14 commit 8e108df

File tree

3 files changed

+17
-6
lines changed

3 files changed

+17
-6
lines changed

dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/api/pu/AbstractPortUnificationServer.java

Lines changed: 14 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,9 @@
3030
import java.util.function.Function;
3131
import java.util.stream.Collectors;
3232

33+
import static org.apache.dubbo.common.constants.CommonConstants.COMMA_SEPARATOR;
34+
import static org.apache.dubbo.common.constants.CommonConstants.EXT_PROTOCOL;
35+
3336
public abstract class AbstractPortUnificationServer extends AbstractServer {
3437

3538
/**
@@ -60,11 +63,18 @@ public Map<String, WireProtocol> getProtocols() {
6063

6164
@Override
6265
protected final void doOpen() {
63-
ExtensionLoader<WireProtocol> extensionLoader =
66+
ExtensionLoader<WireProtocol> loader =
6467
getUrl().getOrDefaultFrameworkModel().getExtensionLoader(WireProtocol.class);
65-
this.protocols = extensionLoader.getActivateExtension(getUrl(), new String[0]).stream()
66-
.collect(Collectors.toConcurrentMap(extensionLoader::getExtensionName, Function.identity()));
67-
68+
Map<String, WireProtocol> protocols = loader.getActivateExtension(getUrl(), new String[0]).stream()
69+
.collect(Collectors.toConcurrentMap(loader::getExtensionName, Function.identity()));
70+
// load extra protocols
71+
String extraProtocols = getUrl().getParameter(EXT_PROTOCOL);
72+
if (StringUtils.isNotEmpty(extraProtocols)) {
73+
Arrays.stream(extraProtocols.split(COMMA_SEPARATOR)).forEach(p -> {
74+
protocols.put(p, loader.getExtension(p));
75+
});
76+
}
77+
this.protocols = protocols;
6878
doOpen0();
6979
}
7080

dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/stream/AbstractTripleClientStream.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,8 @@
1919
import org.apache.dubbo.common.constants.CommonConstants;
2020
import org.apache.dubbo.common.logger.ErrorTypeAwareLogger;
2121
import org.apache.dubbo.common.logger.LoggerFactory;
22+
import org.apache.dubbo.remoting.Constants;
23+
import org.apache.dubbo.remoting.http12.HttpHeaderNames;
2224
import org.apache.dubbo.rpc.TriRpcStatus;
2325
import org.apache.dubbo.rpc.model.FrameworkModel;
2426
import org.apache.dubbo.rpc.protocol.tri.ClassLoadUtil;
@@ -57,7 +59,7 @@
5759
import io.netty.handler.codec.http2.Http2Error;
5860
import io.netty.handler.codec.http2.Http2Headers;
5961
import io.netty.handler.codec.http2.Http2StreamChannel;
60-
import io.netty.handler.codec.http2.Http2StreamChannelBootstrap;
62+
import io.netty.util.AttributeKey;
6163
import io.netty.util.ReferenceCountUtil;
6264

6365
import static org.apache.dubbo.common.constants.LoggerCodeConstants.PROTOCOL_FAILED_RESPONSE;

dubbo-serialization/dubbo-serialization-fastjson2/src/main/java/org/apache/dubbo/common/serialize/fastjson2/Fastjson2ScopeModelInitializer.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@
1818

1919
import org.apache.dubbo.common.beans.factory.ScopeBeanFactory;
2020
import org.apache.dubbo.common.utils.ClassUtils;
21-
import org.apache.dubbo.rpc.model.ApplicationModel;
2221
import org.apache.dubbo.rpc.model.FrameworkModel;
2322
import org.apache.dubbo.rpc.model.ScopeModelInitializer;
2423

0 commit comments

Comments
 (0)