Examples of addBinding()


Examples of org.apache.agila.model.Node.addBinding()

            Binding binding = new Binding(name, value,
                    ("EL".equals(type.toUpperCase()) ? Binding.EL : Binding.STATIC),
                    ("TRUE".equals(input.toUpperCase())),
                    ("TRUE".equals(output.toUpperCase())));

            n.addBinding(binding);
        }
        graph.addNode(n);

    }
View Full Code Here

Examples of org.apache.cxf.service.model.ServiceInfo.addBinding()

       
        BindingFactoryManager bfm = bus.getExtension(BindingFactoryManager.class);
        BindingFactory bindingFactory = bfm.getBindingFactory(soapVersion);
        BindingInfo bi = bindingFactory.createBindingInfo(service,
                                                          soapVersion, null);
        si.addBinding(bi);
        if (transportId == null) {
            ConduitInitiatorManager cim = bus.getExtension(ConduitInitiatorManager.class);
            ConduitInitiator ci = cim.getConduitInitiatorForUri(location);
            transportId = ci.getTransportIds().get(0);
        }
View Full Code Here

Examples of org.apache.qpid.client.messaging.address.Node.QueueNode.addBinding()

            }
        }
        node.setExclusive(true);
        node.setAutoDelete(!node.isDurable());
        send0_10QueueDeclare(dest,null,false,true);
        node.addBinding(new Binding(dest.getAddressName(),
                                    dest.getQueueName(),// should have one by now
                                    dest.getSubject(),
                                    Collections.<String,Object>emptyMap()));
        sendQueueBind(dest.getAMQQueueName(), dest.getRoutingKey(),
                null,dest.getExchangeName(),dest, false);
View Full Code Here

Examples of org.apache.qpid.server.exchange.Exchange.addBinding()

            String bindingKey = String.valueOf(routingKey);

            if (!exch.isBound(bindingKey, arguments, queue))
            {

                if(!exch.addBinding(bindingKey, queue, arguments) && TopicExchange.TYPE.equals(exch.getType()))
                {
                    Binding oldBinding = exch.getBinding(bindingKey, queue, arguments);

                    Map<String, Object> oldArgs = oldBinding.getArguments();
                    if((oldArgs == null && !arguments.isEmpty()) || (oldArgs != null && !oldArgs.equals(arguments)))
View Full Code Here

Examples of org.apache.qpid.server.exchange.ExchangeImpl.addBinding()

                        when(_virtualHost.getExchange(eq(name))).thenReturn(exchange);
                        when(_virtualHost.getExchange(eq(id))).thenReturn(exchange);

                        final ArgumentCaptor<AMQQueue> queue = ArgumentCaptor.forClass(AMQQueue.class);

                        when(exchange.addBinding(anyString(), queue.capture(), anyMap())).then(new Answer<Boolean>()
                        {

                            @Override
                            public Boolean answer(InvocationOnMock invocation) throws Throwable
                            {
View Full Code Here

Examples of org.apache.qpid.server.exchange.topic.TopicExchangeResult.addBinding()

                    // TODO - fix control flow
                    return;
                }
            }
           
            result.addBinding(binding);

        }
        else
        {
View Full Code Here

Examples of org.apache.qpid.server.queue.MockAMQQueue.addBinding()

        TopicDeletePolicy policy = new TopicDeletePolicy();
        policy.configure(_config);

        MockAMQQueue queue = createOwnedQueue();

        queue.addBinding(new Binding(null, null, "bindingKey", queue, new DirectExchange(), null));

        policy.performPolicy(queue);

        assertFalse("Queue should not be deleted", queue.isDeleted());
        assertFalse("Connection should not be closed", _connection.isClosed());
View Full Code Here

Examples of org.apache.webbeans.jms.JMSModel.addBinding()

        JMSModel model = new JMSModel(type,jndiName,mapName);       
        JMSManager.getInstance().addJmsModel(model);
       
        for(Annotation ann : bindingTypes)
        {
            model.addBinding(ann);
        }
    }

    /**
     * Cofigures the initial value of the given field.
View Full Code Here

Examples of org.apache.wsdl.WSDLDescription.addBinding()

        WSDLBinding binding = generateBinding(wsdlComponentFactory,
                portType,
                bindingName,
                "document", "literal", "http://schemas.xmlsoap.org/soap/http",
                "http://www.org.apache.axis2");
        womDescription.addBinding(binding);

        //generating service
        WSDLService service = generateService(wsdlComponentFactory, womDescription, binding, serviceName);
        womDescription.addService(service);
        return womDescription;
View Full Code Here

Examples of org.cipango.kaleo.location.Registration.addBinding()

    assertEquals(0, reginfo.getRegistrationArray(0).getContactArray().length);
   
    Registration registration = new Registration(aor);
    registration.addListener(regResource)
    Binding binding1 = new Binding(new UriImpl("sip:alice@localhost"), "123@localhost", 1, now + 100000);
    registration.addBinding(binding1);
   
    //System.out.println(regResource.getState().getContent());
    assertEquals(1, reginfo.getRegistrationArray(0).getContactArray().length);
    assertEquals(State.ACTIVE, reginfo.getRegistrationArray(0).getState());
    Contact contact = reginfo.getRegistrationArray(0).getContactArray(0);
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.