Spring integration recipient-list-router issue

See also questions close to this topic

• Spring REST Controller mapping JSON

  Wondered if someone could help me out. I have a JSON request

  {
      "blue": "blue",
      "red": "red",
      "greens" : {
          "lightGreen": "lightGreen",
          "darkGreen": "darkGreen"
      }
  }
  

  which I want to map to a pojo using @RequestBody

  done like this:

  @PostMapping(path = "/colors", headers = "Accept=application/json")
  public void generateClaimDocument(@Valid @RequestBody Colors colors) {
          if (colors != null) {
              service.doSomethingWithColors(colors);
          }
      }
  

  Which works fine for blue and red, but it is not mapping JSON greens object at all. Never done this before so could someone shed some light onto how I can do this?

  PoJo's:

  public class Colors {
  
      private String blue;
      private String red;
      private Greens greens;
      //getters and setters
  }
  
  public class Greens {
  
      private String lightGreen;
      private String darkGreen;
      //getters and setters
  }
  
• How to reload embedded Tomcat in Spring Boot in runtime?

  I change default port of my Spring Boot app by changing server.port property in application.properties file.

  But now I need to change this port after the app is started. Is it possible?
• Spring and Thymeleaf form validation using modelandview

  i am having a problem returning the error on thymeleaf template.

  i have this on my controller, viewModel is ModelAndView object.

  @PostMapping("/")
  public ModelAndView Create(HttpServletRequest request, HttpServletResponse response, @Valid @ModelAttribute("viewModel")TViewModel model,
          BindingResult result, Model m) throws Exception {
     if (result.hasErrors()) {
          viewModel.setViewName("maintenance/role/create");
          viewModel.addObject("viewModel", model);
          viewModel.addAllObjects(result.getModel());
  
          return viewModel;
      }
          return viewModel;
  }
  

  And this is my view

  <div class="col-sm-6">
          <input th:field="*{Description}" type="text" class="form-control" />
          <span th:if="${#fields.hasErrors('Description')}" th:errors="*{Description}">Error!</span>
  </div>
  

  I want to show the <span th:if="${#fields.hasErrors('Description')}" th:errors="*{Description}">Error!</span> when there is an error on description field, can somebody help me with this. i tried every possible way. Thank you.
• RedisQueueOutboundChannelAdapter does not put data to redis

  i use RedisQueueOutboundChannelAdapter to push data to redis,like this:

  @Bean
  @Description("redis push queue")
  public RedisQueueOutboundChannelAdapter redisQueueOutboundChannelAdapter(RedisConnectionFactory redisConnectionFactory,
                                                                           GenericJackson2JsonRedisSerializer genericJackson2JsonRedisSerializer) {
      RedisQueueOutboundChannelAdapter redisQueueOutboundChannelAdapter = new RedisQueueOutboundChannelAdapter("mail-delivery-status-queue", redisConnectionFactory);
      redisQueueOutboundChannelAdapter.setSerializer(genericJackson2JsonRedisSerializer);
      return redisQueueOutboundChannelAdapter;
  }
  
  @Bean
  public IntegrationFlow mailDeliveryStatusCacheFlow(RedisQueueOutboundChannelAdapter redisQueueOutboundChannelAdapter) {
      return flow -> flow.channel("mail-delivery-status-channel")
              .log("--> begin store data：")
              .handle(redisQueueOutboundChannelAdapter);
  }
  

  multiple thread will push data to the queue channel named:'mail-delivery-status-channel',then the RedisQueueOutboundChannelAdapter push data to redis,but some data often did not push into the redis, what happened?
• How to Unmarshall XML from JMS queue Using spring integration dsl

  Since i do no have enough reputation to comment on the other topic open about this

  (How to unmarshall xml using spring integration dsl)

  I had to create a new topic in order to ask my question. I have a JMS which polls XML messages from a queue, and i want to transform those messages into Java Objects. Here is the code i have written

  @Bean
  public IntegrationFlow jmsMessageDrivenRedeliveryFlow() {
      return IntegrationFlows
              .from(Jms.messageDrivenChannelAdapter(new ActiveMQConnectionFactory("tcp://localhost:61616"))
                      .errorChannel(IntegrationContextUtils.ERROR_CHANNEL_BEAN_NAME)
                      .destination("foo.bar").jmsMessageConverter(new MarshallingMessageConverter(jaxbMarshaller())))
              .handle(m -> System.out.println(m.getName())).get();
  }
  
  @Bean
  public Marshaller jaxbMarshaller() {
      Jaxb2Marshaller jaxb2Marshaller = new Jaxb2Marshaller();
      return jaxb2Marshaller;
  }
  

  The class that i want to Create from XML is Customer class with the following structure

  @XmlRootElement
  public class Customer {
  
      String name;
      int age;
      int id;
  
      public String getName() {
          return name;
      }
  
      @XmlElement
      public void setName(String name) {
          this.name = name;
      }
  
      public int getAge() {
          return age;
      }
  
      @XmlElement
      public void setAge(int age) {
          this.age = age;
      }
  
      public int getId() {
          return id;
      }
  
      @XmlAttribute
      public void setId(int id) {
          this.id = id;
      }
  
  }
  

  Based on the answers on the other thread, how can i configure the Marshaller to return a Customer object? Thanks a lot in advance.
• Spring integration messages are only serializing after some reaching some capacity causing inconsistent behaviour

  We are having problem with spring integration messages serialization.We are GemFire as our message store. When we have more than 10k messages we are seeing inconsistent results. I have a class like this

  {public class SplitReportInformationImpl implements Comparable {
         private transient List<Comparable> sortFields;
         public SplitReportInformationImpl(List<Comparable> sortFields) {
            this.sortFields = sortFields;
         }
  
       @Override
         public int compareTo(SplitReportInformation o2) {
               // here NullPointException
               for (int k =0; k < getSortFields().size(); k++) { 
               int result = getSortFields().get(k)
                                          .compareTo(o2.getSortFields()
                                          .get(k));
               if (result != 0) {
                  return result;
               }
            }
            return 0;
         }
       }}
  

  We are getting NullPointerException in the compareTo method for getSortFields().size(). There are thousands of jsons being read sequentially and one Message is create per json and SplitReportInformationImpl object is created for each json and stored in the message.

  There is aggregator which combines the messages and that aggregator calls the above compareTo method. That's where it results in NullPointException. Code is little bit complicated not easy to put here and not useful this bug since the SplitReportInformationImpl object is created way before the aggregator.

  There are two sets of jsons one set contains 9k jsons and other contains 3k jsons. If 9k jsons are inputted first then they all produce right output with out any error and if the 3k jsons are inputted straight after then it throws NullPointException for some of them as explained above.

  My question is that if spring messages are serializing the messages it should always serialize and it should always through NullPointException since the sortField variable is transient.

  If Spring messages are not serialized at all then we should not get NullPointException at all.
• Java - JMS Help in my exercise

  In my "Music manager" exercise has 1 problem:

  If there are one more clients running at the same time, then all changes made by one client(s) are synchronized to other clients too. E.g: there are 3 clients (A, B and C) running at the same time, if client A adds a new song, then the new song is automatically added to the song list on the GUI of 2 other clients (B and C).

  They suggested I use JMS, I'd already done some example about JMS, but finally i can not apply it to my application (i'm using swt).
• JMS commit fails

  We have an application that uses JMS with Tibco messaging server. It’s implemented with Spring Boot. Our sessions are transacted sessions and the acknowledge mode is set to auto. We can receive the messages sent to the queue but for some reason that commit() method fails.

  This is the error:

  2018-07-13 15:50:35.858  WARN 2576 --- [enerContainer-8] o.s.j.l.DefaultMessageListenerContainer  : Execution of JMS message listener failed, and no ErrorHandler has been set.
  
  javax.jms.TransactionRolledBackException: Commit failed
  
  2018-07-13 15:50:35.914  WARN 2576 --- [enerContainer-8] o.s.j.l.DefaultMessageListenerContainer  : Setup of JMS message listener invoker failed for destination 'queue' - trying to recover. Cause: Commit failed; nested exception is javax.jms.JMSException: operation='ack' cause='Illegal state' queue='queue'
  

  I should mention two things:

  • I see the commit() failure and stack trace, only when I run in debug mode. If I let the war to just run, I don’t see any trace of commit failure in the logs. I can tell that we received the messages, but can’t tell whether the commit() failed or not.

  • If we use the default JMS implementations of Spring Boot which is ActiveMQ, then the commit() does not fail whether its in debug mode or not, it only happens with Tibco.

  Does anybody have any idea that why the commit() fails? When the commit fails, the transaction is rolled back and the messages won’t be cleared from the queue.

  Why I see this error only in debug mode? OR: it indeed, does happen when I run the war but just not logged?

  Below please find the complete stack trace:

  15:50:35.858 [DefaultMessageListenerContainer-8] WARN  o.s.j.l.DefaultMessageListenerContainer - Execution of JMS message listener failed, and no ErrorHandler has been set.
  javax.jms.TransactionRolledBackException: Commit failed
      at com.tibco.tibjms.Tibjmsx.buildException(Tibjmsx.java:596)
      at com.tibco.tibjms.TibjmsxSessionImp._confirmTransacted(TibjmsxSessionImp.java:3251)
      at com.tibco.tibjms.TibjmsxSessionImp._confirm(TibjmsxSessionImp.java:3643)
      at com.tibco.tibjms.TibjmsxSessionImp._commit(TibjmsxSessionImp.java:2898)
      at com.tibco.tibjms.TibjmsxSessionImp.commit(TibjmsxSessionImp.java:4860)
      at org.springframework.jms.support.JmsUtils.commitIfNecessary(JmsUtils.java:218)
      at org.springframework.jms.listener.AbstractMessageListenerContainer.commitIfNecessary(AbstractMessageListenerContainer.java:776)
      at org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:680)
      at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:318)
      at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:257)
      at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1189)
      at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1179)
      at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:1076)
      at java.lang.Thread.run(Unknown Source)
  2018-07-13 15:50:35.914  WARN 2576 --- [enerContainer-8] o.s.j.l.DefaultMessageListenerContainer  : Setup of JMS message listener invoker failed for destination 'queue' - trying to recover. Cause: Commit failed; nested exception is javax.jms.JMSException: operation='ack' cause='Illegal state' queue='queue'
  2018-07-13 15:50:36.543  INFO 2576 --- [enerContainer-8] o.s.j.l.DefaultMessageListenerContainer  : Successfully refreshed JMS Connection
  15:50:36.543 [DefaultMessageListenerContainer-8] INFO  o.s.j.l.DefaultMessageListenerContainer - Successfully refreshed JMS Connection
  
• Deletion policy in SQSListner

  I have recently started using SQS for one of my project. I am using @SQSListner for making consumer to listen the message and process.

  public class SQSListener {
      private static Object lock = new Object();
      String queueName = "my_queue"
  
      @SqsListener(value = queueName, deletionPolicy = SqsMessageDeletionPolicy.ON_SUCCESS)
      @JmsListener(destination = queueName)
      public void handle(String message) throws Exception {
          synchronized (lock) {
              log.info("received message {} from queue '{}'", message, queueName);
              try {
                  JSONObject jsonObject = new JSONObject(message);
                  String val = jsonObject.getString("key");
                  if(val != null) {
                      //Hit external service
                  } else {
                      throw new IllegalArgumentException("Invalid data");
                  }
              } catch (JSONException e) {
                  log.error("Error occurred while getting merchantId :" ,e);
              } catch (Throwable t) {
                  log.error ("catch....")
              }
          }
      }
  }
  

  Deletion Policy is ON_SUCCESS in my case. Documentation says:

  /**
       * Deletes message when successfully executed by the listener method. If an exception is thrown by the
       * listener method, the message will not be deleted.
       */
      ON_SUCCESS
  

  My doubts:

  I have searched a lot but it's not clearly mentioned that what will it do with message when there is an exception. I can assume I get an JSONException. what will happen in that case. Does it deletes message from queue. In my case I can't find message again(then what is the meaning of If an exception is thrown by the listener method, the message will not be deleted).

  Solution: I have solved it. Problem here was I have catched the error. Instead it worked when I threw an error.

  Further Query Is re queuing the property of spring or AWS-SQS?
• in JMeter, how to send a 4 byte message to a JMS publisher

  Don't think this has been asked this specifically.

  I have to run a performance test on a application that consumes from a ActiveMQ topic. The sampler needs to publish 4 Bytes of data in to the topic which usually be the format of (if you look at the hex value) 0x006403D6.

  If you translate them in to decimals, they will be

  0x03D6 = 00000011 11010110 ==> 982 ==> 03,D6 ==> 03, 214 ==> 3,214 0x0064 = 00000000 01100100 ==> 100 ==> 00,64 ==> 00, 100 ==> 0,100

  So the above example the 4 bytes will be [0,100,3,214].

  To get this done I have used a JMSPublisher.

  The below is the configuration:

  

  Since I have to send a byte stream I thought to use a ByteMessage from a file.

  I tried above with different content in the file in the configuration. But non would give me [0,100,3,214].

  It looks like JMeter does convert the text, characters in to byte values. So If I have a empty file the topic will reeve 0 and application will consider it as [0,0,0,0] (Application considers only the first 4 bytes)

  If I have ???? in the text file I get [63,63,63,63] (As ? ==> 00111111 ==> 63 in Decimal). But If I have to get the first byte a 0, I am unable to get that through? As there is no character I could found to represent 0.

  May be There is a better way of doing this. Please advise ?
• Publishing JMS message on Solace Topic

  I am facing issue while publishing JMS message on Solace server topic. Actually we are successfully able to send message using jmsTemplate.send() method. But unable to see the message count on solace client GUI.

  please can any one suggest me solution for this.

  Thanks in advance. Saurabh Mahajan
• JmsTemplate with RECEIVE_TIMEOUT_NO_WAIT doesn't retrieve messages from JMS queue

  Given I have ActiveMQ queue where many messages are already present.

  When I set receive timeout on JmsTemplate to RECEIVE_TIMEOUT_NO_WAIT which is equal to -1:

  jmsTemplate.setReceiveTimeout(JmsTemplate.RECEIVE_TIMEOUT_NO_WAIT); 
  

  and try to receive one of those messages:

  Message msg = jmsTemplate.receive(queueName);
  

  then msg is null, but it should not be according JavaDoc:

  /**
   * Timeout value indicating that a receive operation should
   * check if a message is immediately available without blocking.
   */
  public static final long RECEIVE_TIMEOUT_NO_WAIT = -1;
  

  Why is that?

  When I do:

  jmsTemplate.setReceiveTimeout(1000);
  

  then messages are retrieved.
• not able to remove message from jms activemq queue

  i am new to jms technology. I am using activeMQ console for monitoring queues. I am able create queue with message in it. But when I try to remove certain queue.. a exception is coming. Tried many things, but all in vein.. below is my code:

  code

      BrokerService brokerService = new BrokerService();
      BrokerFacadeSupport facade=new LocalBrokerFacade(brokerService);
      try {
          QueueViewMBean queue = facade.getQueue(queueName);//queueName coming from parameter
          int count = this.jmsTemplate.browse(queueName, new BrowserCallback<Integer>() {
              public Integer doInJms(final Session session, final QueueBrowser browser) throws JMSException {
                  Enumeration enumeration = browser.getEnumeration();
                  int counter = 0;
                  while (enumeration.hasMoreElements()) {
                      Message msg = (Message) enumeration.nextElement();
  
  //tried setting message properties, but failed..
                                 /*msg.setBooleanProperty("readOnlyProperties", false);
                                      msg.setBooleanProperty("readOnlyBody", false);
                                      msg.setBooleanProperty("droppable", true);*/
  
  
  //tried getting message properties.. but only received 1 property i.e. _type                    
  Enumeration<String> enumr = msg.getPropertyNames();
                      while(enumr.hasMoreElements()) {
                          String name = enumr.nextElement();
                          String value = msg.getStringProperty(name);
                          System.out.println("==>   "+name+" : "+value);//==>   _type : com.crm.jms.SampleObject
                      }
                      try {
                          // queue.moveMessageTo(msg.getJMSMessageID(), "temp_queue");
                          System.out.println("--"+msg.getJMSMessageID());//able to get message ID
                          queue.removeMessage(msg.getJMSMessageID());// exception
                      }catch(Exception ex) {
                          ex.printStackTrace();
                      }
                      System.out.println(String.format("\tFound : %s", msg)); //output for this line mentioned below..
                      counter += 1;
                  }
                  return counter;
              }
          });
          queue.purge(); // exception
      }catch(Exception ex) {
          ex.printStackTrace();
      }
  

  output

  output to System.out.println(String.format("\tFound : %s", msg)); is :

  Found : ActiveMQTextMessage {commandId = 5, responseRequired = true, messageId = ID:CRM-PC-50101-1528866712471-1:1:1:1:1, originalDestination = null, originalTransactionId = null, producerId = ID:CRM-PC-50101-1528866712471-1:1:1:1, destination = queue://testNexus, transactionId = null, expiration = 0, timestamp = 1528866713408, arrival = 0, brokerInTime = 1528866713410, brokerOutTime = 1529047482640, correlationId = null, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = org.apache.activemq.util.ByteSequence@12b82970, marshalledProperties = org.apache.activemq.util.ByteSequence@49abe550, dataStructure = null, redeliveryCounter = 0, size = 0, properties = {_type=com.crm.jms.SampleObject}, readOnlyProperties = true, readOnlyBody = true, droppable = false, jmsXGroupFirstForConsumer = false, text = {"msg":"hello world"}}
  

  final output console

  ==>   _type : com.crm.jms.SampleObject
  --ID:Crm-PC-50101-1528866712471-1:1:1:1:1
  java.lang.NullPointerException
      at com.crm.jms.controller.QueueController$1.doInJms(QueueController.java:171)
      at com.crm.jms.controller.QueueController$1.doInJms(QueueController.java:1)
      at org.springframework.jms.core.JmsTemplate$14.doInJms(JmsTemplate.java:1033)
      at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:484)
      at org.springframework.jms.core.JmsTemplate.browseSelected(JmsTemplate.java:1027)
      at org.springframework.jms.core.JmsTemplate.browse(JmsTemplate.java:989)
      at com.crm.jms.controller.QueueController.deleteQueue(QueueController.java:153)
      at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
      at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
      at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
      at java.lang.reflect.Method.invoke(Method.java:498)
  .
  .
  .
  .
      Found : ActiveMQTextMessage {commandId = 5, responseRequired = true, messageId = ID:Crm-PC-50101-1528866712471-1:1:1:1:1, originalDestination = null, originalTransactionId = null, producerId = ID:Crm-PC-50101-1528866712471-1:1:1:1, destination = queue://testNexus, transactionId = null, expiration = 0, timestamp = 1528866713408, arrival = 0, brokerInTime = 1528866713410, brokerOutTime = 1529049245130, correlationId = null, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = org.apache.activemq.util.ByteSequence@5b55f70f, marshalledProperties = org.apache.activemq.util.ByteSequence@3e116ae6, dataStructure = null, redeliveryCounter = 0, size = 0, properties = {_type=com.crm.jms.SampleObject}, readOnlyProperties = true, readOnlyBody = true, droppable = false, jmsXGroupFirstForConsumer = false, text = {"msg":"hello world"}}
  java.lang.NullPointerException
      at com.crm.jms.controller.QueueController.deleteQueue(QueueController.java:181)
      at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
      at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
      at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
      at java.lang.reflect.Method.invoke(Method.java:498)
      at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205)
      at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:133)
      at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:97)
      at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:827)
      at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:738)
      at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:85)
  .
  .
  .
  .