class SenderService {
	private final static String TEST_OUT = "test-out-0";

	@Resource
	private StreamBridge streamBridge;

	/**
	 * 发送字符消息
	 */
	public void send(String msg) {
		streamBridge.send(TEST_OUT, MessageBuilder.withPayload(msg).build());
	}

	/**
	 * 发送带tag的对象消息
	 */
	public <T> void sendWithTags(T msg, String tag) {<FILL_FUNCTION_BODY>}
}

		Message<T> message = MessageBuilder.withPayload(msg)
				.setHeader(MessageConst.PROPERTY_TAGS, tag)
				.setHeader(MessageHeaders.CONTENT_TYPE, MimeTypeUtils.APPLICATION_JSON)
				.build();
		streamBridge.send(TEST_OUT, message);
	
<no_super_class>