KickJava   Java API By Example, From Geeks To Geeks.

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


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