List of session() Examples

Examples of session()

com.netflix.curator.test.Timing.session()
com.webobjects.appserver.WOComponent.session()
com.webobjects.appserver.WOContext.session()
com.webobjects.eodistribution.EODistributionContext.session()
dust.crypto.Keypair.session()
er.extensions.appserver.ERXWOContext.session()
er.persistentsessionstorage.model.ERSessionInfo.session()
org.apache.curator.test.Timing.session()
Return the value to use for ZK session timeout @return session timeout
org.apache.qpid.proton.engine.Connection.session()
@return a newly created session
org.cipango.server.SipMessage.session()
org.eclipse.sapphire.services.ContentProposalService.session()
org.keycloak.events.EventBuilder.session()
org.springframework.test.web.servlet.request.MockHttpServletRequestBuilder.session()
Set the HTTP session to use, possibly re-used across requests.
Individual attributes provided via {@link #sessionAttr(String,Object)}override the content of the session provided here. @param session the HTTP session

Examples of org.apache.curator.test.Timing.session()


        ExecutorService executorService = Executors.newFixedThreadPool(PARTICIPANT_QTY);
        ExecutorCompletionService<Void> service = new ExecutorCompletionService<Void>(executorService);


        final Timing timing = new Timing();
        final CuratorFramework client = CuratorFrameworkFactory.newClient(server.getConnectString(), timing.session(), timing.connection(), new RetryOneTime(1));
        try
        {
            client.start();


            final AtomicBoolean thereIsALeader = new AtomicBoolean(false);

View Full Code Here

Examples of org.apache.curator.test.Timing.session()

        final CountDownLatch timesSquare = new CountDownLatch(PARTICIPANT_QTY);
        final AtomicLong masterCounter = new AtomicLong(0);
        final AtomicLong notLeaderCounter = new AtomicLong(0);


        Timing timing = new Timing();
        CuratorFramework client = CuratorFrameworkFactory.newClient(server.getConnectString(), timing.session(), timing.connection(), new RetryOneTime(1));
        ExecutorService exec = Executors.newSingleThreadExecutor(new ThreadFactoryBuilder().setDaemon(true).setNameFormat("callbackSanity-%s").build());


        List<LeaderLatch> latches = Lists.newArrayList();
        for ( int i = 0; i < PARTICIPANT_QTY; ++i )
        {

View Full Code Here

Examples of org.apache.curator.test.Timing.session()

        final CountDownLatch timesSquare = new CountDownLatch(PARTICIPANT_QTY);
        final AtomicLong masterCounter = new AtomicLong(0);
        final AtomicLong notLeaderCounter = new AtomicLong(0);


        Timing timing = new Timing();
        CuratorFramework client = CuratorFrameworkFactory.newClient(server.getConnectString(), timing.session(), timing.connection(), new RetryOneTime(1));
        ExecutorService exec = Executors.newSingleThreadExecutor(new ThreadFactoryBuilder().setDaemon(true).setNameFormat("callbackNotifyLeader-%s").build());


        List<LeaderLatch> latches = Lists.newArrayList();
        for ( int i = 0; i < PARTICIPANT_QTY; ++i )
        {

View Full Code Here

Examples of org.apache.curator.test.Timing.session()

    {
        final AtomicLong masterCounter = new AtomicLong(0);
        final AtomicLong notLeaderCounter = new AtomicLong(0);


        Timing timing = new Timing();
        CuratorFramework client = CuratorFrameworkFactory.newClient(server.getConnectString(), timing.session(), timing.connection(), new RetryOneTime(1));


        final LeaderLatch leader = new LeaderLatch(client, PATH_NAME);
        final LeaderLatch notifiedLeader = new LeaderLatch(client, PATH_NAME, "", LeaderLatch.CloseMode.NOTIFY_LEADER);


        leader.addListener(new LeaderLatchListener()

View Full Code Here

Examples of org.apache.curator.test.Timing.session()

    public void testNoServerAtStart()
    {
        CloseableUtils.closeQuietly(server);


        Timing timing = new Timing();
        CuratorFramework client = CuratorFrameworkFactory.newClient(server.getConnectString(), timing.session(), timing.connection(), new RetryNTimes(5, 1000));


        client.start();


        final LeaderLatch leader = new LeaderLatch(client, PATH_NAME);
        final CountDownLatch leaderCounter = new CountDownLatch(1);

View Full Code Here

Examples of org.apache.curator.test.Timing.session()

        final int PARTICIPANT_QTY = 1;//0;


        List<LeaderLatch> latches = Lists.newArrayList();


        Timing timing = new Timing();
        CuratorFramework client = CuratorFrameworkFactory.newClient(server.getConnectString(), timing.session(), timing.connection(), new RetryOneTime(1));
        try
        {
            client.start();


            for ( int i = 0; i < PARTICIPANT_QTY; ++i )

View Full Code Here

Examples of org.apache.curator.test.Timing.session()


    @Test(expectedExceptions = IllegalArgumentException.class)
    public void testRelativePath() throws Exception
    {
        Timing timing = new Timing();
        CuratorFramework client = CuratorFrameworkFactory.newClient(server.getConnectString(), timing.session(), timing.connection(), new RetryOneTime(1));
        LeaderLatch latch = new LeaderLatch(client, "parent");
    }
}

View Full Code Here

Examples of org.apache.curator.test.Timing.session()


        final Timing                        timing = new Timing();
        final ExecutorService               executor = Executors.newCachedThreadPool();
        ExecutorCompletionService<Void>     completionService = new ExecutorCompletionService<Void>(executor);


        final CuratorFramework              client = CuratorFrameworkFactory.newClient(server.getConnectString(), timing.session(), timing.connection(), new RetryOneTime(1));
        try
        {
            client.start();
            client.create().forPath(PATH);

View Full Code Here

Examples of org.apache.curator.test.Timing.session()

                            CuratorFramework            client = null;
                            DistributedQueue<String>    queue = null;


                            try
                            {
                                client = CuratorFrameworkFactory.newClient(server.getConnectString(), timing.session(), timing.connection(), new RetryOneTime(1));
                                client.start();
                                queue = QueueBuilder.builder(client, consumer, serializer, PATH).executor(executor).maxItems(MAX_ITEMS).putInBackground(false).lockPath("/locks").buildQueue();
                                queue.start();


                                for ( int i = 0; i < ADD_ITEMS; ++i )

View Full Code Here

Examples of org.apache.curator.test.Timing.session()

    @Test
    public void         testSimple() throws Exception
    {
        Timing                      timing = new Timing();
        DistributedQueue<String>    queue = null;
        CuratorFramework            client = CuratorFrameworkFactory.newClient(server.getConnectString(), timing.session(), timing.connection(), new RetryOneTime(1));
        try
        {
            client.start();


            final List<String>          messages = new CopyOnWriteArrayList<String>();

View Full Code Here

0 1 2 3 4 5 6

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.