Author: gnodet
Date: Thu Jul 3 02:48:06 2008
New Revision: 673639
URL: http://svn.apache.org/viewvc?rev=673639&view=rev
Log:
SM-1437: Access to the MessageExchange from the pojo in cxf-se
Added:
servicemix/components/engines/servicemix-cxf-se/trunk/src/main/java/org/apache/servicemix/cxfse/JBIContext.java
Modified:
servicemix/components/engines/servicemix-cxf-se/trunk/src/main/java/org/apache/servicemix/cxfse/CxfSeEndpoint.java
Modified:
servicemix/components/engines/servicemix-cxf-se/trunk/src/main/java/org/apache/servicemix/cxfse/CxfSeEndpoint.java
URL:
http://svn.apache.org/viewvc/servicemix/components/engines/servicemix-cxf-se/trunk/src/main/java/org/apache/servicemix/cxfse/CxfSeEndpoint.java?rev=673639&r1=673638&r2=673639&view=diff
==============================================================================
---
servicemix/components/engines/servicemix-cxf-se/trunk/src/main/java/org/apache/servicemix/cxfse/CxfSeEndpoint.java
(original)
+++
servicemix/components/engines/servicemix-cxf-se/trunk/src/main/java/org/apache/servicemix/cxfse/CxfSeEndpoint.java
Thu Jul 3 02:48:06 2008
@@ -183,46 +183,49 @@
*/
@Override
public void process(MessageExchange exchange) throws Exception {
-
- QName opeName = exchange.getOperation();
- EndpointInfo ei = endpoint.getServer().getEndpoint().getEndpointInfo();
- if (opeName == null) {
- // if interface only have one operation, may not specify the
opeName in MessageExchange
- if (ei.getBinding().getOperations().size() == 1) {
- opeName =
ei.getBinding().getOperations().iterator().next().getName();
- exchange.setOperation(opeName);
- } else {
- throw new Fault(
- new Exception("Operation not bound on this
MessageExchange"));
-
+ JBIContext.setMessageExchange(exchange);
+ try {
+ QName opeName = exchange.getOperation();
+ EndpointInfo ei =
endpoint.getServer().getEndpoint().getEndpointInfo();
+ if (opeName == null) {
+ // if interface only have one operation, may not specify the
opeName in MessageExchange
+ if (ei.getBinding().getOperations().size() == 1) {
+ opeName =
ei.getBinding().getOperations().iterator().next().getName();
+ exchange.setOperation(opeName);
+ } else {
+ throw new Fault(
+ new Exception("Operation not bound on this
MessageExchange"));
+
+ }
}
- }
-
- JBITransportFactory jbiTransportFactory = (JBITransportFactory)
getBus()
- .getExtension(ConduitInitiatorManager.class)
- .getConduitInitiator(CxfSeComponent.JBI_TRANSPORT_ID);
-
- QName serviceName = exchange.getService();
- if (serviceName == null) {
- serviceName = getService();
- exchange.setService(serviceName);
- }
- QName interfaceName = exchange.getInterfaceName();
- if (interfaceName == null) {
- interfaceName = getInterfaceName();
- exchange.setInterfaceName(interfaceName);
- }
- JBIDestination jbiDestination = jbiTransportFactory
- .getDestination(serviceName.toString()
- + interfaceName.toString());
- DeliveryChannel dc = getContext().getDeliveryChannel();
- jbiTransportFactory.setDeliveryChannel(dc);
-
- jbiDestination.setDeliveryChannel(dc);
- if (exchange.getStatus() == ExchangeStatus.ACTIVE) {
- jbiDestination.getJBIDispatcherUtil().dispatch(exchange);
+
+ JBITransportFactory jbiTransportFactory = (JBITransportFactory)
getBus()
+ .getExtension(ConduitInitiatorManager.class)
+ .getConduitInitiator(CxfSeComponent.JBI_TRANSPORT_ID);
+
+ QName serviceName = exchange.getService();
+ if (serviceName == null) {
+ serviceName = getService();
+ exchange.setService(serviceName);
+ }
+ QName interfaceName = exchange.getInterfaceName();
+ if (interfaceName == null) {
+ interfaceName = getInterfaceName();
+ exchange.setInterfaceName(interfaceName);
+ }
+ JBIDestination jbiDestination = jbiTransportFactory
+ .getDestination(serviceName.toString()
+ + interfaceName.toString());
+ DeliveryChannel dc = getContext().getDeliveryChannel();
+ jbiTransportFactory.setDeliveryChannel(dc);
+
+ jbiDestination.setDeliveryChannel(dc);
+ if (exchange.getStatus() == ExchangeStatus.ACTIVE) {
+ jbiDestination.getJBIDispatcherUtil().dispatch(exchange);
+ }
+ } finally {
+ JBIContext.setMessageExchange(null);
}
-
}
/*
Added:
servicemix/components/engines/servicemix-cxf-se/trunk/src/main/java/org/apache/servicemix/cxfse/JBIContext.java
URL:
http://svn.apache.org/viewvc/servicemix/components/engines/servicemix-cxf-se/trunk/src/main/java/org/apache/servicemix/cxfse/JBIContext.java?rev=673639&view=auto
==============================================================================
---
servicemix/components/engines/servicemix-cxf-se/trunk/src/main/java/org/apache/servicemix/cxfse/JBIContext.java
(added)
+++
servicemix/components/engines/servicemix-cxf-se/trunk/src/main/java/org/apache/servicemix/cxfse/JBIContext.java
Thu Jul 3 02:48:06 2008
@@ -0,0 +1,46 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.servicemix.cxfse;
+
+import javax.jbi.messaging.MessageExchange;
+
+/**
+ * A static method which provides access to some JBI informations
+ *
+ * @author gnodet
+ */
+public final class JBIContext {
+
+ private static ThreadLocal<MessageExchange> exchanges = new
ThreadLocal<MessageExchange>();
+
+ private JBIContext() {
+ }
+
+ /**
+ * Retrieve the MessageExchange currently being handled
+ *
+ * @return the current MessageExchange or null
+ */
+ public static MessageExchange getMessageExchange() {
+ return exchanges.get();
+ }
+
+ protected static void setMessageExchange(MessageExchange exchange) {
+ exchanges.set(exchange);
+ }
+
+}
