源码类别
热门源码
 当前位置：源码 > Java源码 >

Java源码示例：com.sun.xml.ws.client.ClientTransportException

示例1
@Profiled(logFailuresSeparately = true, tag = "0.ExecutorIntegrationModule#markAsArchived")
@Override
public void markAsArchived(String rid) throws IntegrationModuleException {
    validateRid(rid);
    ApplicationConfig.getInstance().assertValidSession();
    try {
        // create param
        byte[] sealedMarkAsArchivedParam = getSealedMarkAsArchivedParam(rid);

        // create request
        MarkAsArchivedRequest request = new MarkAsArchivedRequest();
        request.setSecuredMarkAsArchivedRequest(createSecuredContentType(sealedMarkAsArchivedParam));
        request.setAdministrativeInformation(getAdministrativeInfo(rid));

        // call WS
        try {
            checkStatus(RecipeExecutorServiceV3Impl.getInstance().markAsArchived(request));
        } catch (ClientTransportException cte) {
            throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), cte);
        }
    } catch (Throwable t) {
        Exceptionutils.errorHandler(t);
    }
}
示例2
@Profiled(logFailuresSeparately = true, tag = "0.ExecutorIntegrationModule#markAsDelivered")
@Override
public void markAsDelivered(String rid) throws IntegrationModuleException {
    validateRid(rid);
    ApplicationConfig.getInstance().assertValidSession();
    try {
        byte[] sealedMarkAsDeliveredParam = getSealedMarkAsDeliveredParam(rid);

        MarkAsDeliveredRequest request = new MarkAsDeliveredRequest();
        request.setSecuredMarkAsDeliveredRequest(createSecuredContentType(sealedMarkAsDeliveredParam));
        request.setAdministrativeInformation(getAdministrativeInfo(rid));

        try {
            checkStatus(RecipeExecutorServiceV3Impl.getInstance().markAsDelivered(request));
        } catch (ClientTransportException cte) {
            throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), cte);
        }
    } catch (Throwable t) {
        Exceptionutils.errorHandler(t);
    }
}
示例3
@Profiled(logFailuresSeparately = true, tag = "0.ExecutorIntegrationModule#markAsUndelivered")
@Override
public void markAsUndelivered(String rid) throws IntegrationModuleException {
    validateRid(rid);
    ApplicationConfig.getInstance().assertValidSession();
    try {
        final byte[] sealedMarkAsUndeliveredParam = getSealedMarkAsUndeliveredParam(rid);

        MarkAsUnDeliveredRequest request = new MarkAsUnDeliveredRequest();
        request.setSecuredMarkAsUnDeliveredRequest(createSecuredContentType(sealedMarkAsUndeliveredParam));
        request.setAdministrativeInformation(getAdministrativeInfo(rid));

        try {
            checkStatus(RecipeExecutorServiceV3Impl.getInstance().markAsUnDelivered(request));
        } catch (ClientTransportException cte) {
            throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), cte);
        }
    } catch (Throwable t) {
        Exceptionutils.errorHandler(t);
    }
}
示例4
@Profiled(logFailuresSeparately = true, tag = "0.ExecutorIntegrationModule#revokePrescription")
@Override
public void revokePrescription(String rid, String reason) throws IntegrationModuleException {
    validateRid(rid);
    ApplicationConfig.getInstance().assertValidSession();
    try {
        final byte[] sealedRevokePrescriptionParam = getSealedRevokePrescriptionParam(rid, reason);

        RevokePrescriptionForExecutorRequest request = new RevokePrescriptionForExecutorRequest();
        request.setAdministrativeInformation(getAdministrativeInfo(rid));
        request.setSecuredRevokePrescriptionRequest(createSecuredContentType(sealedRevokePrescriptionParam));

        try {
            checkStatus(RecipeExecutorServiceV3Impl.getInstance().revokePrescriptionForExecutor(request));
        } catch (ClientTransportException cte) {
            throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), cte);
        }

    } catch (Throwable t) {
        Exceptionutils.errorHandler(t);
    }
}
示例5
@Profiled(logFailuresSeparately = true, tag = "0.ExecutorIntegrationModule#listNotifications")
@Override
public List<ListNotificationsItem> listNotifications(boolean readFlag) throws IntegrationModuleException {
    ApplicationConfig.getInstance().assertValidSession();

    try {
        final byte[] sealedListNotificationsParam = getSealedListNotificationsParam(readFlag);

        ListNotificationsRequest request = new ListNotificationsRequest();
        request.setSecuredListNotificationsRequest(createSecuredContentType(sealedListNotificationsParam));

        ListNotificationsResponse response = null;
        try {
            response = RecipeExecutorServiceV3Impl.getInstance().listNotifications(request);
        } catch (ClientTransportException cte) {
            throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), cte);
        }
        checkStatus(response);

        final byte[] securedContent = response.getSecuredListNotificationsResponse().getSecuredContent();
        return createListNotificationItems(securedContent);
    } catch (Throwable t) {
        Exceptionutils.errorHandler(t);
    }
    return null;
}
示例6
@Profiled(logFailuresSeparately = true, tag = "0.ExecutorIntegrationModule#markAsArchived")
@Override
public void markAsArchived(String rid) throws IntegrationModuleException {
    validateRid(rid);
    ApplicationConfig.getInstance().assertValidSession();
    try {
        // create param
        byte[] sealedMarkAsArchivedParam = getSealedMarkAsArchivedParam(rid);

        // create request
        be.fgov.ehealth.recipe.protocol.v2.MarkAsArchivedRequest request = new MarkAsArchivedRequest();
        request.setSecuredMarkAsArchivedRequest(createSecuredContentType(sealedMarkAsArchivedParam));
        request.setAdministrativeInformation(getAdministrativeInfo(rid));

        // call WS
        try {
            checkStatus(RecipeExecutorServiceImpl.getInstance().markAsArchived(request));
        } catch (ClientTransportException cte) {
            throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), cte);
        }
    } catch (Throwable t) {
        Exceptionutils.errorHandler(t);
    }
}
示例7
@Profiled(logFailuresSeparately = true, tag = "0.ExecutorIntegrationModule#markAsDelivered")
@Override
public void markAsDelivered(String rid) throws IntegrationModuleException {
    validateRid(rid);
    ApplicationConfig.getInstance().assertValidSession();
    try {
        byte[] sealedMarkAsDeliveredParam = getSealedMarkAsDeliveredParam(rid);

        MarkAsDeliveredRequest request = new MarkAsDeliveredRequest();
        request.setSecuredMarkAsDeliveredRequest(createSecuredContentType(sealedMarkAsDeliveredParam));
        request.setAdministrativeInformation(getAdministrativeInfo(rid));

        try {
            checkStatus(RecipeExecutorServiceImpl.getInstance().markAsDelivered(request));
        } catch (ClientTransportException cte) {
            throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), cte);
        }
    } catch (Throwable t) {
        Exceptionutils.errorHandler(t);
    }
}
示例8
@Profiled(logFailuresSeparately = true, tag = "0.ExecutorIntegrationModule#markAsUndelivered")
@Override
public void markAsUndelivered(String rid) throws IntegrationModuleException {
    validateRid(rid);
    ApplicationConfig.getInstance().assertValidSession();
    try {
        final byte[] sealedMarkAsUndeliveredParam = getSealedMarkAsUndeliveredParam(rid);

        MarkAsUnDeliveredRequest request = new MarkAsUnDeliveredRequest();
        request.setSecuredMarkAsUnDeliveredRequest(createSecuredContentType(sealedMarkAsUndeliveredParam));
        request.setAdministrativeInformation(getAdministrativeInfo(rid));

        try {
            checkStatus(RecipeExecutorServiceImpl.getInstance().markAsUnDelivered(request));
        } catch (ClientTransportException cte) {
            throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), cte);
        }
    } catch (Throwable t) {
        Exceptionutils.errorHandler(t);
    }
}
示例9
@Profiled(logFailuresSeparately = true, tag = "0.ExecutorIntegrationModule#revokePrescription")
@Override
public void revokePrescription(String rid, String reason) throws IntegrationModuleException {
    validateRid(rid);
    ApplicationConfig.getInstance().assertValidSession();
    try {
        final byte[] sealedRevokePrescriptionParam = getSealedRevokePrescriptionParam(rid, reason);

        RevokePrescriptionForExecutorRequest request = new RevokePrescriptionForExecutorRequest();
        request.setAdministrativeInformation(getAdministrativeInfo(rid));
        request.setSecuredRevokePrescriptionRequest(createSecuredContentType(sealedRevokePrescriptionParam));

        try {
            checkStatus(RecipeExecutorServiceImpl.getInstance().revokePrescriptionForExecutor(request));
        } catch (ClientTransportException cte) {
            throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), cte);
        }

    } catch (Throwable t) {
        Exceptionutils.errorHandler(t);
    }
}
示例10
@Profiled(logFailuresSeparately = true, tag = "0.ExecutorIntegrationModule#listNotifications")
@Override
public List<ListNotificationsItem> listNotifications(boolean readFlag) throws IntegrationModuleException {
    ApplicationConfig.getInstance().assertValidSession();
    try {
        final byte[] sealedListNotificationsParam = getSealedListNotificationsParam(readFlag);

        ListNotificationsRequest request = new ListNotificationsRequest();
        request.setSecuredListNotificationsRequest(createSecuredContentType(sealedListNotificationsParam));

        ListNotificationsResponse response = null;
        try {
            response = RecipeExecutorServiceImpl.getInstance().listNotifications(request);
        } catch (ClientTransportException cte) {
            throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), cte);
        }
        checkStatus(response);

        final byte[] securedContent = response.getSecuredListNotificationsResponse().getSecuredContent();
        return createListNotificationItems(securedContent);
    } catch (Throwable t) {
        Exceptionutils.errorHandler(t);
    }
    return null;
}
示例11
static final void markAsArchived_aroundBody2(ExecutorIntegrationModuleV3Impl ajc$this, String rid, JoinPoint var2) {
   ajc$this.validateRid(rid);
   ApplicationConfig.getInstance().assertValidSession();

   try {
      byte[] sealedMarkAsArchivedParam = ajc$this.getSealedMarkAsArchivedParam(rid);
      MarkAsArchivedRequest request = new MarkAsArchivedRequest();
      request.setSecuredMarkAsArchivedRequest(ajc$this.createSecuredContentType(sealedMarkAsArchivedParam));
      request.setAdministrativeInformation(ajc$this.getAdministrativeInfo(rid));

      try {
         ajc$this.checkStatus(RecipeExecutorServiceV3Impl.getInstance().markAsArchived(request));
      } catch (ClientTransportException var8) {
         throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), var8);
      }
   } catch (Throwable var9) {
      Exceptionutils.errorHandler(var9);
   }

}
示例12
static final void markAsDelivered_aroundBody4(ExecutorIntegrationModuleV3Impl ajc$this, String rid, JoinPoint var2) {
   ajc$this.validateRid(rid);
   ApplicationConfig.getInstance().assertValidSession();

   try {
      byte[] sealedMarkAsDeliveredParam = ajc$this.getSealedMarkAsDeliveredParam(rid);
      MarkAsDeliveredRequest request = new MarkAsDeliveredRequest();
      request.setSecuredMarkAsDeliveredRequest(ajc$this.createSecuredContentType(sealedMarkAsDeliveredParam));
      request.setAdministrativeInformation(ajc$this.getAdministrativeInfo(rid));

      try {
         ajc$this.checkStatus(RecipeExecutorServiceV3Impl.getInstance().markAsDelivered(request));
      } catch (ClientTransportException var8) {
         throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), var8);
      }
   } catch (Throwable var9) {
      Exceptionutils.errorHandler(var9);
   }

}
示例13
static final void markAsUndelivered_aroundBody6(ExecutorIntegrationModuleV3Impl ajc$this, String rid, JoinPoint var2) {
   ajc$this.validateRid(rid);
   ApplicationConfig.getInstance().assertValidSession();

   try {
      byte[] sealedMarkAsUndeliveredParam = ajc$this.getSealedMarkAsUndeliveredParam(rid);
      MarkAsUnDeliveredRequest request = new MarkAsUnDeliveredRequest();
      request.setSecuredMarkAsUnDeliveredRequest(ajc$this.createSecuredContentType(sealedMarkAsUndeliveredParam));
      request.setAdministrativeInformation(ajc$this.getAdministrativeInfo(rid));

      try {
         ajc$this.checkStatus(RecipeExecutorServiceV3Impl.getInstance().markAsUnDelivered(request));
      } catch (ClientTransportException var8) {
         throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), var8);
      }
   } catch (Throwable var9) {
      Exceptionutils.errorHandler(var9);
   }

}
示例14
static final void revokePrescription_aroundBody8(ExecutorIntegrationModuleV3Impl ajc$this, String rid, String reason, JoinPoint var3) {
   ajc$this.validateRid(rid);
   ApplicationConfig.getInstance().assertValidSession();

   try {
      byte[] sealedRevokePrescriptionParam = ajc$this.getSealedRevokePrescriptionParam(rid, reason);
      RevokePrescriptionForExecutorRequest request = new RevokePrescriptionForExecutorRequest();
      request.setAdministrativeInformation(ajc$this.getAdministrativeInfo(rid));
      request.setSecuredRevokePrescriptionRequest(ajc$this.createSecuredContentType(sealedRevokePrescriptionParam));

      try {
         ajc$this.checkStatus(RecipeExecutorServiceV3Impl.getInstance().revokePrescriptionForExecutor(request));
      } catch (ClientTransportException var9) {
         throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), var9);
      }
   } catch (Throwable var10) {
      Exceptionutils.errorHandler(var10);
   }

}
示例15
static final List listNotifications_aroundBody10(ExecutorIntegrationModuleV3Impl ajc$this, boolean readFlag, JoinPoint var2) {
   ApplicationConfig.getInstance().assertValidSession();

   try {
      byte[] sealedListNotificationsParam = ajc$this.getSealedListNotificationsParam(readFlag);
      ListNotificationsRequest request = new ListNotificationsRequest();
      request.setSecuredListNotificationsRequest(ajc$this.createSecuredContentType(sealedListNotificationsParam));
      ListNotificationsResponse response = null;

      try {
         response = RecipeExecutorServiceV3Impl.getInstance().listNotifications(request);
      } catch (ClientTransportException var10) {
         throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), var10);
      }

      ajc$this.checkStatus(response);
      byte[] securedContent = response.getSecuredListNotificationsResponse().getSecuredContent();
      return ajc$this.createListNotificationItems(securedContent);
   } catch (Throwable var11) {
      Exceptionutils.errorHandler(var11);
      return null;
   }
}
示例16
static final void markAsArchived_aroundBody2(ExecutorIntegrationModuleImpl ajc$this, String rid, JoinPoint var2) {
   ajc$this.validateRid(rid);
   ApplicationConfig.getInstance().assertValidSession();

   try {
      byte[] sealedMarkAsArchivedParam = ajc$this.getSealedMarkAsArchivedParam(rid);
      MarkAsArchivedRequest request = new MarkAsArchivedRequest();
      request.setSecuredMarkAsArchivedRequest(ajc$this.createSecuredContentType(sealedMarkAsArchivedParam));
      request.setAdministrativeInformation(ajc$this.getAdministrativeInfo(rid));

      try {
         ajc$this.checkStatus(RecipeExecutorServiceImpl.getInstance().markAsArchived(request));
      } catch (ClientTransportException var8) {
         throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), var8);
      }
   } catch (Throwable var9) {
      Exceptionutils.errorHandler(var9);
   }

}
示例17
static final void markAsDelivered_aroundBody4(ExecutorIntegrationModuleImpl ajc$this, String rid, JoinPoint var2) {
   ajc$this.validateRid(rid);
   ApplicationConfig.getInstance().assertValidSession();

   try {
      byte[] sealedMarkAsDeliveredParam = ajc$this.getSealedMarkAsDeliveredParam(rid);
      MarkAsDeliveredRequest request = new MarkAsDeliveredRequest();
      request.setSecuredMarkAsDeliveredRequest(ajc$this.createSecuredContentType(sealedMarkAsDeliveredParam));
      request.setAdministrativeInformation(ajc$this.getAdministrativeInfo(rid));

      try {
         ajc$this.checkStatus(RecipeExecutorServiceImpl.getInstance().markAsDelivered(request));
      } catch (ClientTransportException var8) {
         throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), var8);
      }
   } catch (Throwable var9) {
      Exceptionutils.errorHandler(var9);
   }

}
示例18
static final void markAsUndelivered_aroundBody6(ExecutorIntegrationModuleImpl ajc$this, String rid, JoinPoint var2) {
   ajc$this.validateRid(rid);
   ApplicationConfig.getInstance().assertValidSession();

   try {
      byte[] sealedMarkAsUndeliveredParam = ajc$this.getSealedMarkAsUndeliveredParam(rid);
      MarkAsUnDeliveredRequest request = new MarkAsUnDeliveredRequest();
      request.setSecuredMarkAsUnDeliveredRequest(ajc$this.createSecuredContentType(sealedMarkAsUndeliveredParam));
      request.setAdministrativeInformation(ajc$this.getAdministrativeInfo(rid));

      try {
         ajc$this.checkStatus(RecipeExecutorServiceImpl.getInstance().markAsUnDelivered(request));
      } catch (ClientTransportException var8) {
         throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), var8);
      }
   } catch (Throwable var9) {
      Exceptionutils.errorHandler(var9);
   }

}
示例19
static final void revokePrescription_aroundBody8(ExecutorIntegrationModuleImpl ajc$this, String rid, String reason, JoinPoint var3) {
   ajc$this.validateRid(rid);
   ApplicationConfig.getInstance().assertValidSession();

   try {
      byte[] sealedRevokePrescriptionParam = ajc$this.getSealedRevokePrescriptionParam(rid, reason);
      RevokePrescriptionForExecutorRequest request = new RevokePrescriptionForExecutorRequest();
      request.setAdministrativeInformation(ajc$this.getAdministrativeInfo(rid));
      request.setSecuredRevokePrescriptionRequest(ajc$this.createSecuredContentType(sealedRevokePrescriptionParam));

      try {
         ajc$this.checkStatus(RecipeExecutorServiceImpl.getInstance().revokePrescriptionForExecutor(request));
      } catch (ClientTransportException var9) {
         throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), var9);
      }
   } catch (Throwable var10) {
      Exceptionutils.errorHandler(var10);
   }

}
示例20
static final List listNotifications_aroundBody10(ExecutorIntegrationModuleImpl ajc$this, boolean readFlag, JoinPoint var2) {
   ApplicationConfig.getInstance().assertValidSession();

   try {
      byte[] sealedListNotificationsParam = ajc$this.getSealedListNotificationsParam(readFlag);
      ListNotificationsRequest request = new ListNotificationsRequest();
      request.setSecuredListNotificationsRequest(ajc$this.createSecuredContentType(sealedListNotificationsParam));
      ListNotificationsResponse response = null;

      try {
         response = RecipeExecutorServiceImpl.getInstance().listNotifications(request);
      } catch (ClientTransportException var10) {
         throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), var10);
      }

      ajc$this.checkStatus(response);
      byte[] securedContent = response.getSecuredListNotificationsResponse().getSecuredContent();
      return ajc$this.createListNotificationItems(securedContent);
   } catch (Throwable var11) {
      Exceptionutils.errorHandler(var11);
      return null;
   }
}
示例21
@Profiled(logFailuresSeparately = true, tag = "0.ExecutorIntegrationModule#markAsArchived")
@Override
public void markAsArchived(String rid) throws IntegrationModuleException {
    validateRid(rid);
    ApplicationConfig.getInstance().assertValidSession();
    try {
        // create param
        byte[] sealedMarkAsArchivedParam = getSealedMarkAsArchivedParam(rid);

        // create request
        MarkAsArchivedRequest request = new MarkAsArchivedRequest();
        request.setSecuredMarkAsArchivedRequest(createSecuredContentType(sealedMarkAsArchivedParam));
        request.setAdministrativeInformation(getAdministrativeInfo(rid));

        // call WS
        try {
            checkStatus(RecipeExecutorServiceV3Impl.getInstance().markAsArchived(request));
        } catch (ClientTransportException cte) {
            throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), cte);
        }
    } catch (Throwable t) {
        Exceptionutils.errorHandler(t);
    }
}
示例22
@Profiled(logFailuresSeparately = true, tag = "0.ExecutorIntegrationModule#markAsDelivered")
@Override
public void markAsDelivered(String rid) throws IntegrationModuleException {
    validateRid(rid);
    ApplicationConfig.getInstance().assertValidSession();
    try {
        byte[] sealedMarkAsDeliveredParam = getSealedMarkAsDeliveredParam(rid);

        MarkAsDeliveredRequest request = new MarkAsDeliveredRequest();
        request.setSecuredMarkAsDeliveredRequest(createSecuredContentType(sealedMarkAsDeliveredParam));
        request.setAdministrativeInformation(getAdministrativeInfo(rid));

        try {
            checkStatus(RecipeExecutorServiceV3Impl.getInstance().markAsDelivered(request));
        } catch (ClientTransportException cte) {
            throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), cte);
        }
    } catch (Throwable t) {
        Exceptionutils.errorHandler(t);
    }
}
示例23
@Profiled(logFailuresSeparately = true, tag = "0.ExecutorIntegrationModule#markAsUndelivered")
@Override
public void markAsUndelivered(String rid) throws IntegrationModuleException {
    validateRid(rid);
    ApplicationConfig.getInstance().assertValidSession();
    try {
        final byte[] sealedMarkAsUndeliveredParam = getSealedMarkAsUndeliveredParam(rid);

        MarkAsUnDeliveredRequest request = new MarkAsUnDeliveredRequest();
        request.setSecuredMarkAsUnDeliveredRequest(createSecuredContentType(sealedMarkAsUndeliveredParam));
        request.setAdministrativeInformation(getAdministrativeInfo(rid));

        try {
            checkStatus(RecipeExecutorServiceV3Impl.getInstance().markAsUnDelivered(request));
        } catch (ClientTransportException cte) {
            throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), cte);
        }
    } catch (Throwable t) {
        Exceptionutils.errorHandler(t);
    }
}
示例24
@Profiled(logFailuresSeparately = true, tag = "0.ExecutorIntegrationModule#revokePrescription")
@Override
public void revokePrescription(String rid, String reason) throws IntegrationModuleException {
    validateRid(rid);
    ApplicationConfig.getInstance().assertValidSession();
    try {
        final byte[] sealedRevokePrescriptionParam = getSealedRevokePrescriptionParam(rid, reason);

        RevokePrescriptionForExecutorRequest request = new RevokePrescriptionForExecutorRequest();
        request.setAdministrativeInformation(getAdministrativeInfo(rid));
        request.setSecuredRevokePrescriptionRequest(createSecuredContentType(sealedRevokePrescriptionParam));

        try {
            checkStatus(RecipeExecutorServiceV3Impl.getInstance().revokePrescriptionForExecutor(request));
        } catch (ClientTransportException cte) {
            throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), cte);
        }

    } catch (Throwable t) {
        Exceptionutils.errorHandler(t);
    }
}
示例25
@Profiled(logFailuresSeparately = true, tag = "0.ExecutorIntegrationModule#listNotifications")
@Override
public List<ListNotificationsItem> listNotifications(boolean readFlag) throws IntegrationModuleException {
    ApplicationConfig.getInstance().assertValidSession();

    try {
        final byte[] sealedListNotificationsParam = getSealedListNotificationsParam(readFlag);

        ListNotificationsRequest request = new ListNotificationsRequest();
        request.setSecuredListNotificationsRequest(createSecuredContentType(sealedListNotificationsParam));

        ListNotificationsResponse response = null;
        try {
            response = RecipeExecutorServiceV3Impl.getInstance().listNotifications(request);
        } catch (ClientTransportException cte) {
            throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), cte);
        }
        checkStatus(response);

        final byte[] securedContent = response.getSecuredListNotificationsResponse().getSecuredContent();
        return createListNotificationItems(securedContent);
    } catch (Throwable t) {
        Exceptionutils.errorHandler(t);
    }
    return null;
}
示例26
@Profiled(logFailuresSeparately = true, tag = "0.ExecutorIntegrationModule#markAsArchived")
@Override
public void markAsArchived(String rid) throws IntegrationModuleException {
    validateRid(rid);
    ApplicationConfig.getInstance().assertValidSession();
    try {
        // create param
        byte[] sealedMarkAsArchivedParam = getSealedMarkAsArchivedParam(rid);

        // create request
        be.fgov.ehealth.recipe.protocol.v2.MarkAsArchivedRequest request = new MarkAsArchivedRequest();
        request.setSecuredMarkAsArchivedRequest(createSecuredContentType(sealedMarkAsArchivedParam));
        request.setAdministrativeInformation(getAdministrativeInfo(rid));

        // call WS
        try {
            checkStatus(RecipeExecutorServiceImpl.getInstance().markAsArchived(request));
        } catch (ClientTransportException cte) {
            throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), cte);
        }
    } catch (Throwable t) {
        Exceptionutils.errorHandler(t);
    }
}
示例27
@Profiled(logFailuresSeparately = true, tag = "0.ExecutorIntegrationModule#markAsDelivered")
@Override
public void markAsDelivered(String rid) throws IntegrationModuleException {
    validateRid(rid);
    ApplicationConfig.getInstance().assertValidSession();
    try {
        byte[] sealedMarkAsDeliveredParam = getSealedMarkAsDeliveredParam(rid);

        MarkAsDeliveredRequest request = new MarkAsDeliveredRequest();
        request.setSecuredMarkAsDeliveredRequest(createSecuredContentType(sealedMarkAsDeliveredParam));
        request.setAdministrativeInformation(getAdministrativeInfo(rid));

        try {
            checkStatus(RecipeExecutorServiceImpl.getInstance().markAsDelivered(request));
        } catch (ClientTransportException cte) {
            throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), cte);
        }
    } catch (Throwable t) {
        Exceptionutils.errorHandler(t);
    }
}
示例28
@Profiled(logFailuresSeparately = true, tag = "0.ExecutorIntegrationModule#markAsUndelivered")
@Override
public void markAsUndelivered(String rid) throws IntegrationModuleException {
    validateRid(rid);
    ApplicationConfig.getInstance().assertValidSession();
    try {
        final byte[] sealedMarkAsUndeliveredParam = getSealedMarkAsUndeliveredParam(rid);

        MarkAsUnDeliveredRequest request = new MarkAsUnDeliveredRequest();
        request.setSecuredMarkAsUnDeliveredRequest(createSecuredContentType(sealedMarkAsUndeliveredParam));
        request.setAdministrativeInformation(getAdministrativeInfo(rid));

        try {
            checkStatus(RecipeExecutorServiceImpl.getInstance().markAsUnDelivered(request));
        } catch (ClientTransportException cte) {
            throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), cte);
        }
    } catch (Throwable t) {
        Exceptionutils.errorHandler(t);
    }
}
示例29
@Profiled(logFailuresSeparately = true, tag = "0.ExecutorIntegrationModule#revokePrescription")
@Override
public void revokePrescription(String rid, String reason) throws IntegrationModuleException {
    validateRid(rid);
    ApplicationConfig.getInstance().assertValidSession();
    try {
        final byte[] sealedRevokePrescriptionParam = getSealedRevokePrescriptionParam(rid, reason);

        RevokePrescriptionForExecutorRequest request = new RevokePrescriptionForExecutorRequest();
        request.setAdministrativeInformation(getAdministrativeInfo(rid));
        request.setSecuredRevokePrescriptionRequest(createSecuredContentType(sealedRevokePrescriptionParam));

        try {
            checkStatus(RecipeExecutorServiceImpl.getInstance().revokePrescriptionForExecutor(request));
        } catch (ClientTransportException cte) {
            throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), cte);
        }

    } catch (Throwable t) {
        Exceptionutils.errorHandler(t);
    }
}
示例30
@Profiled(logFailuresSeparately = true, tag = "0.ExecutorIntegrationModule#listNotifications")
@Override
public List<ListNotificationsItem> listNotifications(boolean readFlag) throws IntegrationModuleException {
    ApplicationConfig.getInstance().assertValidSession();
    try {
        final byte[] sealedListNotificationsParam = getSealedListNotificationsParam(readFlag);

        ListNotificationsRequest request = new ListNotificationsRequest();
        request.setSecuredListNotificationsRequest(createSecuredContentType(sealedListNotificationsParam));

        ListNotificationsResponse response = null;
        try {
            response = RecipeExecutorServiceImpl.getInstance().listNotifications(request);
        } catch (ClientTransportException cte) {
            throw new IntegrationModuleException(I18nHelper.getLabel("error.connection.executor"), cte);
        }
        checkStatus(response);

        final byte[] securedContent = response.getSecuredListNotificationsResponse().getSecuredContent();
        return createListNotificationItems(securedContent);
    } catch (Throwable t) {
        Exceptionutils.errorHandler(t);
    }
    return null;
}