* SOAP messages are constructed with javax.xml.soap API. The messages * are converted with MessageTransformer utility to convert SOAP to JMS * message types. The JMS messages are then published to the JMS topics. */ public class SendSOAPMessageWithJMS { ConnectionFactory connectionFactory = null; Connection connection = null; Session session = null; Topic topic = null; MessageProducer msgProducer = null; /** * default constructor. */ public SendSOAPMessageWithJMS(String topicName) { init(topicName); } /** * Initialize JMS Connection/Session/Topic and Producer. */ public void init(String topicName) { try { connectionFactory = new com.sun.messaging.ConnectionFactory(); connection = connectionFactory.createConnection(); session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); topic = session.createTopic(topicName); msgProducer = session.createProducer(topic); } catch (JMSException jmse) { jmse.printStackTrace(); } } /** * Send SOAP message with JMS API. */ public void send () throws Exception { /** * Construct a default SOAP message factory. */ MessageFactory mf = MessageFactory.newInstance(); /** * Create a SOAP message object. */ SOAPMessage soapMessage = mf.createMessage(); /** * Get SOAP part. */ SOAPPart soapPart = soapMessage.getSOAPPart(); /** * Get SOAP envelope. */ SOAPEnvelope soapEnvelope = soapPart.getEnvelope(); /** * Get SOAP body. */ SOAPBody soapBody = soapEnvelope.getBody(); /** * Create a name object. with name space http://www.sun.com/imq. */ Name name = soapEnvelope.createName("HelloWorld", "hw", "http://www.sun.com/imq"); /** * Add child element with the above name. */ SOAPElement element = soapBody.addChildElement(name); /** * Add another child element. */ element.addTextNode( "Welcome to SunOne Web Services." ); /** * Create an atachment with activation API. */ URL url = new URL ("http://java.sun.com/webservices/"); DataHandler dh = new DataHandler (url); AttachmentPart ap = soapMessage.createAttachmentPart(dh); /** * set content type/ID. */ ap.setContentType("text/html"); ap.setContentId("cid-001"); /** * add the attachment to the SOAP message. */ soapMessage.addAttachmentPart(ap); soapMessage.saveChanges(); /** * Convert SOAP to JMS message. */ Message message = MessageTransformer.SOAPMessageIntoJMSMessage( soapMessage, session ); /** * publish JMS message. */ msgProducer.send( message ); } /** * close JMS connection. */ public void close() throws JMSException { connection.close(); } /** * The main program to send SOAP messages with JMS. */ public static void main (String[] args) { String topicName = "TestTopic"; if (args.length > 0) { topicName = args[0]; } try { SendSOAPMessageWithJMS ssm = new SendSOAPMessageWithJMS(topicName); ssm.send(); ssm.close(); } catch (Exception e) { e.printStackTrace(); } } } jaxm.zip( 13 k)