jjzjj

messaging

全部标签

java - IllegalArgumentException : com. sun.xml.internal.messaging.saaj.soap.LocalStrings != com.sun.xml.messaging.saaj.soap.LocalStrings

在我的网络应用程序中,我正在联系一个网络服务(使用JAX-WS),但我收到以下错误:java.lang.ExceptionInInitializerErroratcom.sun.xml.ws.message.AttachmentUnmarshallerImpl.(AttachmentUnmarshallerImpl.java:55)atcom.sun.xml.ws.client.sei.ResponseBuilder$DocLit.readResponse(ResponseBuilder.java:500)atcom.sun.xml.ws.client.sei.SyncMethodHa

java - Akka/Java : Handling multiple message types inside a custom actor?

要在Akka(Java绑定(bind))中实现您自己的自定义actor,您可以扩展UntypedActor基类。这需要您定义自己的onReceive(...)方法:@OverridepublicvoidonReceive(Objectmessage){//TODO}手头的问题是确定一种消息处理策略,使参与者能够处理多种类型的消息。一种策略是使用反射/类型。这里的问题是:它迫使我们创建空的“外壳类”,这些类只是为消息提供语义意义(见下文);和它占用了message参数并阻止我们传递任何动态或有意义的内容空壳类的例子:publicclassEmptyShellMessage{}然后在onR

java - 卡夫卡 : No message seen on console consumer after message sent by Java Producer

我是Kafka的新手。我在我的本地机器上创建了一个java生产者,并在网络上的另一台机器上设置了一个Kafka代理,比如M2(我可以ping、SSH、连接到这台机器)。在Eclipse控制台的生产者端,我收到“消息已发送”。但是当我检查机器M2上的控制台消费者时,我看不到这些消息。我的java生产者代码是:importorg.apache.kafka.clients.producer.KafkaProducer;importorg.apache.kafka.clients.producer.ProducerConfig;importorg.apache.kafka.clients.pr

java - 在 spring messages.properties 中,使用错误代码作为键时如何确保错误消息换行?

在messages.properties:error.code=Thisiserrormessage.\nThisisnextlineoferrormessage.现在,当我用这个“errors.rejectValue”为表单字段设置“error.code”时,我无法得到'\n'的换行符。使用form:errors显示错误消息时显示在jsp页面上元素。而不是'\n',使用也不起作用,并按原样显示在页面上。 最佳答案 为了显示一个作为换行符,或使错误消息正文中的任何其他html标记生效,例如一个,只需添加htmlEscape="fal

java - ActiveMQ : dead letter queue keeps my messages order

我使用ActiveMQ作为代理来传递消息。这些消息旨在写入数据库中。有时,数据库无法访问或已关闭。在这种情况下,我想回滚我的消息以便稍后重试此消息,并且我想继续阅读其他消息。这段代码工作正常,除了一点:回滚消息阻止我阅读其他代码:privateConnectiongetConnection()throwsJMSException{RedeliveryPolicyredeliveryPolicy=newRedeliveryPolicy();redeliveryPolicy.setMaximumRedeliveries(3);//willretry3timestodequeuerollba

java - '严重 : SAAJ0009: Message send failed error' while sending a message

Feb8,201111:56:49AMcom.sun.xml.internal.messaging.saaj.client.p2p.HttpSOAPConnectionpostSEVERE:SAAJ0009:Messagesendfailedcom.sun.xml.internal.messaging.saaj.SOAPExceptionImpl:java.security.PrivilegedActionException:com.sun.xml.internal.messaging.saaj.SOAPExceptionImpl:Messagesendfailedatcom.sun.

Java 错误 : "incompatible types" message

我在编译期间遇到Java错误:UserID.java:36:error:incompatibletypes+generator.nextInt(10);^required:Stringfound:intJava代码如下:publicclassUserID{privateStringfirstName;privateStringuserId;privateStringpassword;publicUserID(Stringfirst){Randomgenerator=newRandom();userId=first.substring(0,3)++generator.nextInt(1)

java - java Utility类中logger的使用

我只是想知道在编写Java代码时如何在Utility类中使​​用LoggerAPI。我们总是可以使用记录器,我们将使用我们的实用程序类来记录正确的消息,但我想问的是——在实用类中使用Logger是一种好的做法吗? 最佳答案 我假设您正在编写自己的*Util代码。我个人避免在实用程序类中使用Logger,因为日志文件中存在“噪音”。如果您的实用程序类经过良好测试,您可以删除日志语句。请记住只记录日志,不要在日志语句中执行任何业务逻辑(无论是否使用实用程序类)。例如我在我的一个项目中看到了下面的内容,这不是好的做法。log.info("

java - 亚马逊 SQS : The same message is consumed by two current consumers

我有四个当前消费者在AmazonAWS上收听同一个队列。从队列中拉取消息时,有时会出现同一条消息被两个不同的消费者消费的情况。请看下面的日志:18:01:46,515[jmsContainer-2]DEBUG-从队列中收到消息:ID:3698a927-930b-4d6a-aeca-f6692252879218:02:12,825[jmsContainer-3]DEBUG-从队列中收到消息:ID:3698a927-930b-4d6a-aeca-f66922528792我有一个包含4个并发使用者的JMS容器设置。我将可见性超时设置为30秒。既然container2收到了消息,怎么conta

java - 使用后台线程与使用消息队列

我目前正在研究一系列警报,这些警报将检查来自外部网络服务的响应状态,并根据响应对象的状态(例如超时、无效数据等)发送警报。我希望主线程在评估响应和发送警报时继续工作。我有两个立即可用的选项:使用ActiveMQ并将对象作为objectMessage发送到队列进行处理。使用命令模式并线程化处理警报的异步命令。它们对我来说都是不错的选择,但我更倾向于线程命令,因为我不需要消息队列的大部分功能。问题:您将如何决定使用哪个?为什么? 最佳答案 两个字:保证交付。如果这对您很重要,那么消息队列就是您想要的。