List of declareExchange() Examples

Examples of declareExchange()

eu.mosaic_cloud.drivers.queue.amqp.AmqpDriver.declareExchange()
Declares an exchange and creates a channel for it. @param clientId client identifier @param name the name of the exchange @param type the exchange type @param durable true if we are declaring a durable exchange (the exchange will survive a server restart) @param autoDelete true if the server should delete the exchange when it is no longer in use @param passive true if we declare an exchange passively; that is, check if the named exchange exists @param complHandler handlers to be called when the operation finishes @return true if the exchange declaration succeeded
org.apache.qpid.client.AMQSession.declareExchange()
org.springframework.amqp.rabbit.core.RabbitAdmin.declareExchange()

Examples of org.apache.qpid.client.AMQSession.declareExchange()

    public void declareExchange() throws AMQException, JMSException, URLSyntaxException
    {
        AMQConnection con = new AMQConnection("localhost:9000", "guest", "guest", "test", "/test");
        AMQSession session = (AMQSession) con.createSession(false, AMQSession.NO_ACKNOWLEDGE);
        System.out.println("Session created");
        session.declareExchange("my_exchange", "direct");
        System.out.println("Exchange declared");
        con.close();
        System.out.println("Connection closed");
    }
}

View Full Code Here

Examples of org.apache.qpid.client.AMQSession.declareExchange()

            conn = new AMQConnection(url, null);




            AMQSession sess = (AMQSession) conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
            
            sess.declareExchange(new AMQShortString("test.direct"), 
                    ExchangeDefaults.DIRECT_EXCHANGE_CLASS, false);


            sess.declareExchange(new AMQShortString("tmp.direct"), 
                    ExchangeDefaults.DIRECT_EXCHANGE_CLASS, false);

View Full Code Here

Examples of org.apache.qpid.client.AMQSession.declareExchange()

            AMQSession sess = (AMQSession) conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
            
            sess.declareExchange(new AMQShortString("test.direct"), 
                    ExchangeDefaults.DIRECT_EXCHANGE_CLASS, false);


            sess.declareExchange(new AMQShortString("tmp.direct"), 
                    ExchangeDefaults.DIRECT_EXCHANGE_CLASS, false);


            sess.declareExchange(new AMQShortString("tmp.topic"), 
                    ExchangeDefaults.TOPIC_EXCHANGE_CLASS, false);

View Full Code Here

Examples of org.apache.qpid.client.AMQSession.declareExchange()

                    ExchangeDefaults.DIRECT_EXCHANGE_CLASS, false);


            sess.declareExchange(new AMQShortString("tmp.direct"), 
                    ExchangeDefaults.DIRECT_EXCHANGE_CLASS, false);


            sess.declareExchange(new AMQShortString("tmp.topic"), 
                    ExchangeDefaults.TOPIC_EXCHANGE_CLASS, false);


            sess.declareExchange(new AMQShortString("test.topic"), 
                    ExchangeDefaults.TOPIC_EXCHANGE_CLASS, false);

View Full Code Here

Examples of org.apache.qpid.client.AMQSession.declareExchange()

                    ExchangeDefaults.DIRECT_EXCHANGE_CLASS, false);


            sess.declareExchange(new AMQShortString("tmp.topic"), 
                    ExchangeDefaults.TOPIC_EXCHANGE_CLASS, false);


            sess.declareExchange(new AMQShortString("test.topic"), 
                    ExchangeDefaults.TOPIC_EXCHANGE_CLASS, false);


            QueueSession queueSession = conn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);


            AMQQueue queue = (AMQQueue) queueSession.createQueue("MyQueue");

View Full Code Here

Examples of org.springframework.amqp.rabbit.core.RabbitAdmin.declareExchange()

  public void createQueue() {
    RabbitAdmin admin = new RabbitAdmin(connectionFactory);
    Queue sourceQueue = new Queue(queue, false, false, true);
    admin.declareQueue(sourceQueue);
    TopicExchange exchange = new TopicExchange(DEFAULT_EXCHANGE);
    admin.declareExchange(exchange);
    admin.declareBinding(
        BindingBuilder.bind(sourceQueue).to(exchange).with("rabbitfixture.*"));
  }


  /**

View Full Code Here

Examples of org.springframework.amqp.rabbit.core.RabbitAdmin.declareExchange()

    args.put("x-dead-letter-exchange", "test.DLE");
    Queue queue = new Queue("", false, false, true, args);
    String testQueueName = admin.declareQueue(queue);
    // Create a DeadLetterExchange and bind a queue to it with the original routing key
    DirectExchange dle = new DirectExchange("test.DLE", false, true);
    admin.declareExchange(dle);
    Queue dlq = new AnonymousQueue();
    admin.declareQueue(dlq);
    admin.declareBinding(BindingBuilder.bind(dlq).to(dle).with(testQueueName));


    container.setQueueNames(testQueueName);

View Full Code Here

Examples of org.springframework.amqp.rabbit.core.RabbitAdmin.declareExchange()

      }
      else {
        x = new TopicExchange(exchangeName, durable, autoDelete);
      }
      // admin.deleteExchange(exchangeName);
      admin.declareExchange(x);
    }
  }


  @Override
  public void append(LoggingEvent event) {

View Full Code Here

Examples of org.springframework.amqp.rabbit.core.RabbitAdmin.declareExchange()

        x = new HeadersExchange(this.exchangeType, this.durable, this.autoDelete);
      }
      else {
        x = new TopicExchange(this.exchangeName, this.durable, this.autoDelete);
      }
      admin.declareExchange(x);
    }
  }


  /**
   * Subclasses may modify the final message before sending.

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.