如何对Spring IntegrationFlow进行单元测试？

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.integration.dsl.IntegrationFlow;
import org.springframework.integration.test.util.TestUtils;
import org.springframework.messaging.Message;
import org.springframework.messaging.support.GenericMessage;
import org.springframework.test.context.junit4.SpringRunner;

import static org.junit.Assert.assertEquals;

@RunWith(SpringRunner.class)
@SpringBootTest
public class IntegrationFlowTest {

    @Autowired
    private IntegrationFlow integrationFlow;

    @Test
    public void testIntegrationFlow() {
        // 准备测试数据
        String input = "test message";
        Message<String> message = new GenericMessage<>(input);

        // 执行测试
        TestUtils.sendAndReceive(integrationFlow.getInputChannel(), message);

        // 验证结果
        // TODO: 根据实际情况进行断言验证
        // assertEquals(expectedOutput, actualOutput);
    }
}