1 46 package org.mr.api.simple; 47 48 import javax.jms.JMSException ; 49 50 60 public class Message { 61 private byte[] payload; 62 63 66 public Message(byte[] payload) { 67 this.payload = payload; 68 } 70 public Message(javax.jms.BytesMessage message) throws JMSException { 71 message.reset(); 72 long length = message.getBodyLength(); 73 this.payload = new byte[(int) length]; 74 message.readBytes(this.payload); 75 } 76 77 81 public byte[] getPayload() { 82 return this.payload; 83 } 84 85 javax.jms.BytesMessage toBytesMessage(javax.jms.Session session) throws JMSException { 86 javax.jms.BytesMessage message = session.createBytesMessage(); 87 message.writeBytes(this.payload); 88 return message; 89 } 90 } | Popular Tags |