Examples of SessionAttributeMarshaller

Examples of org.jboss.as.clustering.web.SessionAttributeMarshaller

45
46
47
48
49
50
51
52
53
54
        SessionAttributeMarshallerFactory factory = new SessionAttributeMarshallerFactoryImpl(marshallerFactory);
        ClassResolver resolver = mock(ClassResolver.class);

        when(manager.getApplicationClassResolver()).thenReturn(resolver);

        SessionAttributeMarshaller marshaller = factory.createMarshaller(manager);

        assertNotNull(marshaller);
        assertTrue(marshaller instanceof SessionAttributeMarshallerImpl);
    }
View Full Code Here

Examples of org.jboss.as.clustering.web.SessionAttributeMarshaller

47
48
49
50
51
52
53
54
55
56
57
    public void testField() {
        this.test(ReplicationGranularity.FIELD, CoarseSessionAttributeStorage.class);
    }

    private void test(ReplicationGranularity granularity, Class<? extends SessionAttributeStorage<?>> expectedClass) {
        SessionAttributeMarshaller marshaller = mock(SessionAttributeMarshaller.class);

        SessionAttributeStorageFactory factory = new SessionAttributeStorageFactoryImpl();

        try {
            SessionAttributeStorage<?> storage = factory.createStorage(granularity, marshaller);
View Full Code Here

Examples of org.jboss.web.tomcat.service.session.distributedcache.spi.SessionAttributeMarshaller

63
64
65
66
67
68
69
70
71
72
73
      {
         throw new IllegalStateException("Unexpected transaction manager type: " + ((tm != null) ? tm.getClass().getName() : "null"));
      }
     
      BatchingManager batchingManager = new BatchingManagerImpl(tm);
      SessionAttributeMarshaller marshaller = this.marshallerFactory.createMarshaller(manager);
      SessionAttributeStorage<T> storage = this.storageFactory.createStorage(manager.getReplicationConfig().getReplicationGranularity(), marshaller);
     
      sessionCache = new AtomicMapCache<String, Object, Object>(sessionCache);
     
      return new DistributedCacheManager<T>(manager, sessionCache, null, lockManager, storage, batchingManager, this.invoker);
View Full Code Here

Examples of org.jboss.web.tomcat.service.session.distributedcache.spi.SessionAttributeMarshaller

71
72
73
74
75
76
77
78
79
80
      {
         throw new IllegalStateException("Unexpected transaction manager type: " + ((tm != null) ? tm.getClass().getName() : "null"));
      }
     
      BatchingManager batchingManager = new BatchingManagerImpl(tm);
      SessionAttributeMarshaller marshaller = this.marshallerFactory.createMarshaller(manager);
      SessionAttributeStorage<T> storage = this.storageFactory.createStorage(manager.getReplicationConfig().getReplicationGranularity(), marshaller);
     
      return new DistributedCacheManager<T>(manager, cache, lockManager, storage, batchingManager, this.invoker, this.atomicMapFactory);
   }
View Full Code Here

Examples of org.jboss.web.tomcat.service.session.distributedcache.spi.SessionAttributeMarshaller

63
64
65
66
67
68
69
70
71
72
73
      {
         throw new IllegalStateException("Unexpected transaction manager type: " + ((tm != null) ? tm.getClass().getName() : "null"));
      }
     
      BatchingManager batchingManager = new BatchingManagerImpl(tm);
      SessionAttributeMarshaller marshaller = this.marshallerFactory.createMarshaller(manager);
      SessionAttributeStorage<T> storage = this.storageFactory.createStorage(manager.getReplicationConfig().getReplicationGranularity(), marshaller);
     
//      Cache<Address, String> jvmRouteCache = sessionCache.getCacheManager().getCache(manager.getEngineName());
      sessionCache = new AtomicMapCache<String, Object, Object>(sessionCache);
     
View Full Code Here

Examples of org.jboss.web.tomcat.service.session.distributedcache.spi.SessionAttributeMarshaller

63
64
65
66
67
68
69
70
71
72
      {
         throw new IllegalStateException("Unexpected transaction manager type: " + ((tm != null) ? tm.getClass().getName() : "null"));
      }
     
      BatchingManager batchingManager = new BatchingManagerImpl(tm);
      SessionAttributeMarshaller marshaller = this.marshallerFactory.createMarshaller(manager);
      SessionAttributeStorage<T> storage = this.storageFactory.createStorage(manager.getReplicationConfig().getReplicationGranularity(), marshaller);
     
      return new DistributedCacheManager<T>(manager, cache, lockManager, storage, batchingManager, this.invoker, this.atomicMapFactory);
   }
View Full Code Here

Examples of org.jboss.web.tomcat.service.session.distributedcache.spi.SessionAttributeMarshaller

64
65
66
67
68
69
70
71
72
73
      {
         throw new IllegalStateException("Unexpected transaction manager type: " + ((tm != null) ? tm.getClass().getName() : "null"));
      }
     
      BatchingManager batchingManager = new BatchingManagerImpl(tm);
      SessionAttributeMarshaller marshaller = this.marshallerFactory.createMarshaller(manager);
      SessionAttributeStorage<T> storage = this.storageFactory.createStorage(manager.getReplicationConfig().getReplicationGranularity(), marshaller);
     
      return new DistributedCacheManager<T>(manager, new AtomicMapCache<String, Object, Object>(sessionCache), this.jvmRouteCacheSource, lockManager, storage, batchingManager, this.invoker);
   }
View Full Code Here

Examples of org.jboss.web.tomcat.service.session.distributedcache.spi.SessionAttributeMarshaller

62
63
64
65
66
67
68
69
70
71
      {
         throw new IllegalStateException("Unexpected transaction manager type: " + ((tm != null) ? tm.getClass().getName() : "null"));
      }
     
      BatchingManager batchingManager = new BatchingManagerImpl(tm);
      SessionAttributeMarshaller marshaller = this.marshallerFactory.createMarshaller(manager);
      SessionAttributeStorage<T> storage = this.storageFactory.createStorage(manager.getReplicationConfig().getReplicationGranularity(), marshaller);
     
      return new DistributedCacheManager<T>(manager, cache, storage, batchingManager, this.invoker, this.atomicMapFactory);
   }
View Full Code Here

Examples of org.jboss.web.tomcat.service.session.distributedcache.spi.SessionAttributeMarshaller

46
47
48
49
50
51
52
53
54
55
   private AtomicMapFactory atomicMapFactory = new DefaultAtomicMapFactory();
  
   @Override
   public <T extends OutgoingDistributableSessionData> org.jboss.web.tomcat.service.session.distributedcache.spi.DistributedCacheManager<T> getDistributedCacheManager(LocalDistributableSessionManager manager)
   {
      SessionAttributeMarshaller marshaller = this.marshallerFactory.createMarshaller(manager);
      SessionAttributeStorage<T> storage = this.storageFactory.createStorage(manager.getReplicationConfig().getReplicationGranularity(), marshaller);
     
      return new DistributedCacheManager<T>(manager, this.registry, storage, this.invoker, this.atomicMapFactory);
   }
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.