Java 类org.jivesoftware.smackx.packet.DelayInfo 实例源码

项目：maven-yaxim 文件：SmackableImp.java

public void sendOfflineMessages() {
    Cursor cursor = mContentResolver.query(ChatProvider.CONTENT_URI,
            SEND_OFFLINE_PROJECTION, SEND_OFFLINE_SELECTION,
            null, null);
    final int      _ID_COL = cursor.getColumnIndexOrThrow(ChatConstants._ID);
    final int      JID_COL = cursor.getColumnIndexOrThrow(ChatConstants.JID);
    final int      MSG_COL = cursor.getColumnIndexOrThrow(ChatConstants.MESSAGE);
    final int       TS_COL = cursor.getColumnIndexOrThrow(ChatConstants.DATE);
    final int PACKETID_COL = cursor.getColumnIndexOrThrow(ChatConstants.PACKET_ID);
    ContentValues mark_sent = new ContentValues();
    mark_sent.put(ChatConstants.DELIVERY_STATUS, ChatConstants.DS_SENT_OR_READ);
    while (cursor.moveToNext()) {
        int _id = cursor.getInt(_ID_COL);
        String toJID = cursor.getString(JID_COL);
        String message = cursor.getString(MSG_COL);
        String packetID = cursor.getString(PACKETID_COL);
        long ts = cursor.getLong(TS_COL);
        Log.d(TAG, "sendOfflineMessages: " + toJID + " > " + message);
        final Message newMessage = new Message(toJID, Message.Type.chat);
        newMessage.setBody(message);
        DelayInformation delay = new DelayInformation(new Date(ts));
        newMessage.addExtension(delay);
        newMessage.addExtension(new DelayInfo(delay));
        newMessage.addExtension(new DeliveryReceiptRequest());
        if ((packetID != null) && (packetID.length() > 0)) {
            newMessage.setPacketID(packetID);
        } else {
            packetID = newMessage.getPacketID();
            mark_sent.put(ChatConstants.PACKET_ID, packetID);
        }
        Uri rowuri = Uri.parse("content://" + ChatProvider.AUTHORITY
            + "/" + ChatProvider.TABLE_NAME + "/" + _id);
        mContentResolver.update(rowuri, mark_sent,
                    null, null);
        mXMPPConnection.sendPacket(newMessage);     // must be after marking delivered, otherwise it may override the SendFailListener
    }
    cursor.close();
}

项目：EIM 文件：DelayInfoProvider.java

@Override
public PacketExtension parseExtension(XmlPullParser parser) throws Exception
{
    return new DelayInfo((DelayInformation)super.parseExtension(parser));
}

项目：androidPN-client. 文件：DelayInfoProvider.java

@Override
public PacketExtension parseExtension(XmlPullParser parser) throws Exception
{
    return new DelayInfo((DelayInformation)super.parseExtension(parser));
}

项目：XmppTest 文件：SmackImpl.java

/***************** start 发送离线消息 ***********************/
public void sendOfflineMessages() {
    Cursor cursor = mContentResolver.query(ChatProvider.CONTENT_URI,
            SEND_OFFLINE_PROJECTION, SEND_OFFLINE_SELECTION, null, null);// 查询数据库获取离线消息游标
    final int _ID_COL = cursor.getColumnIndexOrThrow(ChatConstants._ID);
    final int JID_COL = cursor.getColumnIndexOrThrow(ChatConstants.JID);
    final int MSG_COL = cursor.getColumnIndexOrThrow(ChatConstants.MESSAGE);
    final int TS_COL = cursor.getColumnIndexOrThrow(ChatConstants.DATE);
    final int PACKETID_COL = cursor
            .getColumnIndexOrThrow(ChatConstants.PACKET_ID);
    ContentValues mark_sent = new ContentValues();
    mark_sent.put(ChatConstants.DELIVERY_STATUS,
            ChatConstants.DS_SENT_OR_READ);
    while (cursor.moveToNext()) {// 遍历之后将离线消息发出
        int _id = cursor.getInt(_ID_COL);
        String toJID = cursor.getString(JID_COL);
        String message = cursor.getString(MSG_COL);
        String packetID = cursor.getString(PACKETID_COL);
        long ts = cursor.getLong(TS_COL);
        L.d("sendOfflineMessages: " + toJID + " > " + message);
        final Message newMessage = new Message(toJID, Message.Type.chat);
        newMessage.setBody(message);
        DelayInformation delay = new DelayInformation(new Date(ts));
        newMessage.addExtension(delay);
        newMessage.addExtension(new DelayInfo(delay));
        newMessage.addExtension(new DeliveryReceiptRequest());
        if ((packetID != null) && (packetID.length() > 0)) {
            newMessage.setPacketID(packetID);
        } else {
            packetID = newMessage.getPacketID();
            mark_sent.put(ChatConstants.PACKET_ID, packetID);
        }
        Uri rowuri = Uri.parse("content://" + ChatProvider.AUTHORITY + "/"
                + ChatProvider.TABLE_NAME + "/" + _id);
        // 将消息标记为已发送再调用发送，因为，假设此消息又未发送成功，有SendFailListener重新标记消息
        mContentResolver.update(rowuri, mark_sent, null, null);
        mXMPPConnection.sendPacket(newMessage); // must be after marking
                                                // delivered, otherwise it
                                                // may override the
                                                // SendFailListener
    }
    cursor.close();
}

项目：xmppsupport_v2 文件：DelayInfoProvider.java

@Override
public PacketExtension parseExtension(XmlPullParser parser)
        throws Exception {
    return new DelayInfo((DelayInformation) super.parseExtension(parser));
}

项目：smartedu 文件：SmackImpl.java

/***************** start 发送离线消息 ***********************/
public void sendOfflineMessages() {
    Cursor cursor = mContentResolver.query(ChatProvider.CONTENT_URI,
            SEND_OFFLINE_PROJECTION, SEND_OFFLINE_SELECTION, null, null);// 查询数据库获取离线消息游标
    final int _ID_COL = cursor.getColumnIndexOrThrow(ChatConstants._ID);
    final int JID_COL = cursor.getColumnIndexOrThrow(ChatConstants.JID);
    final int MSG_COL = cursor.getColumnIndexOrThrow(ChatConstants.MESSAGE);
    final int TS_COL = cursor.getColumnIndexOrThrow(ChatConstants.DATE);
    final int PACKETID_COL = cursor
            .getColumnIndexOrThrow(ChatConstants.PACKET_ID);
    ContentValues mark_sent = new ContentValues();
    mark_sent.put(ChatConstants.DELIVERY_STATUS,
            ChatConstants.DS_SENT_OR_READ);
    while (cursor.moveToNext()) {// 遍历之后将离线消息发出
        int _id = cursor.getInt(_ID_COL);
        String toJID = cursor.getString(JID_COL);
        String message = cursor.getString(MSG_COL);
        String packetID = cursor.getString(PACKETID_COL);
        long ts = cursor.getLong(TS_COL);
        AppLogger.d("sendOfflineMessages: " + toJID + " > " + message);
        final Message newMessage = new Message(toJID, Message.Type.chat);
        newMessage.setBody(message);
        DelayInformation delay = new DelayInformation(new Date(ts));
        newMessage.addExtension(delay);
        newMessage.addExtension(new DelayInfo(delay));
        newMessage.addExtension(new DeliveryReceiptRequest());
        if ((packetID != null) && (packetID.length() > 0)) {
            newMessage.setPacketID(packetID);
        } else {
            packetID = newMessage.getPacketID();
            mark_sent.put(ChatConstants.PACKET_ID, packetID);
        }
        Uri rowuri = Uri.parse("content://" + ChatProvider.AUTHORITY + "/"
                + ChatProvider.TABLE_NAME + "/" + _id);
        // 将消息标记为已发送再调用发送，因为，假设此消息又未发送成功，有SendFailListener重新标记消息
        mContentResolver.update(rowuri, mark_sent, null, null);
        mXMPPConnection.sendPacket(newMessage); // must be after marking
                                                // delivered, otherwise it
                                                // may override the
                                                // SendFailListener
    }
    cursor.close();
}

项目：java-bells 文件：DelayInfoProvider.java

@Override
public PacketExtension parseExtension(XmlPullParser parser) throws Exception
{
    return new DelayInfo((DelayInformation)super.parseExtension(parser));
}

项目：telegraph 文件：DelayInfoProvider.java

@Override
public PacketExtension parseExtension(XmlPullParser parser) throws Exception
{
    return new DelayInfo((DelayInformation)super.parseExtension(parser));
}

项目：NewCommunication-Android 文件：DelayInfoProvider.java

@Override
public PacketExtension parseExtension(XmlPullParser parser) throws Exception
{
    return new DelayInfo((DelayInformation)super.parseExtension(parser));
}

项目：androidPN-client. 文件：Forwarded.java

/**
 * Creates a new Forwarded packet extension.
 *
 * @param delay an optional {@link DelayInfo} timestamp of the packet.
 * @param fwdPacket the packet that is forwarded (required).
 */
public Forwarded(DelayInfo delay, Packet fwdPacket) {
    this.delay = delay;
    this.forwardedPacket = fwdPacket;
}

项目：androidPN-client. 文件：Forwarded.java

/**
 * get the timestamp of the forwarded packet.
 *
 * @return the {@link DelayInfo} representing the time when the original packet was sent. May be null.
 */
public DelayInfo getDelayInfo() {
    return delay;
}