Package org.apache.ivory

Examples of org.apache.ivory.IvoryException

39
40
41
42
43
44
45
46
47
48
            LOG.info("Initializing service : " + serviceClassName);
            try {
                service.init();
            } catch(Throwable t) {
                LOG.fatal("Failed to initialize service " + serviceClassName, t);
                throw new IvoryException(t);
            }
            LOG.info("Service initialized : " + serviceClassName);
        }
    }
View Full Code Here
52
53
54
55
56
57
58
59
60
61
            LOG.info("Destroying service : " + service.getClass().getName());
            try {
                service.destroy();
            } catch(Throwable t) {
                LOG.fatal("Failed to destroy service " + service.getClass().getName(), t);
                throw new IvoryException(t);
            }
            LOG.info("Service destroyed : " + service.getClass().getName());
        }
    }
View Full Code Here
43
44
45
46
47
48
49
50
51
52
53
            new LinkedHashMap<String, IvoryService>();

    public synchronized void register(IvoryService service)
            throws IvoryException {
        if (services.containsKey(service.getName())) {
            throw new IvoryException("Service " + service.getName() +
                    " already registered");
        } else {
            services.put(service.getName(), service);
        }
    }
View Full Code Here
71
72
73
74
75
76
77
78
79
80
81
        return services.values().iterator();
    }

    public IvoryService init(String serviceName) throws IvoryException {
        if (isRegistered(serviceName)) {
            throw new IvoryException("Service is already initialized " +
                    serviceName);
        }
        IvoryService service = ReflectionUtils.getInstance(serviceName + ".impl");
        register(service);
        return service;
View Full Code Here
62
63
64
65
66
67
68
69
      LOG.debug("Enqueued Message:" + event.toString() + "with delay "
          + event.getDelay(TimeUnit.MILLISECONDS) + " milli sec");
      return true;
    } catch (Exception e) {
      LOG.error("Unable to offer event:" + event + " to activeMqueue", e);
      throw new IvoryException("Unable to offer event:" + event + " to activeMqueue", e);
    }
  }
View Full Code Here
82
83
84
85
86
87
88
89
        "ivory.cleanup.service.frequency", "days(1)");
    try {
      return (Long) EVALUATOR.evaluate("${" + delay + "}", Long.class,
          resolver, resolver);
    } catch (ELException e) {
      throw new IvoryException("Exception in EL evaluation", e);
    }
  }
View Full Code Here
86
87
88
89
90
91
92
93
          textMessage.getText());
      LOG.debug("Dequeued Message:" + event.toString());
      return event;
    } catch (Exception e) {
      LOG.error("Error getting the messge from ActiveMqueue: ", e);
      throw new IvoryException("Error getting the messge from ActiveMqueue: ", e);
    }
  }
View Full Code Here
52
53
54
55
56
57
58
59
60
    try {
      event = QUEUE.take();
      LOG.debug("Dequeued Message:" + event.toString());
      afterRetry(event);
    } catch (InterruptedException e) {
      throw new IvoryException(e);
    }
    return event;
  }
View Full Code Here
52
53
54
55
56
57
58
59
60
    String retention = getRetentionValue(timeUnit);
    try {
      return (Long) EVALUATOR.evaluate("${" + retention + "}",
          Long.class, resolver, resolver);
    } catch (ELException e) {
      throw new IvoryException("Unable to evalue retention limit: "
          + retention + " for entity: " + entity.getName());
    }
  }
View Full Code Here
73
74
75
76
77
78
79
80
81
    FileSystem fs = getFileSystem(cluster);
    FileStatus[] paths;
    try {
      paths = fs.globStatus(logPath);
    } catch (IOException e) {
      throw new IvoryException(e);
    }
    return paths;
  }
View Full Code Here
TOP

Related Classes of org.apache.ivory.IvoryException

  • org.apache.ivory.cleanup.AbstractCleanupHandler
  • org.apache.ivory.converter.AbstractOozieEntityMapper
  • org.apache.ivory.converter.OozieFeedMapper
  • org.apache.ivory.entity.ColoClusterRelation
  • org.apache.ivory.entity.EntityUtil
  • org.apache.ivory.entity.parser.CrossEntityValidations
  • org.apache.ivory.entity.parser.EntityParser
  • org.apache.ivory.entity.parser.FeedEntityParser
  • org.apache.ivory.entity.parser.ProcessEntityParser
  • org.apache.ivory.entity.store.ConfigurationStore
    • Copyright © 2018 www.massapicom. 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.