Repository: qpid-jms Updated Branches: refs/heads/master 477df6443 -> c5ff72993
add a little descriptive javadoc, remove dead code Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/5092f9d0 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/5092f9d0 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/5092f9d0 Branch: refs/heads/master Commit: 5092f9d08939d2287e887699357ee72622561a6a Parents: d376110 Author: Robert Gemmell <rob...@apache.org> Authored: Tue Feb 24 11:13:29 2015 +0000 Committer: Robert Gemmell <rob...@apache.org> Committed: Tue Feb 24 11:13:29 2015 +0000 ---------------------------------------------------------------------- .../jms/provider/amqp/AmqpAbstractResource.java | 20 ++++---------------- 1 file changed, 4 insertions(+), 16 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/5092f9d0/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpAbstractResource.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpAbstractResource.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpAbstractResource.java index 6612786..0d8322c 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpAbstractResource.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpAbstractResource.java @@ -161,24 +161,12 @@ public abstract class AmqpAbstractResource<R extends JmsResource, E extends Endp } } + /** + * Called when remote state becomes closed and there was + * no open or close attempt waiting for update. + */ @Override public void remotelyClosed() { - if (isAwaitingOpen()) { - Exception error = getRemoteError(); - if (error == null) { - error = new IOException("Remote has closed without error information"); - } - - if (endpoint != null) { - // TODO: if this is a producer/consumer link then we may only be detached, - // rather than fully closed, and should respond appropriately. - endpoint.close(); - } - - openRequest.onFailure(error); - openRequest = null; - } - // TODO - We need a way to signal that the remote closed unexpectedly. LOG.info("Resource was remotely closed"); } --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
