Package rocks.xmpp.core.stanza

Examples of rocks.xmpp.core.stanza.MessageListener

49
50
51
52
53
54
55
56
57
58
59
        XmppSession xmppSession1 = new TestXmppSession(ROMEO, mockServer);
        XmppSession xmppSession2 = new TestXmppSession(JULIET, mockServer);

        final boolean[] attentionReceived = {false};
        xmppSession2.addMessageListener(new MessageListener() {
            @Override
            public void handle(MessageEvent e) {
                if (e.isIncoming() && e.getMessage().getExtension(Attention.class) != null && e.getMessage().getType() == AbstractMessage.Type.HEADLINE) {
                    attentionReceived[0] = true;
                    Assert.assertEquals(e.getMessage().getType(), AbstractMessage.Type.HEADLINE);
View Full Code Here
50
51
52
53
54
55
56
57
58
59
60
        XmppSession xmppSession1 = new TestXmppSession(ROMEO, mockServer);
        XmppSession xmppSession2 = new TestXmppSession(JULIET, mockServer);

        final boolean[] attentionReceived = {false};
        xmppSession2.addMessageListener(new MessageListener() {
            @Override
            public void handle(MessageEvent e) {
                if (e.isIncoming() && e.getMessage().getExtension(Attention.class) != null && e.getMessage().getType() == AbstractMessage.Type.HEADLINE) {
                    attentionReceived[0] = true;
                    Assert.assertEquals(e.getMessage().getType(), AbstractMessage.Type.HEADLINE);
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
        MockServer mockServer = new MockServer();

        XmppSession xmppSession1 = new TestXmppSession(ROMEO, mockServer);
        MessageDeliveryReceiptsManager messageDeliveryReceiptsManager1 = xmppSession1.getExtensionManager(MessageDeliveryReceiptsManager.class);
        messageDeliveryReceiptsManager1.setEnabled(true);
        xmppSession1.addMessageListener(new MessageListener() {
            @Override
            public void handle(MessageEvent e) {
                Assert.assertNull(e.getMessage().getExtension(Request.class));
            }
        });
View Full Code Here
132
133
134
135
136
137
138
139
140
141
142
        MockServer mockServer = new MockServer();

        XmppSession xmppSession1 = new TestXmppSession(ROMEO, mockServer);
        MessageDeliveryReceiptsManager messageDeliveryReceiptsManager1 = xmppSession1.getExtensionManager(MessageDeliveryReceiptsManager.class);
        messageDeliveryReceiptsManager1.setEnabled(true);
        xmppSession1.addMessageListener(new MessageListener() {
            @Override
            public void handle(MessageEvent e) {
                Assert.assertNull(e.getMessage().getExtension(Request.class));
            }
        });
View Full Code Here
151
152
153
154
155
156
157
158
159
160
161
    public void testDisabledManager() {
        MockServer mockServer = new MockServer();

        XmppSession xmppSession1 = new TestXmppSession(ROMEO, mockServer);

        xmppSession1.addMessageListener(new MessageListener() {
            @Override
            public void handle(MessageEvent e) {
                Assert.assertNull(e.getMessage().getExtension(Request.class));
            }
        });
View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
                    geoLocationListeners.clear();
                }
            }
        });

        xmppSession.addMessageListener(new MessageListener() {
            @Override
            public void handle(MessageEvent e) {
                if (e.isIncoming() && isEnabled()) {
                    Message message = e.getMessage();
                    Event event = message.getExtension(Event.class);
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
     * @param xmppSession The connection.
     */
    public ChatManager(final XmppSession xmppSession) {
        this.xmppSession = xmppSession;

        xmppSession.addMessageListener(new MessageListener() {
            @Override
            public void handle(MessageEvent e) {
                Message message = e.getMessage();
                if (message.getType() == Message.Type.CHAT && message.getBody() != null && !message.getBody().isEmpty()) {
                    Jid chatPartner = e.isIncoming() ? message.getFrom() : message.getTo();
View Full Code Here
231
232
233
234
235
236
237
238
239
240
241
                        xmppSession.getChatManager().addChatSessionListener(new ChatSessionListener() {
                            @Override
                            public void chatSessionCreated(final ChatSessionEvent chatSessionEvent) {
                                final ChatSession chatSession = chatSessionEvent.getChatSession();

                                chatSession.addMessageListener(new MessageListener() {
                                    @Override
                                    public void handle(final MessageEvent e) {
                                        Platform.runLater(new Runnable() {
                                            @Override
                                            public void run() {
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
                    messageDeliveredListeners.clear();
                    messageFilters.clear();
                }
            }
        });
        xmppSession.addMessageListener(new MessageListener() {
            @Override
            public void handle(MessageEvent e) {
                if (isEnabled()) {
                    Message message = e.getMessage();
View Full Code Here
73
74
75
76
77
78
79
80
81
82
83
                    trustedEntities.clear();
                }
            }
        });

        xmppSession.addMessageListener(new MessageListener() {
            @Override
            public void handle(MessageEvent e) {
                if (e.isIncoming() && isEnabled()) {
                    Message message = e.getMessage();
                    ContactExchange contactExchange = message.getExtension(ContactExchange.class);
View Full Code Here
TOP

Related Classes of rocks.xmpp.core.stanza.MessageListener

  • JavaFXApp
  • rocks.xmpp.core.session.ChatManager
  • rocks.xmpp.extensions.attention.AttentionManagerTest
  • rocks.xmpp.extensions.avatar.AvatarManager
  • rocks.xmpp.extensions.bytestreams.ibb.InBandByteStreamManager
  • rocks.xmpp.extensions.chatstates.ChatStateManager
  • rocks.xmpp.extensions.geoloc.GeoLocationManager
  • rocks.xmpp.extensions.httpauth.HttpAuthenticationManager
  • rocks.xmpp.extensions.muc.MultiUserChatManager
  • rocks.xmpp.extensions.pubsub.PubSubManager
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.