Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Added default id generator to GenericMessage.

Browse Source
This commit is contained in:
Mark Fisher
2008-01-07 18:18:58 +00:00
parent 680fe066b9
commit 9278dd1f50
1 changed files with 23 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
spring-integration-core/src/main/java/org/springframework/integration/message/GenericMessage.java
View File

@@ -19,6 +19,8 @@ package org.springframework.integration.message;
import java.util.concurrent.locks.ReentrantLock;
import org.springframework.integration.SystemInterruptedException;
import org.springframework.integration.util.RandomGuidUidGenerator;
import org.springframework.integration.util.UidGenerator;
import org.springframework.util.Assert;
/**
@@ -34,9 +36,17 @@ public class GenericMessage<T> implements Message<T> {
private T payload;
private UidGenerator defaultUidGenerator = new RandomGuidUidGenerator();
private ReentrantLock lock;
/**
* Create a new message with the given id and payload.
*
* @param id unique identifier for this message
* @param payload the message payload
*/
public GenericMessage(Object id, T payload) {
Assert.notNull(id, "id must not be null");
Assert.notNull(payload, "payload must not be null");
@@ -44,6 +54,19 @@ public class GenericMessage<T> implements Message<T> {
this.payload = payload;
}
/**
* Create a new message with the given payload. The id will be generated by
* the default {@link UidGenerator} strategy.
*
* @param payload the message payload
*/
public GenericMessage(T payload) {
Assert.notNull(payload, "payload must not be null");
this.id = this.defaultUidGenerator.generateUid();
this.payload = payload;
}
public Object getId() {
return this.id;
}