Examples of PolicyMap

com.cloud.utils.cisco.n1kv.vsm.PolicyMap
com.sun.xml.internal.ws.policy.PolicyMap
A PolicyMap holds all policies for a scope. This map is modeled around WSDL 1.1 policy scopes according to WS-PolicyAttachment. The map holds an information about every scope for service, endpoint, operation, and input/output/fault message. It also provide accessibility methods for computing and obtaining effective policy on each scope. TODO: rename createWsdlMessageScopeKey to createWsdlInputOutputMessageScopeKey @author Fabian Ritzmann
com.sun.xml.ws.policy.PolicyMap
A PolicyMap holds all policies for a scope. This map is modeled around WSDL 1.1 policy scopes according to WS-PolicyAttachment. The map holds an information about every scope for service, endpoint, operation, and input/output/fault message. It also provide accessibility methods for computing and obtaining effective policy on each scope. TODO: rename createWsdlMessageScopeKey to createWsdlInputOutputMessageScopeKey @author Fabian Ritzmann
org.apache.activemq.broker.region.policy.PolicyMap
Represents a destination based configuration of policies so that individual destinations or wildcard hierarchies of destinations can be configured using different policies. @org.apache.xbean.XBean

Examples of org.apache.activemq.broker.region.policy.PolicyMap

        
        // optional, reduce the usage limit so that spooling will occur faster
        brokerService.getSystemUsage().getMemoryUsage().setLimit(10 * 1024 * 1024);
        brokerService.getSystemUsage().getTempUsage().setLimit(numMessages * payLoadSize * 2);


        PolicyMap policyMap = new PolicyMap();
        List<PolicyEntry> entries = new ArrayList<PolicyEntry>();
        PolicyEntry policy = new PolicyEntry();
        
        // NB: ensure queue cursor limit is below the default 70% usage that the destination will use
        // if they are the same, the queue memory limit and flow control will kick in first
        policy.setCursorMemoryHighWaterMark(20);
        
        // on by default
        //policy.setProducerFlowControl(true);
        policy.setQueue(">");
        
        // policy that will spool references to disk
        policy.setPendingQueuePolicy(new FilePendingQueueMessageStoragePolicy());
        entries.add(policy);
        policyMap.setPolicyEntries(entries);
        brokerService.setDestinationPolicy(policyMap);
        
        brokerService.start();
    }

View Full Code Here

Examples of org.apache.activemq.broker.region.policy.PolicyMap

        PolicyEntry defaultPolicy = new PolicyEntry();
        // defaultPolicy.setTopic("FooTwo");
        defaultPolicy.setProducerFlowControl(false);
        defaultPolicy.setMemoryLimit(10 * 1024);


        PolicyMap policyMap = new PolicyMap();
        policyMap.setDefaultEntry(defaultPolicy);


        sysUsage.setMemoryUsage(memUsage);
        sysUsage.setStoreUsage(storeUsage);
        sysUsage.setTempUsage(tmpUsage);

View Full Code Here

Examples of org.apache.activemq.broker.region.policy.PolicyMap

        broker.setDeleteAllMessagesOnStartup(true);


        KahaDBPersistenceAdapter kahaDb = (KahaDBPersistenceAdapter) broker.getPersistenceAdapter();
        kahaDb.setConcurrentStoreAndDispatchQueues(false);
        broker.addConnector("tcp://0.0.0.0:2401");
        PolicyMap policies = new PolicyMap();
        PolicyEntry entry = new PolicyEntry();
        entry.setMemoryLimit(1024 * 1024);
        entry.setProducerFlowControl(true);
        if (useVMCursor) {
            entry.setPendingQueuePolicy(new VMPendingQueueMessageStoragePolicy());
        }
        entry.setQueue(">");
        policies.setDefaultEntry(entry);
        broker.setDestinationPolicy(policies);
        broker.start();
        broker.waitUntilStarted();


        count.set(0);

View Full Code Here

Examples of org.apache.activemq.broker.region.policy.PolicyMap

                new StorePendingDurableSubscriberMessageStoragePolicy();
        durableSubPending.setImmediatePriorityDispatch(true);
        durableSubPending.setUseCache(true);
        policy.setPendingDurableSubscriberPolicy(durableSubPending);


        PolicyMap policyMap = new PolicyMap();
        policyMap.setDefaultEntry(policy);
        brokerService.setDestinationPolicy(policyMap);


//        if (false) {
//            // external mysql works a lot faster
//            //

View Full Code Here

Examples of org.apache.activemq.broker.region.policy.PolicyMap

        policy.setAdvisoryForDelivery(true);
        policy.setAdvisoryForDiscardingMessages(true);
        policy.setAdvisoryForSlowConsumers(true);
        policy.setAdvisoryWhenFull(true);
        policy.setProducerFlowControl(false);
        PolicyMap pMap = new PolicyMap();
        pMap.setDefaultEntry(policy);
        broker.setDestinationPolicy(pMap);


        broker.start();
    }

View Full Code Here

Examples of org.apache.activemq.broker.region.policy.PolicyMap

        entry.setProducerFlowControl(false);
        entry.setMemoryLimit(504857608);
        entry.setPendingQueuePolicy(new FilePendingQueueMessageStoragePolicy());
        policyEntries.add(entry);


        final PolicyMap policyMap = new PolicyMap();
        policyMap.setPolicyEntries(policyEntries);
        broker.setDestinationPolicy(policyMap);
    }

View Full Code Here

Examples of org.apache.activemq.broker.region.policy.PolicyMap

        DeadLetterStrategy defaultDeadLetterStrategy = policy.getDeadLetterStrategy();
        if(defaultDeadLetterStrategy!=null) {
            defaultDeadLetterStrategy.setProcessNonPersistent(true);
            ((AbstractDeadLetterStrategy) defaultDeadLetterStrategy).setEnableAudit(false);
        }
        PolicyMap pMap = new PolicyMap();
        pMap.setDefaultEntry(policy);
        broker.setDestinationPolicy(pMap);
        return broker;
    }

View Full Code Here

Examples of org.apache.activemq.broker.region.policy.PolicyMap

        return master;
    }


    private void configureBroker(BrokerService broker) {
        broker.setUseJmx(false);
        PolicyMap policyMap = new PolicyMap();
        PolicyEntry defaultEntry = new PolicyEntry();
        defaultEntry.setOptimizedDispatch(true);
        policyMap.setDefaultEntry(defaultEntry);
        // optimized dispatch does not effect the determinism of inflight between
        // master and slave in this test
        //broker.setDestinationPolicy(policyMap);


    }

View Full Code Here

Examples of org.apache.activemq.broker.region.policy.PolicyMap

        broker = new BrokerService();
        broker.setDeleteAllMessagesOnStartup(true);
        broker.setBrokerName(brokerName);
        broker.addConnector(brokerUrl);


        PolicyMap policyMap = new PolicyMap();
        PolicyEntry defaultEntry = new PolicyEntry();
        defaultEntry.setExpireMessagesPeriod(500);
        policyMap.setDefaultEntry(defaultEntry);
        broker.setDestinationPolicy(policyMap);


        broker.start();
    }

View Full Code Here

Examples of org.apache.activemq.broker.region.policy.PolicyMap

        
        return localBroker;
    }


    private void configureBroker(BrokerService broker) {
        PolicyMap policyMap = new PolicyMap();
        PolicyEntry defaultEntry = new PolicyEntry();
        defaultEntry.setExpireMessagesPeriod(0);
        ConditionalNetworkBridgeFilterFactory filterFactory = new ConditionalNetworkBridgeFilterFactory();
        filterFactory.setReplayWhenNoConsumers(true);
        defaultEntry.setNetworkBridgeFilterFactory(filterFactory);
        policyMap.setDefaultEntry(defaultEntry);
        broker.setDestinationPolicy(policyMap);
    }

View Full Code Here

0 1 2 3 4 5

TOP

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.