我在做一个项目，使用activemq异步消费方式，继承messagelistener做了一个outmsglistener，希望在收到消息时能够运用发送接口发送出去，onmessage中的代码为：
if (message instanceof ObjectMessage) {
ObjectMessage objectMsg = (ObjectMessage) message;
MsgObject msg = (MsgObject)objectMsg.getObject();
String phone=msg.getPhonenum();
String outmsg=msg.getMsgBody();
SmsSendManager.getInstance().send(phone, outmsg);
}
这样启动该程序就可以侦听了，本来是没有问题的，也可以使用了。
但是现在我在smsSendManager中写了一个静态代码，启动一个httpserver来侦听对方给我返回的状态，现在启动时就会报错，说是启动这个httpserver时初始化错误，不知为什么？
问题补充：报错信息：
Exception in thread "ActiveMQ Session Task" java.lang.ExceptionInInitializerError
at com.abacusys.server.mobileserversend.vcomcn.SmsSendManager.runReceiveStateServer(SmsSendManager.java:147)
这个runReceiveStateServer就是那个httpserver，用来接收对方给我post的state信息。
1条评论
关注(0)
相关推荐
在Spring中，实现异步消息监听器有三种方式：实现 javax.jms.MessageListener 接口、实现 Spring 的 SessionAwareMessageListener 和捆绑一个标准 POJO 到 Spring 的 MessageListenerAdapter 类上。这三种方法在消息...
var message = session.CreateTextMessage("Hello, ActiveMQ!"); producer.Send(message); } ``` 5. 创建`Consumer`并订阅消息： ```csharp using (var consumer = session.CreateConsumer(topic)) { var message...
总的来说，"activemqactivemq"这个主题涵盖了使用ActiveMQ进行消息收发的核心知识，通过理解和实践提供的代码示例，可以深入理解ActiveMQ的工作原理和使用方法。在实际项目中，合理利用消息中间件如ActiveMQ，能够极...
这里，我们创建了一个ConnectionFactory，指定了连接到ActiveMQ服务器的URL，然后定义了消息的目标（Queue），并配置了一个MessageListenerContainer，用于接收和处理消息。 **三、编写MessageListener** `Message...
<property name="messageListener" ref="messageListener" /> ``` 在这里，`MyMessageListener`是你自定义的消息监听器，负责处理接收到的消息。 接着，我们可以创建消息生产者，使用`JmsTemplate`发送消息。...
<property name="messageListener" ref="messageListener"/> ``` 3. **注解方式** Spring 4.0之后引入了基于注解的配置，可以在Java配置类中定义消息监听器。首先创建一个`@Configuration`类，并使用`@...
<property name="messageListener" ref="messageListener"/> <bean id="messageListener" class="com.example.YourMessageListenerClass"/> ``` 这里，`destinationName`是你要监听的消息队列名称，`message...
<property name="messageListener" ref="messageListener"/> <bean id="messageListener" class="com.example.MessageListener"/> ``` ```java public class MessageListener implements MessageListener { ...
在这里，我们定义了一个监听器容器，监听"myQueue"上的消息，并将接收到的消息传递给`MessageListener`类的`onMessage`方法处理。 在实际应用中，`activeMQ_p2s`和`activeMQ_spring`这两个文件可能包含了示例代码，...
<property name="messageListener" ref="messageListener"/> <bean id="messageListener" class="com.example.MessageListener"> <!-- 实现MessageListener接口 --> ``` 在`MessageListener`中，你需要实现`...
Spring通过JMS Template和MessageListener接口，简化了与ActiveMQ的交互。首先，我们需要在Spring配置文件中声明JMS相关组件，包括ConnectionFactory、Destination（队列或主题）以及MessageListener容器。然后，...
在这里，`destinationName`是你要监听的消息目的地（队列或主题），而`messageListener`是自定义的消息监听器类，它实现了`MessageListener`接口。 在代码中，你可以使用`JmsTemplate`发送消息，`MyMessageListener...
其中，`MessageListener`是自定义的消息监听器，实现了`javax.jms.MessageListener`接口，用于处理接收到的消息。 **三、发送和接收消息** 1. **发送消息** 使用`JmsTemplate`的`send`方法发送消息到指定的队列或...
- `src/main/resources/`：存放Spring的配置文件，如`applicationContext.xml`，其中定义了JmsTemplate和MessageListenerContainer的配置。 - `src/main/java/com/example/`：包含消息生产者和消费者的相关类，如`...
public class MessageListener implements javax.jms.MessageListener { @Override public void onMessage(Message message) { TextMessage textMessage = (TextMessage) message; try { System.out.println(...
<property name="messageListener" ref="messageListener"/> <bean id="messageListener" class="com.example.MyMessageListener"/> ``` 5. **编写消息监听器**：在`MyMessageListener`类中，实现`Message...
<property name="messageListener" ref="messageListener"/> <bean id="messageListener" class="com.example.MyMessageListener"/> ``` `MyMessageListener`类需要实现`MessageListener`接口，覆盖`...
- Spring框架提供了与ActiveMQ集成的强大支持，通过Spring的JmsTemplate和MessageListenerContainer等组件可以简化消息的生产和消费。 - Spring配置文件中，你可能看到 `<bean>` 标签用于配置ConnectionFactory、...
<property name="messageListener" ref="messageListener"/> ``` 然后，**消息的生产和消费**：在Spring应用中，你可以通过`JmsTemplate`的`convertAndSend`方法发送消息，而`MessageListener`接口的实现类则用于...
4. **MessageListener**: 如果需要异步接收消息，可以实现 javax.jms.MessageListener 接口并提供 onMessage 方法。Spring 可以自动将该接口的实现注册为消息监听器。 **注解驱动的实例** 在描述中提到的“注解的...