KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > apache > cayenne > remote > service > DispatchHelper


1 /*****************************************************************
2  * Licensed to the Apache Software Foundation (ASF) under one
3  * or more contributor license agreements. See the NOTICE file
4  * distributed with this work for additional information
5  * regarding copyright ownership. The ASF licenses this file
6  * to you under the Apache License, Version 2.0 (the
7  * "License"); you may not use this file except in compliance
8  * with the License. You may obtain a copy of the License at
9  *
10  * http://www.apache.org/licenses/LICENSE-2.0
11  *
12  * Unless required by applicable law or agreed to in writing,
13  * software distributed under the License is distributed on an
14  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15  * KIND, either express or implied. See the License for the
16  * specific language governing permissions and limitations
17  * under the License.
18  ****************************************************************/
19
20 package org.apache.cayenne.remote.service;
21
22 import org.apache.cayenne.CayenneRuntimeException;
23 import org.apache.cayenne.DataChannel;
24 import org.apache.cayenne.remote.BootstrapMessage;
25 import org.apache.cayenne.remote.ClientMessage;
26 import org.apache.cayenne.remote.QueryMessage;
27 import org.apache.cayenne.remote.SyncMessage;
28
29 /**
30  * A helper class to match message types with DataChannel methods.
31  *
32  * @since 1.2
33  * @author Andrus Adamchik
34  */
35 class DispatchHelper {
36
37     static Object JavaDoc dispatch(DataChannel channel, ClientMessage message) {
38         // do most common messages first...
39 if (message instanceof QueryMessage) {
40             return channel.onQuery(null, ((QueryMessage) message).getQuery());
41         }
42         else if (message instanceof SyncMessage) {
43             SyncMessage sync = (SyncMessage) message;
44             return channel.onSync(null, sync.getSenderChanges(), sync.getType());
45         }
46         else if (message instanceof BootstrapMessage) {
47             return channel.getEntityResolver().getClientEntityResolver();
48         }
49         else {
50             throw new CayenneRuntimeException(
51                     "Message dispatch error. Unsupported message: " + message);
52         }
53     }
54 }
55
Popular Tags