Author: gaohoward Date: 2011-09-25 09:40:24 -0400 (Sun, 25 Sep 2011) New Revision: 11412 Modified: branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/StompDecoder.java Log: fix compilation error Modified: branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/StompDecoder.java =================================================================== --- branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/StompDecoder.java 2011-09-25 08:18:23 UTC (rev 11411) +++ branches/STOMP11/hornetq-core/src/main/java/org/hornetq/core/protocol/stomp/StompDecoder.java 2011-09-25 13:40:24 UTC (rev 11412) @@ -166,6 +166,11 @@ init(); } + public StompDecoder() + { + init(); + } + public boolean hasBytes() { return data > pos; @@ -184,7 +189,7 @@ */ public synchronized StompFrame decode(final HornetQBuffer buffer) throws Exception { - if (connection.isValid()) + if (connection != null && connection.isValid()) { VersionedStompFrameHandler handler = connection.getFrameHandler(); return handler.decode(this, buffer);