KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > apache > servicemix > components > activesoap > ASOutBinding


1 /*
2  * Licensed to the Apache Software Foundation (ASF) under one or more
3  * contributor license agreements. See the NOTICE file distributed with
4  * this work for additional information regarding copyright ownership.
5  * The ASF licenses this file to You under the Apache License, Version 2.0
6  * (the "License"); you may not use this file except in compliance with
7  * the License. You may obtain a copy of the License at
8  *
9  * http://www.apache.org/licenses/LICENSE-2.0
10  *
11  * Unless required by applicable law or agreed to in writing, software
12  * distributed under the License is distributed on an "AS IS" BASIS,
13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14  * See the License for the specific language governing permissions and
15  * limitations under the License.
16  */
17 package org.apache.servicemix.components.activesoap;
18
19 import javax.jbi.messaging.MessageExchange;
20 import javax.jbi.messaging.NormalizedMessage;
21 import javax.xml.stream.XMLStreamReader;
22
23 import org.apache.servicemix.components.util.OutBinding;
24 import org.codehaus.activesoap.RestService;
25
26 /**
27  * Converts an inbound JBI message into an <a HREF="http://activesoap.codehaus.org/">ActiveSOAP</a>
28  * one way invocation.
29  *
30  * @version $Revision: 429277 $
31  */
32 public class ASOutBinding extends OutBinding {
33
34     private RestService service;
35     private ASMarshaler marshaler = new ASMarshaler();
36
37     public ASOutBinding(RestService service) {
38         this.service = service;
39     }
40
41     /**
42      * @deprecated use getMarshaler instead
43      */
44     public ASMarshaler getMarshaller() {
45         return marshaler;
46     }
47
48     /**
49      * @deprecated use setMarshaler instead
50      */
51     public void setMarshaller(ASMarshaler marshaler) {
52         this.marshaler = marshaler;
53     }
54
55     /**
56      * @return the marshaler
57      */
58     public ASMarshaler getMarshaler() {
59         return marshaler;
60     }
61
62     /**
63      * @param marshaler the marshaler to set
64      */
65     public void setMarshaler(ASMarshaler marshaler) {
66         this.marshaler = marshaler;
67     }
68
69     // Implementation methods
70 //-------------------------------------------------------------------------
71 protected void process(MessageExchange messageExchange, NormalizedMessage inMessage) throws Exception JavaDoc {
72         XMLStreamReader in = marshaler.createStreamReader(inMessage);
73
74         org.codehaus.activesoap.MessageExchange asExchange = service.createMessageExchange(in, null);
75         marshaler.fromNMS(asExchange, inMessage);
76         service.invoke(asExchange);
77
78         done(messageExchange);
79     }
80 }
81
Popular Tags