-
Notifications
You must be signed in to change notification settings - Fork 627
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #91 from soliad/master
QFJ-285 Add proxy support (compatible with SSL) (cherry picked from commit 47a0c78)
- Loading branch information
Showing
6 changed files
with
392 additions
and
19 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
68 changes: 68 additions & 0 deletions
68
quickfixj-core/src/main/java/quickfix/mina/initiator/InitiatorProxyIoHandler.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,68 @@ | ||
| /******************************************************************************* | ||
| * Copyright (c) quickfixengine.org All rights reserved. | ||
| * | ||
| * This file is part of the QuickFIX FIX Engine | ||
| * | ||
| * This file may be distributed under the terms of the quickfixengine.org | ||
| * license as defined by quickfixengine.org and appearing in the file | ||
| * LICENSE included in the packaging of this file. | ||
| * | ||
| * This file is provided AS IS with NO WARRANTY OF ANY KIND, INCLUDING | ||
| * THE WARRANTY OF DESIGN, MERCHANTABILITY AND FITNESS FOR A | ||
| * PARTICULAR PURPOSE. | ||
| * | ||
| * See http://www.quickfixengine.org/LICENSE for licensing information. | ||
| * | ||
| * Contact ask@quickfixengine.org if any conditions of this licensing | ||
| * are not clear to you. | ||
| ******************************************************************************/ | ||
|
|
||
| package quickfix.mina.initiator; | ||
|
|
||
| import org.apache.mina.core.session.IoSession; | ||
| import org.apache.mina.proxy.AbstractProxyIoHandler; | ||
|
|
||
| import quickfix.mina.ssl.SSLFilter; | ||
|
|
||
| class InitiatorProxyIoHandler extends AbstractProxyIoHandler { | ||
| private final InitiatorIoHandler initiatorIoHandler; | ||
| private final SSLFilter sslFilter; | ||
|
|
||
| InitiatorProxyIoHandler(InitiatorIoHandler initiatorIoHandler, SSLFilter sslFilter) { | ||
| super(); | ||
| this.initiatorIoHandler = initiatorIoHandler; | ||
| this.sslFilter = sslFilter; | ||
| } | ||
|
|
||
| @Override | ||
| public void sessionCreated(IoSession session) throws Exception { | ||
| this.initiatorIoHandler.sessionCreated(session); | ||
| } | ||
|
|
||
| @Override | ||
| public void sessionClosed(IoSession ioSession) throws Exception { | ||
| this.initiatorIoHandler.sessionClosed(ioSession); | ||
| } | ||
|
|
||
| @Override | ||
| public void messageReceived(IoSession session, Object message) throws Exception { | ||
| this.initiatorIoHandler.messageReceived(session, message); | ||
| } | ||
|
|
||
| @Override | ||
| public void messageSent(IoSession session, Object message) throws Exception { | ||
| this.initiatorIoHandler.messageSent(session, message); | ||
| } | ||
|
|
||
| @Override | ||
| public void exceptionCaught(IoSession ioSession, Throwable cause) throws Exception { | ||
| this.initiatorIoHandler.exceptionCaught(ioSession, cause); | ||
| } | ||
|
|
||
| @Override | ||
| public void proxySessionOpened(IoSession ioSession) throws Exception { | ||
| if (this.sslFilter != null) { | ||
| this.sslFilter.initiateHandshake(ioSession); | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.