public abstract class AbstractProtocolManager<P,I extends BaseInterceptor<P>,C extends RemotingConnection> extends Object implements ProtocolManager<I>
| Constructor and Description |
|---|
AbstractProtocolManager() |
| Modifier and Type | Method and Description |
|---|---|
Map<SimpleString,RoutingType> |
getPrefixes() |
protected void |
invokeInterceptors(List<I> interceptors,
P message,
C connection) |
void |
setAnycastPrefix(String anycastPrefix) |
void |
setMulticastPrefix(String multicastPrefix) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitacceptsNoHandshake, addChannelHandlers, createConnectionEntry, getFactory, handleBuffer, handshake, isProtocol, removeHandler, updateInterceptors, websocketSubprotocolIdentifierspublic void setAnycastPrefix(String anycastPrefix)
setAnycastPrefix in interface ProtocolManager<I extends BaseInterceptor<P>>public void setMulticastPrefix(String multicastPrefix)
setMulticastPrefix in interface ProtocolManager<I extends BaseInterceptor<P>>public Map<SimpleString,RoutingType> getPrefixes()
getPrefixes in interface ProtocolManager<I extends BaseInterceptor<P>>Copyright © 2018 The Apache Software Foundation. All rights reserved.