File tree Expand file tree Collapse file tree
proxy/src/main/java/org/apache/rocketmq/proxy Expand file tree Collapse file tree Original file line number Diff line number Diff line change 4444import org .apache .rocketmq .proxy .processor .DefaultMessagingProcessor ;
4545import org .apache .rocketmq .proxy .processor .MessagingProcessor ;
4646import org .apache .rocketmq .proxy .remoting .RemotingProtocolServer ;
47+ import org .apache .rocketmq .proxy .service .cert .CertChangeSource ;
4748import org .apache .rocketmq .proxy .service .cert .FileCertChangeSource ;
4849import org .apache .rocketmq .proxy .service .cert .TlsCertificateManager ;
4950import org .apache .rocketmq .remoting .protocol .RemotingCommand ;
@@ -78,7 +79,7 @@ public static void main(String[] args) {
7879
7980 MessagingProcessor messagingProcessor = createMessagingProcessor ();
8081
81- FileCertChangeSource fileCertChangeSource = new FileCertChangeSource (
82+ CertChangeSource fileCertChangeSource = new FileCertChangeSource (
8283 ConfigurationManager .getProxyConfig ().getTlsCertPath (),
8384 ConfigurationManager .getProxyConfig ().getTlsKeyPath ());
8485 TlsCertificateManager tlsCertificateManager = new TlsCertificateManager (fileCertChangeSource );
You can’t perform that action at this time.
0 commit comments