org.springframework.util.AlternativeJdkIdGenerator#org.springframework.messaging.support.IdTimestampMessageHeaderInitializer源码实例Demo

下面列出了org.springframework.util.AlternativeJdkIdGenerator#org.springframework.messaging.support.IdTimestampMessageHeaderInitializer 实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。

@Test
public void messageIdAndTimestampEnabled() {
	IdTimestampMessageHeaderInitializer headerInitializer = new IdTimestampMessageHeaderInitializer();
	headerInitializer.setIdGenerator(new AlternativeJdkIdGenerator());
	headerInitializer.setEnableTimestamp(true);

	StompHeaderAccessor headerAccessor = StompHeaderAccessor.create(StompCommand.SEND);
	headerInitializer.initHeaders(headerAccessor);

	assertNotNull(headerAccessor.getMessageHeaders().getId());
	assertNotNull(headerAccessor.getMessageHeaders().getTimestamp());
}
 
@Test
public void messageIdAndTimestampEnabled() {
	IdTimestampMessageHeaderInitializer headerInitializer = new IdTimestampMessageHeaderInitializer();
	headerInitializer.setIdGenerator(new AlternativeJdkIdGenerator());
	headerInitializer.setEnableTimestamp(true);

	StompHeaderAccessor headerAccessor = StompHeaderAccessor.create(StompCommand.SEND);
	headerInitializer.initHeaders(headerAccessor);

	assertNotNull(headerAccessor.getMessageHeaders().getId());
	assertNotNull(headerAccessor.getMessageHeaders().getTimestamp());
}
 
@Test
public void messageIdAndTimestampEnabled() {
	IdTimestampMessageHeaderInitializer headerInitializer = new IdTimestampMessageHeaderInitializer();
	headerInitializer.setIdGenerator(new AlternativeJdkIdGenerator());
	headerInitializer.setEnableTimestamp(true);

	StompHeaderAccessor headerAccessor = StompHeaderAccessor.create(StompCommand.SEND);
	headerInitializer.initHeaders(headerAccessor);

	assertNotNull(headerAccessor.getMessageHeaders().getId());
	assertNotNull(headerAccessor.getMessageHeaders().getTimestamp());
}