public class org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher extends java.lang.Object implements org.apache.dubbo.remoting.exchange.ExchangeHandler
{
private final org.apache.dubbo.remoting.exchange.support.ReplierDispatcher replierDispatcher;
private final org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher handlerDispatcher;
private final org.apache.dubbo.remoting.telnet.TelnetHandler telnetHandler;
public void <init>()
{
org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher v;
org.apache.dubbo.remoting.exchange.support.ReplierDispatcher v;
org.apache.dubbo.remoting.telnet.support.TelnetHandlerAdapter v;
org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher v;
v := @this: org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new org.apache.dubbo.remoting.exchange.support.ReplierDispatcher;
specialinvoke v.<org.apache.dubbo.remoting.exchange.support.ReplierDispatcher: void <init>()>();
v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.exchange.support.ReplierDispatcher replierDispatcher> = v;
v = new org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher;
specialinvoke v.<org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher: void <init>()>();
v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher handlerDispatcher> = v;
v = new org.apache.dubbo.remoting.telnet.support.TelnetHandlerAdapter;
specialinvoke v.<org.apache.dubbo.remoting.telnet.support.TelnetHandlerAdapter: void <init>()>();
v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.telnet.TelnetHandler telnetHandler> = v;
return;
}
public void <init>(org.apache.dubbo.remoting.exchange.support.Replier)
{
org.apache.dubbo.remoting.exchange.support.Replier v;
org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher v;
org.apache.dubbo.remoting.exchange.support.ReplierDispatcher v;
org.apache.dubbo.remoting.telnet.support.TelnetHandlerAdapter v;
org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher v;
v := @this: org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher;
v := @parameter: org.apache.dubbo.remoting.exchange.support.Replier;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new org.apache.dubbo.remoting.exchange.support.ReplierDispatcher;
specialinvoke v.<org.apache.dubbo.remoting.exchange.support.ReplierDispatcher: void <init>(org.apache.dubbo.remoting.exchange.support.Replier)>(v);
v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.exchange.support.ReplierDispatcher replierDispatcher> = v;
v = new org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher;
specialinvoke v.<org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher: void <init>()>();
v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher handlerDispatcher> = v;
v = new org.apache.dubbo.remoting.telnet.support.TelnetHandlerAdapter;
specialinvoke v.<org.apache.dubbo.remoting.telnet.support.TelnetHandlerAdapter: void <init>()>();
v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.telnet.TelnetHandler telnetHandler> = v;
return;
}
public transient void <init>(org.apache.dubbo.remoting.ChannelHandler[])
{
org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher v;
org.apache.dubbo.remoting.exchange.support.ReplierDispatcher v;
org.apache.dubbo.remoting.ChannelHandler[] v;
org.apache.dubbo.remoting.telnet.support.TelnetHandlerAdapter v;
org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher v;
v := @this: org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher;
v := @parameter: org.apache.dubbo.remoting.ChannelHandler[];
specialinvoke v.<java.lang.Object: void <init>()>();
v = new org.apache.dubbo.remoting.exchange.support.ReplierDispatcher;
specialinvoke v.<org.apache.dubbo.remoting.exchange.support.ReplierDispatcher: void <init>()>();
v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.exchange.support.ReplierDispatcher replierDispatcher> = v;
v = new org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher;
specialinvoke v.<org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher: void <init>(org.apache.dubbo.remoting.ChannelHandler[])>(v);
v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher handlerDispatcher> = v;
v = new org.apache.dubbo.remoting.telnet.support.TelnetHandlerAdapter;
specialinvoke v.<org.apache.dubbo.remoting.telnet.support.TelnetHandlerAdapter: void <init>()>();
v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.telnet.TelnetHandler telnetHandler> = v;
return;
}
public transient void <init>(org.apache.dubbo.remoting.exchange.support.Replier, org.apache.dubbo.remoting.ChannelHandler[])
{
org.apache.dubbo.remoting.exchange.support.Replier v;
org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher v;
org.apache.dubbo.remoting.exchange.support.ReplierDispatcher v;
org.apache.dubbo.remoting.ChannelHandler[] v;
org.apache.dubbo.remoting.telnet.support.TelnetHandlerAdapter v;
org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher v;
v := @this: org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher;
v := @parameter: org.apache.dubbo.remoting.exchange.support.Replier;
v := @parameter: org.apache.dubbo.remoting.ChannelHandler[];
specialinvoke v.<java.lang.Object: void <init>()>();
v = new org.apache.dubbo.remoting.exchange.support.ReplierDispatcher;
specialinvoke v.<org.apache.dubbo.remoting.exchange.support.ReplierDispatcher: void <init>(org.apache.dubbo.remoting.exchange.support.Replier)>(v);
v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.exchange.support.ReplierDispatcher replierDispatcher> = v;
v = new org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher;
specialinvoke v.<org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher: void <init>(org.apache.dubbo.remoting.ChannelHandler[])>(v);
v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher handlerDispatcher> = v;
v = new org.apache.dubbo.remoting.telnet.support.TelnetHandlerAdapter;
specialinvoke v.<org.apache.dubbo.remoting.telnet.support.TelnetHandlerAdapter: void <init>()>();
v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.telnet.TelnetHandler telnetHandler> = v;
return;
}
public org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher addChannelHandler(org.apache.dubbo.remoting.ChannelHandler)
{
org.apache.dubbo.remoting.ChannelHandler v;
org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher v;
org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher v;
v := @this: org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher;
v := @parameter: org.apache.dubbo.remoting.ChannelHandler;
v = v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher handlerDispatcher>;
virtualinvoke v.<org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher: org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher addChannelHandler(org.apache.dubbo.remoting.ChannelHandler)>(v);
return v;
}
public org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher removeChannelHandler(org.apache.dubbo.remoting.ChannelHandler)
{
org.apache.dubbo.remoting.ChannelHandler v;
org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher v;
org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher v;
v := @this: org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher;
v := @parameter: org.apache.dubbo.remoting.ChannelHandler;
v = v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher handlerDispatcher>;
virtualinvoke v.<org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher: org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher removeChannelHandler(org.apache.dubbo.remoting.ChannelHandler)>(v);
return v;
}
public org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher addReplier(java.lang.Class, org.apache.dubbo.remoting.exchange.support.Replier)
{
org.apache.dubbo.remoting.exchange.support.Replier v;
org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher v;
org.apache.dubbo.remoting.exchange.support.ReplierDispatcher v;
java.lang.Class v;
v := @this: org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher;
v := @parameter: java.lang.Class;
v := @parameter: org.apache.dubbo.remoting.exchange.support.Replier;
v = v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.exchange.support.ReplierDispatcher replierDispatcher>;
virtualinvoke v.<org.apache.dubbo.remoting.exchange.support.ReplierDispatcher: org.apache.dubbo.remoting.exchange.support.ReplierDispatcher addReplier(java.lang.Class,org.apache.dubbo.remoting.exchange.support.Replier)>(v, v);
return v;
}
public org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher removeReplier(java.lang.Class)
{
java.lang.Class v;
org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher v;
org.apache.dubbo.remoting.exchange.support.ReplierDispatcher v;
v := @this: org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher;
v := @parameter: java.lang.Class;
v = v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.exchange.support.ReplierDispatcher replierDispatcher>;
virtualinvoke v.<org.apache.dubbo.remoting.exchange.support.ReplierDispatcher: org.apache.dubbo.remoting.exchange.support.ReplierDispatcher removeReplier(java.lang.Class)>(v);
return v;
}
public java.util.concurrent.CompletableFuture reply(org.apache.dubbo.remoting.exchange.ExchangeChannel, java.lang.Object) throws org.apache.dubbo.remoting.RemotingException
{
org.apache.dubbo.remoting.exchange.ExchangeChannel v;
org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher v;
org.apache.dubbo.remoting.exchange.support.ReplierDispatcher v;
java.lang.Object v, v;
java.util.concurrent.CompletableFuture v;
v := @this: org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher;
v := @parameter: org.apache.dubbo.remoting.exchange.ExchangeChannel;
v := @parameter: java.lang.Object;
v = v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.exchange.support.ReplierDispatcher replierDispatcher>;
v = interfaceinvoke v.<org.apache.dubbo.remoting.exchange.support.Replier: java.lang.Object reply(org.apache.dubbo.remoting.exchange.ExchangeChannel,java.lang.Object)>(v, v);
v = staticinvoke <java.util.concurrent.CompletableFuture: java.util.concurrent.CompletableFuture completedFuture(java.lang.Object)>(v);
return v;
}
public void connected(org.apache.dubbo.remoting.Channel)
{
org.apache.dubbo.remoting.Channel v;
org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher v;
org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher v;
v := @this: org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher;
v := @parameter: org.apache.dubbo.remoting.Channel;
v = v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher handlerDispatcher>;
virtualinvoke v.<org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher: void connected(org.apache.dubbo.remoting.Channel)>(v);
return;
}
public void disconnected(org.apache.dubbo.remoting.Channel)
{
org.apache.dubbo.remoting.Channel v;
org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher v;
org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher v;
v := @this: org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher;
v := @parameter: org.apache.dubbo.remoting.Channel;
v = v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher handlerDispatcher>;
virtualinvoke v.<org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher: void disconnected(org.apache.dubbo.remoting.Channel)>(v);
return;
}
public void sent(org.apache.dubbo.remoting.Channel, java.lang.Object)
{
org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher v;
java.lang.Object v;
org.apache.dubbo.remoting.Channel v;
org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher v;
v := @this: org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher;
v := @parameter: org.apache.dubbo.remoting.Channel;
v := @parameter: java.lang.Object;
v = v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher handlerDispatcher>;
virtualinvoke v.<org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher: void sent(org.apache.dubbo.remoting.Channel,java.lang.Object)>(v, v);
return;
}
public void received(org.apache.dubbo.remoting.Channel, java.lang.Object)
{
org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher v;
java.lang.Object v;
org.apache.dubbo.remoting.Channel v;
org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher v;
v := @this: org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher;
v := @parameter: org.apache.dubbo.remoting.Channel;
v := @parameter: java.lang.Object;
v = v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher handlerDispatcher>;
virtualinvoke v.<org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher: void received(org.apache.dubbo.remoting.Channel,java.lang.Object)>(v, v);
return;
}
public void caught(org.apache.dubbo.remoting.Channel, java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher v;
org.apache.dubbo.remoting.Channel v;
org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher v;
v := @this: org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher;
v := @parameter: org.apache.dubbo.remoting.Channel;
v := @parameter: java.lang.Throwable;
v = v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher handlerDispatcher>;
virtualinvoke v.<org.apache.dubbo.remoting.transport.ChannelHandlerDispatcher: void caught(org.apache.dubbo.remoting.Channel,java.lang.Throwable)>(v, v);
return;
}
public java.lang.String telnet(org.apache.dubbo.remoting.Channel, java.lang.String) throws org.apache.dubbo.remoting.RemotingException
{
org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher v;
org.apache.dubbo.remoting.telnet.TelnetHandler v;
java.lang.String v, v;
org.apache.dubbo.remoting.Channel v;
v := @this: org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher;
v := @parameter: org.apache.dubbo.remoting.Channel;
v := @parameter: java.lang.String;
v = v.<org.apache.dubbo.remoting.exchange.support.ExchangeHandlerDispatcher: org.apache.dubbo.remoting.telnet.TelnetHandler telnetHandler>;
v = interfaceinvoke v.<org.apache.dubbo.remoting.telnet.TelnetHandler: java.lang.String telnet(org.apache.dubbo.remoting.Channel,java.lang.String)>(v, v);
return v;
}
}