From: <pke...@us...> - 2001-05-17 23:44:45
|
User: pkendall Date: 01/05/17 16:44:44 Modified: src/main/org/jbossmq SpyBytesMessage.java Log: Throw MessageEOFException when EOFException is caught on read* methods. Revision Changes Path 1.3 +24 -1 jbossmq/src/main/org/jbossmq/SpyBytesMessage.java Index: SpyBytesMessage.java =================================================================== RCS file: /cvsroot/jboss/jbossmq/src/main/org/jbossmq/SpyBytesMessage.java,v retrieving revision 1.2 retrieving revision 1.3 diff -u -r1.2 -r1.3 --- SpyBytesMessage.java 2001/03/02 01:12:40 1.2 +++ SpyBytesMessage.java 2001/05/17 23:44:44 1.3 @@ -8,6 +8,7 @@ import javax.jms.BytesMessage; import javax.jms.JMSException; +import javax.jms.MessageEOFException; import javax.jms.MessageFormatException; import javax.jms.MessageNotWriteableException; import java.io.IOException; @@ -21,7 +22,7 @@ * * @author Norbert Lataille (Nor...@m4...) * - * @version $Revision: 1.2 $ + * @version $Revision: 1.3 $ */ public class SpyBytesMessage extends SpyMessage @@ -52,6 +53,8 @@ checkRead(); try { return m.readBoolean(); + } catch (EOFException e) { + throw new MessageEOFException(""); } catch (IOException e) { throw new JMSException("IOException"); } @@ -62,6 +65,8 @@ checkRead(); try { return m.readByte(); + } catch (EOFException e) { + throw new MessageEOFException(""); } catch (IOException e) { throw new JMSException("IOException"); } @@ -72,6 +77,8 @@ checkRead(); try { return m.readUnsignedByte(); + } catch (EOFException e) { + throw new MessageEOFException(""); } catch (IOException e) { throw new JMSException("IOException"); } @@ -82,6 +89,8 @@ checkRead(); try { return m.readShort(); + } catch (EOFException e) { + throw new MessageEOFException(""); } catch (IOException e) { throw new JMSException("IOException"); } @@ -92,6 +101,8 @@ checkRead(); try { return m.readUnsignedShort(); + } catch (EOFException e) { + throw new MessageEOFException(""); } catch (IOException e) { throw new JMSException("IOException"); } @@ -102,6 +113,8 @@ checkRead(); try { return m.readChar(); + } catch (EOFException e) { + throw new MessageEOFException(""); } catch (IOException e) { throw new JMSException("IOException"); } @@ -112,6 +125,8 @@ checkRead(); try { return m.readInt(); + } catch (EOFException e) { + throw new MessageEOFException(""); } catch (IOException e) { throw new JMSException("IOException"); } @@ -122,6 +137,8 @@ checkRead(); try { return m.readLong(); + } catch (EOFException e) { + throw new MessageEOFException(""); } catch (IOException e) { throw new JMSException("IOException"); } @@ -132,6 +149,8 @@ checkRead(); try { return m.readFloat(); + } catch (EOFException e) { + throw new MessageEOFException(""); } catch (IOException e) { throw new JMSException("IOException"); } @@ -142,6 +161,8 @@ checkRead(); try { return m.readDouble(); + } catch (EOFException e) { + throw new MessageEOFException(""); } catch (IOException e) { throw new JMSException("IOException"); } @@ -152,6 +173,8 @@ checkRead(); try { return m.readUTF(); + } catch (EOFException e) { + throw new MessageEOFException(""); } catch (IOException e) { throw new JMSException("IOException"); } |