插入的 Java 代码通过使用提供的队列连接工厂引用和队列名称引用来将消息发送到 JMS 队列侦听器。您可以更新 setText() 方法中的参数值来更改消息文本。
插入片段以将消息发送到 JMS 队列侦听器的示例
public class Main { public void sendMyMessage() { // insert snippet here } }
import com.ibm.etools.service.locator.ServiceLocatorManager; import javax.jms.*; import javax.naming.*; public class Main { private final static String STATIC_CONNECTION_FACTORY_REF_NAME = "queueconnectionfactoryreference"; private final static String STATIC_QUEUE_REF_NAME = "queuename"; public void sendMyMessage() { // insert snippet here send_queuenameMessage(); } protected void send_queuenameMessage() { try { QueueConnectionFactory qConnectionFactory = ServiceLocatorManager .lookupQueueConnectionFactory(STATIC_CONNECTION_FACTORY_REF_NAME); Queue queue = ServiceLocatorManager .lookupQueue(STATIC_QUEUE_REF_NAME); QueueConnection qConnection = qConnectionFactory .createQueueConnection(); QueueSession qSession = qConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE); QueueSender sender = qSession.createSender(queue); TextMessage message = qSession.createTextMessage(); message.setText("Foo Sample Queue message"); sender.send(message); sender.close(); qSession.close(); qConnection.close(); } catch (JMSException jmse) { // TODO Auto-generated catch block jmse.printStackTrace(); } } }
要插入 Java 代码以将消息发送到 JMS 队列侦听器,请执行以下操作:
ServiceLocatorManager 类具有称为 setErrorHandler(ServiceLocatorErrorHandler handler) 的静态方法,可以使用该方法来为在查找 home 接口时出现的错误状态指定特定错误处理程序。缺省处理程序只对处理的异常调用 printStackTrace()。