Examples of org.jivesoftware.smack.Chat.sendMessage()

org.jivesoftware.smack.Chat.sendMessage()
Sends the specified text as a message to the other chat participant. This is a convenience method for:
```
 Message message = chat.createMessage(); message.setBody(messageText); chat.sendMessage(message); 
```
@param text the text to send. @throws XMPPException if sending the message fails.

        for (int i = 0; i < 10; i++) {
            System.out.println("Sending message: " + i);
            Message message = new Message("consumer");
            message.setType(Message.Type.chat);
            message.setBody("Hello from producer, message # " + i);
            chat.sendMessage(message);
        }


        System.out.println("Sent all messages!");
        Thread.sleep(sleepTime);
        System.out.println("Consumer received - " + listener1.getMessageCount());

View Full Code Here

            endpoint.getBinding().populateXmppMessage(message, exchange);


            if (LOG.isDebugEnabled()) {
                LOG.debug("Sending XMPP message to " + endpoint.getParticipant() + " from " + endpoint.getUser() + " : " + message.getBody());
            }
            chat.sendMessage(message);
        } catch (XMPPException xmppe) {
            throw new RuntimeExchangeException("Cannot send XMPP message: to " + endpoint.getParticipant() + " from " + endpoint.getUser() + " : " + message
                    + " to: " + XmppEndpoint.getConnectionMessage(connection), exchange, xmppe);
        } catch (Exception e) {
            throw new RuntimeExchangeException("Cannot send XMPP message to " + endpoint.getParticipant() + " from " + endpoint.getUser() + " : " + message

View Full Code Here

        PacketFilter filter = new PacketTypeFilter(message.getClass());        
        xmppClientSidePacketListener = new XMPPClientSidePacketListener(msgCtx);
        xmppConnection.addPacketListener(xmppClientSidePacketListener,filter);
      }      


      chat.sendMessage(message);
      log.debug("Sent message :"+message.toXML());


      //If this is on client side, wait for the response from server.
      //Is this the best way to do this?
      if(waitForResponse && !msgCtx.isServerSide()){

View Full Code Here

        //initialize the chat manager using connection
        ChatManager chatManager = xmppConnection.getChatManager();
        Chat chat = chatManager.createChat(xmppOutTransportInfo.getDestinationAccount(), null);        
        try{         
           message.setBody(responseMsg);    
          chat.sendMessage(message);
          log.debug("Sent message :"+message.toXML());
        } catch (XMPPException e) {
          XMPPSender.handleException("Error occurred while sending the message : "+message.toXML(),e);
        }
        }

View Full Code Here

        key = UUID.randomUUID().toString();
        xmppClientSidePacketListener.listenForResponse(key, msgCtx);
        message.setProperty(XMPPConstants.SEQUENCE_ID, key);
      }      


      chat.sendMessage(message);
      log.debug("Sent message :"+message.toXML());


      //If this is on client side, wait for the response from server.
      //Is this the best way to do this?
      if(waitForResponse && !msgCtx.isServerSide()){

View Full Code Here

        Chat chat = chatManager.createChat(xmppOutTransportInfo.getDestinationAccount(), null);        
        try{         
            message.setProperty(XMPPConstants.SEQUENCE_ID, 
                    xmppOutTransportInfo.getSequenceID());
           message.setBody(responseMsg);    
          chat.sendMessage(message);
          log.debug("Sent message :"+message.toXML());
        } catch (XMPPException e) {
          XMPPSender.handleException("Error occurred while sending the message : "+message.toXML(),e);
        }
        }

View Full Code Here

            logger.debug("Will send chat message to \"" + recipient + "\" with payload \"" + payload + "\"");
        }


        Chat chat = chatWith(recipient);
        Message message = buildMessage(Message.Type.chat, recipient, payload);
        chat.sendMessage(message);
    }
    
    private Chat chatWith(String recipient)
    {
        Chat chat = chats.get(recipient);

View Full Code Here

        PacketFilter filter = new PacketTypeFilter(message.getClass());        
        xmppClientSidePacketListener = new XMPPClientSidePacketListener(msgCtx);
        xmppConnection.addPacketListener(xmppClientSidePacketListener,filter);
      }      


      chat.sendMessage(message);
      log.debug("Sent message :"+message.toXML());


      //If this is on client side, wait for the response from server.
      //Is this the best way to do this?
      if(waitForResponse && !msgCtx.isServerSide()){

View Full Code Here

        try {
            Thread.sleep(500);


            // User1 sends some messages to User2 which is not available at the moment
            Chat chat = getConnection(0).getChatManager().createChat(getBareJID(1), null);
            chat.sendMessage("Test 1");
            chat.sendMessage("Test 2");


            Thread.sleep(500);


            // User2 checks the number of offline messages

View Full Code Here

            Thread.sleep(500);


            // User1 sends some messages to User2 which is not available at the moment
            Chat chat = getConnection(0).getChatManager().createChat(getBareJID(1), null);
            chat.sendMessage("Test 1");
            chat.sendMessage("Test 2");


            Thread.sleep(500);


            // User2 checks the number of offline messages
            OfflineMessageManager offlineManager = new OfflineMessageManager(getConnection(1));

View Full Code Here

0 1 2 3 4 5 6 7

TOP

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.