Rolling back changes from previous check-in.
Project: http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/commit/bbe5c99c Tree: http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/tree/bbe5c99c Diff: http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/diff/bbe5c99c Branch: refs/heads/1.5.x Commit: bbe5c99c58e8c411607919ca447c6781980bea6a Parents: 07cda02 Author: Jim Gomes <[email protected]> Authored: Wed Feb 29 20:40:13 2012 +0000 Committer: Jim Gomes <[email protected]> Committed: Wed Feb 29 20:40:13 2012 +0000 ---------------------------------------------------------------------- src/main/csharp/Connection.cs | 25 ++++++------------------- 1 file changed, 6 insertions(+), 19 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/blob/bbe5c99c/src/main/csharp/Connection.cs ---------------------------------------------------------------------- diff --git a/src/main/csharp/Connection.cs b/src/main/csharp/Connection.cs index 16f664a..4ca6aa5 100755 --- a/src/main/csharp/Connection.cs +++ b/src/main/csharp/Connection.cs @@ -721,27 +721,14 @@ namespace Apache.NMS.Stomp internal void OnException(Exception error) { - if(this.transport.IsFaultTolerant) - { - Tracer.ErrorFormat("Attempting recovery from Exception: {0}", error.Message); - while(null != (error = error.InnerException)) - { - Tracer.ErrorFormat(" {0}", error.Message); - } + // Will fire an exception listener callback if there's any set. + OnAsyncException(error); - OnTransportInterrupted(this.transport); - } - else + if(!this.closing.Value && !this.closed.Value) { - // Will fire an exception listener callback if there's any set. - OnAsyncException(error); - - if(!this.closing.Value && !this.closed.Value) - { - // Perform the actual work in another thread to avoid lock contention - // and allow the caller to continue on in its error cleanup. - executor.QueueUserWorkItem(AsyncOnExceptionHandler, error); - } + // Perform the actual work in another thread to avoid lock contention + // and allow the caller to continue on in its error cleanup. + executor.QueueUserWorkItem(AsyncOnExceptionHandler, error); } }
