From users-return-50553-archive-asf-public=cust-asf.ponee.io@activemq.apache.org Wed Oct 3 15:23:37 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id 3E8CF18065B for ; Wed, 3 Oct 2018 15:23:37 +0200 (CEST) Received: (qmail 84076 invoked by uid 500); 3 Oct 2018 13:23:36 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 84065 invoked by uid 99); 3 Oct 2018 13:23:35 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 03 Oct 2018 13:23:35 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id E91361A190C for ; Wed, 3 Oct 2018 13:23:34 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 3.486 X-Spam-Level: *** X-Spam-Status: No, score=3.486 tagged_above=-999 required=6.31 tests=[DKIM_ADSP_CUSTOM_MED=0.001, NML_ADSP_CUSTOM_MED=1.2, SPF_HELO_PASS=-0.001, SPF_SOFTFAIL=0.972, URI_HEX=1.313, URI_TRY_3LD=0.001] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id g4baXtOwrK10 for ; Wed, 3 Oct 2018 13:23:34 +0000 (UTC) Received: from n4.nabble.com (n4.nabble.com [199.38.86.66]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTP id 6277B5F41A for ; Wed, 3 Oct 2018 13:23:33 +0000 (UTC) Received: from n4.nabble.com (localhost [127.0.0.1]) by n4.nabble.com (Postfix) with ESMTP id 7C2152015402 for ; Wed, 3 Oct 2018 08:23:32 -0500 (CDT) Date: Wed, 3 Oct 2018 08:23:32 -0500 (CDT) From: Hemanathan To: users@activemq.apache.org Message-ID: <1538573012506-0.post@n4.nabble.com> In-Reply-To: <1537975216262-0.post@n4.nabble.com> References: <1537532569040-0.post@n4.nabble.com> <1537772650010-0.post@n4.nabble.com> <1537813348155-0.post@n4.nabble.com> <1537881695919-0.post@n4.nabble.com> <1537975216262-0.post@n4.nabble.com> Subject: Re: Stale connection hanging at broker during consumer crash MIME-Version: 1.0 Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: 7bit I am getting this exception on broker side when consumer crashes. Is there anyway to close the connection completely on broker side.? 2018-10-01T09:50:27.589+0200 [ActiveMQ Transport: ssl:///x.x.x.x:42188] DEBUG o.a.a.t.logwriters.DefaultLogWriter:65 logReceivedException RECEIVED Exception: java.io.EOFException java.io.EOFException: null at java.io.DataInputStream.readInt(DataInputStream.java:392) ~[na:1.8.0_152] at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:268) ~[activemq-client-5.14.0.jar:5.14.0] at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:240) ~[activemq-client-5.14.0.jar:5.14.0] at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:232) ~[activemq-client-5.14.0.jar:5.14.0] at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:215) ~[activemq-client-5.14.0.jar:5.14.0] at java.lang.Thread.run(Thread.java:748) [na:1.8.0_152] 2018-10-01T09:50:27.592+0200 [ActiveMQ Transport: ssl:///x.x.x.x:42188] DEBUG o.a.a.broker.TransportConnection:238 serviceTransportException Transport Connection to: tcp://x.x.x.x:42188 failed: java.io.EOFException java.io.EOFException: null at java.io.DataInputStream.readInt(DataInputStream.java:392) ~[na:1.8.0_152] at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:268) ~[activemq-client-5.14.0.jar:5.14.0] at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:240) ~[activemq-client-5.14.0.jar:5.14.0] at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:232) ~[activemq-client-5.14.0.jar:5.14.0] at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:215) ~[activemq-client-5.14.0.jar:5.14.0] at java.lang.Thread.run(Thread.java:748) [na:1.8.0_152] -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html