Examples of QueueUserPermission

org.wso2.carbon.messagebox.queue.QueueUserPermission

Examples of org.wso2.carbon.messagebox.queue.QueueUserPermission

    }


    private void allowQueuePermissionOnCreateQueue(String username, String messageBoxId)
            throws MessageBoxException {
        List<QueueUserPermission> userPermissions = new ArrayList<QueueUserPermission>();
        QueueUserPermission queueUserPermission = new QueueUserPermission();
        queueUserPermission.setUserName(username);
        queueUserPermission.setAllowedToConsume(true);
        queueUserPermission.setAllowedToPublish(true);
        userPermissions.add(queueUserPermission);
        queueManager.updateUserPermission(userPermissions, messageBoxId);
    }

View Full Code Here

Examples of org.wso2.carbon.messagebox.queue.QueueUserPermission

        //ToDo: all permissions are removed. but using queue manager, permissions may have set.
        // ToDo: those permissions too removed. this is wrong
        // remove consume/publish permissions
        List<String> removePermissionOperations = removedPermissionLabel.getOperations();
        for (String sharedUser : removedPermissionLabel.getSharedUsers()) {
            QueueUserPermission queueUserPermission = new QueueUserPermission();


            setPublishPermission(removePermissionOperations, queueUserPermission, false);
            setConsumePermission(removePermissionOperations, queueUserPermission, false);
            queueUserPermission.setUserName(sharedUser);


            List<QueueUserPermission> userPermissions = new ArrayList<QueueUserPermission>();
            userPermissions.add(queueUserPermission);


            queueManager.updateUserPermission(userPermissions,
                                              Utils.getTenantBasedQueueName(
                                                      JMSQueueHandler.getJMSQueueName(messageBoxId)));
        }


        // re-authorize removed permissions since those were authorized in a different permission label
        for (PermissionLabel permissionLabel : otherAllowedPermissions) {
            authorizationHandler.addPermission(messageBoxId, permissionLabel);
            for (String sharedUser : permissionLabel.getSharedUsers()) {
                QueueUserPermission queueUserPermission = new QueueUserPermission();


                setPublishPermission(removePermissionOperations, queueUserPermission, true);
                setConsumePermission(removePermissionOperations, queueUserPermission, true);
                queueUserPermission.setUserName(sharedUser);


                List<QueueUserPermission> userPermissions = new ArrayList<QueueUserPermission>();
                userPermissions.add(queueUserPermission);


                queueManager.updateUserPermission(userPermissions,

View Full Code Here

Examples of org.wso2.carbon.messagebox.queue.QueueUserPermission

        authorizationHandler.addPermission(messageBoxId, permissionLabel);


        // allow consume/publish permissions
        List<String> operationList = permissionLabel.getOperations();
        for (String sharedUser : sharedUsers) {
            QueueUserPermission queueUserPermission = new QueueUserPermission();
            setPublishPermission(operationList, queueUserPermission, true);
            setConsumePermission(operationList, queueUserPermission, true);
            queueUserPermission.setUserName(sharedUser);
            List<QueueUserPermission> userPermissions = new ArrayList<QueueUserPermission>();
            userPermissions.add(queueUserPermission);


            queueManager.updateUserPermission(userPermissions,
                                              Utils.getTenantBasedQueueName(

View Full Code Here

Examples of org.wso2.carbon.messagebox.queue.QueueUserPermission

                = new ArrayList<org.wso2.carbon.messagebox.queue.QueueUserPermission>();
        try {
            QueueManager queueManager =
                    MessageBoxHolder.getInstance().getMessageboxService().getQueueManager();
            for (QueueUserPermissionBean adminQueueUserPermission : adminQueueUserPermissions) {
                QueueUserPermission queueUserPermission = new QueueUserPermission();
                queueUserPermission.setUserName(adminQueueUserPermission.getUserName());
                queueUserPermission.setAllowedToConsume(adminQueueUserPermission.isAllowedToConsume());
                queueUserPermission.setAllowedToPublish(adminQueueUserPermission.isAllowedToPublish());
                queueUserPermissions.add(queueUserPermission);
            }
            queueManager.updateUserPermission(queueUserPermissions, queueName);
        } catch (MessageBoxException e) {
            throw new MessageBoxAdminException("Unable to access the queue manager", e);

View Full Code Here

Examples of org.wso2.carbon.messagebox.queue.QueueUserPermission

            throws MessageBoxException {


        String queueResoucePath = MessageBoxConstants.MB_QUEUE_STORAGE_PATH + "/" + queueName;
        List<QueueUserPermission> queueUserPermissions = new ArrayList<QueueUserPermission>();
        UserRealm userRealm = CarbonContext.getCurrentContext().getUserRealm();
        QueueUserPermission queueUserPermission;
        try {
            for (String user : userRealm.getUserStoreManager().listUsers("*", 10)) {
                queueUserPermission = new QueueUserPermission();
                queueUserPermission.setUserName(user);
                queueUserPermission.setAllowedToConsume(
                        userRealm.getAuthorizationManager().isUserAuthorized(
                                user, queueResoucePath, MessageBoxConstants.MB_PERMISSION_CONSUME));
                queueUserPermission.setAllowedToPublish(
                        userRealm.getAuthorizationManager().isUserAuthorized(
                                user, queueResoucePath, MessageBoxConstants.MB_PERMISSION_PUBLISH));
                queueUserPermissions.add(queueUserPermission);
            }
            return queueUserPermissions;

View Full Code Here

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.