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