|
Apache CXF example source code file (AtomPushEngineConfigurator.java)
The Apache CXF AtomPushEngineConfigurator.java source code/** * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, * software distributed under the License is distributed on an * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY * KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. */ package org.apache.cxf.management.web.logging.atom; import java.lang.reflect.Constructor; import org.apache.cxf.management.web.logging.atom.converter.Converter; import org.apache.cxf.management.web.logging.atom.converter.StandardConverter; import org.apache.cxf.management.web.logging.atom.converter.StandardConverter.Format; import org.apache.cxf.management.web.logging.atom.converter.StandardConverter.Multiplicity; import org.apache.cxf.management.web.logging.atom.converter.StandardConverter.Output; import org.apache.cxf.management.web.logging.atom.deliverer.Deliverer; import org.apache.cxf.management.web.logging.atom.deliverer.RetryingDeliverer; import org.apache.cxf.management.web.logging.atom.deliverer.WebClientDeliverer; /** * Package private interpreter of incomplete input of engine configuration. Used commonly by * {@link AtomPushHandler properties file} and {@link AtomPushBean spring} configuration schemes. */ // TODO extract 'general rules' of interpretation in handler and bean and put here final class AtomPushEngineConfigurator { private Deliverer deliverer; private Converter converter; private String delivererClass; private String converterClass; private String batchSize; private String batchCleanupTime; private String delivererUrl; private String retryTimeout; private String retryPause; private String retryPauseTime; private String output; private String multiplicity; private String format; public void setUrl(String url) { this.delivererUrl = url; } public void setRetryTimeout(String retryTimeout) { this.retryTimeout = retryTimeout; } public void setRetryPause(String retryPause) { this.retryPause = retryPause; } public void setRetryPauseTime(String retryPauseTime) { this.retryPauseTime = retryPauseTime; } public void setBatchCleanupTime(String cleanupTime) { this.batchCleanupTime = cleanupTime; } public void setBatchSize(String batchSize) { this.batchSize = batchSize; } public void setDeliverer(Deliverer deliverer) { this.deliverer = deliverer; } public void setConverter(Converter converter) { this.converter = converter; } public void setDelivererClass(String delivererClass) { this.delivererClass = delivererClass; } public void setConverterClass(String converterClass) { this.converterClass = converterClass; } public void setOutput(String output) { this.output = output; } public void setMultiplicity(String multiplicity) { this.multiplicity = multiplicity; } public void setFormat(String format) { this.format = format; } public AtomPushEngine createEngine() { Deliverer d = deliverer; Converter c = converter; int batch = parseInt(batchSize, 1, 1); int batchTime = parseInt(batchCleanupTime, 0); if (d == null) { if (delivererUrl != null) { if (delivererClass != null) { d = createDeliverer(delivererClass, delivererUrl); } else { d = new WebClientDeliverer(delivererUrl); } } else { throw new IllegalStateException("Either url, deliverer or " + "deliverer class with url must be setup"); } } if (c == null) { if (converterClass != null) { c = createConverter(converterClass); } else { Output out = parseEnum(output, Output.FEED, Output.class); Multiplicity defaultMul = out == Output.FEED ? Multiplicity.MANY : batch > 1 ? Multiplicity.MANY : Multiplicity.ONE; Multiplicity mul = parseEnum(multiplicity, defaultMul, Multiplicity.class); Format form = parseEnum(format, Format.CONTENT, Format.class); if (out == Output.FEED) { c = new StandardConverter(out, mul, form); } else { c = new StandardConverter(out, mul, form); } if (retryPause != null) { int timeout = parseInt(retryTimeout, 0, 0); int pause = parseInt(retryPauseTime, 1, 30); boolean linear = !retryPause.equalsIgnoreCase("exponential"); d = new RetryingDeliverer(d, timeout, pause, linear); } } } AtomPushEngine engine = new AtomPushEngine(); engine.setDeliverer(d); engine.setConverter(c); engine.setBatchSize(batch); engine.setBatchTime(batchTime); return engine; } private Deliverer createDeliverer(String clazz, String url) { try { Constructor<Deliverer> ctor = loadClass(clazz, Deliverer.class).getConstructor(String.class); return ctor.newInstance(url); } catch (Exception e) { throw new IllegalArgumentException(e); } } private Converter createConverter(String clazz) { try { Constructor<Converter> ctor = loadClass(clazz, Converter.class).getConstructor(); return ctor.newInstance(); } catch (Exception e) { throw new IllegalArgumentException(e); } } @SuppressWarnings("unchecked") private <T> Class Other Apache CXF examples (source code examples)Here is a short list of links related to this Apache CXF AtomPushEngineConfigurator.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.