正在加载图片...
lelse if(msg instanceof obiectMessage) ObjectMessage omsg-(ObjectMessage)msg: man (Man)omsg.getobject() String content man.getName()+ ”家住” man.getAddress () System.out.printin(content): lelse if (msg instanceof MapMessage) MapMessage map-(MapMessage)msg string content-map.getst ing ("nol") system.out.println(content); lelse if(msg instanceof BvtesMessage) BytesMessage bmsa (BytesMessage)msg ByteArrayoutputstream bytestream byte[]buffer new byte[256]; int length 0: while ((length bmsg.readBytes(buffer))!-1){ bytestream.write(buffer,0,length); content new String(bytestream.toByteArray()); bytestream.close(); System.out.println(content): )else if(mag instanceof StreamMessage) essage smsg (StreamMessage)msg; string content smsg.readstring() System.out.println(content); catch (Exception e)[ e.printstackTrace() 1 在项目上建立一个bean,名称为Man,类Man在包cn.edu.jms,bean下,内容如 package cn.edu.ims.bean; import java.io.Serializable; public class Man implements serializable( private static final long serialversionUID -1789733418716736359L:}else if(msg instanceof ObjectMessage){ ObjectMessage omsg = (ObjectMessage) msg; Man man = (Man) omsg.getObject(); String content = man.getName()+ " 家 住 "+ man.getAddress(); System.out.println(content); }else if(msg instanceof MapMessage){ MapMessage map = (MapMessage) msg; String content = map.getString("no1"); System.out.println(content); }else if(msg instanceof BytesMessage){ BytesMessage bmsg = (BytesMessage) msg; ByteArrayOutputStream byteStream = new ByteArrayOutputStream(); byte[] buffer = new byte[256]; int length = 0; while ((length = bmsg.readBytes(buffer)) != -1) { byteStream.write(buffer, 0, length); } String content = new String(byteStream.toByteArray()); byteStream.close(); System.out.println(content); }else if(msg instanceof StreamMessage){ StreamMessage smsg = (StreamMessage) msg; String content = smsg.readString(); System.out.println(content); } } catch (Exception e){ e.printStackTrace(); } } } 在项目上建立一个 bean,名称为 Man,类 Man 在包 cn.edu.jms.bean 下,内容如 下: package cn.edu.jms.bean; import java.io.Serializable; public class Man implements Serializable{ private static final long serialVersionUID = -1789733418716736359L;
<<向上翻页向下翻页>>
©2008-现在 cucdc.com 高等教育资讯网 版权所有