Package org.wso2.carbon.registry.core.session

Examples of org.wso2.carbon.registry.core.session.UserRegistry.resourceExists()

42
43
44
45
46
47
48
49
50
51
52
        TenantManager tenantManager = Util.getRealmService().getTenantManager();
        SystemMeteringAgent meteringAgent = Util.getSystemMeteringAgent();

        //get super tenant governance registry
        UserRegistry superTenantGovernanceRegistry = Util.getSuperTenantGovernanceSystemRegistry();
        if (!superTenantGovernanceRegistry.resourceExists(OLD_BANDWIDTH_USE_STORE_PATH)) {
            return;
        }

        Tenant[] tenants = tenantManager.getAllTenants();
        // uses only the current year month 2010-july
View Full Code Here
74
75
76
77
78
79
80
81
82
83
84
            throws RegistryException {
        UserRegistry superTenantGovernanceRegistry = Util.getSuperTenantGovernanceSystemRegistry();

        String incomingBandwidthUserCollectionPath =
                OLD_BANDWIDTH_USE_STORE_PATH + RegistryConstants.PATH_SEPARATOR + tenantId;
        if (!superTenantGovernanceRegistry.resourceExists(incomingBandwidthUserCollectionPath)) {
            return 0;
        }

        Resource incomingBandwidthUserCollectionR =
                superTenantGovernanceRegistry.get(incomingBandwidthUserCollectionPath);
View Full Code Here
95
96
97
98
99
100
101
102
103
104
105
        for (String incomingBandwidthUserPath : incomingBandwidthUserPaths) {
            String incomingBandwidthResourcePath =
                    incomingBandwidthUserPath + RegistryConstants.PATH_SEPARATOR + yearMonth +
                            RegistryConstants.PATH_SEPARATOR + StratosConstants.INCOMING_PATH_DIR;

            if (!superTenantGovernanceRegistry.resourceExists(incomingBandwidthResourcePath)) {
                return 0;
            }
            Resource incomingBandwidthResource =
                    superTenantGovernanceRegistry.get(incomingBandwidthResourcePath);
            if (incomingBandwidthResource instanceof Collection) {
View Full Code Here
125
126
127
128
129
130
131
132
133
134
135
    public long getOldOutgoingRegistryBandwidth(String yearMonth, int tenantId)
            throws RegistryException {
        UserRegistry superTenantGovernanceRegistry = Util.getSuperTenantGovernanceSystemRegistry();
        String outgoingBandwidthUserCollectionPath =
                OLD_BANDWIDTH_USE_STORE_PATH + RegistryConstants.PATH_SEPARATOR + tenantId;
        if (!superTenantGovernanceRegistry.resourceExists(outgoingBandwidthUserCollectionPath)) {
            return 0;
        }

        Resource outgoingBandwidthUserCollectionR =
                superTenantGovernanceRegistry.get(outgoingBandwidthUserCollectionPath);
View Full Code Here
146
147
148
149
150
151
152
153
154
155
156
        for (String outgoingBandwidthUserPath : outgoingBandwidthUserPaths) {
            String outgoingBandwidthResourcePath =
                    outgoingBandwidthUserPath + RegistryConstants.PATH_SEPARATOR + yearMonth +
                            RegistryConstants.PATH_SEPARATOR + StratosConstants.OUTGOING_PATH_DIR;

            if (!superTenantGovernanceRegistry.resourceExists(outgoingBandwidthResourcePath)) {
                return 0;
            }
            Resource outgoingBandwidthResource =
                    superTenantGovernanceRegistry.get(outgoingBandwidthResourcePath);
            if (outgoingBandwidthResource instanceof Collection) {
View Full Code Here
32
33
34
35
36
37
38
39
40
41
42
    public void createdConfigurationContext(ConfigurationContext configurationContext) {
        try {
            UserRegistry userRegistry =
                    MessageBoxServiceValueHolder.getInstance().getRegistryService().getGovernanceSystemRegistry(
                            SuperTenantCarbonContext.getCurrentContext(configurationContext).getTenantId());
            if (!userRegistry.resourceExists(MessageBoxConstants.MB_MESSAGE_BOX_STORAGE_PATH)) {
                userRegistry.put(MessageBoxConstants.MB_MESSAGE_BOX_STORAGE_PATH,
                                 userRegistry.newCollection());
            }
            if (!userRegistry.resourceExists(MessageBoxConstants.MB_QUEUE_STORAGE_PATH)) {
                userRegistry.put(MessageBoxConstants.MB_QUEUE_STORAGE_PATH,
View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
                            SuperTenantCarbonContext.getCurrentContext(configurationContext).getTenantId());
            if (!userRegistry.resourceExists(MessageBoxConstants.MB_MESSAGE_BOX_STORAGE_PATH)) {
                userRegistry.put(MessageBoxConstants.MB_MESSAGE_BOX_STORAGE_PATH,
                                 userRegistry.newCollection());
            }
            if (!userRegistry.resourceExists(MessageBoxConstants.MB_QUEUE_STORAGE_PATH)) {
                userRegistry.put(MessageBoxConstants.MB_QUEUE_STORAGE_PATH,
                                 userRegistry.newCollection());
            }
        } catch (RegistryException e) {
            log.error("Error in setting message box storage path in tenant", e);
View Full Code Here
58
59
60
61
62
63
64
65
66
67
68
        // when creating subscriptions we going to add entries to this this resource
        try {
            UserRegistry userRegistry = Utils.getUserRegistry();

            //create the topic storage path if it does not exists
            if (!userRegistry.resourceExists(MessageBoxConstants.MB_QUEUE_STORAGE_PATH)) {
                userRegistry.put(MessageBoxConstants.MB_QUEUE_STORAGE_PATH, userRegistry.newCollection());
            }

        } catch (RegistryException e) {
            throw new MessageBoxException("Can not access the registry", e);
View Full Code Here
151
152
153
154
155
156
157
158
159
160
161
            String resourcePath = MessageBoxConstants.MB_QUEUE_STORAGE_PATH + "/" + queueName;
            String ownerName = CarbonContext.getCurrentContext().getUsername();

            //we add the queue only if it does not exits. if the topic exists then
            //we don't do any thing.
            if (!userRegistry.resourceExists(resourcePath)) {
                Collection collection = userRegistry.newCollection();
                collection.setProperty(MessageBoxConstants.MB_QUEUE_PROPERTY_CREATED_TIME,
                                       ConverterUtil.convertToString(Calendar.getInstance()));
                collection.setProperty(MessageBoxConstants.MB_QUEUE_PROPERTY_UPDATED_TIME,
                                       ConverterUtil.convertToString(Calendar.getInstance()));
View Full Code Here
357
358
359
360
361
362
363
364
365
366
367
    public void setQueueUpdatedTime(String queueName) throws MessageBoxException {
        try {
            UserRegistry userRegistry = Utils.getUserRegistry();
            String resourcePath = MessageBoxConstants.MB_QUEUE_STORAGE_PATH + "/" + queueName;

            if (userRegistry.resourceExists(resourcePath)) {
                Collection collection = (Collection) userRegistry.get(resourcePath);
                collection.removeProperty(MessageBoxConstants.MB_QUEUE_PROPERTY_UPDATED_TIME);
                collection.setProperty(MessageBoxConstants.MB_QUEUE_PROPERTY_UPDATED_TIME,
                                       ConverterUtil.convertToString(Calendar.getInstance()));
                userRegistry.put(resourcePath, collection);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.