return Message.class.isAssignableFrom(paramType);
}
@Override
public void handleReturnValue(Object returnValue, MethodParameter returnType, Message<?> message)
throws Exception {
<BUG>Assert.notNull(this.clientChannel, "No clientChannel to send messages to");
if (message == null) {</BUG>
return;
}
PubSubHeaderAccesssor headers = PubSubHeaderAccesssor.wrap(message);

return Message.class.isAssignableFrom(paramType);
}
@Override
public void handleReturnValue(Object returnValue, MethodParameter returnType, Message<?> message)
throws Exception {
Assert.notNull(this.clientChannel, "No clientChannel to send messages to");
Message<?> returnMessage = (Message<?>) returnValue;
if (message == null) {
return;
}
PubSubHeaderAccesssor headers = PubSubHeaderAccesssor.wrap(message);
