Announcement Announcement Module
Collapse
No announcement yet.
Exception in directchannel - messageendpoint freeze execution Page Title Module
Move Remove Collapse
X
Conversation Detail Module
Collapse
  • Filter
  • Time
  • Show
Clear All
new posts

  • Exception in directchannel - messageendpoint freeze execution

    Hi folks!

    I have this scenario:

    A message arrive at a messageendpoint, gets processed, then a new messaget is sent to a directchannel.

    Code:
    @ServiceActivator(inputChannel = "fileInput")
    	public void split(Message<File> message) {
    
    ...
    //for loop goes here {
    ...
    
    somechannel.send(MessageBuilder.from(payload).build());
    ...
    // }
    }
    the message endpoint at the destination directchannel starts to process the submessage, then throws a exception, handled as usual.

    Code:
    @ServiceActivator(inputChannel="somechannel")
    	public void parse(Message<List<String>> message) {
    ...
    // do stuff
    catch (BusinessException be){
     // log it
    }
    ...
    }
    I've getting the strange behavior of the sender thread being blocked, and stuck at send() method, even if the messageendpoint finished its task.

    I dont have any "printStackTrace()" exception method being called on my code, but someone between my code and the SI code are calling it, showing the stack of a catched exception!

    Any ideas?
    Last edited by qmx; Dec 9th, 2008, 01:10 PM.

  • #2
    Hi, I just discovered that "sith happens"

    The queue channel type just don't warn when you don't have a endpoint on it.

    When the return queue filled up, the BlockingQueue will block!

    one more lesson learned

    Cheers

    Comment

    Working...
    X