![]() If anyone has any workaround to do retry, dead-letter-queue inside reactive function please provide an answer. ![]() There is an open incident on spring-cloud-stream repo for this issue onErrorContinue, in this case my application is not getting broken on first message, but messages are not going to DLQ. When I try to send another message, I keep on getting a different exception in console logs until I restart the application to get first message again, but now the message goes to DLQ. Also, will the client reconnect after this.I have an application where I have to move the message to DLQ (dead-letter queue) on a particular case, but on the first message, the exception is thrown, but it ignores my max-attempts:2 value and I can see my exception message 4 times and the message has not gone to DLQ.Īs mentioned in spring cloud stream docs, the message should go to DLQ on throwing an exception. What could be the possible reasons for this. I think in this case, the client sends the SessionCreateConsumerMessage, but the jms topic binding is not found in postoffice. The other exception I received for durable topic subscriber is slightly different.Ģ3:46:11,596 ERROR HQ224016: Caught exception: HornetQException Īt .(RemotingConnectionImpl.java:523) [hornetq-core-client.jar: ![]() Following exception is occuring in case of durable subscriber attached to the topic:Ģ3:46:11,596 ERROR HQ224016: Caught exception: HornetQException [errorType=QUEUE_DOES_NOT_EXIST message=HQ119017Īt .(ServerSessionImpl.java:348) Īt .(ServerSessionPacketHandler.java:218) The exception occurs in case of Topic also. Some of the operations of the Java queue raise an exception whereas some of these operations return a particular value when the program is completed. ![]() The Queue interface promotes different methods like insert, delete, peek, etc. When the queue is non-durable the exception occurs, if the queue is durable, the exception is not thrown.Ī) Start hornetq server and start a receiver for the queue.ī) Stop hornetq server and restart again.ģ. In the Java queue, there are many methods that are used very commonly. Note: If queue receiver is stopped first before starting hornetq server, no error is thrown.Īfter some analysis, following are the findings:ġ. Stop and restart hornetq server and I get this error in hornetq server. It has been configured in hornetq server hornetq-jms.xml:Īnd I use JNDI to look up the queue while configuring the receiver.ģ. Start another server having jms receiver for the queue "MyQueue" The error is produced in the following scenario:Ģ. I get the following error while using hornetq 2.3:Ġ0:42:28,435 ERROR HQ224016: Caught exception: HornetQExceptionĪt .(HornetQServerImpl.java:1811) Īt .(HornetQServerImpl.java:1107) Īt .(ServerSessionImpl.java:427) Īt .(ServerSessionPacketHandler.java:235) Īt .(ChannelImpl.java:631) Īt .(RemotingConnectionImpl.java:547) Īt .(RemotingConnectionImpl.java:523) Īt .$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:564) Īt .(HornetQChannelHandler.java:72) Īt .SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:88) Īt .ndUpstream(DefaultChannelPipeline.java:560) Īt .DefaultChannelPipeline$ndUpstream(DefaultChannelPipeline.java:787) Īt .Channels.fireMessageReceived(Channels.java:281) Īt .(HornetQFrameDecoder2.java:169) Īt .(HornetQFrameDecoder2.java:134) Īt .SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70) Īt .ndUpstream(DefaultChannelPipeline.java:555) Īt .Channels.fireMessageReceived(Channels.java:268) Īt .Channels.fireMessageReceived(Channels.java:255) Īt .(OioWorker.java:71) Īt .(AbstractOioWorker.java:73) Īt .(OioWorker.java:51) Īt .n(ThreadRenamingRunnable.java:108) Īt .internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42) Īt .VirtualExecutorService$n(VirtualExecutorService.java:175) Īt .runWorker(ThreadPoolExecutor.java:1110) Īt $n(ThreadPoolExecutor.java:603) Īt (Thread.java:722) Hot Network Questions How to escape 0.5mm ball grid array pins Why does this sentence have a 'back': 'Loving India back since 1924.' Is it ok to set the unused I/O pins of the ATmega8A to input and connect all of them to ground Do ChatGPT and other AI bots force a rethinking of anonymity. ![]()
0 Comments
Leave a Reply. |
Details
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |