Tag: jms

Oracle数据库在到达列中指定的时间时发送通知/调用java方法: 我有一张表有事件详情。新记录将由另一个进程连续插入此表。该表有一个Event-end-time列。我必须设计一种机制来调用java方法来处理事件到达事件结束时间。我的一些选择是：连续查询数据库（每1分钟）并找到要处理的下一个最新报告，并在到达结束时间时调用它。弄清楚ORACLE数据库中是否有任何内置机制向java应用程序发送通知/ Oracle itslef在到达事件结束时调用java方法。如果记录是插入/更新/删除（基于触发器），我已经看到了通知选项，但是到目前为止，如果通知条件是自定义的（如果达到了记录列中的时间），我没有运气。任何有关这方面的建议将不胜感激。此致，迪帕克

按Jms ID选择消息的语法: 根据相应的JMS ID选择消息的正确语法是什么？目前我使用： String selector = “JMSMessageID=’ID:305:1:5:1:1′”; messageConsumer = session.createConsumer(getRetryQueue(), selector); 上面的语法适用于模拟代理的测试。但是对于ActiveMQ，消息不会被轮询。原始代码： @Override public Message readMessageFromRetryQueueByJmsId(String jmsId) throws QueueingException { Connection connection = null; Session session = null; MessageConsumer messageConsumer = null; Message message = null; try { connection = getConnectionFactory().createConnection(); session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); messageConsumer = session.createConsumer(getRetryQueue(), “JMSMessageID='”+jmsId+”‘”); message = messageConsumer.receiveNoWait(); } […]

我将如何向Activemq发送消息: 我从不在JMS工作。最近我在所有conf/activemq-*.xml文件中下载了Activemq并将端口号从61616更改为61617.I从命令提示符运行以下命令并在浏览器上打开控制台页面。 C:\Users\Infratab Bangalore\Desktop\Queueing\apache-activemq-5.8.0\bin>activemq 现在我想使用JMS将消息从java代码发送到Activemq 。为此，我编写了以下代码。并使用Apache Tomcat server.it运行我的代码此代码在Eclipse中实现。 package PackageName; import java.io.IOException; import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.Queue; import javax.jms.Session; import javax.jms.TextMessage; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.apache.activemq.ActiveMQConnectionFactory; public class MessageProducer extends HttpServlet { @Override protected void service(HttpServletRequest arg0, HttpServletResponse arg1) throws ServletException, IOException { try { //created ConnectionFactory […]

Java和Android之间的交互: 我目前正在尝试研究如何在现有的基于java的系统中使用Android。基本上，我需要与Android应用程序进行通信。系统当前使用ActiveMQ作为JMS提供程序将对象数据从计算机传递到计算机。在其中一台计算机上是一个向用户显示对象数据的显示器。我们现在要做的是使用手机（运行Android）作为另一个选项，向具有wifi /网络访问权限的用户显示此对象数据。理想情况下，我们希望在Android上有一个本机应用程序，它可以监听ActiveMQ主题并发布到另一个主题并读取/写入/显示对象数据，但是从我做过的一些研究中，我不确定这是否可行。有什么其他方法可以解决这个问题？ Android手机需要能够发送/接收数据。我一直在使用AndroidEmulator进行测试。

Weblogic 12.1.3未找到PrivilegedActions类: 我创建一个简单的项目，调用一个jms队列并放入一条消息。这里的代码： public class QueueSend { // Defines the JNDI context factory. public final static String JNDI_FACTORY=”weblogic.jndi.WLInitialContextFactory”; // Defines the JMS context factory. public final static String JMS_FACTORY=”jms/MyConnectionFactory”; // Defines the queue. public final static String QUEUE=”jms/MyTestQueue”; private QueueConnectionFactory qconFactory; private QueueConnection qcon; private QueueSession qsession; private QueueSender qsender; private Queue queue; private TextMessage msg; […]

IBM MQ消息侦听器: 您有没有人知道如何使用IBM MQ创建消息监听器？我知道如何使用JMS规范来完成它，但我不知道如何为IBM MQ做到这一点。非常感谢任何链接或指针。

可以以某种方式查看AMQ主题的内容吗？: 我正在尝试使用activemq-admin查看主题的内容。这就是我正在尝试的： ./activemq-admin browse –amqurl tcp://localhost:61616 my.topic 这是我得到的输出： Java Runtime: Sun Microsystems Inc. 1.6.0_24 /usr/lib/jvm/java-6-sun-1.6.0.24/jre Heap sizes: current=62848k free=62190k max=932096k JVM args: -Dactivemq.classpath=/home/pc/dev/apache-activemq-5.3.1/conf; -Dactivemq.home=/home/pc/dev/apache-activemq-5.3.1 -Dactivemq.base=/home/pc/dev/apache-activemq-5.3.1 ACTIVEMQ_HOME: /home/pc/dev/apache-activemq-5.3.1 ACTIVEMQ_BASE: /home/pc/dev/apache-activemq-5.3.1 这不是我想要的。我希望以某种方式以原始forms看到队列中的消息。那可能吗？谢谢，

activemq优先级: 我们目前正在使用JMS和activemq（5.5.1）开发应用程序。我们希望为某些消息定义更高的优先级，这将使它们首先被消耗。在设置生产者和使用者之后（通过spring（3.1）JMSTemplate），优先级不能完全发挥作用。实际上，当我们“关闭”消费者并发送一些消息时，优先权得到尊重，但是当我们在消费者开启时添加消息时，消息的接收顺序与他们发送的顺序相同。配置很简单：在activemq配置文件中激活优先级： ” prioritizedMessages=”true”/> … 并且在生产者模板配置中启用了QoS：要发送具有高优先级的消息，我们只需更改生产者端的模板优先级属性： template.setPriority(9); 任何想法？这是正常的行为，还是有一些我们会忘记的配置？

从PL / SQL调用/使用JMS: 是否可以从PL / SQL调用/使用JAVA消息服务（JMS）？我知道我们可以从pl / SQL调用java，但调用java与调用JMS Queues或JMS Topics不同，因为JMS依赖于JNDI资源命名，当我们使用基于JNDI的资源时，我们首先必须将它们部署在某些J2EE容器中，然后使用它们。所以调用JMS总是涉及在某个J2EE容器上部署然后利用它的function。回到我之前提到的问题，我想使用PL / SQL中的JMS以及如何处理部署和基于JNDI的资源。

使用ActiveMQ，Camel和Spring实现Request-Reply模式: 我正在尝试实现以下function：然后逐行读取CSV文件：根据该行包含的值构建请求将请求发送到消息队列其他组件需要接收消息，处理请求并将响应发送到另一个消息队列（生产者已知，因此生产者可以获取响应）。我相信请求 – 回复模式适合该法案。我安装了ActiveMQ，下载了camel并尝试使用他们的jms项目。配置组件，队列和测试连接（工作）后，我试图弄清楚实际上如何实现请求 – 回复？我没有找到任何好的例子我有一个RouteBuilder RouteBuilder public class MyRouteBuilder extends RouteBuilder { public static void main(String[] args) throws Exception { new Main().run(args); } public void configure() { from(“file:src/data?noop=true”) .to(“activemq:RequestQ”); from(“activemq:RequestQ?exchangePattern=InOut&timeToLive=5000”) .inOut(“activemq:RequestQ”, “bean:myBean?method=someMethod”); } } 骆驼的context.xml org.apache.camel.example.spring 问题：如何读取文件逐行构造并根据行内容发布消息？如何配置路由以及如何配置邮件头以便在获取响应后将被删除的临时队列中获取响应？您可以推荐哪些快速入门指南？编辑我得到了下面的代码。现在让我们说在处理器中我创建响应。我该如何寄回？我该如何使用响应？ public […]