KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > apache > servicemix > jbi > messaging > InOnlyImpl


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.jbi.messaging;
18
19 import javax.jbi.messaging.InOnly;
20
21 import java.io.IOException JavaDoc;
22 import java.io.ObjectInput JavaDoc;
23
24 /**
25  * InOnly message exchange.
26  *
27  * @version $Revision: 426415 $
28  */
29 public class InOnlyImpl extends MessageExchangeImpl implements InOnly {
30     
31     private static final long serialVersionUID = -4851111881482457905L;
32     
33     private static int[][] STATES_CONSUMER = {
34         { CAN_CONSUMER + CAN_OWNER + CAN_SET_IN_MSG + CAN_SEND + CAN_STATUS_ACTIVE, 1, -1, -1, -1 },
35         { CAN_CONSUMER, -1, -1, 2, 2 },
36         { CAN_CONSUMER + CAN_OWNER, -1, -1, -1, -1 },
37     };
38     private static int[][] STATES_PROVIDER = {
39         { CAN_PROVIDER, 1, -1, -1, -1 },
40         { CAN_PROVIDER + CAN_OWNER + CAN_SEND + CAN_STATUS_DONE + CAN_STATUS_ERROR, -1, -1, 2, 2 },
41         { CAN_PROVIDER, -1, -1, -1, -1 },
42     };
43     
44     public InOnlyImpl() {
45     }
46     
47     public InOnlyImpl(String JavaDoc exchangeId) {
48         super(exchangeId, MessageExchangeSupport.IN_ONLY, STATES_CONSUMER);
49         this.mirror = new InOnlyImpl(this);
50     }
51     
52     public InOnlyImpl(ExchangePacket packet) {
53         super(packet, STATES_CONSUMER);
54         this.mirror = new InOnlyImpl(this);
55     }
56     
57     protected InOnlyImpl(InOnlyImpl mep) {
58         super(mep.packet, STATES_PROVIDER);
59         this.mirror = mep;
60     }
61
62     public void readExternal(ObjectInput JavaDoc in) throws IOException JavaDoc, ClassNotFoundException JavaDoc {
63         this.packet = new ExchangePacket();
64         this.packet.readExternal(in);
65         if (this.packet.in != null) {
66             this.packet.in.exchange = this;
67         }
68         if (this.packet.out != null) {
69             this.packet.out.exchange = this;
70         }
71         if (this.packet.fault != null) {
72             this.packet.fault.exchange = this;
73         }
74         this.state = in.read();
75         this.mirror = new InOnlyImpl();
76         this.mirror.mirror = this;
77         this.mirror.packet = this.packet;
78         this.mirror.state = in.read();
79         boolean provider = in.readBoolean();
80         if (provider) {
81             this.states = STATES_PROVIDER;
82             this.mirror.states = STATES_CONSUMER;
83         } else {
84             this.states = STATES_CONSUMER;
85             this.mirror.states = STATES_PROVIDER;
86         }
87     }
88
89
90 }
Popular Tags