Package org.jivesoftware.smack

Examples of org.jivesoftware.smack.XMPPConnection.connect()

56
57
58
59
60
61
62
63
64
65
66
        // config.setDebuggerEnabled(true);

        try {
            // SmackConfiguration.setPacketReplyTimeout(1000);
            XMPPConnection con = new XMPPConnection(config);
            con.connect();
            con.login("amq-user", "amq-pwd");
            ChatManager chatManager = con.getChatManager();
            Chat chat = chatManager.createChat("test@localhost", new MessageListener() {
                public void processMessage(Chat chat, Message message) {
                    LOG.info("Got XMPP message from chat " + chat.getParticipant() + " message - " + message.getBody());
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
    public void testChat() throws Exception {
        ConnectionConfiguration config = new ConnectionConfiguration("localhost", 61222);
        //config.setDebuggerEnabled(true);

        XMPPConnection consumerCon = new XMPPConnection(config);
        consumerCon.connect();
        consumerCon.login("consumer", "consumer");
        consumerCon.addPacketListener(new XmppLogger("CONSUMER INBOUND"), new PacketFilter() {
            public boolean accept(Packet packet) {
                return true;
            }
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
                chat.addMessageListener(listener);
            }
        });

        XMPPConnection producerCon = new XMPPConnection(config);
        producerCon.connect();
        producerCon.login("producer", "producer");
        producerCon.addPacketListener(new XmppLogger("PRODUCER INBOUND"), new PacketFilter() {
            public boolean accept(Packet packet) {
                return true;
            }
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
    long connectionHandle = ((IntegerValue) args[0].itemAt(0)).getLong();
    XMPPConnection connection = XMPPModule.retrieveConnection(connectionHandle);

    try
    {
      connection.connect();
      return BooleanValue.TRUE;
     
    } catch (XMPPException e) {
      return BooleanValue.FALSE;
    }
View Full Code Here
246
247
248
249
250
251
252
253
254
255
256
            }
        } else {
            connection = new XMPPConnection(host);
        }

        connection.connect();

        if (login && !connection.isAuthenticated()) {
            if (user != null) {
                LOG.info("Logging in to XMPP as user: " + user + " on connection: " + connection);
                if (password == null) {
View Full Code Here
110
111
112
113
114
115
116
117
118
119
120
            }
        } else {
            connection = new XMPPConnection(host);
        }

        connection.connect();

        if (login && !connection.isAuthenticated()) {
            if (user != null) {
                if (LOG.isDebugEnabled()) {
                    LOG.debug("Logging in to XMPP as user: " + user + " on connection: " + getConnectionMessage(connection));
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
        // config.setDebuggerEnabled(true);

        try {
            // SmackConfiguration.setPacketReplyTimeout(1000);
            XMPPConnection con = new XMPPConnection(config);
            con.connect();
            con.login("amq-user", "amq-pwd");
            Chat chat = con.getChatManager().createChat("test@localhost",
                new MessageListener() {
                    public void processMessage(Chat chat, Message message) {
                        //
View Full Code Here
121
122
123
124
125
126
127
128
129
130
131
            }
        } else {
            connection = new XMPPConnection(host);
        }

        connection.connect();

        if (login && !connection.isAuthenticated()) {
            if (user != null) {
                if (LOG.isDebugEnabled()) {
                    LOG.debug("Logging in to XMPP as user: " + user + " on connection: " + getConnectionMessage(connection));
View Full Code Here
28
29
30
31
32
33
34
35
36
37
38
    if(!p.load()) {
      return;
    }
   
    XMPPConnection connection = new XMPPConnection(p.fJabberServer);
    connection.connect();
    connection.login(p.fJabberLogin, p.fJabberPassword);
    final Chat chat = connection.getChatManager().createChat(p.fJabberAdmin, new MessageListener() {

        public void processMessage(Chat chat, Message message) {
            System.out.println("Received message: " + message.getThread() + " " + message.getBody());
View Full Code Here
80
81
82
83
84
85
86
87
88
89
90
             connection = new XMPPConnection(conf);
           } else {
             connection = new XMPPConnection(service);
           }

           connection.connect();
           System.out.println("Connected to " + connection.getHost());

        } catch (XMPPException ex) {
            Logger.getLogger(JabberWorkItemHandler.class.getName()).log(Level.SEVERE, null, ex);
            System.out.println("Failed to connect to " + connection.getHost());
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.