anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Minor, just code layout

Browse Source
This commit is contained in:
andsel
2016-12-13 23:43:01 +01:00
parent 296af8b4f6
commit c62f549176
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java
+10 -10
View File
@@ -474,16 +474,6 @@ public class ProtocolProcessor {
m_interceptor.notifyTopicPublished(msg, clientID, username);
}
private boolean checkWriteOnTopic(String topic, Channel channel) {
String clientID = NettyUtils.clientID(channel);
String username = NettyUtils.userName(channel);
if (!m_authorizator.canWrite(topic, username, clientID)) {
LOG.debug("topic {} doesn't have write credentials", topic);
return true;
}
return false;
}
private void receivedPublishQos1(Channel channel, PublishMessage msg) {
//verify if topic can be write
final String topic = msg.getTopicName();
@@ -552,6 +542,16 @@ public class ProtocolProcessor {
m_interceptor.notifyTopicPublished(msg, clientID, username);
}
private boolean checkWriteOnTopic(String topic, Channel channel) {
String clientID = NettyUtils.clientID(channel);
String username = NettyUtils.userName(channel);
if (!m_authorizator.canWrite(topic, username, clientID)) {
LOG.debug("topic {} doesn't have write credentials", topic);
return true;
}
return false;
}
/**
* Intended usage is only for embedded versions of the broker, where the hosting application want to use the
* broker to send a publish message.