From 77312e5a6487dd2bd384bf3cf167cef6b61aa658 Mon Sep 17 00:00:00 2001 From: "Hiram R. Chirino" Date: Wed, 23 Jan 2013 14:54:15 +0000 Subject: [PATCH] Fixes AMQ-4258: Endless loop when received incorrect AMQP message Applied patch sumbitted by Robert Balent. Many thanks! git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1437427 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/activemq/transport/amqp/AmqpProtocolConverter.java | 1 + 1 file changed, 1 insertion(+) diff --git a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java index c082edf905..9bbed32129 100644 --- a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java +++ b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java @@ -159,6 +159,7 @@ class AmqpProtocolConverter { frame.moveHead(count); } catch (Throwable e) { handleException(new AmqpProtocolException("Could not decode AMQP frame: " + frame, true, e)); + return; } try {