Java MessageEOFException类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中javax.jms.MessageEOFException类的典型用法代码示例。如果您正苦于以下问题：Java MessageEOFException类的具体用法？Java MessageEOFException怎么用？Java MessageEOFException使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

MessageEOFException类属于javax.jms包，在下文中一共展示了MessageEOFException类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: readByte

import javax.jms.MessageEOFException; //导入依赖的package包/类
@Override
public byte readByte() throws JMSException {
   if (bodyWriteOnly) {
      throw new MessageNotReadableException("The message body is writeonly");
   }

   try {
      Object value = content.get(position);
      offset = 0;
      if (value == null) {
         throw new NullPointerException("Value is null");
      } else if (value instanceof Byte) {
         position++;
         return ((Byte) value).byteValue();
      } else if (value instanceof String) {
         byte result = Byte.parseByte((String) value);
         position++;
         return result;
      } else {
         throw new MessageFormatException("Invalid conversion");
      }
   } catch (IndexOutOfBoundsException e) {
      throw new MessageEOFException("");
   }
}

开发者ID:apache，项目名称:activemq-artemis，代码行数:26，代码来源:SimpleJMSStreamMessage.java

示例2: readChar

import javax.jms.MessageEOFException; //导入依赖的package包/类
@Override
public char readChar() throws JMSException {
   if (bodyWriteOnly) {
      throw new MessageNotReadableException("The message body is writeonly");
   }
   try {
      Object value = content.get(position);
      offset = 0;

      if (value == null) {
         throw new NullPointerException("Value is null");
      } else if (value instanceof Character) {
         position++;
         return ((Character) value).charValue();
      } else {
         throw new MessageFormatException("Invalid conversion");
      }
   } catch (IndexOutOfBoundsException e) {
      throw new MessageEOFException("");
   }
}

开发者ID:apache，项目名称:activemq-artemis，代码行数:22，代码来源:SimpleJMSStreamMessage.java

示例3: readFloat

import javax.jms.MessageEOFException; //导入依赖的package包/类
@Override
public float readFloat() throws JMSException {
   if (bodyWriteOnly) {
      throw new MessageNotReadableException("The message body is writeonly");
   }
   try {
      Object value = content.get(position);
      offset = 0;

      if (value == null) {
         throw new NullPointerException("Value is null");
      } else if (value instanceof Float) {
         position++;
         return ((Float) value).floatValue();
      } else if (value instanceof String) {
         float result = Float.parseFloat((String) value);
         position++;
         return result;
      } else {
         throw new MessageFormatException("Invalid conversion");
      }
   } catch (IndexOutOfBoundsException e) {
      throw new MessageEOFException("");
   }
}

开发者ID:apache，项目名称:activemq-artemis，代码行数:26，代码来源:SimpleJMSStreamMessage.java

示例4: duplicateStreamMessage

import javax.jms.MessageEOFException; //导入依赖的package包/类
private static AbstractMessage duplicateStreamMessage( StreamMessage srcMessage ) throws JMSException
{
    StreamMessageImpl copy = new StreamMessageImpl();
    copyHeaders(srcMessage,copy);
    
    srcMessage.reset();
    try
    {
        while (true)
            copy.writeObject(srcMessage.readObject());
    }
    catch (MessageEOFException e)
    {
        // Complete
    }
    
    return copy;
}

开发者ID:timewalker74，项目名称:ffmq，代码行数:19，代码来源:MessageTools.java

示例5: testClearBody

import javax.jms.MessageEOFException; //导入依赖的package包/类
public void testClearBody() throws Exception
{
	BytesMessageImpl msg;
	
	byte[] dummy = { (byte)1 , (byte)2 , (byte)3 };
	
	msg = new BytesMessageImpl();
	msg.writeBytes(dummy);
	msg.reset();
	assertEquals(true,msg.readBoolean());
	assertEquals(true,msg.readBoolean());
	assertEquals(true,msg.readBoolean());
	msg.clearBody();
	msg.writeBytes(dummy);
	msg.reset();
	assertEquals(true,msg.readBoolean());
	assertEquals(true,msg.readBoolean());
	assertEquals(true,msg.readBoolean());
	msg.clearBody();
	msg.writeBytes(dummy);
	msg.clearBody();
	msg.reset();
	try { msg.readByte(); fail("Should have failed"); } catch (MessageEOFException e) { /* OK */ }
}

开发者ID:timewalker74，项目名称:ffmq，代码行数:25，代码来源:BytesMessageImplTest.java