1 23 package com.sun.enterprise.jbi.serviceengine.bridge.transport; 24 import com.sun.enterprise.jbi.serviceengine.util.soap.MessageExchangeHelper; 25 import java.io.InputStream ; 26 import javax.jbi.messaging.MessageExchange; 27 import javax.xml.soap.SOAPMessage ; 28 29 30 34 public class NMRServerConnection extends NMRConnection { 35 36 private MessageExchangeHelper meHelper; 37 38 39 public NMRServerConnection(MessageExchange messageExchange) { 40 meHelper = new MessageExchangeHelper(); 41 meHelper.setMessageExchange(messageExchange); 42 setContentType(); 43 44 } 45 46 public InputStream getInput () { 47 try { 48 SOAPMessage soapMessage = meHelper.denormalizeMessage(true); 49 createSOAPMessageInputStream(soapMessage); 50 } catch(Exception e) { 51 throw new TransportFailedException(e.getMessage()); 52 } 53 return inputStream; 54 } 55 56 public void closeOutput() { 57 try { 58 SOAPMessage incomingMessage = null; 59 if(meHelper.isInOutMessageExchange()) { 60 incomingMessage = createSOAPMessageFromOutputStream(); 61 } 62 meHelper.handleResponse(incomingMessage, false); 63 64 } catch(Exception e) { 65 throw new TransportFailedException(e.getMessage()); 66 } 67 } 68 69 public void handleException(Exception e) { 70 meHelper.handleException(e); 71 } 72 } 73 | Popular Tags |