`
473687880
  • 浏览: 535916 次
文章分类
社区版块
存档分类
最新评论

MessageListener 类

 
阅读更多

消息的消费者接收消息可以采用两种方式:

(1)consumer.receive()或者consumer.receive(int timeOut)

(2)注册一个messageListener

采用第一种方式消息会一直等待下去,直到有消息到达,或者超时。后一种方式会注册一个监听器,当有消息到达的时候会回调它的Onmessage()方法,下面举例说明。

MessageConsumer consumer=new MessageConsumer();

consumer.setMessageListener(new MessageListener()

{

          @Override

          public void Onmessage(Message m)

          {

               Textmessage text=(Textmessage)m;

               try

               {

                    System.out.print(text.getText());

               }

               catch(Exception e)

               {

                    e.printStackTrace();

               }

          }

 

});


分享到:
评论

相关推荐

    JMS与Spring之二(用message listener container异步收发消息)

    在Spring中,实现异步消息监听器有三种方式:实现 javax.jms.MessageListener 接口、实现 Spring 的 SessionAwareMessageListener 和捆绑一个标准 POJO 到 Spring 的 MessageListenerAdapter 类上。这三种方法在消息...

    消息队列监听器无法注入bean的问题解决

    在Spring框架中,监听器通常通过实现`MessageListener`接口或者使用`@RabbitListener`注解来定义。如果这个类中的bean无法被正确地注入,那么可能是由于配置问题或者依赖注入机制出现了故障。 `BeanUtil.java`可能...

    Redis 发布订阅 Demo

    创建一个实现了`MessageListener`接口的类,用于接收和处理发布的消息: ```java @Component public class RedisMessageListener implements MessageListener { @Override public void onMessage(Channel ...

    【JMS接收端需要用到的jar包】

    它包括了`JmsTemplate`、`MessageListenerContainer`等组件,可以简化消息的发送和监听。 9. **jta.jar**(Java Transaction API):如果你的应用需要在多个资源(如数据库和JMS)之间进行事务管理,那么JTA是必不...

    ActiveMQ与spring集成实例之使用消息监听器

    <property name="messageListener" ref="messageListener"/> <bean id="messageListener" class="com.example.MessageListener"> <!-- 实现MessageListener接口 --> ``` 在`MessageListener`中,你需要实现`...

    activemq+spring实例

    4. 编写消息监听器:在`MessageListener`类中,重写`onMessage`方法来处理接收到的消息。 5. 发送消息:使用`JmsTemplate`发送消息到Queue或Topic。例如: ```java jmsTemplate.convertAndSend("myQueue", "Hello, ...

    spring + activemq 消息sample

    然后创建一个实现MessageListener接口的类,用于处理接收到的消息。 ```xml <bean id="messageListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> ...

    spring-kafka-batch-listener.zip

    2. **监听器接口**:接下来,我们需要创建一个实现了`MessageListener`接口的类,该接口包含一个`onMessage(ConsumerRecord, ?>[] records)`方法,用于处理批量消息。在这个方法中,我们可以遍历`records`数组,按...

    ActiveMQ 与Spring结合示例

    对于消息的消费,我们可以定义一个监听器容器(MessageListenerContainer),并注册一个实现 `MessageListener` 接口的类。下面是一个例子: ```xml <bean id="messageListenerContainer" class="org.spring...

    spring-jms-oracle-aq.rar_oracle aq_spring oracle aq_spring oracl

    通常,你会使用OracleJmsTemplate类来发送消息,并配置一个MessageListener来接收消息。在Spring配置文件中,你需要指定Oracle数据库的连接信息,包括数据库URL、用户名、密码以及Oracle AQ相关的JNDI名称。 2. ...

    rocketmq 公共类库

    消费者通过`subscribe`方法来指定其关心的主题和标签,然后通过`MessageListener`接口来处理接收到的消息。 6. **rocketmq** 这个可能是RocketMQ的主配置文件或库,包含与RocketMQ客户端连接相关的配置,如服务器...

    Spring+weblogic接收JMS消息

    - 将这个`MessageListener`类注入到Spring容器中,并与配置的`MessageListenerContainer`关联。 - 当消息到达时,`MessageListenerContainer`会自动调用`onMessage`方法,从而实现异步处理。 5. **测试与调试**:...

    JMS之Spring +activeMQ实现消息队列

    5. 实现MessageListener:如果需要消费消息,需要创建一个实现了`MessageListener`接口的类,并重写`onMessage`方法。 6. 配置MessageListenerContainer:这负责启动和管理MessageListener,可以是`...

    ActiveMQ整合Spring使用连接池

    在这里,`destinationName`是你要监听的消息目的地(队列或主题),而`messageListener`是自定义的消息监听器类,它实现了`MessageListener`接口。 在代码中,你可以使用`JmsTemplate`发送消息,`MyMessageListener...

    spring使用activeMQ

    - **consumer**:这部分可能包含消息消费者的代码,比如实现了 MessageListener 的类,以及配置了监听特定 Destination 的 MessageListenerContainer。 - **producer**:这部分可能是消息生产者的代码,它创建并...

    使用Spring JMS轻松实现异步消息传递.pdf

    public MessageListener messageListener() { return new MyMessageListener(); } @Bean public DefaultMessageListenerContainer listenerContainer() { DefaultMessageListenerContainer container = new ...

    activemq与spring的整合案例

    这里,`destinationName`是你要监听的消息队列名称,`messageListener`是指定的消息监听器类。 在`YourMessageListenerClass`中,你需要实现`javax.jms.MessageListener`接口,重写`onMessage(Message message)`...

    Spring整合ActiveMQ简单实例

    5. **编写消息消费者**:创建一个实现了 `MessageListener` 接口的类,用于接收并处理消息。例如: ```java @Component public class MessageListener implements javax.jms.MessageListener { @Override public ...

    kafka使用案例公共类

    5. **MessageListener.java**: `MessageListener`接口或类是Kafka消费者处理接收到消息的方式。当消费者从Kafka拉取到新的消息时,会触发监听器的回调方法,进行实际的数据处理。这个接口通常定义了一个`onMessage`...

    Spring JMS消息处理-不基于JNDI

    <property name="messageListener" ref="messageListener" /> <bean id="messageListener" class="com.example.MyMessageListener" /> ``` 这里定义了一个DefaultMessageListenerContainer,指定了之前配置的...

Global site tag (gtag.js) - Google Analytics