|
1
22 package org.objectweb.petals.binding.jms.outgoing;
23
24 import java.io.ByteArrayOutputStream  ;
25 import java.io.IOException ;
26 import java.util.Iterator ;
27 import java.util.Map ;
28 import java.util.logging.Level ;
29 import java.util.logging.Logger ;
30
31 import javax.jbi.messaging.ExchangeStatus;
32 import javax.jbi.messaging.MessageExchange;
33 import javax.jbi.messaging.MessagingException;
34 import javax.jbi.messaging.NormalizedMessage;
35 import javax.jms.JMSException ;
36 import javax.jms.JMSSecurityException ;
37 import javax.jms.TextMessage ;
38 import javax.xml.namespace.QName ;
39 import javax.xml.transform.Transformer ;
40 import javax.xml.transform.TransformerException ;
41 import javax.xml.transform.TransformerFactory ;
42 import javax.xml.transform.stream.StreamResult ;
43
44 import org.objectweb.petals.binding.jms.JMSConnection;
45 import org.objectweb.petals.component.common.HandlingException;
46 import org.objectweb.petals.component.common.MEPConstants;
47 import org.objectweb.petals.component.common.util.MessageExchangeWrapper;
48 import org.objectweb.petals.tools.jbicommon.descriptor.Extensions;
49
50
58 public class JBIListener implements
59 org.objectweb.petals.component.common.bc.JBIListener {
60
61 private static final String PROPERTY_OPERATION = "javax.jbi.messaging.operation";
62
63 private Logger logger;
64
65 private Map <String , JMSConnection> jmsConnections;
66
67 public JBIListener(Map <String , JMSConnection> jmsConnections, Logger log) {
68 this.jmsConnections = jmsConnections;
69 logger = log;
70 }
71
72
87 public boolean onJBIMessage(String address, MessageExchangeWrapper exchange,
88 Extensions extensions) throws HandlingException {
89 logger.log(Level.FINE, "onJBIMessage");
90
91 if (ExchangeStatus.ACTIVE.equals(exchange.getStatus())) {
92 if (MessageExchange.Role.PROVIDER.equals(exchange.getRole())) {
93 if (MEPConstants.IN_ONLY_PATTERN.value().equals(exchange.getPattern())
94 || MEPConstants.ROBUST_IN_ONLY_PATTERN.value().equals(exchange
95 .getPattern())
96 || MEPConstants.IN_OPTIONAL_OUT_PATTERN.value().equals(exchange
97 .getPattern())) {
98 sendJMSMessage(address, exchange);
99 } else {
100 Exception e = new Exception (
101 "MessageExchangePattern not allowed :"
102 + exchange.getPattern());
103 try {
104 setErrorStatus(exchange, e, true);
105 } catch (MessagingException e1) {
106 throw new HandlingException(e1);
107 }
108 }
109 }
110 }
111 return false;
112 }
113
114
128 protected void setErrorStatus(MessageExchange msgExchange, Exception ex,
129 boolean severe) throws MessagingException {
130 msgExchange.setError(ex);
131 msgExchange.setStatus(ExchangeStatus.ERROR);
132 if (!severe) {
133 logger.log(Level.WARNING, ex.getMessage(), ex);
134 } else {
135 logger.log(Level.SEVERE, ex.getMessage(), ex);
136 }
137 }
138
139
150 protected void sendJMSMessage(String address, MessageExchange exchange)
151 throws HandlingException {
152 logger.log(Level.FINE, "sendJMSMessage");
153 logger.log(Level.INFO, "A JBI message is received for '" + address
154 + "' JMS provider.");
155
156 JMSConnection conn = jmsConnections.get(address);
158
159 if (conn == null) {
160 throw new HandlingException("'" + address
162 + "' JMS provider not found.");
163 }
164
165 TextMessage msg = null;
167 try {
168 msg = conn.getSession().createTextMessage();
169 transform(exchange, msg);
170 } catch (JMSException e) {
171 logger.log(Level.SEVERE, "Can not create a JMS text message.", e);
172 throw new HandlingException(e);
173 } catch (Exception e) {
174 logger.log(Level.SEVERE,
175 "Can not transform the JBI message to a JMS message.", e);
176 throw new HandlingException(e);
177 }
178
179 try {
181 conn.getMessageProducer().send(msg);
182 if(conn.isTransacted()){
183 conn.getSession().commit();
184 }
185 } catch (JMSSecurityException e) {
186 logger.log(Level.SEVERE, "Can not send the JMS message, WRITE right not granted.", e);
187 throw new HandlingException(e);
188 } catch (JMSException e) {
189 logger.log(Level.SEVERE, "Can not send the JMS message.", e);
190 throw new HandlingException(e);
191 }
192 logger.log(Level.INFO, "Message sent to '" + conn.getDestinationName()
193 + "'.");
194 }
195
196
209 protected void transform(MessageExchange exchange, TextMessage jms) throws JMSException , TransformerException , IOException {
210 logger.log(Level.FINE, "transform");
211
212 NormalizedMessage in = exchange.getMessage("in");
213 QName operation = exchange.getOperation();
214
215 for (Iterator it = in.getPropertyNames().iterator(); it.hasNext();) {
217 String pName = (String ) it.next();
218 jms.setObjectProperty(pName, in.getProperty(pName));
219 }
220 if (operation != null) {
222 jms.setStringProperty(PROPERTY_OPERATION, operation.toString());
223 }
224
225 StreamResult stream = new StreamResult (new ByteArrayOutputStream ());
227 Transformer transformer = TransformerFactory.newInstance()
228 .newTransformer();
229 transformer.transform(in.getContent(), stream);
230 stream.getOutputStream().close();
231 jms.setText(stream.getOutputStream().toString());
232 }
233
234 }
235 |
Popular Tags |
Java API By Example, From Geeks To Geeks.