Examples of AcknowledgementInterval


Examples of org.apache.cxf.ws.rmp.v200502.RMAssertion.AcknowledgementInterval

        bval = null;
        if (null != b.getAcknowledgementInterval()) {
            bval = b.getAcknowledgementInterval().getMilliseconds();
        }
        if (null != aval || null != bval) {
            AcknowledgementInterval ai = new RMAssertion.AcknowledgementInterval();
            if (null != aval && null != bval) {
                ai.setMilliseconds(bval);
            } else {
                ai.setMilliseconds(aval != null ? aval : bval);
            }
            compatible.setAcknowledgementInterval(ai);
        }
   
        // backoff parameter
View Full Code Here

Examples of org.apache.cxf.ws.rmp.v200502.RMAssertion.AcknowledgementInterval

        assertEquals(7200000L, c.getInactivityTimeout().getMilliseconds().longValue());
        assertEquals(20000L, c.getBaseRetransmissionInterval().getMilliseconds().longValue());
        assertNull(c.getAcknowledgementInterval());
        assertNull(c.getExponentialBackoff());
      
        AcknowledgementInterval aai = new RMAssertion.AcknowledgementInterval();
        aai.setMilliseconds(new Long(2000));
        a.setAcknowledgementInterval(aai);
       
        c = RM10PolicyUtils.intersect(a, b);
        assertEquals(7200000L, c.getInactivityTimeout().getMilliseconds().longValue());
        assertEquals(20000L, c.getBaseRetransmissionInterval().getMilliseconds().longValue());
View Full Code Here

Examples of org.apache.cxf.ws.rmp.v200502.RMAssertion.AcknowledgementInterval

        SpringBusFactory bf = new SpringBusFactory();
        bus = bf.createBus("/org/apache/cxf/systest/ws/rm/seqlength1.xml");
        // set the client retry interval much shorter than the slow processing delay
        RMManager manager = bus.getExtension(RMManager.class);
       
        AcknowledgementInterval ai
            = new org.apache.cxf.ws.rmp.v200502.ObjectFactory()
                .createRMAssertionAcknowledgementInterval();
        ai.setMilliseconds(new Long(5000));
        manager.getRMAssertion().setAcknowledgementInterval(ai);

        BusFactory.setDefaultBus(bus);
        GreeterService gs = new GreeterService();
        greeter = gs.getGreeterPort();
View Full Code Here

Examples of org.apache.cxf.ws.rmp.v200502.RMAssertion.AcknowledgementInterval

            // use a at-most-once server with sync ack processing
            Bus bus = bf.createBus("/org/apache/cxf/systest/ws/rm/atmostonce.xml");
            BusFactory.setDefaultBus(bus);
            setBus(bus);
           
            AcknowledgementInterval ai
                = new org.apache.cxf.ws.rmp.v200502.ObjectFactory()
                    .createRMAssertionAcknowledgementInterval();
            ai.setMilliseconds(new Long(0));
            bus.getExtension(RMManager.class).getRMAssertion().setAcknowledgementInterval(ai);

            serverGreeter = new GreeterCounterImpl();
            String address = "http://localhost:" + PORT + "/SoapContext/GreeterPort";
           
View Full Code Here

Examples of org.objectweb.celtix.ws.rm.policy.RMAssertionType.AcknowledgementInterval

        assertFalse(seq.sendAcknowledgement());
    }
   
    public void testAcknowledgeDeferred() throws SequenceFault, IOException {
        ap.setIntraMessageThreshold(0);
        AcknowledgementInterval ai =
            RMUtils.getWSRMPolicyFactory().createRMAssertionTypeAcknowledgementInterval();
        ai.setMilliseconds(new BigInteger("200"));
        rma.setAcknowledgementInterval(ai);       
      
        Timer timer = new Timer();
        destination.getHandler();
        expectLastCall().andReturn(handler).times(3);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.