本文整理了Java中org.jivesoftware.smack.packet.Message.getPacketID()
方法的一些代码示例,展示了Message.getPacketID()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Message.getPacketID()
方法的具体详情如下:
包路径:org.jivesoftware.smack.packet.Message
类名称:Message
方法名:getPacketID
暂无
代码示例来源:origin: org.mobicents.resources/mobicents-slee-ra-xmpp-library
IBBOutputStream(String userID, String sid, int blockSize) {
if (blockSize <= 0) {
throw new IllegalArgumentException("Buffer size <= 0");
}
buffer = new byte[blockSize];
this.userID = userID;
Message template = new Message(userID);
messageID = template.getPacketID();
this.sid = sid;
closePacket = createClosePacket(userID, sid);
}
代码示例来源:origin: org.littleshoot/xmpp
@Override
public void processPacket(final Packet packet) {
final Message msg = (Message) packet;
final String id = msg.getPacketID();
log.info("Checking message ID: {}", id);
if (loggedOut.get()) {
log.warn("Got a message while logged out?");
return;
}
if (sentMessageIds.contains(id)) {
log.warn("Message is from us!!");
// This is a little silly in that we're sending a
// message back to ourselves, but this signals to the
// client thread right away that the invite has failed.
final Message error = newError(msg);
xmppConnection.sendPacket(error);
} else {
exec.execute(new PacketProcessor(msg));
}
}
};
代码示例来源:origin: org.littleshoot/xmpp
@Override
public void processPacket(final Packet packet) {
final Message msg = (Message) packet;
final String id = msg.getPacketID();
log.info("Checking message ID: {}", id);
if (loggedOut.get()) {
log.warn("Got a message while logged out?");
return;
}
if (sentMessageIds.contains(id)) {
log.warn("Message is from us!!");
// This is a little silly in that we're sending a
// message back to ourselves, but this signals to the
// client thread right away that the invite has failed.
final Message error = newError(msg);
xmppConnection.sendPacket(error);
} else {
exec.execute(new PacketProcessor(msg));
}
}
};
代码示例来源:origin: org.mobicents.resources/mobicents-slee-ra-xmpp-library
public String toXML() {
StringBuffer buf = new StringBuffer();
buf.append("<message");
if (getPacketID() != null) {
buf.append(" id=\"").append(getPacketID()).append("\"");
代码示例来源:origin: org.igniterealtime.smack/smackx
public void processPacket(Packet packet) {
Message message = (Message) packet;
MessageEvent messageEvent =
(MessageEvent) message.getExtension("x", "jabber:x:event");
if (messageEvent.isMessageEventRequest()) {
// Fire event for requests of message events
for (Iterator it = messageEvent.getEventTypes(); it.hasNext();)
fireMessageEventRequestListeners(
message.getFrom(),
message.getPacketID(),
((String) it.next()).concat("NotificationRequested"));
} else
// Fire event for notifications of message events
for (Iterator it = messageEvent.getEventTypes(); it.hasNext();)
fireMessageEventNotificationListeners(
message.getFrom(),
messageEvent.getPacketID(),
((String) it.next()).concat("Notification"));
};
代码示例来源:origin: org.mobicents.resources/mobicents-slee-ra-xmpp-library
public void processPacket(Packet packet) {
Message message = (Message) packet;
MessageEvent messageEvent =
(MessageEvent) message.getExtension("x", "jabber:x:event");
if (messageEvent.isMessageEventRequest()) {
// Fire event for requests of message events
for (Iterator it = messageEvent.getEventTypes(); it.hasNext();)
fireMessageEventRequestListeners(
message.getFrom(),
message.getPacketID(),
((String) it.next()).concat("NotificationRequested"));
} else
// Fire event for notifications of message events
for (Iterator it = messageEvent.getEventTypes(); it.hasNext();)
fireMessageEventNotificationListeners(
message.getFrom(),
messageEvent.getPacketID(),
((String) it.next()).concat("Notification"));
};
代码示例来源:origin: tiandawu/IotXmpp
public void processPacket(Packet packet) {
Message message = (Message) packet;
MessageEvent messageEvent =
(MessageEvent) message.getExtension("x", "jabber:x:event");
if (messageEvent.isMessageEventRequest()) {
// Fire event for requests of message events
for (Iterator<String> it = messageEvent.getEventTypes(); it.hasNext();)
fireMessageEventRequestListeners(
message.getFrom(),
message.getPacketID(),
it.next().concat("NotificationRequested"));
} else
// Fire event for notifications of message events
for (Iterator<String> it = messageEvent.getEventTypes(); it.hasNext();)
fireMessageEventNotificationListeners(
message.getFrom(),
messageEvent.getPacketID(),
it.next().concat("Notification"));
};
代码示例来源:origin: org.littleshoot/smack-xmpp-3-2-2
public void processPacket(Packet packet) {
Message message = (Message) packet;
MessageEvent messageEvent =
(MessageEvent) message.getExtension("x", "jabber:x:event");
if (messageEvent.isMessageEventRequest()) {
// Fire event for requests of message events
for (Iterator it = messageEvent.getEventTypes(); it.hasNext();)
fireMessageEventRequestListeners(
message.getFrom(),
message.getPacketID(),
((String) it.next()).concat("NotificationRequested"));
} else
// Fire event for notifications of message events
for (Iterator it = messageEvent.getEventTypes(); it.hasNext();)
fireMessageEventNotificationListeners(
message.getFrom(),
messageEvent.getPacketID(),
((String) it.next()).concat("Notification"));
};
代码示例来源:origin: org.igniterealtime.smack/smack
buf.append(" xml:lang=\"").append(getLanguage()).append("\"");
if (getPacketID() != null) {
buf.append(" id=\"").append(getPacketID()).append("\"");
代码示例来源:origin: org.littleshoot/smack-xmpp-3-2-2
buf.append(" xml:lang=\"").append(getLanguage()).append("\"");
if (getPacketID() != null) {
buf.append(" id=\"").append(getPacketID()).append("\"");
代码示例来源:origin: tiandawu/IotXmpp
buf.append(" xml:lang=\"").append(getLanguage()).append("\"");
if (getPacketID() != null) {
buf.append(" id=\"").append(getPacketID()).append("\"");
代码示例来源:origin: org.mobicents.resources/mobicents-slee-ra-xmpp-library
private void sendCancelMessage(Message message) {
IQ error = FileTransferNegotiator.createIQ(message.getPacketID(), message.getFrom(), message.getTo(),
IQ.Type.ERROR);
error.setError(new XMPPError(504));
connection.sendPacket(error);
}
代码示例来源:origin: org.geoserver.community/gs-wps-remote
+ origin
+ "','"
+ message.getPacketID()
+ "');");
内容来源于网络,如有侵权,请联系作者删除!