@@ -33,7 +33,7 @@ public final class PluginMessageListenerRegistration {
|
||||
|
||||
/**
|
||||
* Gets the plugin channel that this registration is about.
|
||||
*
|
||||
*
|
||||
* @return Plugin channel.
|
||||
*/
|
||||
public String getChannel() {
|
||||
|
||||
@@ -362,7 +362,7 @@ public class StandardMessenger implements Messenger {
|
||||
|
||||
synchronized (incomingLock) {
|
||||
Set<PluginMessageListenerRegistration> registrations = incomingByPlugin.get(registration.getPlugin());
|
||||
|
||||
|
||||
if (registrations != null) {
|
||||
return registrations.contains(registration);
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user