KickJava   Java API By Example, From Geeks To Geeks.

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


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