zoukankan      html  css  js  c++  java
  • ActiveMQ之MessageListener

    消息的消费者接收消息可以采用两种方式:
    1.consumer.receive()或 consumer.receive(int timeout);
    2.注册一个MessageListener.
    采用第一种方式,消息的接收者会一直等待下去,知道有消息到达或者超时。后一种方式会注册一个监听器,
    当有消息到达的时候,会调用它的onMessage()方法。以下举例说明:
    MessageConsumer consumer=session.createConsumer(queue);
    consumer.setMessageListener(new MessageListener(){
    public void onMessage(Message msg)
    {
    System.out.println("接收到的消息为+"((TextMessage)msg).getText());
    }
    })

  • 相关阅读:
    锁详解
    消息组件
    分布式锁
    jvm调优
    类加载
    垃圾回收
    Mysql
    redis
    悲观锁和乐光锁
    算法常见
  • 原文地址:https://www.cnblogs.com/fjhh/p/5370581.html
Copyright © 2011-2022 走看看