本文整理汇总了Java中com.hazelcast.spi.serialization.SerializationService类的典型用法代码示例。如果您正苦于以下问题:Java SerializationService类的具体用法?Java SerializationService怎么用?Java SerializationService使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
SerializationService类属于com.hazelcast.spi.serialization包,在下文中一共展示了SerializationService类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: testAutoregistrationOnHibernate5Available
import com.hazelcast.spi.serialization.SerializationService; //导入依赖的package包/类
@Test
public void testAutoregistrationOnHibernate5Available()
throws Exception {
HazelcastInstance hz = Hazelcast.newHazelcastInstance();
HazelcastInstanceImpl impl = (HazelcastInstanceImpl) ORIGINAL.get(hz);
SerializationService ss = impl.getSerializationService();
@SuppressWarnings("unchecked")
ConcurrentMap<Class, ?> typeMap = (ConcurrentMap) TYPE_MAP.get(ss);
boolean cacheEntrySerializerFound = false;
for (Class clazz : typeMap.keySet()) {
if (StandardCacheEntryImpl.class.equals(clazz)
|| "com.hazelcast.hibernate.serialization.CacheEntryImpl".equals(clazz.getName())) {
cacheEntrySerializerFound = true;
}
}
assertTrue("CacheEntry serializer not found", cacheEntrySerializerFound);
}
开发者ID:hazelcast,项目名称:hazelcast-hibernate5,代码行数:21,代码来源:HibernateSerializationHookAvailableTest.java
示例2: testAttributeReloadSession
import com.hazelcast.spi.serialization.SerializationService; //导入依赖的package包/类
@Test(timeout = 60000)
public void testAttributeReloadSession() throws Exception {
IMap<String, Object> map = hz.getMap(DEFAULT_MAP_NAME);
CookieStore cookieStore = new BasicCookieStore();
assertEquals("true", executeRequest("write", serverPort1, cookieStore));
assertEquals(1, map.size());
String oldSessionId = findHazelcastSessionId(map);
assertNotNull(oldSessionId);
assertEquals("value", executeRequest("read", serverPort2, cookieStore));
assertEquals("true", executeRequest("reload", serverPort2, cookieStore));
String newSessionId = findHazelcastSessionId(map);
assertEquals(1, map.size());
assertNotNull(map.get(newSessionId));
SessionState sessionState = (SessionState) map.get(newSessionId);
SerializationService ss = getNode(hz).getSerializationService();
assertEquals("first-value", ss.toObject(sessionState.getAttributes().get("first-key")));
assertEquals("second-value", ss.toObject(sessionState.getAttributes().get("second-key")));
}
开发者ID:hazelcast,项目名称:hazelcast-wm,代码行数:19,代码来源:WebFilterSlowTests.java
示例3: testAutoregistrationOnHibernate4Available
import com.hazelcast.spi.serialization.SerializationService; //导入依赖的package包/类
@Test
public void testAutoregistrationOnHibernate4Available()
throws Exception {
HazelcastInstance hz = Hazelcast.newHazelcastInstance();
HazelcastInstanceImpl impl = (HazelcastInstanceImpl) ORIGINAL.get(hz);
SerializationService ss = impl.getSerializationService();
ConcurrentMap<Class, ?> typeMap = (ConcurrentMap<Class, ?>) TYPE_MAP.get(ss);
boolean cacheKeySerializerFound = false;
boolean cacheEntrySerializerFound = false;
for (Class clazz : typeMap.keySet()) {
if (clazz == CacheKey.class) {
cacheKeySerializerFound = true;
} else if (clazz == CacheEntry.class) {
cacheEntrySerializerFound = true;
}
}
assertTrue("CacheKey serializer not found", cacheKeySerializerFound);
assertTrue("CacheEntry serializer not found", cacheEntrySerializerFound);
}
开发者ID:hazelcast,项目名称:hazelcast-hibernate,代码行数:23,代码来源:HibernateSerializationHookAvailableTest.java
示例4: testAutoregistrationOnHibernate3Available
import com.hazelcast.spi.serialization.SerializationService; //导入依赖的package包/类
@Test
public void testAutoregistrationOnHibernate3Available()
throws Exception {
HazelcastInstance hz = Hazelcast.newHazelcastInstance();
HazelcastInstanceImpl impl = (HazelcastInstanceImpl) ORIGINAL.get(hz);
SerializationService ss = impl.getSerializationService();
ConcurrentMap<Class, ?> typeMap = (ConcurrentMap<Class, ?>) TYPE_MAP.get(ss);
boolean cacheKeySerializerFound = false;
boolean cacheEntrySerializerFound = false;
for (Class clazz : typeMap.keySet()) {
if (clazz == CacheKey.class) {
cacheKeySerializerFound = true;
} else if (clazz == CacheEntry.class) {
cacheEntrySerializerFound = true;
}
}
assertTrue("CacheKey serializer not found", cacheKeySerializerFound);
assertTrue("CacheEntry serializer not found", cacheEntrySerializerFound);
}
开发者ID:hazelcast,项目名称:hazelcast-hibernate,代码行数:23,代码来源:HibernateSerializationHookAvailableTest.java
示例5: setupSerialization
import com.hazelcast.spi.serialization.SerializationService; //导入依赖的package包/类
protected void setupSerialization() {
// set up the serializer for the storage record if not already configured
SerializationService serializationService;
if (this.hazelcastInstance instanceof HazelcastInstanceImpl) {
serializationService = ((HazelcastInstanceImpl) this.hazelcastInstance).getSerializationService();
} else if (this.hazelcastInstance instanceof SerializationServiceSupport) {
serializationService = ((SerializationServiceSupport) this.hazelcastInstance).getSerializationService();
} else {
serializationService = null;
}
if (serializationService != null) {
try {
((AbstractSerializationService) serializationService).register(MutableStorageRecord.class, new MutableStorageRecordSerializer());
} catch (IllegalStateException e) {
logger.warn("Problem registering storage record serializer", e);
}
}
}
开发者ID:UniconLabs,项目名称:shibboleth-hazelcast-storage-service,代码行数:19,代码来源:AbstractHazelcastMapBackedStorageService.java
示例6: updateAttributes
import com.hazelcast.spi.serialization.SerializationService; //导入依赖的package包/类
/**
* Update attributes.
*
* @param id the id
* @param updates the updates
* @throws Exception the exception
*/
public void updateAttributes(String id, Map<String, Object> updates) throws Exception {
SerializationService ss = sss.getSerializationService();
SessionUpdateEntryProcessor sessionUpdate = new SessionUpdateEntryProcessor(updates.size());
for (Map.Entry<String, Object> entry : updates.entrySet()) {
String name = entry.getKey();
Object value = entry.getValue();
sessionUpdate.getAttributes().put(name, ss.toData(value));
}
executeOnKey(id, sessionUpdate);
}
开发者ID:hazelcast,项目名称:hazelcast-wm,代码行数:18,代码来源:ClusteredSessionService.java
示例7: test_updateAttribute
import com.hazelcast.spi.serialization.SerializationService; //导入依赖的package包/类
@Test(timeout = 20000)
public void test_updateAttribute() throws Exception {
IMap<String, Object> map = hz.getMap(DEFAULT_MAP_NAME);
CookieStore cookieStore = new BasicCookieStore();
executeRequest("write", serverPort1, cookieStore);
executeRequest("update", serverPort2, cookieStore);
assertEquals("value-updated", executeRequest("read", serverPort1, cookieStore));
String newSessionId = map.keySet().iterator().next();
SessionState sessionState = (SessionState) map.get(newSessionId);
SerializationService ss = getNode(hz).getSerializationService();
assertSizeEventually(1, map);
assertSizeEventually(1, sessionState.getAttributes());
}
开发者ID:hazelcast,项目名称:hazelcast-wm,代码行数:14,代码来源:WebFilterBasicTest.java
示例8: ProcCtx
import com.hazelcast.spi.serialization.SerializationService; //导入依赖的package包/类
public ProcCtx(JetInstance instance, SerializationService serService, ILogger logger, String vertexName,
int index, ProcessingGuarantee processingGuarantee) {
this.instance = instance;
this.serService = serService;
this.logger = logger;
this.vertexName = vertexName;
this.index = index;
this.processingGuarantee = processingGuarantee;
}
开发者ID:hazelcast,项目名称:hazelcast-jet,代码行数:10,代码来源:Contexts.java
示例9: deserializeWithCustomClassLoader
import com.hazelcast.spi.serialization.SerializationService; //导入依赖的package包/类
public static <T> T deserializeWithCustomClassLoader(
SerializationService serializationService, ClassLoader cl, Data data
) {
ClassLoader previous = Thread.currentThread().getContextClassLoader();
Thread.currentThread().setContextClassLoader(cl);
try {
return serializationService.toObject(data);
} finally {
Thread.currentThread().setContextClassLoader(previous);
}
}
开发者ID:hazelcast,项目名称:hazelcast-jet,代码行数:12,代码来源:CustomClassLoadedObject.java
示例10: OutboxImpl
import com.hazelcast.spi.serialization.SerializationService; //导入依赖的package包/类
/**
* @param outstreams The output queues
* @param hasSnapshot If the last queue in {@code outstreams} is the snapshot queue
* @param progTracker Tracker to track progress. Only madeProgress will be called,
* done status won't be ever changed
* @param batchSize Maximum number of items that will be allowed to offer until
* {@link #resetBatch()} is called.
*/
@SuppressFBWarnings("EI_EXPOSE_REP")
public OutboxImpl(OutboundCollector[] outstreams, boolean hasSnapshot, ProgressTracker progTracker,
SerializationService serializationService, int batchSize) {
this.outstreams = outstreams;
this.progTracker = progTracker;
this.serializationService = serializationService;
this.batchSize = batchSize;
checkPositive(batchSize, "batchSize must be positive");
allEdges = IntStream.range(0, outstreams.length - (hasSnapshot ? 1 : 0)).toArray();
allEdgesAndSnapshot = IntStream.range(0, outstreams.length).toArray();
snapshotEdge = hasSnapshot ? new int[] {outstreams.length - 1} : null;
broadcastTracker = new BitSet(outstreams.length);
}
开发者ID:hazelcast,项目名称:hazelcast-jet,代码行数:23,代码来源:OutboxImpl.java
示例11: testSerializerHook
import com.hazelcast.spi.serialization.SerializationService; //导入依赖的package包/类
@Test
public void testSerializerHook() throws Exception {
assertFalse("Type implements java.io.Serializable", instance instanceof Serializable);
SerializationService serializationService = new DefaultSerializationServiceBuilder().build();
Data serialized = serializationService.toData(instance);
Object deserialized = serializationService.toObject(serialized);
assertNotSame("serialization/deserialization didn't take place", instance, deserialized);
assertEquals("objects are not equal after serialize/deserialize", instance, deserialized);
}
开发者ID:hazelcast,项目名称:hazelcast-jet,代码行数:10,代码来源:AccumulatorSerializerHooksTest.java
示例12: testSerializerHook
import com.hazelcast.spi.serialization.SerializationService; //导入依赖的package包/类
@Test
public void testSerializerHook() throws Exception {
if (!(instance instanceof Map.Entry || instance instanceof Tag)) {
assertFalse(instance.getClass() + " implements java.io.Serializable", instance instanceof Serializable);
}
SerializationService serializationService = new DefaultSerializationServiceBuilder().build();
Data serialized = serializationService.toData(instance);
Object deserialized = serializationService.toObject(serialized);
if (!(instance instanceof Tag)) {
assertNotSame("serialization/deserialization didn't take place", instance, deserialized);
}
assertEquals("objects are not equal after serialize/deserialize", instance, deserialized);
}
开发者ID:hazelcast,项目名称:hazelcast-jet,代码行数:14,代码来源:DataModelSerializerHooksTest.java
示例13: testSerializerHooks
import com.hazelcast.spi.serialization.SerializationService; //导入依赖的package包/类
@Test
public void testSerializerHooks() throws Exception {
SerializationService serializationService = new DefaultSerializationServiceBuilder().build();
Data serialized = serializationService.toData(instance);
Object deserialized = serializationService.toObject(serialized);
assertNotSame("serialization/deserialization didn't take place", instance, deserialized);
if (instance instanceof Object[]) {
assertArrayEquals("objects are not equal after serialize/deserialize",
(Object[]) instance, (Object[]) deserialized);
} else {
assertEquals("objects are not equal after serialize/deserialize", instance, deserialized);
}
}
开发者ID:hazelcast,项目名称:hazelcast-jet,代码行数:16,代码来源:SerializerHooksTest.java
示例14: testSerializerHooks
import com.hazelcast.spi.serialization.SerializationService; //导入依赖的package包/类
@Test
public void testSerializerHooks() throws Exception {
if (!(instance instanceof Map.Entry)) {
assertFalse("Type implements java.io.Serializable", instance instanceof Serializable);
}
SerializationService serializationService = new DefaultSerializationServiceBuilder().build();
Data serialized = serializationService.toData(instance);
Object deserialized = serializationService.toObject(serialized);
assertNotSame("serialization/deserialization didn't take place", instance, deserialized);
assertEquals("objects are not equal after serialize/deserialize", instance, deserialized);
}
开发者ID:hazelcast,项目名称:hazelcast-jet,代码行数:12,代码来源:ExecutionSerializerHooksTest.java
示例15: testSerializerHook
import com.hazelcast.spi.serialization.SerializationService; //导入依赖的package包/类
@Test
public void testSerializerHook() throws Exception {
SerializationService serializationService = new DefaultSerializationServiceBuilder().build();
Data serialized = serializationService.toData(instance);
Object deserialized = serializationService.toObject(serialized);
assertEquals("objects are not equal after serialize/deserialize", instance, deserialized);
}
开发者ID:hazelcast,项目名称:hazelcast-jet,代码行数:10,代码来源:CoreSerializerHooksTest.java
示例16: handle
import com.hazelcast.spi.serialization.SerializationService; //导入依赖的package包/类
@Override
public void handle(Data item, long publishTime, String uuid) {
TRACER.trace("New event message retrieved");
ClientContext context = clientSequencer.getContext();
SerializationService serializationService = context.getSerializationService();
Object message = serializationService.toObject(item);
if (message instanceof ClientDestroySequencerNotification) {
TRACER.trace("ClientDestroySequencerNotification received");
clientSequencer.stateTransition(SnowcastSequenceState.Destroyed);
sequencerContext.unregisterClientChannel(clientSequencer);
}
}
开发者ID:noctarius,项目名称:snowcast,代码行数:14,代码来源:ClientSequencer.java
示例17: getSerializationService
import com.hazelcast.spi.serialization.SerializationService; //导入依赖的package包/类
public SerializationService getSerializationService() {
return serService;
}
开发者ID:hazelcast,项目名称:hazelcast-jet,代码行数:4,代码来源:Contexts.java
示例18: serializationService
import com.hazelcast.spi.serialization.SerializationService; //导入依赖的package包/类
@Override
protected SerializationService serializationService() {
return container().getSerializationService();
}
开发者ID:hazelcast,项目名称:hazelcast-jet,代码行数:5,代码来源:ClientJobProxy.java
示例19: onResponse
import com.hazelcast.spi.serialization.SerializationService; //导入依赖的package包/类
@Override
public void onResponse(Object response) {
SerializationService serializationService = nodeEngine.getSerializationService();
sendResponse(serializationService.toData(response));
}
开发者ID:hazelcast,项目名称:hazelcast-jet,代码行数:6,代码来源:JetGetJobStatusMessageTask.java
示例20: ClientChannelHandler
import com.hazelcast.spi.serialization.SerializationService; //导入依赖的package包/类
ClientChannelHandler(@Nonnull MessageChannel messageChannel, @Nonnull SerializationService serializationService) {
this.messageChannel = messageChannel;
this.serializationService = serializationService;
}
开发者ID:noctarius,项目名称:snowcast,代码行数:5,代码来源:NodeSequencerService.java
注:本文中的com.hazelcast.spi.serialization.SerializationService类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论