1 /*******************************************************************************
\r
2 * Copyright (c) 2007, 2010 Association for Decentralized Information Management
\r
3 * in Industry THTH ry.
\r
4 * All rights reserved. This program and the accompanying materials
\r
5 * are made available under the terms of the Eclipse Public License v1.0
\r
6 * which accompanies this distribution, and is available at
\r
7 * http://www.eclipse.org/legal/epl-v10.html
\r
10 * VTT Technical Research Centre of Finland - initial API and implementation
\r
11 *******************************************************************************/
\r
12 package org.simantics.db.common.processor;
\r
14 import java.util.Collection;
\r
16 import org.simantics.db.RequestProcessor;
\r
17 import org.simantics.db.Resource;
\r
18 import org.simantics.db.Session;
\r
19 import org.simantics.db.exception.DatabaseException;
\r
20 import org.simantics.db.procedure.AsyncListener;
\r
21 import org.simantics.db.procedure.AsyncMultiListener;
\r
22 import org.simantics.db.procedure.AsyncMultiProcedure;
\r
23 import org.simantics.db.procedure.AsyncProcedure;
\r
24 import org.simantics.db.procedure.Listener;
\r
25 import org.simantics.db.procedure.MultiListener;
\r
26 import org.simantics.db.procedure.MultiProcedure;
\r
27 import org.simantics.db.procedure.Procedure;
\r
28 import org.simantics.db.procedure.SyncListener;
\r
29 import org.simantics.db.procedure.SyncMultiListener;
\r
30 import org.simantics.db.procedure.SyncMultiProcedure;
\r
31 import org.simantics.db.procedure.SyncProcedure;
\r
32 import org.simantics.db.request.AsyncMultiRead;
\r
33 import org.simantics.db.request.AsyncRead;
\r
34 import org.simantics.db.request.DelayedWrite;
\r
35 import org.simantics.db.request.DelayedWriteResult;
\r
36 import org.simantics.db.request.ExternalRead;
\r
37 import org.simantics.db.request.MultiRead;
\r
38 import org.simantics.db.request.Read;
\r
39 import org.simantics.db.request.ReadInterface;
\r
40 import org.simantics.db.request.Write;
\r
41 import org.simantics.db.request.WriteInterface;
\r
42 import org.simantics.db.request.WriteOnly;
\r
43 import org.simantics.db.request.WriteOnlyResult;
\r
44 import org.simantics.db.request.WriteResult;
\r
45 import org.simantics.utils.datastructures.Callback;
\r
47 public class ProcessorBase implements RequestProcessor {
\r
50 public <T> void asyncRequest(AsyncMultiRead<T> request, AsyncMultiProcedure<T> procedure) {
\r
51 throw new UnsupportedOperationException();
\r
55 public <T> void asyncRequest(AsyncRead<T> request, AsyncProcedure<T> procedure) {
\r
56 throw new UnsupportedOperationException();
\r
60 public void asyncRequest(Write request, Callback<DatabaseException> callback) {
\r
61 throw new UnsupportedOperationException();
\r
65 public void asyncRequest(DelayedWrite request, Callback<DatabaseException> callback) {
\r
66 throw new UnsupportedOperationException();
\r
70 public void asyncRequest(WriteOnly request, Callback<DatabaseException> callback) {
\r
71 throw new UnsupportedOperationException();
\r
75 public <T> Collection<T> syncRequest(AsyncMultiRead<T> request, final AsyncMultiProcedure<T> procedure) {
\r
76 throw new UnsupportedOperationException();
\r
80 public <T> T syncRequest(AsyncRead<T> request, final AsyncProcedure<T> procedure) {
\r
81 throw new UnsupportedOperationException();
\r
86 public void syncRequest(Write request) {
\r
87 throw new UnsupportedOperationException();
\r
91 public void syncRequest(WriteOnly request) {
\r
92 throw new UnsupportedOperationException();
\r
96 public Session getSession() {
\r
97 throw new UnsupportedOperationException();
\r
101 public <T> void asyncRequest(AsyncRead<T> request) {
\r
102 throw new UnsupportedOperationException();
\r
106 public <T> void asyncRequest(AsyncRead<T> request,
\r
107 Procedure<T> procedure) {
\r
108 throw new UnsupportedOperationException();
\r
112 public <T> void asyncRequest(AsyncMultiRead<T> request) {
\r
113 throw new UnsupportedOperationException();
\r
117 public <T> void asyncRequest(AsyncMultiRead<T> request,
\r
118 MultiProcedure<T> procedure) {
\r
119 throw new UnsupportedOperationException();
\r
123 public <T> T syncRequest(AsyncRead<T> request) {
\r
124 throw new UnsupportedOperationException();
\r
128 public <T> T syncRequest(AsyncRead<T> request,
\r
129 Procedure<T> procedure) {
\r
130 throw new UnsupportedOperationException();
\r
134 public <T> Collection<T> syncRequest(AsyncMultiRead<T> request) {
\r
135 throw new UnsupportedOperationException();
\r
139 public <T> Collection<T> syncRequest(AsyncMultiRead<T> request,
\r
140 MultiProcedure<T> procedure) {
\r
141 throw new UnsupportedOperationException();
\r
145 public <T> T syncRequest(Read<T> request) {
\r
146 throw new UnsupportedOperationException();
\r
150 public <T> T syncRequest(Read<T> request,
\r
151 final AsyncProcedure<T> procedure) {
\r
152 throw new UnsupportedOperationException();
\r
156 public <T> void asyncRequest(Read<T> request) {
\r
157 throw new UnsupportedOperationException();
\r
161 public <T> void asyncRequest(Read<T> request,
\r
162 AsyncProcedure<T> procedure) {
\r
163 throw new UnsupportedOperationException();
\r
167 public <T> T syncRequest(Read<T> request, Procedure<T> procedure) {
\r
168 throw new UnsupportedOperationException();
\r
172 public <T> Collection<T> syncRequest(final MultiRead<T> request) throws DatabaseException {
\r
173 throw new UnsupportedOperationException();
\r
177 public <T> Collection<T> syncRequest(MultiRead<T> request, AsyncMultiProcedure<T> procedure) {
\r
178 throw new UnsupportedOperationException();
\r
182 public <T> Collection<T> syncRequest(MultiRead<T> request, MultiProcedure<T> procedure) {
\r
183 throw new UnsupportedOperationException();
\r
187 public <T> void asyncRequest(Read<T> request, Procedure<T> procedure) {
\r
188 throw new UnsupportedOperationException();
\r
192 public <T> void asyncRequest(MultiRead<T> request) {
\r
193 throw new UnsupportedOperationException();
\r
197 public <T> void asyncRequest(MultiRead<T> request, AsyncMultiProcedure<T> procedure) {
\r
198 throw new UnsupportedOperationException();
\r
202 public <T> void asyncRequest(MultiRead<T> request, MultiProcedure<T> procedure) {
\r
203 throw new UnsupportedOperationException();
\r
207 public void asyncRequest(Write r) {
\r
208 throw new UnsupportedOperationException();
\r
212 public void asyncRequest(WriteOnly r) {
\r
213 throw new UnsupportedOperationException();
\r
217 public <T> T getService(Class<T> api) {
\r
218 throw new UnsupportedOperationException();
\r
222 public <T> T peekService(Class<T> api) {
\r
223 throw new UnsupportedOperationException();
\r
227 public boolean hasService(Class<?> api) {
\r
228 throw new UnsupportedOperationException();
\r
232 public <T> void registerService(Class<T> api, T service) {
\r
233 throw new UnsupportedOperationException();
\r
237 // public <T> T syncRequest(Read<T> arg0, AsyncListener<T> arg1) {
\r
238 // throw new UnsupportedOperationException();
\r
242 public <T> T syncRequest(Read<T> arg0, SyncListener<T> arg1) {
\r
243 throw new UnsupportedOperationException();
\r
247 public <T> T syncRequest(Read<T> arg0, Listener<T> arg1) {
\r
248 throw new UnsupportedOperationException();
\r
252 public <T> T syncRequest(Read<T> arg0, SyncProcedure<T> arg1) {
\r
253 throw new UnsupportedOperationException();
\r
257 public <T> T syncRequest(AsyncRead<T> arg0, AsyncListener<T> arg1) {
\r
258 throw new UnsupportedOperationException();
\r
262 public <T> T syncRequest(AsyncRead<T> arg0, SyncListener<T> arg1) {
\r
263 throw new UnsupportedOperationException();
\r
267 public <T> T syncRequest(AsyncRead<T> arg0, Listener<T> arg1) {
\r
268 throw new UnsupportedOperationException();
\r
272 public <T> T syncRequest(AsyncRead<T> arg0, SyncProcedure<T> arg1) {
\r
273 throw new UnsupportedOperationException();
\r
277 public <T> void asyncRequest(Read<T> arg0, AsyncListener<T> arg1) {
\r
278 throw new UnsupportedOperationException();
\r
282 public <T> void asyncRequest(Read<T> arg0, SyncListener<T> arg1) {
\r
283 throw new UnsupportedOperationException();
\r
287 public <T> void asyncRequest(Read<T> arg0, Listener<T> arg1) {
\r
288 throw new UnsupportedOperationException();
\r
292 public <T> void asyncRequest(Read<T> arg0, SyncProcedure<T> arg1) {
\r
293 throw new UnsupportedOperationException();
\r
297 public <T> void asyncRequest(AsyncRead<T> arg0, AsyncListener<T> arg1) {
\r
298 throw new UnsupportedOperationException();
\r
302 public <T> void asyncRequest(AsyncRead<T> arg0, SyncListener<T> arg1) {
\r
303 throw new UnsupportedOperationException();
\r
307 public <T> void asyncRequest(AsyncRead<T> arg0, Listener<T> arg1) {
\r
308 throw new UnsupportedOperationException();
\r
312 public <T> void asyncRequest(AsyncRead<T> arg0, SyncProcedure<T> arg1) {
\r
313 throw new UnsupportedOperationException();
\r
317 public <T> Collection<T> syncRequest(MultiRead<T> arg0, AsyncMultiListener<T> arg1) {
\r
318 throw new UnsupportedOperationException();
\r
322 public <T> Collection<T> syncRequest(MultiRead<T> arg0, SyncMultiListener<T> arg1) {
\r
323 throw new UnsupportedOperationException();
\r
327 public <T> Collection<T> syncRequest(MultiRead<T> arg0, MultiListener<T> arg1) {
\r
328 throw new UnsupportedOperationException();
\r
332 public <T> Collection<T> syncRequest(MultiRead<T> arg0, SyncMultiProcedure<T> arg1) {
\r
333 throw new UnsupportedOperationException();
\r
337 public <T> Collection<T> syncRequest(AsyncMultiRead<T> arg0,
\r
338 AsyncMultiListener<T> arg1) {
\r
339 throw new UnsupportedOperationException();
\r
343 public <T> Collection<T> syncRequest(AsyncMultiRead<T> arg0, SyncMultiListener<T> arg1) {
\r
344 throw new UnsupportedOperationException();
\r
348 public <T> Collection<T> syncRequest(AsyncMultiRead<T> arg0,
\r
349 MultiListener<T> arg1) {
\r
350 throw new UnsupportedOperationException();
\r
354 public <T> Collection<T> syncRequest(AsyncMultiRead<T> arg0, SyncMultiProcedure<T> arg1) {
\r
355 throw new UnsupportedOperationException();
\r
359 public <T> void asyncRequest(MultiRead<T> arg0, AsyncMultiListener<T> arg1) {
\r
360 throw new UnsupportedOperationException();
\r
364 public <T> void asyncRequest(MultiRead<T> arg0, SyncMultiListener<T> arg1) {
\r
365 throw new UnsupportedOperationException();
\r
369 public <T> void asyncRequest(MultiRead<T> arg0, MultiListener<T> arg1) {
\r
370 throw new UnsupportedOperationException();
\r
374 public <T> void asyncRequest(MultiRead<T> arg0, SyncMultiProcedure<T> arg1) {
\r
375 throw new UnsupportedOperationException();
\r
379 public <T> void asyncRequest(AsyncMultiRead<T> arg0,
\r
380 AsyncMultiListener<T> arg1) {
\r
381 throw new UnsupportedOperationException();
\r
385 public <T> void asyncRequest(AsyncMultiRead<T> arg0, SyncMultiListener<T> arg1) {
\r
386 throw new UnsupportedOperationException();
\r
390 public <T> void asyncRequest(AsyncMultiRead<T> arg0,
\r
391 MultiListener<T> arg1) {
\r
392 throw new UnsupportedOperationException();
\r
396 public <T> void asyncRequest(AsyncMultiRead<T> arg0, SyncMultiProcedure<T> arg1) {
\r
397 throw new UnsupportedOperationException();
\r
401 public <T> void asyncRequest(ExternalRead<T> request, Procedure<T> procedure) {
\r
402 throw new UnsupportedOperationException();
\r
406 public <T> T syncRequest(ExternalRead<T> request) {
\r
407 throw new UnsupportedOperationException();
\r
411 public <T> T syncRequest(ExternalRead<T> request, Listener<T> procedure) {
\r
412 throw new UnsupportedOperationException();
\r
416 public <T> T syncRequest(ExternalRead<T> request, Procedure<T> procedure) {
\r
417 throw new UnsupportedOperationException();
\r
421 public <T> void asyncRequest(ExternalRead<T> request) {
\r
422 throw new UnsupportedOperationException();
\r
426 public <T> void asyncRequest(ExternalRead<T> request, Listener<T> procedure) {
\r
427 throw new UnsupportedOperationException();
\r
431 public void syncRequest(DelayedWrite request) throws DatabaseException {
\r
432 throw new UnsupportedOperationException();
\r
436 public void asyncRequest(DelayedWrite request) {
\r
437 throw new UnsupportedOperationException();
\r
441 public <T> T syncRequest(WriteResult<T> request) throws DatabaseException {
\r
442 throw new UnsupportedOperationException();
\r
446 public <T> T syncRequest(DelayedWriteResult<T> request)
\r
447 throws DatabaseException {
\r
448 throw new UnsupportedOperationException();
\r
452 public <T> T syncRequest(WriteOnlyResult<T> r) throws DatabaseException {
\r
453 throw new UnsupportedOperationException();
\r
457 public <T> void asyncRequest(WriteResult<T> r, Procedure<T> procedure) {
\r
458 throw new UnsupportedOperationException();
\r
462 public <T> void asyncRequest(DelayedWriteResult<T> r, Procedure<T> procedure) {
\r
463 throw new UnsupportedOperationException();
\r
467 public <T> void asyncRequest(WriteOnlyResult<T> r, Procedure<T> procedure) {
\r
468 throw new UnsupportedOperationException();
\r
472 public Resource getRootLibrary() {
\r
473 throw new UnsupportedOperationException();
\r
477 public <T> void async(ReadInterface<T> r, Procedure<T> procedure) {
\r
478 throw new UnsupportedOperationException();
\r
482 public <T> void async(ReadInterface<T> r, AsyncProcedure<T> procedure) {
\r
483 throw new UnsupportedOperationException();
\r
487 public <T> void async(ReadInterface<T> r, SyncProcedure<T> procedure) {
\r
488 throw new UnsupportedOperationException();
\r
492 public <T> void async(ReadInterface<T> r, Listener<T> procedure) {
\r
493 throw new UnsupportedOperationException();
\r
497 public <T> void async(ReadInterface<T> r, AsyncListener<T> procedure) {
\r
498 throw new UnsupportedOperationException();
\r
502 public <T> void async(ReadInterface<T> r, SyncListener<T> procedure) {
\r
503 throw new UnsupportedOperationException();
\r
507 public <T> T sync(ReadInterface<T> r) throws DatabaseException {
\r
508 throw new UnsupportedOperationException();
\r
512 public <T> T sync(WriteInterface<T> r) throws DatabaseException {
\r
513 throw new UnsupportedOperationException();
\r
517 public <T> void async(WriteInterface<T> r, Procedure<T> procedure) {
\r
518 throw new UnsupportedOperationException();
\r
522 public <T> void async(WriteInterface<T> r) {
\r
523 throw new UnsupportedOperationException();
\r
527 public Object getModificationCounter() {
\r
528 throw new UnsupportedOperationException();
\r