List of declareQueue() Examples

Examples of declareQueue()

eu.mosaic_cloud.drivers.queue.amqp.AmqpDriver.declareQueue()
Declare a queue. @param clientId client identifier @param queue the name of the queue @param exclusive true if we are declaring an exclusive queue (restricted to this connection) @param durable true if we are declaring a durable queue (the queue will survive a server restart) @param autoDelete true if we are declaring an autodelete queue (server will delete it when no longer in use) @param passive true if we declare a queue passively; i.e., check if it exists @param complHandler handlers to be called when the operation finishes @return true if the queue declaration succeeded
org.springframework.amqp.core.AmqpAdmin.declareQueue()
Declare a queue whose name is automatically named. It is created with exclusive = true, autoDelete=true, and durable = false. @return The queue.
org.springframework.amqp.rabbit.core.RabbitAdmin.declareQueue()
Declare the given queue. If the queue doesn't have a value for 'name' property, the queue name will be generated by Broker and returned from this method. But the 'name' property of the queue remains as is.

Examples of eu.mosaic_cloud.drivers.queue.amqp.AmqpDriver.declareQueue()

        autoDelete = declQueue.getAutoDelete ();
        passive = declQueue.getPassive ();
        AmqpStub.logger.trace ("AmqpStub - Received request for DECLARE QUEUE"); // $NON-NLS-1$
        // NOTE: execute operation
        final DriverOperationFinishedHandler queueHandler = new DriverOperationFinishedHandler (token, session);
        resultBool = driver.declareQueue (token.getClientId (), queue, exclusive, durable, autoDelete, passive, queueHandler);
        queueHandler.setDetails (AmqpOperations.DECLARE_QUEUE, resultBool);
        break;
      case BIND_QUEUE_REQUEST :
        final AmqpPayloads.BindQueueRequest bindQueue = (BindQueueRequest) message.payload;
        token = bindQueue.getToken ();

View Full Code Here

Examples of org.springframework.amqp.core.AmqpAdmin.declareQueue()

    connectionFactory.setVirtualHost(svc_vhost);


    String queueName = "CLOUD";
    AmqpAdmin amqpAdmin = new RabbitAdmin(connectionFactory);
    Queue cloudQueue = new Queue(queueName);
    amqpAdmin.declareQueue(cloudQueue);


    RabbitTemplate template = new RabbitTemplate(connectionFactory);
    template.setRoutingKey(queueName);
    template.setQueue(queueName);
    template.afterPropertiesSet();

View Full Code Here

Examples of org.springframework.amqp.core.AmqpAdmin.declareQueue()

  public static void main(String[] args) throws Exception {
    ApplicationContext context = new ClassPathXmlApplicationContext("rabbitConfiguration.xml");
    AmqpAdmin amqpAdmin = context.getBean(AmqpAdmin.class);
    Queue helloWorldQueue = new Queue("hello.world.queue");
    
    amqpAdmin.declareQueue(helloWorldQueue);


  }


}

View Full Code Here

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

    connectionFactory.setVirtualHost(svc_vhost);


    String queueName = "CLOUD";
    AmqpAdmin amqpAdmin = new RabbitAdmin(connectionFactory);
    Queue cloudQueue = new Queue(queueName);
    amqpAdmin.declareQueue(cloudQueue);


    RabbitTemplate template = new RabbitTemplate(connectionFactory);
    template.setRoutingKey(queueName);
    template.setQueue(queueName);
    template.afterPropertiesSet();

View Full Code Here

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

    // pre-declare the queue with dead-lettering, users can also use a policy
    RabbitAdmin admin = new RabbitAdmin(this.rabbitAvailableRule.getResource());
    Map<String, Object> args = new HashMap<String, Object>();
    args.put("x-dead-letter-exchange", "xdbustest.DLX");
    Queue queue = new Queue("xdbustest.dlqtest", true, false, false, args);
    admin.declareQueue(queue);


    MessageBus bus = getMessageBus();
    Properties properties = new Properties();
    properties.put("prefix", "xdbustest.");
    properties.put("autoBindDLQ", "true");

View Full Code Here

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

   * Creates an instance of the queue on the rabbit broker. If already present then no action is taken.
   */
  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.declareQueue()


    RabbitAdmin admin = new RabbitAdmin(template.getConnectionFactory());
    Map<String, Object> args = new HashMap<String, Object>();
    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);

View Full Code Here

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

    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);
    container.afterPropertiesSet();
    container.start();

View Full Code Here

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

        if (isDefaultQueue(queueName)) {
          // Just for test probe.
          admin.deleteQueue(queueName);
        }
        else {
          admin.declareQueue(queue);
        }
      }
      brokerOffline.put(port, false);
      if (!assumeOnline) {
        Assume.assumeTrue(brokerOffline.get(port));

View Full Code Here

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

  public SimpleMessageListenerContainer listenerContainer() {
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory());
    Queue q = testQueue();


    RabbitAdmin admin = rabbitAdmin();
    admin.declareQueue(q);
    admin.declareBinding(testBinding());


    container.setQueues(q);
    // container.setMessageListener(testListener(4));
    container.setAutoStartup(false);

View Full Code Here

0 1

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.