本文整理汇总了Java中org.jivesoftware.openfire.auth.UnauthorizedException类的典型用法代码示例。如果您正苦于以下问题:Java UnauthorizedException类的具体用法?Java UnauthorizedException怎么用?Java UnauthorizedException使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
UnauthorizedException类属于org.jivesoftware.openfire.auth包,在下文中一共展示了UnauthorizedException类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: checkAppId
import org.jivesoftware.openfire.auth.UnauthorizedException; //导入依赖的package包/类
public static String checkAppId(String username) throws UnauthorizedException {
if (username.contains(APPID_DELIMITER)) {
// Check that the specified domain matches the server's domain
int index = username.indexOf(APPID_DELIMITER);
String appId = username.substring(index + 1);
Log.info("app id is "+appId);
AppEntity appEntity = appFound(appId);
if (appEntity != null) {
username = username.substring(0, index);
} else {
// Unknown app key. Return authentication failed.
throw new UnauthorizedException("Fail to authenticate the connection for user " + username + ". Cannot find app with app id "+appId);
}
}
return username;
}
开发者ID:magnetsystems,项目名称:message-server,代码行数:18,代码来源:MmxAppUtil.java
示例2: handleIQ
import org.jivesoftware.openfire.auth.UnauthorizedException; //导入依赖的package包/类
@Override
public IQ handleIQ(IQ iq) throws UnauthorizedException {
LOGGER.trace("handleIQ : {}", iq);
JID fromJID = iq.getFrom();
String appId = JIDUtil.getAppId(fromJID);
Element element = iq.getChildElement();
String customType = element.attributeValue(Constants.MMX_ATTR_COMMAND);
String dst = element.attributeValue(Constants.MMX_ATTR_DST);
LOGGER.trace("handleIQ : dst={}, type={}", dst, customType);
MMXPushManager pushMsgMgr = MMXPushManager.getInstance();
MMXid to = new MMXid(JIDUtil.getUserId(dst), JIDUtil.getResource(dst), null);
PushResult result = pushMsgMgr.send(fromJID, appId, to,
Action.PUSH, customType, element.getText());
return IQUtils.createResultIQ(iq, GsonData.getGson().toJson(result));
}
开发者ID:magnetsystems,项目名称:message-server,代码行数:17,代码来源:MMXPushNSHandler.java
示例3: handleIQ
import org.jivesoftware.openfire.auth.UnauthorizedException; //导入依赖的package包/类
@Override
public IQ handleIQ(IQ iq) throws UnauthorizedException {
LOGGER.trace("handleIQ : {}", iq);
JID fromJID = iq.getFrom();
String appId = JIDUtil.getAppId(fromJID);
Element element = iq.getChildElement();
String customType = element.attributeValue(Constants.MMX_ATTR_COMMAND);
String dst = element.attributeValue(Constants.MMX_ATTR_DST);
LOGGER.trace("handleIQ : dst={}, type={}", dst, customType);
MMXPushManager pushMsgMgr = MMXPushManager.getInstance();
MMXid to = new MMXid(JIDUtil.getUserId(dst), JIDUtil.getResource(dst), null);
PushResult result = pushMsgMgr.send(fromJID, appId, to,
Action.WAKEUP, customType, element.getText());
return IQUtils.createResultIQ(iq, GsonData.getGson().toJson(result));
}
开发者ID:magnetsystems,项目名称:message-server,代码行数:17,代码来源:MMXWakeupNSHandler.java
示例4: handleDeleteUser
import org.jivesoftware.openfire.auth.UnauthorizedException; //导入依赖的package包/类
/**
* Handle delete user. The initiator (e.g. app-server user) must be from
* the same app.
* @param packet
* @return
* @throws UnauthorizedException
*/
IQ handleDeleteUser(IQ packet, JID from, String appId, String payload)
throws UnauthorizedException {
UserCreate userRqt = UserCreate.fromJson(payload);
AppDAO appDAO = new AppDAOImpl(getConnectionProvider());
IQ validationError = validateUserDeleteRequest(packet, userRqt, appDAO);
if (validationError != null) {
return validationError;
}
String userId = userRqt.getUserId();
String constructedUserId = JIDUtil.makeNode(userId, appId);
MMXUserManager userManager = getUserManager();
userManager.deleteUser(constructedUserId);
LOGGER.info("Deleted a user with userId:" + constructedUserId);
MMXStatus userResp = new MMXStatus();
userResp.setCode(UserOperationStatusCode.USER_DELETED.getCode());
userResp.setMessage(UserOperationStatusCode.USER_DELETED.getMessage());
IQ response = IQUtils.createResultIQ(packet, userResp.toJson());
return response;
}
开发者ID:magnetsystems,项目名称:message-server,代码行数:28,代码来源:MMXUserHandler.java
示例5: handleListUsers
import org.jivesoftware.openfire.auth.UnauthorizedException; //导入依赖的package包/类
IQ handleListUsers(IQ packet, JID from, String appId, String payload)
throws UnauthorizedException {
ListOfUserId userIds = GsonData.getGson().fromJson(payload, ListOfUserId.class);
HashMap<String, UserInfo> map = new HashMap<String, UserInfo>(userIds.size());
UserManager userManager = XMPPServer.getInstance().getUserManager();
for (UserId userId : userIds) {
String uid = userId.getUserId().toLowerCase();
String userName = JIDUtil.makeNode(uid, appId);
try {
User user = userManager.getUser(userName);
map.put(uid, new UserInfo()
.setUserId(uid)
.setDisplayName(user.getName())
.setEmail(user.getEmail()));
} catch (UserNotFoundException e) {
// Ignored.
}
}
IQ response = IQUtils.createResultIQ(packet, GsonData.getGson().toJson(map));
return response;
}
开发者ID:magnetsystems,项目名称:message-server,代码行数:22,代码来源:MMXUserHandler.java
示例6: handleGetUser
import org.jivesoftware.openfire.auth.UnauthorizedException; //导入依赖的package包/类
IQ handleGetUser(IQ packet, JID from, String appId, String payload)
throws UnauthorizedException {
String userName;
UserId userId = UserId.fromJson(payload);
if (userId == null || userId.getUserId() == null)
userName = from.getNode();
else
userName = JIDUtil.makeNode(userId.getUserId().toLowerCase(), appId);
try {
UserManager userManager = XMPPServer.getInstance().getUserManager();
User user = userManager.getUser(userName);
UserInfo accountInfo = new UserInfo()
.setUserId(userId.getUserId())
.setDisplayName(user.getName())
.setEmail(user.getEmail());
IQ response = IQUtils.createResultIQ(packet, accountInfo.toJson());
return response;
} catch (UserNotFoundException e) {
return IQUtils.createErrorIQ(packet,
UserOperationStatusCode.USER_NOT_FOUND.getMessage(),
UserOperationStatusCode.USER_NOT_FOUND.getCode());
}
}
开发者ID:magnetsystems,项目名称:message-server,代码行数:25,代码来源:MMXUserHandler.java
示例7: handleIQ
import org.jivesoftware.openfire.auth.UnauthorizedException; //导入依赖的package包/类
@Override
public IQ handleIQ(IQ iq) throws UnauthorizedException {
Log.info("AppHandler.handleIQ called");
String command = IQUtils.getCommand(iq);
if ("create".equals(command)) {
return handleCreateApp(iq);
} else if ("read".equals(command)) {
return handleReadApps(iq);
} else if ("readMine".equals(command)) {
return handleReadMyApps(iq);
} else if ("update".equals(command)) {
return handleUpdateApp(iq);
} else if ("delete".equals(command)) {
return handleDeleteApp(iq);
}
return IQUtils.createErrorIQ(iq, "Unsupported operation " + command, 1);
}
开发者ID:magnetsystems,项目名称:message-server,代码行数:19,代码来源:AppHandler.java
示例8: handleIQ
import org.jivesoftware.openfire.auth.UnauthorizedException; //导入依赖的package包/类
@Override
public IQ handleIQ(IQ packet) throws UnauthorizedException {
IQ result = IQ.createResultIQ(packet);
String username = packet.getFrom().getNode();
if (!serverName.equals(packet.getFrom().getDomain()) || username == null) {
// Users of remote servers are not allowed to get their "shared groups". Users of
// remote servers cannot have shared groups in this server.
// Besides, anonymous users do not belong to shared groups so answer an error
result.setChildElement(packet.getChildElement().createCopy());
result.setError(PacketError.Condition.not_allowed);
return result;
}
Collection<Group> groups = rosterManager.getSharedGroups(username);
Element sharedGroups = result.setChildElement("sharedgroup",
"http://www.jivesoftware.org/protocol/sharedgroup");
for (Group sharedGroup : groups) {
String displayName = sharedGroup.getProperties().get("sharedRoster.displayName");
if (displayName != null) {
sharedGroups.addElement("group").setText(displayName);
}
}
return result;
}
开发者ID:idwanglu2010,项目名称:openfire,代码行数:25,代码来源:IQSharedGroupHandler.java
示例9: deliver
import org.jivesoftware.openfire.auth.UnauthorizedException; //导入依赖的package包/类
@Override
public void deliver(Packet packet) throws UnauthorizedException
{
final String xml;
if (Namespace.NO_NAMESPACE.equals(packet.getElement().getNamespace())) {
// use string-based operation here to avoid cascading xmlns wonkery
StringBuilder packetXml = new StringBuilder(packet.toXML());
packetXml.insert(packetXml.indexOf(" "), " xmlns=\"jabber:client\"");
xml = packetXml.toString();
} else {
xml = packet.toXML();
}
if (validate()) {
deliverRawText(xml);
} else {
// use fallback delivery mechanism (offline)
getPacketDeliverer().deliver(packet);
}
}
开发者ID:igniterealtime,项目名称:Openfire,代码行数:20,代码来源:WebSocketConnection.java
示例10: updateClearspaceSharedSecret
import org.jivesoftware.openfire.auth.UnauthorizedException; //导入依赖的package包/类
private void updateClearspaceSharedSecret(String newSecret) {
try {
String path = IM_URL_PREFIX + "updateSharedSecret/";
// Creates the XML with the data
Document groupDoc = DocumentHelper.createDocument();
Element rootE = groupDoc.addElement("updateSharedSecret");
rootE.addElement("newSecret").setText(newSecret);
executeRequest(POST, path, groupDoc.asXML());
} catch (UnauthorizedException ue) {
Log.error("Error updating the password of Clearspace", ue);
} catch (Exception e) {
Log.error("Error updating the password of Clearspace", e);
}
}
开发者ID:idwanglu2010,项目名称:openfire,代码行数:19,代码来源:ClearspaceManager.java
示例11: process
import org.jivesoftware.openfire.auth.UnauthorizedException; //导入依赖的package包/类
/**
* Handle presence updates that affect roster subscriptions.
*
* @param presence The presence presence to handle
* @throws PacketException if the packet is null or the packet could not be routed.
*/
public void process(Presence presence) throws PacketException {
try {
process((Packet)presence);
}
catch (UnauthorizedException e) {
try {
LocalSession session = (LocalSession) sessionManager.getSession(presence.getFrom());
presence = presence.createCopy();
if (session != null) {
presence.setFrom(new JID(null, session.getServerName(), null, true));
presence.setTo(session.getAddress());
}
else {
JID sender = presence.getFrom();
presence.setFrom(presence.getTo());
presence.setTo(sender);
}
presence.setError(PacketError.Condition.not_authorized);
deliverer.deliver(presence);
}
catch (Exception err) {
Log.error(LocaleUtils.getLocalizedString("admin.error"), err);
}
}
}
开发者ID:coodeer,项目名称:g3server,代码行数:32,代码来源:PresenceUpdateHandler.java
示例12: deliver
import org.jivesoftware.openfire.auth.UnauthorizedException; //导入依赖的package包/类
public void deliver(Packet packet) throws UnauthorizedException, PacketException {
// Check if we can send the packet using another session
if (connectionManagerDomain == null) {
// Packet deliverer has not yet been configured so handle unprocessed packet
handleUnprocessedPacket(packet);
}
else {
// Try getting another session to the same connection manager
ConnectionMultiplexerSession session =
multiplexerManager.getMultiplexerSession(connectionManagerDomain);
if (session == null || session.isClosed()) {
// No other session was found so handle unprocessed packet
handleUnprocessedPacket(packet);
}
else {
// Send the packet using this other session to the same connection manager
session.process(packet);
}
}
}
开发者ID:idwanglu2010,项目名称:openfire,代码行数:21,代码来源:MultiplexerPacketDeliverer.java
示例13: createNewSession
import org.jivesoftware.openfire.auth.UnauthorizedException; //导入依赖的package包/类
protected void createNewSession(AsyncContext context, Element rootNode)
throws IOException
{
final long rid = getLongAttribute(rootNode.attributeValue("rid"), -1);
try {
final X509Certificate[] certificates = (X509Certificate[]) context.getRequest().getAttribute("javax.servlet.request.X509Certificate");
final HttpConnection connection = new HttpConnection(rid, context.getRequest().isSecure(), certificates, context);
final InetAddress address = InetAddress.getByName(context.getRequest().getRemoteAddr());
connection.setSession(sessionManager.createSession(address, rootNode, connection));
if (JiveGlobals.getBooleanProperty("log.httpbind.enabled", false)) {
Log.info(new Date() + ": HTTP RECV(" + connection.getSession().getStreamID().getID() + "): " + rootNode.asXML());
}
}
catch (UnauthorizedException | HttpBindException e) {
// Server wasn't initialized yet.
sendLegacyError(context, BoshBindingError.internalServerError, "Server has not finished initialization." );
}
}
开发者ID:igniterealtime,项目名称:Openfire,代码行数:20,代码来源:HttpBindServlet.java
示例14: processIQ
import org.jivesoftware.openfire.auth.UnauthorizedException; //导入依赖的package包/类
@Override
protected void processIQ(IQ packet) throws UnauthorizedException {
if (session.getStatus() != Session.STATUS_AUTHENTICATED) {
// Session is not authenticated so return error
IQ reply = new IQ();
reply.setChildElement(packet.getChildElement().createCopy());
reply.setID(packet.getID());
reply.setTo(packet.getFrom());
reply.setFrom(packet.getTo());
reply.setError(PacketError.Condition.not_authorized);
session.process(reply);
return;
}
// Keep track of the component that sent an IQ get/set
if (packet.getType() == IQ.Type.get || packet.getType() == IQ.Type.set) {
// Handle subsequent bind packets
LocalComponentSession componentSession = (LocalComponentSession) session;
// Get the external component of this session
LocalComponentSession.LocalExternalComponent component =
(LocalComponentSession.LocalExternalComponent) componentSession.getExternalComponent();
component.track(packet);
}
super.processIQ(packet);
}
开发者ID:coodeer,项目名称:g3server,代码行数:25,代码来源:ComponentStanzaHandler.java
示例15: processUnknowPacket
import org.jivesoftware.openfire.auth.UnauthorizedException; //导入依赖的package包/类
@Override
boolean processUnknowPacket(Element doc) throws UnauthorizedException {
// Handle subsequent db:result packets
if ("db".equals(doc.getNamespacePrefix()) && "result".equals(doc.getName())) {
if (!((LocalIncomingServerSession) session).validateSubsequentDomain(doc)) {
throw new UnauthorizedException("Failed to validate domain when using piggyback.");
}
return true;
}
else if ("db".equals(doc.getNamespacePrefix()) && "verify".equals(doc.getName())) {
// The Receiving Server is reusing an existing connection for sending the
// Authoritative Server a request for verification of a key
((LocalIncomingServerSession) session).verifyReceivedKey(doc);
return true;
}
return false;
}
开发者ID:coodeer,项目名称:g3server,代码行数:18,代码来源:ServerStanzaHandler.java
示例16: failDelivery
import org.jivesoftware.openfire.auth.UnauthorizedException; //导入依赖的package包/类
private void failDelivery(final Collection<Packet> packets) {
if (packets == null) {
// Do nothing if someone asked to deliver nothing :)
return;
}
// use a separate thread to schedule backup delivery
TaskEngine.getInstance().submit(new Runnable() {
public void run() {
for (Packet packet : packets) {
try {
backupDeliverer.deliver(packet);
}
catch (UnauthorizedException e) {
Log.error("Unable to deliver message to backup deliverer", e);
}
}
}
});
}
开发者ID:idwanglu2010,项目名称:openfire,代码行数:20,代码来源:HttpSession.java
示例17: passwordReset
import org.jivesoftware.openfire.auth.UnauthorizedException; //导入依赖的package包/类
private IQ passwordReset(String password, IQ packet, String username, Session session)
throws UnauthorizedException
{
IQ response;
// Check if users can change their passwords and a password was specified
if (!registerHandler.canChangePassword() || password == null || password.length() == 0) {
throw new UnauthorizedException();
}
else {
try {
userManager.getUser(username).setPassword(password);
response = IQ.createResultIQ(packet);
List<String> params = new ArrayList<String>();
params.add(username);
params.add(session.toString());
Log.info(LocaleUtils.getLocalizedString("admin.password.update", params));
}
catch (UserNotFoundException e) {
throw new UnauthorizedException();
}
}
return response;
}
开发者ID:coodeer,项目名称:g3server,代码行数:24,代码来源:IQAuthHandler.java
示例18: handleIQ
import org.jivesoftware.openfire.auth.UnauthorizedException; //导入依赖的package包/类
public IQ handleIQ(IQ packet) throws UnauthorizedException {
IQ reply = IQ.createResultIQ(packet);
ListRequest listRequest = new ListRequest(packet.getChildElement());
JID from = packet.getFrom();
Element listElement = reply.setChildElement("list", NAMESPACE);
Collection<Conversation> conversations = list(from, listRequest);
XmppResultSet resultSet = listRequest.getResultSet();
for (Conversation conversation : conversations) {
addChatElement(listElement, conversation);
}
if (resultSet != null) {
listElement.add(resultSet.createResultElement());
}
return reply;
}
开发者ID:igniterealtime,项目名称:Openfire,代码行数:20,代码来源:IQListHandler.java
示例19: deliver
import org.jivesoftware.openfire.auth.UnauthorizedException; //导入依赖的package包/类
/**
* Delivers the given packet based on packet recipient and sender. The
* deliverer defers actual routing decisions to other classes.
* <h2>Warning</h2>
* Be careful to enforce concurrency DbC of concurrent by synchronizing
* any accesses to class resources.
*
* @param packet The packet to route
* @throws NullPointerException If the packet is null or the
* packet could not be routed
*/
public void deliver(Packet packet) throws UnauthorizedException, PacketException {
if (packet == null) {
throw new NullPointerException();
}
if (xmppServer != null && xmppServer.isLocal(packet.getTo())) {
deliverer.deliver(packet);
}
else if (transportHandler != null) {
transportHandler.process(packet);
}
else {
Log.warn("Could not deliver message: no deliverer available "
+ packet.toString());
}
}
开发者ID:coodeer,项目名称:g3server,代码行数:28,代码来源:PacketTransporterImpl.java
示例20: extractUserName
import org.jivesoftware.openfire.auth.UnauthorizedException; //导入依赖的package包/类
public static String extractUserName(String username) throws UnauthorizedException {
String result = username.trim().toLowerCase();
if (username.contains(DOMAIN_DELIMITER)) {
// Check that the specified domain matches the server's domain
int index = username.lastIndexOf(DOMAIN_DELIMITER);
String domain = username.substring(index + 1);
result = username.substring(0, index);
}
return result;
}
开发者ID:magnetsystems,项目名称:message-server,代码行数:11,代码来源:MmxAppUtil.java
注:本文中的org.jivesoftware.openfire.auth.UnauthorizedException类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论