Examples of org.apache.openejb.loader.Options$TomEEPropertyAdapter

org.apache.openejb.loader.Options
This adapter aims at supporting all configuration properties with tomee. prefix instead of openejb. prefix

    private static final String tmpDir = System.getProperty("java.io.tmpdir");
    private Exception exception;
    private AppInfo appInfo;


    private Deployer lookup() {
        final Options options = new Options(System.getProperties());
        Properties props = new Properties();
        props.put(Context.INITIAL_CONTEXT_FACTORY, RemoteInitialContextFactory.class.getName());
        String port = System.getProperty("server.http.port");
        if (port != null) {
            props.put(Context.PROVIDER_URL, options.get(Context.PROVIDER_URL,"http://localhost:" + port + "/openejb/ejb"));
        } else {
            throw new RuntimeException("Please set the tomee port as a system property");
        }
        try {
            InitialContext context = new InitialContext(props);

View Full Code Here

    private Tracker tracker;
    private Multicast multicast;


    public void init(Properties props) {


        Options options = new Options(props);
        host = props.getProperty("bind", host);
        loopbackMode = options.get("loopback_mode", loopbackMode);
        port = options.get("port", port);
        heartRate = options.get("heart_rate", heartRate);




        Tracker.Builder builder = new Tracker.Builder();
        builder.setGroup(props.getProperty("group", builder.getGroup()));
        builder.setMaxMissedHeartbeats(options.get("max_missed_heartbeats", builder.getMaxMissedHeartbeats()));
        builder.setMaxReconnectDelay(options.get("max_reconnect_delay", builder.getMaxReconnectDelay()));
        builder.setReconnectDelay(options.get("reconnect_delay", builder.getReconnectDelay()));
        builder.setExponentialBackoff(options.get("exponential_backoff", builder.getExponentialBackoff()));
        builder.setMaxReconnectAttempts(options.get("max_reconnect_attempts", builder.getMaxReconnectAttempts()));


        tracker = builder.build();
    }

View Full Code Here

    private Set<Skip> skip;


    public TempClassLoader(ClassLoader parent) {
        super(new URL[0], parent);


        Options options = SystemInstance.get().getOptions();
        skip = options.getAll("openejb.tempclassloader.skip", Skip.NONE);
    }

View Full Code Here

        assertTrue("Expected ["+expected+"], actual ["+message+"]", message.contains(expected));
    }


    public void setUp() {
        properties = new Properties();
        options = new Options(properties);
        log = new TestLog();
        options.setLogger(log);
    }

View Full Code Here

        this.globalJndiContext = new GlobalContext(appContext.getGlobalJndiContext());


        final Properties properties = new Properties();
        properties.putAll(map);


        options = new Options(properties);


        startNetworkServices();
    }

View Full Code Here

    private final boolean failOnCollision;


    public JndiBuilder(Context openejbContext) {
        this.openejbContext = openejbContext;


        final Options options = SystemInstance.get().getOptions();


        failOnCollision = options.get(JNDINAME_FAILONCOLLISION, true);
        embeddedEjbContainerApi = options.get(EJBContainer.class.getName(), false);
    }

View Full Code Here

            }
        }
    }


    public static JndiNameStrategy createStrategy(EjbJarInfo ejbJar, Map<String, BeanContext> deployments) {
        Options options = new Options(ejbJar.properties, SystemInstance.get().getOptions());


        Class strategyClass = options.get(JNDINAME_STRATEGY_CLASS, TemplatedStrategy.class);


        String strategyClassName = strategyClass.getName();


        try {
            try {

View Full Code Here


        if (inboundRecovery != null) {
            inboundRecovery.recover(resourceAdapter, activationSpec, containerID.toString());
        }
        
        Options options = new Options(beanContext.getProperties());
        int instanceLimit = options.get("InstanceLimit", this.instanceLimit);
        // create the message endpoint
        MdbInstanceFactory instanceFactory = new MdbInstanceFactory(beanContext, securityService, instanceLimit);
        EndpointFactory endpointFactory = new EndpointFactory(activationSpec, this, beanContext, instanceFactory, xaResourceWrapper);


        // update the data structures

View Full Code Here

        SystemInstance.get().setComponent(OpenEjbConfiguration.class, this.config);
    }


    public void init(Properties props) throws OpenEJBException {
        this.props = new Properties(props);
        Options options = new Options(props, SystemInstance.get().getOptions());
        String className = options.get("openejb.configurator", "org.apache.openejb.config.ConfigurationFactory");


        configFactory = (OpenEjbConfigurationFactory) toolkit.newInstance(className);
        configFactory.init(props);
    }

View Full Code Here

    public static void _loadFromClasspath(FileUtils base, List<URL> jarList, ClassLoader classLoader) {


        PerformanceTimer timer = new PerformanceTimer();


        timer.event("create filters");
        Options options = SystemInstance.get().getOptions();
        String include = "";
        String exclude = "";
        PatternFilter classpathInclude = new PatternFilter(options.get(DeploymentFilterable.CLASSPATH_INCLUDE, ".*"));
        PatternFilter classpathExclude = new PatternFilter(options.get(DeploymentFilterable.CLASSPATH_EXCLUDE, ""));
        IncludeExcludeFilter classpathFilter = new IncludeExcludeFilter(classpathInclude, classpathExclude);




        PatternFilter packageInclude = new PatternFilter(options.get(DeploymentFilterable.PACKAGE_INCLUDE, ".*"));
        PatternFilter packageExclude = new PatternFilter(options.get(DeploymentFilterable.PACKAGE_EXCLUDE, ""));


        IncludeExcludeFilter packageFilter;
        if (classpathInclude.getPattern().pattern().equals(".*") && packageInclude.getPattern().pattern().equals(".*")) {


            timer.event("callers");


            Set<String> callers = callers();


            timer.event("parse packages");


            callers.size();


            Set<String> packages = new HashSet<String>();
            for (String caller : callers) {
                String[] parts = caller.split("\\.");
                if (parts.length > 2) {
                    parts = new String[]{parts[0], parts[1]};
                }
                packages.add(Join.join(".", parts));
            }


            Filter includes = Filters.packages(packages.toArray(new String[0]));


            packageFilter = new IncludeExcludeFilter(includes, packageExclude);


        } else {


            packageFilter = new IncludeExcludeFilter(packageInclude, packageExclude);


        }


        timer.event("urlset");


        Set<RequireDescriptors> requireDescriptors = options.getAll(DeploymentFilterable.CLASSPATH_REQUIRE_DESCRIPTOR, RequireDescriptors.CLIENT);
        boolean filterDescriptors = options.get(DeploymentFilterable.CLASSPATH_FILTER_DESCRIPTORS, false);
        boolean filterSystemApps = options.get(DeploymentFilterable.CLASSPATH_FILTER_SYSTEMAPPS, true);


        try {
            UrlSet urlSet = new UrlSet(classLoader);


            timer.event("exclude system urls");

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of org.apache.openejb.loader.Options$TomEEPropertyAdapter

org.apache.openejb.arquillian.common.TomEEContainer

org.apache.openejb.assembler.classic.Assembler

org.apache.openejb.assembler.classic.JndiBuilder

org.apache.openejb.assembler.classic.JndiBuilder$TemplatedStrategy

org.apache.openejb.async.AsynchronousPool

org.apache.openejb.client.LocalInitialContext

org.apache.openejb.config.AutoDeployer

org.apache.openejb.config.ConfigurationFactory

org.apache.openejb.config.DeploymentsResolver

org.apache.openejb.config.DeploymentsResolver$ClasspathSearcher

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.