List of bindings() Examples

Examples of bindings()

com.linkedin.data.schema.DataSchemaResolver.bindings()
Return a map of names to {@link NamedDataSchema} bindings that have been resolved. @return map of names to {@link NamedDataSchema} bindings that have been resolved.
com.sun.tools.ws.wsdl.document.Definitions.bindings()
net.tomp2p.connection.ChannelClientConfiguration.bindings()
@return The bindings
net.tomp2p.connection.ChannelServerConfiguration.bindings()
org.apache.qpid.management.common.mbeans.ManagedExchange.bindings()
Returns all the bindings this exchange has with the queues. @return the bindings with the exchange. @throws IOException @throws JMException
xsul5.wsdl.WsdlDefinitions.bindings()

Examples of com.linkedin.data.schema.DataSchemaResolver.bindings()

  {
    ArrayList<File> generatedFiles = new ArrayList<File>();


    DataSchemaResolver resolver = getSchemaResolver();
    Map<String, DataSchemaLocation> nameToLocations = resolver.nameToDataSchemaLocations();
    Map<String, NamedDataSchema> nameToSchema = resolver.bindings();


    for (Map.Entry<String, DataSchemaLocation> entry : nameToLocations.entrySet())
    {
      String fullName = entry.getKey();
      DataSchemaLocation location = entry.getValue();

View Full Code Here

Examples of com.sun.tools.ws.wsdl.document.Definitions.bindings()

    String value = null;
    // process the bindings in definitions of model.entity
    if (model.getEntity() instanceof Definitions) {
      Definitions definitions = (Definitions) model.getEntity();
      if (definitions != null) {
        Iterator bindings = definitions.bindings();
        if (bindings != null) {
          while (bindings.hasNext()) {
            Binding binding = (Binding) bindings.next();
            if (bName.getLocalPart().equals(binding.getName())
                && bName.getNamespaceURI().equals(binding.getNamespaceURI())) {

View Full Code Here

Examples of net.tomp2p.connection.ChannelClientConfiguration.bindings()

    return channelServerConfiguration;
  }


  public static ChannelClientConfiguration createDefaultChannelClientConfiguration() {
    ChannelClientConfiguration channelClientConfiguration = new ChannelClientConfiguration();
    channelClientConfiguration.bindings(new Bindings());
    channelClientConfiguration.maxPermitsPermanentTCP(MAX_PERMITS_PERMANENT_TCP);
    channelClientConfiguration.maxPermitsTCP(MAX_PERMITS_TCP);
    channelClientConfiguration.maxPermitsUDP(MAX_PERMITS_UDP);
    channelClientConfiguration.pipelineFilter(new DefaultPipelineFilter());
    channelClientConfiguration.signatureFactory(new DSASignatureFactory());

View Full Code Here

Examples of net.tomp2p.connection.ChannelServerConfiguration.bindings()

    return peer;
  }


  public static ChannelServerConfiguration createDefaultChannelServerConfiguration() {
    ChannelServerConfiguration channelServerConfiguration = new ChannelServerConfiguration();
    channelServerConfiguration.bindings(new Bindings());
    //these two values may be overwritten in the peer builder
    channelServerConfiguration.ports(new Ports(Ports.DEFAULT_PORT, Ports.DEFAULT_PORT));
    channelServerConfiguration.portsForwarding(new Ports(Ports.DEFAULT_PORT, Ports.DEFAULT_PORT));
    channelServerConfiguration.behindFirewall(false);
    channelServerConfiguration.pipelineFilter(new DefaultPipelineFilter());

View Full Code Here

Examples of org.apache.qpid.management.common.mbeans.ManagedExchange.bindings()

        try
        {
            //verify the DLE exchange exists, has the expected type, and a single binding for the DLQ
            ManagedExchange exchange = jmxUtils.getManagedExchange(QUEUE_WITH_DLQ_NAME + "_DLE");
            assertEquals("Wrong exchange type", "fanout", exchange.getExchangeType());
            TabularDataSupport bindings = (TabularDataSupport) exchange.bindings();
            assertEquals(1, bindings.size());
            for(Object o : bindings.values())
            {
                CompositeData binding = (CompositeData) o;

View Full Code Here

Examples of org.apache.qpid.management.common.mbeans.ManagedExchange.bindings()

        final String queueName = getTestQueueName();
        final ManagedExchange defaultExchange = _jmxUtils.getManagedExchange(ExchangeDefaults.DEFAULT_EXCHANGE_NAME.asString());


        // Check that bind does not exist before queue creation
        assertFalse("Binding to " + queueName + " should not exist in default exchange before queue creation",
                     defaultExchange.bindings().containsKey(new String[] {queueName}));


        _managedBroker.createNewQueue(queueName, "testowner", true);


        // Ensure the queue exists
        assertNotNull("Queue object name expected to exist", _jmxUtils.getQueueObjectName(VIRTUAL_HOST, queueName));

View Full Code Here

Examples of org.apache.qpid.management.common.mbeans.ManagedExchange.bindings()

        assertNotNull("Queue object name expected to exist", _jmxUtils.getQueueObjectName(VIRTUAL_HOST, queueName));
        assertNotNull("Manager queue expected to be available", _jmxUtils.getManagedQueue(queueName));


        // Now verify that the default exchange has been bound.
        assertTrue("Binding to " + queueName + " should exist in default exchange after queue creation",
                     defaultExchange.bindings().containsKey(new String[] {queueName}));


        // Now delete the queue
        _managedBroker.deleteQueue(queueName);


        // Finally ensure that the binding has been removed.

View Full Code Here

Examples of org.apache.qpid.management.common.mbeans.ManagedExchange.bindings()

        // Now delete the queue
        _managedBroker.deleteQueue(queueName);


        // Finally ensure that the binding has been removed.
        assertFalse("Binding to " + queueName + " should not exist in default exchange after queue deletion",
                defaultExchange.bindings().containsKey(new String[] {queueName}));
    }


    /**
     * Tests exchange creation/deletion via JMX API.
     */

View Full Code Here

Examples of org.apache.qpid.management.common.mbeans.ManagedExchange.bindings()

        final String queueName = getTestQueueName();
        final ManagedExchange defaultExchange = _jmxUtils.getManagedExchange(ExchangeDefaults.DEFAULT_EXCHANGE_NAME.asString());


        // Check that bind does not exist before queue creation
        assertFalse("Binding to " + queueName + " should not exist in default exchange before queue creation",
                     defaultExchange.bindings().containsKey(new String[] {queueName}));


        _managedBroker.createNewQueue(queueName, "testowner", true);


        // Ensure the queue exists
        assertNotNull("Queue object name expected to exist", _jmxUtils.getQueueObjectName(VIRTUAL_HOST, queueName));

View Full Code Here

Examples of org.apache.qpid.management.common.mbeans.ManagedExchange.bindings()

        assertNotNull("Queue object name expected to exist", _jmxUtils.getQueueObjectName(VIRTUAL_HOST, queueName));
        assertNotNull("Manager queue expected to be available", _jmxUtils.getManagedQueue(queueName));


        // Now verify that the default exchange has been bound.
        assertTrue("Binding to " + queueName + " should exist in default exchange after queue creation",
                     defaultExchange.bindings().containsKey(new String[] {queueName}));


        // Now delete the queue
        _managedBroker.deleteQueue(queueName);


        // Finally ensure that the binding has been removed.

View Full Code Here

0 1 2 3

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.