Package org.apache.uima.aae.client

Examples of org.apache.uima.aae.client.UimaASProcessStatusImpl.addEventStatus()

1201
1202
1203
1204
1205
1206
1207
1208
1209
1210
1211
    switch (aTimeoutKind)
    {
    case (MetadataTimeout):
      UIMAFramework.getLogger(CLASS_NAME).logrb(Level.FINEST, CLASS_NAME.getName(), "notifyOnTimout", JmsConstants.JMS_LOG_RESOURCE_BUNDLE, "UIMAJMS_meta_timeout_INFO", new Object[] { anEndpoint });
      status.addEventStatus("GetMeta", "Failed", new UimaASMetaRequestTimeout());
      notifyListeners(null, status, AsynchAEMessage.GetMeta);
      synchronized (metadataReplyMonitor)
      {
        abort = true;
        metadataReplyMonitor.notifyAll();
View Full Code Here
1211
1212
1213
1214
1215
1216
1217
1218
1219
1220
1221
        metadataReplyMonitor.notifyAll();
      }
      break;
    case (CpCTimeout):
      UIMAFramework.getLogger(CLASS_NAME).logrb(Level.FINEST, CLASS_NAME.getName(), "notifyOnTimout", JmsConstants.JMS_LOG_RESOURCE_BUNDLE, "UIMAJMS_cpc_timeout_INFO", new Object[] { anEndpoint });
      status.addEventStatus("CpC", "Failed", new UimaASCollectionProcessCompleteTimeout());
      notifyListeners(null, status, AsynchAEMessage.CollectionProcessComplete);
      receivedCpcReply = true;
      synchronized(endOfCollectionMonitor)
      {
        endOfCollectionMonitor.notifyAll();
View Full Code Here
1256
1257
1258
1259
1260
1261
1262
1263
1264
1265
1266
      }
      else
      {
        // notify the application listener with the error
        exc = new UimaASProcessCasTimeout();
        status.addEventStatus("Process", "Failed", exc);
        notifyListeners(aCAS, status, AsynchAEMessage.Process);
      }
      cachedRequest.removeEntry(casReferenceId);

      synchronized (gater)
View Full Code Here
591
592
593
594
595
596
597
598
599
600
601
            // Send CAS and wait for a response
            uimaClient.sendAndReceiveCAS(cas, pt);
          }
          catch( ResourceProcessException rpe)
          {
            status.addEventStatus("Process", "Failed", rpe);
          }
          finally
          {
            entityProcessComplete(cas, status);
            cas.release();
View Full Code Here
1021
1022
1023
1024
1025
1026
1027
1028
1029
1030
1031
      if (AsynchAEMessage.Exception == payload) {
        ProcessTrace pt = new ProcessTrace_impl();
        UimaASProcessStatusImpl status = new UimaASProcessStatusImpl(pt);
        Exception exception = retrieveExceptionFromMessage(message);

        status.addEventStatus("CpC", "Failed", exception);
        notifyListeners(null, status, AsynchAEMessage.CollectionProcessComplete);
        if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.INFO)) {
          UIMAFramework.getLogger(CLASS_NAME).logrb(
                  Level.INFO,
                  CLASS_NAME.getName(),
View Full Code Here
1116
1117
1118
1119
1120
1121
1122
1123
1124
1125
1126
      if (AsynchAEMessage.Exception == payload) {
        ProcessTrace pt = new ProcessTrace_impl();
        UimaASProcessStatusImpl status = new UimaASProcessStatusImpl(pt);
        Exception exception = retrieveExceptionFromMessage(message);
        clientSideJmxStats.incrementMetaErrorCount();
        status.addEventStatus("GetMeta", "Failed", exception);
        notifyListeners(null, status, AsynchAEMessage.GetMeta);
        if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.INFO)) {
          UIMAFramework.getLogger(CLASS_NAME).logrb(
                  Level.INFO,
                  CLASS_NAME.getName(),
View Full Code Here
1576
1577
1578
1579
1580
1581
1582
1583
1584
1585
1586
  protected void handleNonProcessException(Exception exception )
  throws Exception {
    ProcessTrace pt = new ProcessTrace_impl();
    UimaASProcessStatusImpl status = new UimaASProcessStatusImpl(pt);
    clientSideJmxStats.incrementMetaErrorCount();
    status.addEventStatus("GetMeta", "Failed", exception);
    notifyListeners(null, status, AsynchAEMessage.GetMeta);
  }
  protected void handleException(Exception exception, String casReferenceId, String inputCasReferenceId, ClientRequest cachedRequest, boolean doNotify)
  throws Exception {
    handleException(exception, casReferenceId, inputCasReferenceId, cachedRequest, doNotify, true);
View Full Code Here
1624
1625
1626
1627
1628
1629
1630
1631
1632
1633
1634
                    inputCasReferenceId);
        } else {
            status = new UimaASProcessStatusImpl(pt, null, casReferenceId,
                    inputCasReferenceId);
        }
        status.addEventStatus("Process", "Failed", exception);
        if (cachedRequest != null && !cachedRequest.isSynchronousInvocation()
                && cachedRequest.getCAS() != null) {
          notifyListeners(cachedRequest.getCAS(), status, AsynchAEMessage.Process);
        } else {
          notifyListeners(null, status, AsynchAEMessage.Process);
View Full Code Here
2285
2286
2287
2288
2289
2290
2291
2292
2293
2294
2295
        if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.WARNING)) {
          UIMAFramework.getLogger(CLASS_NAME).logrb(Level.WARNING, CLASS_NAME.getName(),
                  "notifyOnTimout", JmsConstants.JMS_LOG_RESOURCE_BUNDLE,
                  "UIMAJMS_meta_timeout_WARNING", new Object[] { anEndpoint });
        }
        status.addEventStatus("GetMeta", "Failed", new UimaASMetaRequestTimeout("UIMA AS Client Timed Out Waiting For GetMeta Reply From a Service On Queue:"+anEndpoint));
        notifyListeners(null, status, AsynchAEMessage.GetMeta);
        abort = true;
        getMetaSemaphore.release();
        break;
      case (PingTimeout):
View Full Code Here
2296
2297
2298
2299
2300
2301
2302
2303
2304
2305
2306
        if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.WARNING)) {
          UIMAFramework.getLogger(CLASS_NAME).logrb(Level.WARNING, CLASS_NAME.getName(),
                  "notifyOnTimout", JmsConstants.JMS_LOG_RESOURCE_BUNDLE,
                  "UIMAJMS_meta_timeout_WARNING", new Object[] { anEndpoint });
        }
        status.addEventStatus("Ping", "Failed", new UimaASPingTimeout("UIMA AS Client Timed Out Waiting For Ping Reply From a Service On Queue:"+anEndpoint));
        notifyListeners(null, status, AsynchAEMessage.Ping);
        // The main thread could be stuck waiting for a CAS. Grab any CAS in the
        // client cache and release it so that we can shutdown.
        if (!clientCache.isEmpty()) {
          ClientRequest anyCasRequest = clientCache.elements().nextElement();
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.