Package de.danet.an.workflow.tools.util

Examples of de.danet.an.workflow.tools.util.SimpleApplicationInfo.state()

141
142
143
144
145
146
147
148
149
150
151
    logger.debug ("Application " + applId
            + " updated to " + activity);
      }
      SimpleApplicationInfo info
    = applicationDirectory().instanceInfo (applId);
      Object[] data = (Object[])info.state();
      data[1] = fps[1].id();
      applicationDirectory().updateState (applId, data);
      return;
  } catch (InvalidKeyException invKey) {
      if (logger.isDebugEnabled()) {
View Full Code Here
193
194
195
196
197
198
199
200
201
202
203
      if (logger.isDebugEnabled()) {
    logger.debug ("Terminating application " + info.id()
             + " invoked by " + auk);
      }
      applicationDirectory().removeInstance (info.id());
      timerHandler().removeTimer (((Object[])info.state())[0]);
  } catch (InvalidKeyException e) {
      // terminate is called by engine "to make sure"
      logger.debug ("Terminate called for " + auk + " but application "
        + "already removed (is OK): " + e.getMessage ());
  }
View Full Code Here
126
127
128
129
130
131
132
133
134
135
136
  } catch (InvalidKeyException e) {
      logger.warn ("Timer application " + applId + " could not be "
       + "canceled because is does not exist.");
      return;
  }
  Object timer = ((Object[])info.state())[0];
  timerHandler().removeTimer (timer);
  ActivityUniqueKey auk = info.activityUniqueKey();
  Activity act = null;
  try {
      act = toolAgentContext().lookupActivity(auk);
View Full Code Here
137
138
139
140
141
142
143
144
145
146
147
  } catch (InvalidKeyException e) {
      logger.warn (auk + " is unknown, cannot cancel wait tool.");
      return;
  }
  ProcessData res = new DefaultProcessData ();
  String resParam = (String)((Object[])info.state())[1];
  res.put (resParam, "CANCELED");
  try {
      act.setResult (res);
      act.complete ();
      if (logger.isDebugEnabled ()) {
View Full Code Here
309
310
311
312
313
314
315
316
317
318
319
                    logger.debug ("Nothing to do for application " + applId
                            + " (no associated activity)");
                }
                return;
            }
            resParam = (String)((Object[])applInfo.state())[1];
            ActivityLocal act = null;
            try {
                Long pk = Long.valueOf (auk.activityKey());
                act = activityLocalHome().findByPrimaryKey(pk);
            } catch (FinderException nex) {
View Full Code Here
197
198
199
200
201
202
203
204
205
206
207
            Collection infos
                = ad.infosByKey("unittests.Test1", "ToolTest");
            assertTrue (infos.size() == 1);
            SimpleApplicationInfo info
                = (SimpleApplicationInfo)infos.iterator().next();
            assertTrue (info.state() instanceof Object[]);
            WfActivity actFound = workflowService.processDirectory()
                .lookupActivity(info.activityUniqueKey());
            actFound.complete ();
            ad.removeInstance(info.id());
           
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.