1 7 package org.jboss.jms.client.p2p; 8 9 import javax.jms.Destination ; 10 import javax.jms.JMSException ; 11 import javax.jms.Message ; 12 13 import org.jboss.jms.MessageImpl; 14 import org.jboss.jms.client.ProducerDelegate; 15 import org.jboss.jms.message.JBossMessage; 16 17 24 public class P2PProducerDelegate 25 implements ProducerDelegate 26 { 27 29 31 private P2PSessionDelegate session = null; 32 33 35 37 public P2PProducerDelegate(P2PSessionDelegate session, Destination destination) 38 throws JMSException 39 { 40 this.session = session; 41 } 42 43 45 47 public void close() throws JMSException 48 { 49 } 50 51 public void closing() throws JMSException 52 { 53 } 54 55 public void send(Message message) 56 throws JMSException 57 { 58 this.session.send((MessageImpl) ((MessageImpl) message).clone()); 59 } 60 61 public JBossMessage encapsulateMessage(Message message) 62 { 63 return null; 65 } 66 67 69 71 73 75 } 76 | Popular Tags |