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

+ rename Message#getPayload to Message#getBody

Browse Source
This commit is contained in:
Costin Leau
2011-01-20 17:10:31 +02:00
parent 1a463ff810
commit 8aa1df5a9d
4 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/DefaultMessage.java
View File

@@ -38,7 +38,7 @@ public class DefaultMessage implements Message {
}
@Override
public byte[] getPayload() {
public byte[] getBody() {
return (payload != null ? payload.clone() : null);
}

2
spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/Message.java
View File

@@ -24,7 +24,7 @@ import java.io.Serializable;
*/
public interface Message extends Serializable {
byte[] getPayload();
byte[] getBody();
byte[] getChannel();
}

2
spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/listener/adapter/MessageListenerAdapter.java
View File

@@ -220,7 +220,7 @@ public class MessageListenerAdapter implements MessageListener {
*/
protected Object extractMessage(Message message) {
if (serializer != null) {
return serializer.deserialize(message.getPayload());
return serializer.deserialize(message.getBody());
}
return message;
}

8
spring-data-redis/src/test/java/org/springframework/data/keyvalue/redis/connection/jedis/JedisConnectionIntegrationTests.java
View File

@@ -54,8 +54,8 @@ public class JedisConnectionIntegrationTests extends AbstractConnectionIntegrati
@Override
public void onMessage(Message message, byte[] pattern) {
assertArrayEquals(expectedChannel, message.getChannel());
assertArrayEquals(expectedMessage, message.getPayload());
System.out.println("Received message '" + new String(message.getPayload()) + "'");
assertArrayEquals(expectedMessage, message.getBody());
System.out.println("Received message '" + new String(message.getBody()) + "'");
}
};
@@ -92,8 +92,8 @@ public class JedisConnectionIntegrationTests extends AbstractConnectionIntegrati
@Override
public void onMessage(Message message, byte[] pattern) {
assertArrayEquals(expectedPattern, pattern);
assertArrayEquals(expectedMessage, message.getPayload());
System.out.println("Received message '" + new String(message.getPayload()) + "'");
assertArrayEquals(expectedMessage, message.getBody());
System.out.println("Received message '" + new String(message.getBody()) + "'");
}
};