|
34 | 34 | import quickfix.SessionSettings; |
35 | 35 | import quickfix.SystemTime; |
36 | 36 | import quickfix.mina.CompositeIoFilterChainBuilder; |
37 | | -import quickfix.mina.CustomSslFilter; |
38 | 37 | import quickfix.mina.EventHandlingStrategy; |
39 | 38 | import quickfix.mina.NetworkingOptions; |
40 | 39 | import quickfix.mina.ProtocolFactory; |
@@ -159,9 +158,8 @@ private void setupIoConnector() throws ConfigError, GeneralSecurityException { |
159 | 158 |
|
160 | 159 | boolean hasProxy = proxyType != null && proxyPort > 0 && socketAddresses[nextSocketAddressIndex] instanceof InetSocketAddress; |
161 | 160 |
|
162 | | - SslFilter sslFilter = null; |
163 | 161 | if (sslEnabled) { |
164 | | - sslFilter = installSslFilter(ioFilterChainBuilder); |
| 162 | + installSslFilter(ioFilterChainBuilder); |
165 | 163 | } |
166 | 164 |
|
167 | 165 | ioFilterChainBuilder.addLast(FIXProtocolCodecFactory.FILTER_NAME, new ProtocolCodecFilter(new FIXProtocolCodecFactory())); |
@@ -192,17 +190,16 @@ private void setupIoConnector() throws ConfigError, GeneralSecurityException { |
192 | 190 | ioConnector = newConnector; |
193 | 191 | } |
194 | 192 |
|
195 | | - private SslFilter installSslFilter(CompositeIoFilterChainBuilder ioFilterChainBuilder) |
| 193 | + private void installSslFilter(CompositeIoFilterChainBuilder ioFilterChainBuilder) |
196 | 194 | throws GeneralSecurityException { |
197 | 195 | final SSLContext sslContext = SSLContextFactory.getInstance(sslConfig); |
198 | | - final SslFilter sslFilter = new CustomSslFilter(sslContext, false); |
| 196 | + final SslFilter sslFilter = new SslFilter(sslContext, false); |
199 | 197 | sslFilter.setEnabledCipherSuites(sslConfig.getEnabledCipherSuites() != null ? sslConfig.getEnabledCipherSuites() |
200 | 198 | : SSLSupport.getDefaultCipherSuites(sslContext)); |
201 | 199 | sslFilter.setEnabledProtocols(sslConfig.getEnabledProtocols() != null ? sslConfig.getEnabledProtocols() |
202 | 200 | : SSLSupport.getSupportedProtocols(sslContext)); |
203 | 201 | sslFilter.setEndpointIdentificationAlgorithm(sslConfig.getEndpointIdentificationAlgorithm()); |
204 | 202 | ioFilterChainBuilder.addLast(SSLSupport.FILTER_NAME, sslFilter); |
205 | | - return sslFilter; |
206 | 203 | } |
207 | 204 |
|
208 | 205 | @Override |
|
0 commit comments