Examples of registerProtofiles()

Examples of org.infinispan.query.remote.ProtobufMetadataManager.registerProtofiles()

66
67
68
69
70
71
72
73
74
75
76
                 String urlString = modelNode.asString();
                 nameArray[i] = extractFile(urlString);
                 contentArray[i] = Util.read(new URL(urlString).openStream());
                 i++;  
              }
              protoManager.registerProtofiles(nameArray,contentArray);
           } catch (Exception e) {
              throw new OperationFailedException(new ModelNode().set(MESSAGES.failedToInvokeOperation(e.getLocalizedMessage())));
           }
        }
        context.stepCompleted();
View Full Code Here

Examples of org.infinispan.query.remote.ProtobufMetadataManager.registerProtofiles()

50
51
52
53
54
55
56
57
58
59
60
            for (ModelNode modelNode : descriptorsNames) {
               nameArray[i] = modelNode.asString();
               contentArray[i] = descriptorsContents.get(i).asString();
               i++;
            }
            protoManager.registerProtofiles(nameArray, contentArray);
         } catch (Exception e) {
            throw new OperationFailedException(new ModelNode().set(MESSAGES.failedToInvokeOperation(e.getLocalizedMessage())));
         }
      }
      context.stepCompleted();
View Full Code Here

Examples of org.infinispan.query.remote.ProtobufMetadataManager.registerProtofiles()

63
64
65
66
67
68
69
70
71
72
73
   @BeforeClass(alwaysRun = true)
   protected void populateCache() throws Exception {
      //initialize server-side serialization context
      ProtobufMetadataManager protobufMetadataManager = manager(0).getGlobalComponentRegistry().getComponent(ProtobufMetadataManager.class);
      protobufMetadataManager.registerProtofiles(MarshallerRegistration.PROTOBUF_RES);

      //initialize client-side serialization context
      for (RemoteCacheManager rcm : clients) {
         MarshallerRegistration.registerMarshallers(ProtoStreamMarshaller.getSerializationContext(rcm));
      }
View Full Code Here

Examples of org.infinispan.query.remote.ProtobufMetadataManagerMBean.registerProtofiles()

90
91
92
93
94
95
96
97
98
99
100
                                                + ObjectName.quote("DefaultCacheManager")
                                                + ",component=" + ProtobufMetadataManager.OBJECT_NAME);

      MBeanServer mBeanServer = PerThreadMBeanServerLookup.getThreadMBeanServer();
      ProtobufMetadataManagerMBean protobufMetadataManagerMBean = JMX.newMBeanProxy(mBeanServer, objName, ProtobufMetadataManagerMBean.class);
      protobufMetadataManagerMBean.registerProtofiles(
              new String[]{"bank.proto","indexing.proto","descriptor.proto"},
              new String[]{
                      read("/sample_bank_account/bank.proto"),
                      read("/infinispan/indexing.proto"),
                      read("/google/protobuf/descriptor.proto")
View Full Code Here

Examples of org.infinispan.query.remote.ProtobufMetadataManagerMBean.registerProtofiles()

88
89
90
91
92
93
94
95
96
97
98
      remoteCache = remoteCacheManager.getCache(TEST_CACHE_NAME);

      mBeanServer = PerThreadMBeanServerLookup.getThreadMBeanServer();

      ProtobufMetadataManagerMBean protobufMetadataManagerMBean = JMX.newMBeanProxy(mBeanServer, getProtobufMetadataManagerObjectName(), ProtobufMetadataManagerMBean.class);
      protobufMetadataManagerMBean.registerProtofiles(
            new String[]{"bank.proto", "indexing.proto", "descriptor.proto"},
            new String[]{
                  read("/sample_bank_account/bank.proto"),
                  read("/infinispan/indexing.proto"),
                  read("/google/protobuf/descriptor.proto")
View Full Code Here

Examples of org.infinispan.query.remote.ProtobufMetadataManagerMBean.registerProtofiles()

88
89
90
91
92
93
94
95
96
97
98
      remoteCache = remoteCacheManager.getCache(TEST_CACHE_NAME);

      mBeanServer = PerThreadMBeanServerLookup.getThreadMBeanServer();

      ProtobufMetadataManagerMBean protobufMetadataManagerMBean = JMX.newMBeanProxy(mBeanServer, getProtobufMetadataManagerObjectName(), ProtobufMetadataManagerMBean.class);
      protobufMetadataManagerMBean.registerProtofiles(
            new String[]{"sample_bank_account/bank.proto", "infinispan/indexing.proto", "google/protobuf/descriptor.proto"},
            new String[]{
                  read("/sample_bank_account/bank.proto"),
                  read("/infinispan/indexing.proto"),
                  read("/google/protobuf/descriptor.proto")
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.