Examples of addInterceptor()

Examples of com.buschmais.cdo.impl.interceptor.InterceptorFactory.addInterceptor()

62
63
64
65
66
67
68
69
70
71
72
        InterceptorFactory interceptorFactory = new InterceptorFactory(cdoTransaction, defaultTransactionAttribute);
        InstanceManager instanceManager = new InstanceManager(metadataProvider, datastoreSession, classLoader, cdoTransaction, cache, interceptorFactory);
        // Register default synchronizations.
        cdoTransaction.registerDefaultSynchronization(new ValidatorSynchronization(instanceValidator));
        cdoTransaction.registerDefaultSynchronization(new CacheSynchronization(instanceManager, cache, datastoreSession));
        return interceptorFactory.addInterceptor(new CdoManagerImpl(metadataProvider, cdoTransaction, cache, datastoreSession, instanceManager, interceptorFactory, instanceValidator));
    }

    @Override
    public void close() {
        datastore.close();
View Full Code Here

Examples of com.buschmais.xo.spi.interceptor.InterceptorFactory.addInterceptor()

32
33
34
35
36
37
38
39
        Class<XODatastoreProvider> delegateProviderType = ClassHelper.getType(delegateProviderName);
        XODatastoreProvider<EntityMetadata, EntityDiscriminator, RelationMetadata, RelationDiscriminator> delegateProvider = ClassHelper.newInstance(delegateProviderType);
        Datastore<?, EntityMetadata, EntityDiscriminator, RelationMetadata, RelationDiscriminator> delegateDatastore = delegateProvider.createDatastore(xoUnit);
        TraceMonitor traceMonitor = new TraceMonitor(xoUnit);
        InterceptorFactory interceptorFactory = new InterceptorFactory(Arrays.asList(new TraceMonitorInterceptor(traceMonitor)));
        return new TraceDatastore<>(interceptorFactory.addInterceptor(delegateDatastore, Datastore.class), interceptorFactory, traceMonitor);
    }
}
View Full Code Here

Examples of com.dyuproject.web.rest.InterceptorCollection.addInterceptor()

147
148
149
150
151
152
153
154
155
156
157
            else if(ph._interceptor instanceof InterceptorCollection)
                ((InterceptorCollection)ph._interceptor).addInterceptor(i);
            else
            {
                InterceptorCollection ic = new InterceptorCollection();
                ic.addInterceptor(ph._interceptor);
                ic.addInterceptor(i);
                ph._interceptor = ic;
            }
        }
    }
View Full Code Here

Examples of com.hazelcast.core.IMap.addInterceptor()

129
130
131
132
133
134
135
136
137
138
139
        HazelcastInstance instance1 = nodeFactory.newHazelcastInstance(cfg);
        IMap map = instance1.getMap("map");
        for (int i = 0; i < 100; i++) {
            map.put(i,i);
        }
        map.addInterceptor(new NegativeInterceptor());
        for (int i = 0; i < 100; i++) {
            assertEquals(i*-1, map.get(i));
        }
        HazelcastInstance instance2 = nodeFactory.newHazelcastInstance(cfg);
        for (int i = 0; i < 100; i++) {
View Full Code Here

Examples of com.hazelcast.map.MapContainer.addInterceptor()

173
174
175
176
177
178
179
180
181
182
183
            final MapContainer mapContainer = mapService.getMapContainer(interceptorInfo.mapName);
            Map<String, MapInterceptor> interceptorMap = mapContainer.getInterceptorMap();
            List<Map.Entry<String, MapInterceptor>> entryList = interceptorInfo.interceptors;
            for (Map.Entry<String, MapInterceptor> entry : entryList) {
                if (!interceptorMap.containsKey(entry.getKey())) {
                    mapContainer.addInterceptor(entry.getKey(), entry.getValue());
                }
            }
        }
    }
View Full Code Here

Examples of com.hazelcast.map.MapService.addInterceptor()

67
68
69
70
71
72
73
74
75
76
77
    }

    @Override
    protected OperationFactory createOperationFactory() {
        final MapService mapService = getService();
        id = mapService.addInterceptor(name, mapInterceptor);
        return new AddInterceptorOperationFactory(id, name, mapInterceptor);
    }

    @Override
    protected Object reduce(Map<Address, Object> map) {
View Full Code Here

Examples of com.hazelcast.map.impl.MapContainer.addInterceptor()

176
177
178
179
180
181
182
183
184
185
186
            final MapContainer mapContainer = mapService.getMapServiceContext().getMapContainer(interceptorInfo.mapName);
            Map<String, MapInterceptor> interceptorMap = mapContainer.getInterceptorMap();
            List<Map.Entry<String, MapInterceptor>> entryList = interceptorInfo.interceptors;
            for (Map.Entry<String, MapInterceptor> entry : entryList) {
                if (!interceptorMap.containsKey(entry.getKey())) {
                    mapContainer.addInterceptor(entry.getKey(), entry.getValue());
                }
            }
        }
    }
View Full Code Here

Examples of com.sun.xml.internal.ws.api.pipe.Fiber.addInterceptor()

184
185
186
187
188
189
190
191
192
193
194
        if (wsdlProperties != null) {
            request.addSatellite(wsdlProperties);
        }
        Fiber fiber = engine.createFiber();
        if (interceptor != null) {
            fiber.addInterceptor(interceptor);
        }
        final Tube tube = tubePool.take();
        fiber.start(tube, request, new Fiber.CompletionCallback() {
            public void onCompletion(@NotNull Packet response) {
                tubePool.recycle(tube);
View Full Code Here

Examples of com.sun.xml.ws.api.pipe.Fiber.addInterceptor()

247
248
249
250
251
252
253
254
255
256
257
        if (wsdlProperties != null) {
            request.addSatellite(wsdlProperties);
        }
        Fiber fiber = engine.createFiber();
        if (interceptor != null) {
            fiber.addInterceptor(interceptor);
        }
        final Tube tube = tubePool.take();
        fiber.start(tube, request, new Fiber.CompletionCallback() {
            public void onCompletion(@NotNull Packet response) {
                tubePool.recycle(tube);
View Full Code Here

Examples of org.apache.cactus.extension.jsp.JspTagLifecycle.addInterceptor()

135
136
137
138
139
140
141
142
143
144
145
    {
        try
        {
            JspTagLifecycle lifecycle =
                new JspTagLifecycle(pageContext, new OutTag());
            lifecycle.addInterceptor(null);
            fail("Expected NullPointerException");
        }
        catch (NullPointerException expected)
        {
            // expected
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.