public TClientProxyProtocolServer(ClientProxyCommons commons, ClientProxyService proxyService) { this.proxyService = proxyService; ThriftCodecManager codecManager = new ThriftCodecManager(); ThriftEventHandler eventHandler = new ThriftEventHandler(); ThriftServiceProcessor processor = new ThriftServiceProcessor(codecManager, Arrays.asList( eventHandler), this); server = new ThriftServer(processor, getServerConfig(commons.conf)).start(); }
ScribeCollector(Builder builder) { ScribeSpanConsumer scribe = new ScribeSpanConsumer(builder); ThriftServiceProcessor processor = new ThriftServiceProcessor(new ThriftCodecManager(), emptyList(), scribe); server = new ThriftServer(processor, new ThriftServerConfig().setPort(builder.port)); }