本文整理汇总了Java中com.google.appengine.api.xmpp.XMPPService类的典型用法代码示例。如果您正苦于以下问题:Java XMPPService类的具体用法?Java XMPPService怎么用?Java XMPPService使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
XMPPService类属于com.google.appengine.api.xmpp包,在下文中一共展示了XMPPService类的13个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: doPost
import com.google.appengine.api.xmpp.XMPPService; //导入依赖的package包/类
@Override
public void doPost(HttpServletRequest req, HttpServletResponse res) throws IOException
{
XMPPService xmpp = XMPPServiceFactory.getXMPPService();
Message message = xmpp.parseMessage( req );
// Split the XMPP address (e.g., [email protected])
// from the resource (e.g., gmail.CD6EBC4A)
String jid = message.getFromJid().getId();
String pseudo = FmgDataStore.getPseudoFromJid( jid );
String body = message.getBody();
ChatMessage chatMessage = new ChatMessage( 0, pseudo, body );
PresenceRoom room = ChannelManager.getRoom( 0 );
Presence presence = room.getPresence( pseudo, 0 );
if( presence == null )
{
// presence of the sender wasn't found in room...
presence = new Presence( pseudo, 0, 0 );
presence.setJabberId( jid );
ChannelManager.connect( presence );
}
ChannelManager.broadcast( room, chatMessage );
}
开发者ID:kroc702,项目名称:fullmetalgalaxy,代码行数:26,代码来源:XMPPMessageServlet.java
示例2: sendXmppMessage
import com.google.appengine.api.xmpp.XMPPService; //导入依赖的package包/类
public static boolean sendXmppMessage(String p_jabberId, ChatMessage p_chatMessage)
{
boolean messageSent = false;
if( p_jabberId != null )
{
JID jid = new JID(p_jabberId);
String msgBody = "[" + p_chatMessage.getFromPseudo() + "] " + p_chatMessage.getText();
Message msg = new MessageBuilder()
.withRecipientJids(jid)
.withBody(msgBody)
.build();
XMPPService xmpp = XMPPServiceFactory.getXMPPService();
SendResponse status = xmpp.sendMessage(msg);
messageSent = (status.getStatusMap().get(jid) == SendResponse.Status.SUCCESS);
}
return messageSent;
}
开发者ID:kroc702,项目名称:fullmetalgalaxy,代码行数:19,代码来源:XMPPMessageServlet.java
示例3: doPost
import com.google.appengine.api.xmpp.XMPPService; //导入依赖的package包/类
public void doPost(HttpServletRequest req, HttpServletResponse res)
throws IOException {
XMPPService xmpp = XMPPServiceFactory.getXMPPService();
Message message = xmpp.parseMessage(req);
JID fromJid = message.getFromJid();
String body = message.getBody();
JID toJid = new JID("[email protected]/arlearn");
//XMPPService xmppService = XMPPServiceFactory.getXMPPService();
xmpp.sendPresence( toJid, PresenceType.AVAILABLE, PresenceShow.NONE, "Dit is mijn status");
Message msg = new MessageBuilder()
.asXml(true)
.withRecipientJids( toJid)
.withBody("Dit is een bericht voor stefaan op android")
.build();
xmpp.sendMessage(msg);
}
开发者ID:WELTEN,项目名称:dojo-ibl,代码行数:21,代码来源:XMPPReceiverServlet.java
示例4: doPost
import com.google.appengine.api.xmpp.XMPPService; //导入依赖的package包/类
public void doPost(HttpServletRequest req, HttpServletResponse res) throws IOException {
XMPPService xmpp = XMPPServiceFactory.getXMPPService();
Message msg = xmpp.parseMessage(req);
JID fromJid = msg.getFromJid();
String body = msg.getBody();
// Unsubscribe, if requested
if (body.startsWith("STOP")) {
MultichannelChatManager.removeSub(fromJid.getId());
} else {
// If they aren't subscribed, subscribe them
if (!MultichannelChatManager.isSubscribed(fromJid.getId())) {
MultichannelChatManager.addSub(fromJid.getId());
}
MultichannelChatManager.sendMessage(body, "xmpp");
}
}
开发者ID:kwhinnery,项目名称:gae-chat,代码行数:19,代码来源:XMPPReceiverServlet.java
示例5: doPost
import com.google.appengine.api.xmpp.XMPPService; //导入依赖的package包/类
@Override
public void doPost(HttpServletRequest req, HttpServletResponse res) throws IOException
{
XMPPService xmppService = XMPPServiceFactory.getXMPPService();
com.google.appengine.api.xmpp.Presence xmppPresence = xmppService.parsePresence(req);
String pseudo = FmgDataStore.getPseudoFromJid( xmppPresence.getFromJid().getId() );
Presence presence = new Presence( pseudo, 0, 0 );
presence.setJabberId( xmppPresence.getFromJid().getId() );
ChannelManager.connect( presence );
}
开发者ID:kroc702,项目名称:fullmetalgalaxy,代码行数:13,代码来源:XMPPAvailableServlet.java
示例6: isPresent
import com.google.appengine.api.xmpp.XMPPService; //导入依赖的package包/类
public static boolean isPresent(String p_jabberId)
{
if( p_jabberId == null )
{
return false;
}
XMPPService xmpp = XMPPServiceFactory.getXMPPService();
return xmpp.getPresence( new JID( p_jabberId ) ).isAvailable();
}
开发者ID:kroc702,项目名称:fullmetalgalaxy,代码行数:10,代码来源:XMPPMessageServlet.java
示例7: doPost
import com.google.appengine.api.xmpp.XMPPService; //导入依赖的package包/类
@Override
public void doPost(HttpServletRequest req, HttpServletResponse res) throws IOException
{
XMPPService xmppService = XMPPServiceFactory.getXMPPService();
com.google.appengine.api.xmpp.Presence xmppPresence = xmppService.parsePresence(req);
String pseudo = FmgDataStore.getPseudoFromJid( xmppPresence.getFromJid().getId() );
// TODO well pseudo is different from JID !
// we should request datastore
Presence fmgPresence = new Presence( pseudo, 0, 0 );
fmgPresence.setJabberId( xmppPresence.getFromJid().getId() );
ChannelManager.disconnect( fmgPresence );
}
开发者ID:kroc702,项目名称:fullmetalgalaxy,代码行数:15,代码来源:XMPPUnavailableServlet.java
示例8: doPost
import com.google.appengine.api.xmpp.XMPPService; //导入依赖的package包/类
@Override
public void doPost(HttpServletRequest req, HttpServletResponse res) throws IOException
{
XMPPService xmppService = XMPPServiceFactory.getXMPPService();
com.google.appengine.api.xmpp.Presence xmppPresence = xmppService.parsePresence(req);
sendPresence(xmppPresence.getFromJid());
}
开发者ID:kroc702,项目名称:fullmetalgalaxy,代码行数:9,代码来源:XMPPProbeServlet.java
示例9: sendPresence
import com.google.appengine.api.xmpp.XMPPService; //导入依赖的package包/类
public static void sendPresence(JID p_jid)
{
PresenceRoom room = ChannelManager.getRoom( 0 );
PresenceType pt = PresenceType.AVAILABLE;
int count = room.countPseudo();
if( count <= 1 )
{
pt = PresenceType.UNAVAILABLE;
}
XMPPService xmppService = XMPPServiceFactory.getXMPPService();
xmppService.sendPresence( p_jid, pt, PresenceShow.NONE, "" + count + " joueurs" );
}
开发者ID:kroc702,项目名称:fullmetalgalaxy,代码行数:13,代码来源:XMPPProbeServlet.java
示例10: doPost
import com.google.appengine.api.xmpp.XMPPService; //导入依赖的package包/类
@Override
public void doPost(HttpServletRequest req, HttpServletResponse res) throws IOException
{
XMPPService xmppService = XMPPServiceFactory.getXMPPService();
Subscription sub = xmppService.parseSubscription(req);
String pseudo = FmgDataStore.getPseudoFromJid( sub.getFromJid().getId() );
// TODO well pseudo is different from JID !
// we should request datastore
Presence fmgPresence = new Presence( pseudo, 0, 0 );
fmgPresence.setJabberId( sub.getFromJid().getId() );
ChannelManager.disconnect( fmgPresence );
}
开发者ID:kroc702,项目名称:fullmetalgalaxy,代码行数:15,代码来源:XMPPUnsuscribeServlet.java
示例11: doPost
import com.google.appengine.api.xmpp.XMPPService; //导入依赖的package包/类
@Override
public void doPost(HttpServletRequest req, HttpServletResponse res) throws IOException
{
XMPPService xmppService = XMPPServiceFactory.getXMPPService();
Subscription sub = xmppService.parseSubscription(req);
String pseudo = FmgDataStore.getPseudoFromJid( sub.getFromJid().getId() );
// TODO well pseudo is different from JID !
// we should request datastore
Presence presence = new Presence( pseudo, 0, 0 );
presence.setJabberId( sub.getFromJid().getId() );
ChannelManager.connect( presence );
}
开发者ID:kroc702,项目名称:fullmetalgalaxy,代码行数:15,代码来源:XMPPSuscribeServlet.java
示例12: doPost
import com.google.appengine.api.xmpp.XMPPService; //导入依赖的package包/类
@Override
protected void doPost(HttpServletRequest req, HttpServletResponse resp)
throws IOException {
XMPPService xmppService = XMPPServiceFactory.getXMPPService();
Message message = xmppService.parseMessage(req);
log.info("Chat received: " + message.getStanza());
Entity entity = new Entity("XmppMsg", "test");
entity.setProperty("type", message.getMessageType().toString());
entity.setProperty("from", message.getFromJid().toString());
entity.setProperty("to", message.getRecipientJids()[0].toString());
entity.setProperty("body", message.getBody());
datastoreService.put(entity);
}
开发者ID:GoogleCloudPlatform,项目名称:appengine-tck,代码行数:16,代码来源:XmppMessageServlet.java
示例13: sendMessage
import com.google.appengine.api.xmpp.XMPPService; //导入依赖的package包/类
public static void sendMessage(String body, String source) {
Iterator<String> it = subs.iterator();
while (it.hasNext()) {
String sub = it.next();
String messageBody = source + ": " + body;
// We assume an at symbol is an XMPP client...
if (sub.indexOf("@") >= 0) {
JID jid = new JID(sub);
Message msg = new MessageBuilder().withRecipientJids(jid).withBody(messageBody).build();
XMPPService xmpp = XMPPServiceFactory.getXMPPService();
xmpp.sendMessage(msg);
}
// If it starts with a "+" it's an SMS number...
else if (sub.startsWith("+")) {
TwilioRestClient client = new TwilioRestClient("ACCOUNT_SID", "AUTH_TOKEN");
Map<String, String> params = new HashMap<String, String>();
params.put("Body", messageBody);
params.put("To", sub);
params.put("From", "+16122948105");
SmsFactory messageFactory = client.getAccount().getSmsFactory();
try {
Sms message = messageFactory.create(params);
System.out.println(message.getSid());
} catch (TwilioRestException e) {
e.printStackTrace();
}
}
// Otherwise, it's a browser-based client
else {
ChannelService channelService = ChannelServiceFactory.getChannelService();
channelService.sendMessage(new ChannelMessage(sub,messageBody));
}
}
}
开发者ID:kwhinnery,项目名称:gae-chat,代码行数:41,代码来源:MultichannelChatManager.java
注:本文中的com.google.appengine.api.xmpp.XMPPService类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论