1 files changed, 123 insertions, 0 deletions
diff --git a/BKUOnline/src/main/java/at/gv/egiz/mocca/id/AbstractCommandSequenceBindingProcessor.java b/BKUOnline/src/main/java/at/gv/egiz/mocca/id/AbstractCommandSequenceBindingProcessor.java
new file mode 100644
index 00000000..897ec227
--- /dev/null
+++ b/BKUOnline/src/main/java/at/gv/egiz/mocca/id/AbstractCommandSequenceBindingProcessor.java
@@ -0,0 +1,123 @@
+/*
+* Copyright 2009 Federal Chancellery Austria and
+* Graz University of Technology
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*     http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+package at.gv.egiz.mocca.id;
+
+import java.util.Collections;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import at.gv.egiz.bku.binding.AbstractBindingProcessor;
+import at.gv.egiz.bku.slcommands.SLCommand;
+import at.gv.egiz.bku.slcommands.SLCommandContext;
+import at.gv.egiz.bku.slcommands.SLResult;
+import at.gv.egiz.bku.slexceptions.SLCommandException;
+import at.gv.egiz.bku.slexceptions.SLException;
+import at.gv.egiz.stal.QuitRequest;
+
+public abstract class AbstractCommandSequenceBindingProcessor extends AbstractBindingProcessor {
+
+  protected static Logger log = LoggerFactory.getLogger(AbstractCommandSequenceBindingProcessor.class);
+  
+  /**
+   * @return the error
+   */
+  protected Exception getError() {
+    return error;
+  }
+
+  /**
+   * @param error the error to set
+   */
+  protected void setError(Exception error) {
+    this.error = error;
+  }
+
+  private Exception error;
+
+  private SLCommandBrocker commandBrocker = new SLCommandBrocker();
+  
+  /**
+   * External processing?
+   */
+  private boolean external;
+  
+  /**
+   * Constructs a new instance of this IdBindingProcessorImpl with
+   * the given ID.
+   */
+  public AbstractCommandSequenceBindingProcessor() {
+    super();
+  }
+
+  /**
+   * @return the external
+   */
+  public boolean isExternal() {
+    return external;
+  }
+
+  /**
+   * @param external the external to set
+   */
+  public void setExternal(boolean external) {
+    this.external = external;
+  }
+
+  protected abstract SLCommand getNextCommand();
+  
+  protected abstract void processResult(SLResult result);
+  
+  @Override
+  public synchronized void process() {
+
+    try {
+    
+      SLCommand command;
+      do {
+        command = getNextCommand();
+        SLCommandContext context = new SLCommandContext(getSTAL(), getUrlDereferencer(), locale);
+        SLResult result = null;
+        if (external) {
+          result = commandBrocker.execute(command, context, 3 * 60 * 1000);
+        } else {
+          if (command != null) {
+            result = command.execute(context);
+          } else {
+            stal.handleRequest(Collections.singletonList(new QuitRequest()));
+          }
+        }
+        if (result != null) {
+          processResult(result);
+        }
+      } while (command != null);
+      
+    } catch (InterruptedException e) {
+      setError(new SLException(6000));
+    } catch (Exception e) {
+      log.info("BindingProcessor error.", e);
+      setError(e);
+    }
+    
+  }
+
+  public SLCommand setExternalResult(SLResult slResult) throws SLCommandException, InterruptedException {
+    return commandBrocker.nextCommand(slResult, 3 * 60 * 1000);
+  }
+
+}