本文整理汇总了Java中org.infinispan.protostream.SerializationContext类的典型用法代码示例。如果您正苦于以下问题：Java SerializationContext类的具体用法？Java SerializationContext怎么用？Java SerializationContext使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
SerializationContext类属于org.infinispan.protostream包，在下文中一共展示了SerializationContext类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: registerProtoBufSchema
import org.infinispan.protostream.SerializationContext; //导入依赖的package包/类
private void registerProtoBufSchema() {
SerializationContext serCtx = ProtoStreamMarshaller.getSerializationContext(cacheManager);
String generatedSchema = null;
try {
ProtoSchemaBuilder protoSchemaBuilder = new ProtoSchemaBuilder();
generatedSchema = protoSchemaBuilder.fileName("heschema.proto").packageName("model")
.addClass(HEElementModel.class).addClass(HEElementCategoryModel.class).build(serCtx);
// register the schemas with the server too
RemoteCache<String, String> metadataCache = cacheManager
.getCache(ProtobufMetadataManagerConstants.PROTOBUF_METADATA_CACHE_NAME);
metadataCache.put("heschema.proto", generatedSchema);
} catch (Exception e1) {
StringBuilder sb = new StringBuilder();
sb.append("No schema generated because of Exception");
log.error(sb.toString(), e1);
}
log.debug(generatedSchema);
}
开发者ID:benemon，项目名称:he-rss-poll，代码行数:26，代码来源:AbstractJDGVerticle.java
示例2: setUp
import org.infinispan.protostream.SerializationContext; //导入依赖的package包/类
@Before
public void setUp() {
ConfigurationBuilder builder = new ConfigurationBuilder().addServer().host("localhost").port(11222)
.marshaller(new ProtoStreamMarshaller());
cacheManager = new RemoteCacheManager(builder.build());
SerializationContext serCtx = ProtoStreamMarshaller.getSerializationContext(cacheManager);
ProtoSchemaBuilder protoSchemaBuilder = new ProtoSchemaBuilder();
String memoSchemaFile = null;
try {
memoSchemaFile = protoSchemaBuilder.fileName("file.proto").packageName("test").addClass(Author.class)
.build(serCtx);
} catch (ProtoSchemaBuilderException | IOException e) {
e.printStackTrace();
}
// register the schemas with the server too
RemoteCache<String, String> metadataCache = cacheManager
.getCache(ProtobufMetadataManagerConstants.PROTOBUF_METADATA_CACHE_NAME);
metadataCache.put("file.proto", memoSchemaFile);
}
开发者ID:infinispan，项目名称:infinispan-kafka，代码行数:23，代码来源:InfinispanTaskTestIT.java
示例3: doPreSetup
import org.infinispan.protostream.SerializationContext; //导入依赖的package包/类
@Override
protected void doPreSetup() throws IOException {
ConfigurationBuilder builder = new ConfigurationBuilder()
.addServer()
.host("localhost")
.port(11222)
.marshaller(new ProtoStreamMarshaller());
manager = new RemoteCacheManager(builder.build());
RemoteCache<String, String> metadataCache = manager
.getCache(ProtobufMetadataManagerConstants.PROTOBUF_METADATA_CACHE_NAME);
metadataCache
.put("sample_bank_account/bank.proto",
Util.read(InfinispanRemoteQueryProducerIT.class
.getResourceAsStream("/sample_bank_account/bank.proto")));
MarshallerRegistration.registerMarshallers(ProtoStreamMarshaller
.getSerializationContext(manager));
SerializationContext serCtx = ProtoStreamMarshaller
.getSerializationContext(manager);
serCtx.registerProtoFiles(FileDescriptorSource
.fromResources("/sample_bank_account/bank.proto"));
serCtx.registerMarshaller(new UserMarshaller());
serCtx.registerMarshaller(new GenderMarshaller());
}
开发者ID:HydAu，项目名称:Camel，代码行数:27，代码来源:InfinispanRemoteQueryProducerIT.java
示例4: registerMarshallers
import org.infinispan.protostream.SerializationContext; //导入依赖的package包/类
@SuppressWarnings({ "rawtypes", "unchecked" })
protected void registerMarshallers(SerializationContext ctx, ClassLoader cl) throws ResourceException {
try {
FileDescriptorSource fds = new FileDescriptorSource();
fds.addProtoFile("protofile", cl.getResourceAsStream(getProtobufDefinitionFile() ) );
ctx.registerProtoFiles( fds );
List<Class<?>> registeredClasses = methodUtil.getRegisteredClasses();
for (Class clz:registeredClasses) {
BaseMarshaller m = messageMarshallerMap.get(clz.getName());
ctx.registerMarshaller(m);
}
} catch (IOException e) {
throw new ResourceException(InfinispanPlugin.Util.gs(InfinispanPlugin.Event.TEIID25032), e);
}
}
开发者ID:kenweezy，项目名称:teiid，代码行数:20，代码来源:AbstractInfinispanManagedConnectionFactory.java
示例5: build
import org.infinispan.protostream.SerializationContext; //导入依赖的package包/类
/**
* Builds the Protocol Buffers schema file defining the types and generates marshaller implementations for these
* types and registers everything with the given {@link SerializationContext}.
*
* @param serializationContext
* @return the generated Protocol Buffers schema file
* @throws ProtoSchemaBuilderException
* @throws IOException
*/
public String build(SerializationContext serializationContext) throws ProtoSchemaBuilderException, IOException {
if (fileName == null) {
throw new ProtoSchemaBuilderException("fileName cannot be null");
}
if (classes.isEmpty()) {
throw new ProtoSchemaBuilderException("At least one class must be specified");
}
String schemaFile = new ProtoSchemaGenerator(serializationContext, fileName, packageName, classes)
.generateAndRegister();
fileName = null;
packageName = null;
classes.clear();
return schemaFile;
}
开发者ID:infinispan，项目名称:protostream，代码行数:26，代码来源:ProtoSchemaBuilder.java
示例6: createCtxWithHandWrittenMarshaller
import org.infinispan.protostream.SerializationContext; //导入依赖的package包/类
private SerializationContext createCtxWithHandWrittenMarshaller() throws IOException {
Configuration.Builder cfgBuilder = Configuration.builder()
.setLogOutOfSequenceWrites(false)
.setLogOutOfSequenceReads(false);
SerializationContext ctx = createContext(cfgBuilder);
String file = " package sample_bank_account;\n" +
"import \"sample_bank_account/bank.proto\";\n" +
"message Note {\n" +
" optional string text = 1;\n" +
" optional User author = 2;\n" +
" optional Note note = 3;\n" +
" repeated Note notes = 4;\n" +
" optional uint64 creationDate = 5 [default = 0];\n" +
" optional bytes digest = 6;\n" +
"}\n";
ctx.registerProtoFiles(FileDescriptorSource.fromString("note.proto", file));
ctx.registerMarshaller(new UserMarshaller());
ctx.registerMarshaller(new NoteMarshaller());
return ctx;
}
开发者ID:infinispan，项目名称:protostream，代码行数:23，代码来源:AnnotationsPerformanceTest.java
示例7: createCtxWithGeneratedMarshaller
import org.infinispan.protostream.SerializationContext; //导入依赖的package包/类
private SerializationContext createCtxWithGeneratedMarshaller() throws IOException {
Configuration.Builder cfgBuilder = Configuration.builder()
.setLogOutOfSequenceWrites(false)
.setLogOutOfSequenceReads(false);
SerializationContext ctx = createContext(cfgBuilder);
ProtoSchemaBuilder protoSchemaBuilder = new ProtoSchemaBuilder();
protoSchemaBuilder
.fileName("note.proto")
.packageName("sample_bank_account2")
.addClass(User.class)
.addClass(Note.class)
.build(ctx);
return ctx;
}
开发者ID:infinispan，项目名称:protostream，代码行数:17，代码来源:AnnotationsPerformanceTest.java
示例8: writeWithProtoStream
import org.infinispan.protostream.SerializationContext; //导入依赖的package包/类
private byte[] writeWithProtoStream(User user, long[] result) throws IOException, DescriptorParserException {
Configuration.Builder cfgBuilder = Configuration.builder().setLogOutOfSequenceWrites(false);
SerializationContext ctx = createContext(cfgBuilder);
ByteArrayOutputStream out = new ByteArrayOutputStream(1024);
long tStart = System.nanoTime();
for (int i = 0; i < NUM_INNER_LOOPS; i++) {
ProtobufUtil.writeTo(ctx, out, user);
if (i != NUM_INNER_LOOPS - 1) {
out.reset();
}
}
result[0] = System.nanoTime() - tStart;
log.infof("ProtoStream write duration = %d ns", result[0]);
return out.toByteArray();
}
开发者ID:infinispan，项目名称:protostream，代码行数:17，代码来源:PerformanceTest.java
示例9: testGeneration2
import org.infinispan.protostream.SerializationContext; //导入依赖的package包/类
@Test
public void testGeneration2() throws Exception {
SerializationContext ctx = createContext();
ProtoSchemaBuilder protoSchemaBuilder = new ProtoSchemaBuilder();
protoSchemaBuilder
.fileName("test.proto")
.packageName("test_package")
.addClass(TestArraysAndCollectionsClass.class)
.build(ctx);
assertTrue(ctx.canMarshall(TestArraysAndCollectionsClass.class));
assertTrue(ctx.canMarshall("test_package.TestArraysAndCollectionsClass"));
TestArraysAndCollectionsClass testObject = new TestArraysAndCollectionsClass();
byte[] bytes = ProtobufUtil.toWrappedByteArray(ctx, testObject);
Object unmarshalled = ProtobufUtil.fromWrappedByteArray(ctx, bytes);
assertTrue(unmarshalled instanceof TestArraysAndCollectionsClass);
}
开发者ID:infinispan，项目名称:protostream，代码行数:20，代码来源:ProtoSchemaBuilderTest.java
示例10: testGeneration3
import org.infinispan.protostream.SerializationContext; //导入依赖的package包/类
@Test
public void testGeneration3() throws Exception {
SerializationContext ctx = createContext();
ProtoSchemaBuilder protoSchemaBuilder = new ProtoSchemaBuilder();
protoSchemaBuilder
.fileName("test.proto")
.packageName("test_package")
.addClass(TestArraysAndCollectionsClass2.class)
.build(ctx);
assertTrue(ctx.canMarshall(TestArraysAndCollectionsClass2.class));
assertTrue(ctx.canMarshall("test_package.TestArraysAndCollectionsClass2"));
TestArraysAndCollectionsClass2 testObject = new TestArraysAndCollectionsClass2();
byte[] bytes = ProtobufUtil.toWrappedByteArray(ctx, testObject);
Object unmarshalled = ProtobufUtil.fromWrappedByteArray(ctx, bytes);
assertTrue(unmarshalled instanceof TestArraysAndCollectionsClass2);
}
开发者ID:infinispan，项目名称:protostream，代码行数:20，代码来源:ProtoSchemaBuilderTest.java
示例11: testTwoFilesGeneration
import org.infinispan.protostream.SerializationContext; //导入依赖的package包/类
@Test
public void testTwoFilesGeneration() throws Exception {
SerializationContext ctx = createContext();
ProtoSchemaBuilder protoSchemaBuilder1 = new ProtoSchemaBuilder();
protoSchemaBuilder1
.fileName("test1.proto")
.packageName("test_package1")
.addClass(TestEnum.class)
.build(ctx);
assertTrue(ctx.canMarshall(TestEnum.class));
assertTrue(ctx.canMarshall("test_package1.TestEnumABC"));
ProtoSchemaBuilder protoSchemaBuilder2 = new ProtoSchemaBuilder();
protoSchemaBuilder2
.fileName("test2.proto")
.packageName("test_package2")
.addClass(TestClass.class)
.build(ctx);
assertTrue(ctx.canMarshall(TestClass.class));
assertTrue(ctx.canMarshall("test_package2.TestClass"));
assertFalse(ctx.canMarshall("test_package2.TestEnumABC"));
}
开发者ID:infinispan，项目名称:protostream，代码行数:26，代码来源:ProtoSchemaBuilderTest.java
示例12: startInternal
import org.infinispan.protostream.SerializationContext; //导入依赖的package包/类
protected void startInternal() throws Exception {
SerializationContext serializationContext = ProtoStreamMarshaller.getSerializationContext(remoteCacheManager);
String protoFile = builder.build(serializationContext);
//initialize server-side serialization context
RemoteCache<String, String> metadataCache = remoteCacheManager.getCache(ProtobufMetadataManagerConstants.PROTOBUF_METADATA_CACHE_NAME);
metadataCache.put(fileName, protoFile);
Object error = metadataCache.get(fileName + ProtobufMetadataManagerConstants.ERRORS_KEY_SUFFIX);
if (error != null) {
throw new IllegalStateException("Protobuf metadata failed: " + error);
}
}
开发者ID:snowdrop，项目名称:spring-data-snowdrop，代码行数:14，代码来源:ProtobufInitializer.java
示例13: doPreSetup
import org.infinispan.protostream.SerializationContext; //导入依赖的package包/类
@Override
protected void doPreSetup() throws IOException {
ConfigurationBuilder builder = new ConfigurationBuilder()
.addServer()
.host("localhost")
.port(11222)
.marshaller(new ProtoStreamMarshaller());
manager = new RemoteCacheManager(builder.build());
RemoteCache<String, String> metadataCache = manager.getCache(
ProtobufMetadataManagerConstants.PROTOBUF_METADATA_CACHE_NAME);
metadataCache.put(
"sample_bank_account/bank.proto",
Util.read(InfinispanContinuousQueryIT.class.getResourceAsStream("/sample_bank_account/bank.proto")));
MarshallerRegistration.registerMarshallers(ProtoStreamMarshaller.getSerializationContext(manager));
SerializationContext serCtx = ProtoStreamMarshaller.getSerializationContext(manager);
serCtx.registerProtoFiles(FileDescriptorSource.fromResources("/sample_bank_account/bank.proto"));
serCtx.registerMarshaller(new UserMarshaller());
serCtx.registerMarshaller(new GenderMarshaller());
// pre-load data
cache = manager.getCache("remote_query");
cache.clear();
}
开发者ID:HydAu，项目名称:Camel，代码行数:28，代码来源:InfinispanContinuousQueryIT.java
示例14: registerMarshallers
import org.infinispan.protostream.SerializationContext; //导入依赖的package包/类
public static void registerMarshallers(SerializationContext ctx) throws IOException, DescriptorParserException {
ctx.registerProtoFiles(FileDescriptorSource.fromResources(PROTOBUF_RES));
ctx.registerMarshaller(new UserMarshaller());
ctx.registerMarshaller(new GenderMarshaller());
ctx.registerMarshaller(new AddressMarshaller());
ctx.registerMarshaller(new AccountMarshaller());
ctx.registerMarshaller(new LimitsMarshaller());
ctx.registerMarshaller(new TransactionMarshaller());
}
开发者ID:infinispan，项目名称:protostream，代码行数:10，代码来源:MarshallerRegistration.java
示例15: readWithProtoStream
import org.infinispan.protostream.SerializationContext; //导入依赖的package包/类
private long readWithProtoStream(SerializationContext ctx, byte[] bytes) throws IOException {
ByteArrayInputStream bais = new ByteArrayInputStream(bytes);
long tStart = System.nanoTime();
for (int i = 0; i < NUM_LOOPS; i++) {
ProtobufUtil.readFrom(ctx, bais, Note.class);
bais.close();
bais.reset();
}
long duration = System.nanoTime() - tStart;
return duration / NUM_LOOPS;
}
开发者ID:infinispan，项目名称:protostream，代码行数:12，代码来源:AnnotationsPerformanceTest.java
示例16: writeWithProtoStream
import org.infinispan.protostream.SerializationContext; //导入依赖的package包/类
private byte[] writeWithProtoStream(SerializationContext ctx, Note note) throws IOException {
ByteArrayOutputStream out = new ByteArrayOutputStream(1024);
long tStart = System.nanoTime();
for (int i = 0; i < NUM_LOOPS; i++) {
ProtobufUtil.writeTo(ctx, out, note);
if (i != NUM_LOOPS - 1) {
out.reset();
}
}
long duration = System.nanoTime() - tStart;
log.infof("ProtoStream write duration = %d ns", duration / NUM_LOOPS);
return out.toByteArray();
}
开发者ID:infinispan，项目名称:protostream，代码行数:14，代码来源:AnnotationsPerformanceTest.java
示例17: readWithProtoStream
import org.infinispan.protostream.SerializationContext; //导入依赖的package包/类
private void readWithProtoStream(byte[] bytes, long[] result) throws IOException, DescriptorParserException {
Configuration.Builder cfgBuilder = Configuration.builder().setLogOutOfSequenceReads(false);
SerializationContext ctx = createContext(cfgBuilder);
ByteArrayInputStream bais = new ByteArrayInputStream(bytes);
long tStart = System.nanoTime();
for (int i = 0; i < NUM_INNER_LOOPS; i++) {
ProtobufUtil.readFrom(ctx, bais, User.class);
bais.close();
bais.reset();
}
result[0] = System.nanoTime() - tStart;
log.infof("ProtoStream read duration = %d ns", result[0]);
}
开发者ID:infinispan，项目名称:protostream，代码行数:16，代码来源:PerformanceTest.java
示例18: testNullFileName
import org.infinispan.protostream.SerializationContext; //导入依赖的package包/类
@Test
public void testNullFileName() throws Exception {
exception.expect(ProtoSchemaBuilderException.class);
exception.expectMessage("fileName cannot be null");
SerializationContext ctx = createContext();
ProtoSchemaBuilder protoSchemaBuilder = new ProtoSchemaBuilder();
protoSchemaBuilder.addClass(Simple.class).build(ctx);
}
开发者ID:infinispan，项目名称:protostream，代码行数:10，代码来源:ProtoSchemaBuilderTest.java
示例19: testNoAnnotations
import org.infinispan.protostream.SerializationContext; //导入依赖的package包/类
@Test
public void testNoAnnotations() throws Exception {
exception.expect(ProtoSchemaBuilderException.class);
exception.expectMessage("Class java.lang.Object does not have any @ProtoField annotated fields. The class should be either annotated or it should have a custom marshaller");
SerializationContext ctx = createContext();
ProtoSchemaBuilder protoSchemaBuilder = new ProtoSchemaBuilder();
protoSchemaBuilder.fileName("test.proto");
protoSchemaBuilder.addClass(Object.class).build(ctx);
}
开发者ID:infinispan，项目名称:protostream，代码行数:11，代码来源:ProtoSchemaBuilderTest.java
示例20: testDocumentation
import org.infinispan.protostream.SerializationContext; //导入依赖的package包/类
@Test
public void testDocumentation() throws Exception {
SerializationContext ctx = createContext();
ProtoSchemaBuilder protoSchemaBuilder = new ProtoSchemaBuilder();
String schemaFile = protoSchemaBuilder
.fileName("test1.proto")
.packageName("test_package1")
.addClass(TestEnum.class)
.addClass(TestClass.class)
.build(ctx);
FileDescriptorSource fileDescriptorSource = FileDescriptorSource.fromString("test1.proto", schemaFile);
Map<String, FileDescriptor> fileDescriptors = new SquareProtoParser(ctx.getConfiguration()).parse(fileDescriptorSource);
FileDescriptor fd = fileDescriptors.get("test1.proto");
assertNotNull(fd);
Map<String, EnumDescriptor> enums = new HashMap<>();
for (EnumDescriptor e : fd.getEnumTypes()) {
enums.put(e.getFullName(), e);
}
Map<String, Descriptor> messages = new HashMap<>();
for (Descriptor m : fd.getMessageTypes()) {
messages.put(m.getFullName(), m);
}
EnumDescriptor testEnum = enums.get("test_package1.TestEnumABC");
assertNotNull(testEnum);
assertEquals("bla bla bla\nand some more bla", testEnum.getDocumentation());
assertEquals("This should never be read.", testEnum.getValues().get(0).getDocumentation());
Descriptor testClass = messages.get("test_package1.TestClass");
assertNotNull(testClass);
assertEquals("@Indexed()\nbla bla bla\nand some more bla", testClass.getDocumentation());
assertEquals("The surname, of course", testClass.getFields().get(0).getDocumentation());
}
开发者ID:infinispan，项目名称:protostream，代码行数:41，代码来源:ProtoSchemaBuilderTest.java
注：本文中的org.infinispan.protostream.SerializationContext类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论