Package org.apache.uima.aae.client

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

1312
1313
1314
1315
1316
1317
1318
1319
1320
1321
1322
  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
1354
1355
1356
1357
1358
1359
1360
1361
1362
1363
1364
        // Add Cas referenceId(s) to enable matching replies with requests (ids may be null)
        UimaASProcessStatusImpl status = new UimaASProcessStatusImpl(pt, 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
1906
1907
1908
1909
1910
1911
1912
1913
1914
1915
1916
        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
1917
1918
1919
1920
1921
1922
1923
1924
1925
1926
1927
        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
1935
1936
1937
1938
1939
1940
1941
1942
1943
1944
1945
        if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.INFO)) {
          UIMAFramework.getLogger(CLASS_NAME).logrb(Level.INFO, CLASS_NAME.getName(),
                  "notifyOnTimout", JmsConstants.JMS_LOG_RESOURCE_BUNDLE,
                  "UIMAJMS_cpc_timeout_INFO", new Object[] { anEndpoint });
        }
        status.addEventStatus("CpC", "Failed",
                new UimaASCollectionProcessCompleteTimeout("UIMA AS Client Timed Out Waiting For CPC Reply From a Service On Queue:"+anEndpoint));
        // release the semaphore acquired in collectionProcessingComplete()
        cpcReplySemaphore.release();
        notifyListeners(null, status, AsynchAEMessage.CollectionProcessComplete);
        break;
View Full Code Here
1986
1987
1988
1989
1990
1991
1992
1993
1994
1995
1996
            exc = new UimaASProcessCasTimeout(new UimaASPingTimeout("UIMA AS Client Ping Time While Waiting For Reply From a Service On Queue:"+anEndpoint));
            serviceDelegate.resetPingTimeout();
          } else {
            exc = new UimaASProcessCasTimeout("UIMA AS Client Timed Out Waiting For CAS:"+casReferenceId+ " Reply From a Service On Queue:"+anEndpoint);
          }
          status.addEventStatus("Process", "Failed", exc);
          notifyListeners(aCAS, status, AsynchAEMessage.Process);
        }
        cachedRequest.removeEntry(casReferenceId);
        serviceDelegate.removeCasFromOutstandingList(casReferenceId);
        // Check if all replies have been received
View Full Code Here
936
937
938
939
940
941
942
943
944
945
946
            String casReferenceId = uimaClient.sendAndReceiveCAS(cas, pt);
            status = new UimaASProcessStatusImpl(pt, casReferenceId);
          } catch (ResourceProcessException rpe) {
            //rpe.printStackTrace();
            status = new UimaASProcessStatusImpl(pt);
            status.addEventStatus("Process", "Failed", rpe);
          } finally {
            if ( callbackListener != null ) {
              callbackListener.entityProcessComplete(cas, status);
            }
            cas.release();
View Full Code Here
589
590
591
592
593
594
595
596
597
598
599
      ProcessTrace pt = new ProcessTrace_impl();
      UimaASProcessStatusImpl status = new UimaASProcessStatusImpl(pt);
      Exception exception = retrieveExceptionFormMessage(message);

//      Exception exception = (Exception) ((ObjectMessage) message).getObject();
      status.addEventStatus("CpC", "Failed", exception);
      notifyListeners(null, status, AsynchAEMessage.CollectionProcessComplete);
      UIMAFramework.getLogger(CLASS_NAME).logrb(Level.FINEST, CLASS_NAME.getName(), "handleCollectionProcessCompleteReply", JmsConstants.JMS_LOG_RESOURCE_BUNDLE, "UIMAJMS_received_exception_msg_INFO",
          new Object[] { message.getStringProperty(AsynchAEMessage.MessageFrom), message.getStringProperty(AsynchAEMessage.CasReference), exception });
    }
    else
View Full Code Here
626
627
628
629
630
631
632
633
634
635
636
    {
      ProcessTrace pt = new ProcessTrace_impl();
      UimaASProcessStatusImpl status = new UimaASProcessStatusImpl(pt);
      Exception exception = retrieveExceptionFormMessage(message);
      clientSideJmxStats.incrementMetaErrorCount();
      status.addEventStatus("GetMeta", "Failed", exception);
      notifyListeners(null, status, AsynchAEMessage.GetMeta);
      UIMAFramework.getLogger(CLASS_NAME).logrb(Level.FINEST, CLASS_NAME.getName(), "handleMetadataReply", JmsConstants.JMS_LOG_RESOURCE_BUNDLE, "UIMAJMS_received_exception_msg_INFO",
          new Object[] { message.getStringProperty(AsynchAEMessage.MessageFrom), message.getStringProperty(AsynchAEMessage.CasReference), exception });
      synchronized( metadataReplyMonitor )
      {
View Full Code Here
826
827
828
829
830
831
832
833
834
835
836
      }
      else
      {
        status = new UimaASProcessStatusImpl(pt);
      }
      status.addEventStatus("Process", "Failed", exception);
      notifyListeners(null, status, AsynchAEMessage.Process);
      //   Done here
      return;
    }
    else
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.