aboutsummaryrefslogtreecommitdiff
path: root/src/com/juick/jabber/ws/XMPPConnection.java
diff options
context:
space:
mode:
authorGravatar Ugnich Anton2014-08-05 04:51:57 +0700
committerGravatar Ugnich Anton2014-08-05 04:51:57 +0700
commit694bc7b9dd4f3e7d0a918ddb2327dbb676fc6465 (patch)
treeedf774001a748d236e39cd378a3dfaba47f754a7 /src/com/juick/jabber/ws/XMPPConnection.java
parentb86eb130ef8a1b06a34454a47738e0a8ba9b50dd (diff)
bugfix (messages sent to subscribers)
Diffstat (limited to 'src/com/juick/jabber/ws/XMPPConnection.java')
-rw-r--r--src/com/juick/jabber/ws/XMPPConnection.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/com/juick/jabber/ws/XMPPConnection.java b/src/com/juick/jabber/ws/XMPPConnection.java
index b85c8bee..39815da5 100644
--- a/src/com/juick/jabber/ws/XMPPConnection.java
+++ b/src/com/juick/jabber/ws/XMPPConnection.java
@@ -86,7 +86,7 @@ public class XMPPConnection implements Runnable, Stream.StreamListener, Message.
synchronized (Main.clients) {
for (Iterator<SocketSubscribed> i = Main.clients.iterator(); i.hasNext();) {
SocketSubscribed s = i.next();
- if (s.VUID == uid_to) {
+ if (s.VUID == uid_to && s.MID == 0 && s.allMessages == false && s.allReplies == false) {
if (!s.sendByteBuffer(bbMsg)) {
i.remove();
}
@@ -122,7 +122,7 @@ public class XMPPConnection implements Runnable, Stream.StreamListener, Message.
synchronized (Main.clients) {
for (Iterator<SocketSubscribed> i = Main.clients.iterator(); i.hasNext();) {
SocketSubscribed s = i.next();
- if ((jmsg.Privacy >= 0 && (s.allMessages || s.UID == jmsg.User.UID)) || uids.contains(s.VUID)) {
+ if (s.MID == 0 && s.allReplies == false && ((jmsg.Privacy >= 0 && (s.allMessages || s.UID == jmsg.User.UID)) || uids.contains(s.VUID))) {
if (!s.sendByteBuffer(bbMsg)) {
i.remove();
}