Author: philharveyonline Date: Thu Jul 11 16:11:57 2013 New Revision: 1502264
URL: http://svn.apache.org/r1502264 Log: NO-JIRA: make Transport's FrameHandler configurable to facilitate testing Modified: qpid/proton/trunk/proton-j/proton/src/main/java/org/apache/qpid/proton/engine/impl/TransportImpl.java Modified: qpid/proton/trunk/proton-j/proton/src/main/java/org/apache/qpid/proton/engine/impl/TransportImpl.java URL: http://svn.apache.org/viewvc/qpid/proton/trunk/proton-j/proton/src/main/java/org/apache/qpid/proton/engine/impl/TransportImpl.java?rev=1502264&r1=1502263&r2=1502264&view=diff ============================================================================== --- qpid/proton/trunk/proton-j/proton/src/main/java/org/apache/qpid/proton/engine/impl/TransportImpl.java (original) +++ qpid/proton/trunk/proton-j/proton/src/main/java/org/apache/qpid/proton/engine/impl/TransportImpl.java Thu Jul 11 16:11:57 2013 @@ -109,6 +109,8 @@ public class TransportImpl extends Endpo private EngineLogger _engineLogger; + private FrameHandler _frameHandler = this; + /** * @deprecated This constructor's visibility will be reduced to the default scope in a future release. * Client code outside this module should use a {@link EngineFactory} instead @@ -153,7 +155,7 @@ public class TransportImpl extends Endpo if(!_init) { _init = true; - _frameParser = new FrameParser(this, _decoder, _maxFrameSize); + _frameParser = new FrameParser(_frameHandler , _decoder, _maxFrameSize); _inputProcessor = _frameParser; _outputProcessor = new TransportOutputAdaptor(this, _maxFrameSize); _outputOverflowBuffer = newReadableBuffer(_maxFrameSize); @@ -166,6 +168,9 @@ public class TransportImpl extends Endpo return _maxFrameSize; } + /** + * TODO propagate the new value to {@link #_outputProcessor} etc + */ @Override public void setMaxFrameSize(int maxFrameSize) { @@ -1277,4 +1282,13 @@ public class TransportImpl extends Endpo { _engineLogger = engineLogger; } + + /** + * Override the default frame handler. Must be called before the transport starts being used + * (e.g. {@link #getInputBuffer()}, {@link #getOutputBuffer()}, {@link #ssl(SslDomain)} etc). + */ + public void setFrameHandler(FrameHandler frameHandler) + { + _frameHandler = frameHandler; + } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
