switch message with channel on the low level publish
This commit is contained in:
@@ -43,11 +43,11 @@ public interface RedisPubSubCommands {
|
||||
/**
|
||||
* Publishes the given message to the given channel.
|
||||
*
|
||||
* @param message message to publish
|
||||
* @param channel the channel to publish to
|
||||
* @param message message to publish
|
||||
* @return the number of clients that received the message
|
||||
*/
|
||||
Long publish(byte[] message, byte[] channel);
|
||||
Long publish(byte[] channel, byte[] message);
|
||||
|
||||
/**
|
||||
* Subscribes the connection to the given channels.
|
||||
|
||||
@@ -1609,7 +1609,7 @@ public class JedisConnection implements RedisConnection {
|
||||
// Pub/Sub functionality
|
||||
//
|
||||
@Override
|
||||
public Long publish(byte[] message, byte[] channel) {
|
||||
public Long publish(byte[] channel, byte[] message) {
|
||||
try {
|
||||
if (isQueueing()) {
|
||||
throw new UnsupportedOperationException();
|
||||
|
||||
@@ -1058,7 +1058,7 @@ public class JredisConnection implements RedisConnection {
|
||||
}
|
||||
|
||||
@Override
|
||||
public Long publish(byte[] message, byte[] channel) {
|
||||
public Long publish(byte[] channel, byte[] message) {
|
||||
throw new UnsupportedOperationException();
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user