Examples of Coordinator


Examples of org.apache.qpid.amqp_1_0.type.transaction.Coordinator

        }
        else
        {
            if(endpoint.getTarget() instanceof Coordinator)
            {
                Coordinator coordinator = (Coordinator) endpoint.getTarget();
                TxnCapability[] capabilities = coordinator.getCapabilities();
                boolean localTxn = false;
                boolean multiplePerSession = false;
                if(capabilities != null)
                {
                    for(TxnCapability capability : capabilities)
View Full Code Here

Examples of org.apache.qpid.amqp_1_0.type.transaction.Coordinator

        }
        else
        {
            if(endpoint.getTarget() instanceof Coordinator)
            {
                Coordinator coordinator = (Coordinator) endpoint.getTarget();
                TxnCapability[] capabilities = coordinator.getCapabilities();
                boolean localTxn = false;
                boolean multiplePerSession = false;
                if(capabilities != null)
                {
                    for(TxnCapability capability : capabilities)
View Full Code Here

Examples of org.apache.qpid.amqp_1_0.type.transaction.Coordinator

        }
        else
        {
            if(endpoint.getTarget() instanceof Coordinator)
            {
                Coordinator coordinator = (Coordinator) endpoint.getTarget();
                TxnCapability[] capabilities = coordinator.getCapabilities();
                boolean localTxn = false;
                boolean multiplePerSession = false;
                if(capabilities != null)
                {
                    for(TxnCapability capability : capabilities)
View Full Code Here

Examples of org.apache.qpid.amqp_1_0.type.transaction.Coordinator

    public Coordinator construct(Object underlying)
    {
        if(underlying instanceof List)
        {
            List list = (List) underlying;
            Coordinator obj = new Coordinator();
            int position = 0;
            final int size = list.size();

            if(position < size)
            {
                Object val = list.get(position);
                position++;

                if(val != null)
                {


                    if (val instanceof TxnCapability[] )
                    {
                        obj.setCapabilities( (TxnCapability[]) val );
                    }
                    else if (val instanceof Symbol[])
                    {
                        Symbol[] symVal = (Symbol[]) val;
                        TxnCapability[] cap = new TxnCapability[symVal.length];
                        int i = 0;
                        for(Symbol sym : symVal)
                        {
                            cap[i++] = TxnCapability.valueOf(sym);
                        }
                        obj.setCapabilities(cap);
                    }
                    else
                {
                        try
                        {
                            obj.setCapabilities( new TxnCapability[] { (TxnCapability) val } );
                        }
                        catch(ClassCastException e)
                        {
                            // TODO Error
                        }
View Full Code Here

Examples of org.apache.qpid.amqp_1_0.type.transaction.Coordinator

        }
        else
        {
            if(endpoint.getTarget() instanceof Coordinator)
            {
                Coordinator coordinator = (Coordinator) endpoint.getTarget();
                TxnCapability[] capabilities = coordinator.getCapabilities();
                boolean localTxn = false;
                boolean multiplePerSession = false;
                if(capabilities != null)
                {
                    for(TxnCapability capability : capabilities)
View Full Code Here

Examples of org.apache.qpid.amqp_1_0.type.transaction.Coordinator

        }
        else
        {
            if(endpoint.getTarget() instanceof Coordinator)
            {
                Coordinator coordinator = (Coordinator) endpoint.getTarget();
                TxnCapability[] capabilities = coordinator.getCapabilities();
                boolean localTxn = false;
                boolean multiplePerSession = false;
                if(capabilities != null)
                {
                    for(TxnCapability capability : capabilities)
View Full Code Here

Examples of org.apache.qpid.amqp_1_0.type.transaction.Coordinator

        }
        else
        {
            if(endpoint.getTarget() instanceof Coordinator)
            {
                Coordinator coordinator = (Coordinator) endpoint.getTarget();
                TxnCapability[] capabilities = coordinator.getCapabilities();
                boolean localTxn = false;
                boolean multiplePerSession = false;
                if(capabilities != null)
                {
                    for(TxnCapability capability : capabilities)
View Full Code Here

Examples of org.apache.qpid.amqp_1_0.type.transaction.Coordinator

        return _connection;
    }

    public SendingLinkEndpoint createTransactionController(String name, TxnCapability... capabilities)
    {
        Coordinator coordinator = new Coordinator();
        coordinator.setCapabilities(capabilities);

        Source src = new Source();

        return createSendingLinkEndpoint(name, src, coordinator);
    }
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

      {
         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
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.