Examples of Coordinator


Examples of org.apache.qpid.proton.amqp.transaction.Coordinator

                return t;
            }
            else if(pn_terminus_type_t.PN_COORDINATOR.equals(pn_terminus_type))
            {
                Coordinator c = new Coordinator();

                // TODO

                return c;
            }
View Full Code Here

Examples of org.apache.qpid.proton.amqp.transaction.Coordinator

                return t;
            }
            else if(pn_terminus_type_t.PN_COORDINATOR.equals(pn_terminus_type))
            {
                Coordinator c = new Coordinator();

                // TODO

                return c;
            }
View Full Code Here

Examples of org.apache.qpid.proton.amqp.transaction.Coordinator

                return t;
            }
            else if(pn_terminus_type_t.PN_COORDINATOR.equals(pn_terminus_type))
            {
                Coordinator c = new Coordinator();

                // TODO

                return c;
            }
View Full Code Here

Examples of org.apache.qpid.proton.amqp.transaction.Coordinator

      {
         Receiver receiver = (Receiver) link;
         if (link.getRemoteTarget() instanceof Coordinator)
         {
            protonSession.initialise(true);
            Coordinator coordinator = (Coordinator) link.getRemoteTarget();
            protonSession.addTransactionHandler(coordinator, receiver);
         }
         else
         {
            protonSession.initialise(false);
View Full Code Here

Examples of org.apache.qpid.proton.amqp.transaction.Coordinator

    public Coordinator newInstance(Object described)
    {
        List l = (List) described;

        Coordinator o = new Coordinator();


        switch(1 - l.size())
        {

            case 0:
                Object val0 = l.get( 0 );
                if( val0 == null || val0.getClass().isArray() )
                {
                    o.setCapabilities( (Symbol[]) val0 );
                }
                else
                {
                    o.setCapabilities( (Symbol) val0 );
                }
        }


        return o;
View Full Code Here

Examples of org.apache.qpid.proton.amqp.transaction.Coordinator

      {
         Receiver receiver = (Receiver) link;
         if (link.getRemoteTarget() instanceof Coordinator)
         {
            protonSession.initialise(true);
            Coordinator coordinator = (Coordinator) link.getRemoteTarget();
            protonSession.addTransactionHandler(coordinator, receiver);
         }
         else
         {
            protonSession.initialise(false);
View Full Code Here

Examples of org.fenixedu.academic.domain.Coordinator

    public ActionForward switchResponsability(ActionMapping mapping, ActionForm form, HttpServletRequest request,
            HttpServletResponse response) {

        final String coordinatorId = request.getParameter("coordinatorId");
        Coordinator coordinator = FenixFramework.getDomainObject(coordinatorId);

        final String executionDegreeId = request.getParameter("executionDegreeId");
        ExecutionDegree executionDegree = FenixFramework.getDomainObject(executionDegreeId);

        final String personId = request.getParameter("personId");
        final Person personSwitching = FenixFramework.getDomainObject(personId);

        String backPath = request.getParameter("backPath");

        if (coordinator.isResponsible()) {
            coordinator.makeAction(OperationType.CHANGERESPONSIBLE_FALSE, personSwitching);
            // coordinator.setAsNotResponsible();
        } else {
            coordinator.makeAction(OperationType.CHANGERESPONSIBLE_TRUE, personSwitching);
            // coordinator.setAsResponsible();
        }

        ExecutionDegreeCoordinatorsBean coordsBean = new ExecutionDegreeCoordinatorsBean(executionDegree);
        coordsBean.setEscapedBackPath(backPath);
View Full Code Here

Examples of org.omg.CosTransactions.Coordinator

        if (crashPoint == null) {
      _logger.log(Level.SEVERE,"jts.invalid_crash_point");
            return;
        }

        Coordinator coord = Utility.getCoordinator(Utility.getControl());
        JCoordinator jcoord = JCoordinatorHelper.narrow(coord);
        if (jcoord != null) {
            GlobalTID gtid = new GlobalTID(jcoord.getGlobalTID());
            crashList.put(gtid, crashPoint);
        }
View Full Code Here

Examples of org.omg.CosTransactions.Coordinator

        if (waitPoint == null) {
      _logger.log(Level.SEVERE,"jts.invalid_wait_point");
            return;
        }

        Coordinator coord = Utility.getCoordinator(Utility.getControl());
        JCoordinator jcoord = JCoordinatorHelper.narrow(coord);
        if (jcoord != null) {
            GlobalTID gtid = new GlobalTID(jcoord.getGlobalTID());
            waitList.put(gtid, waitPoint);
            waitTime.put(gtid, new Integer(waitDuration));
View Full Code Here

Examples of org.omg.CosTransactions.Coordinator

             */
            ORB orb = ORB.getInstance( PerformanceFramework.ORB_INSTANCE_NAME );
            OA oa = OA.getRootOA( orb );

            Control control = OTSManager.get_current().get_control();
            Coordinator coordinator = control.get_coordinator();

            DemoResource resource = new DemoResource();

            oa.objectIsReady(resource);
            Resource res = ResourceHelper.narrow(oa.corbaReference(resource));

            coordinator.register_resource(res);
        }
        catch (Exception e)
        {
            e.printStackTrace(System.err);
            throw new PerfTestException();
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.