org.infinispan.query.remote

Class ProtobufMetadataManager

java.lang.Object

org.infinispan.query.remote.ProtobufMetadataManager

All Implemented Interfaces:

ProtobufMetadataManagerMBean

public class ProtobufMetadataManager
extends Object
implements ProtobufMetadataManagerMBean

A clustered repository of protobuf descriptors. All protobuf types and their marshallers must be registered with this repository before being used.

Since:

6.0

Author:

anistor@redhat.com

Field Summary

Fields

Modifier and Type	Field and Description
static String	OBJECT_NAME

Constructor Summary

Constructors

Constructor and Description
ProtobufMetadataManager(org.infinispan.protostream.SerializationContext serCtx)

Method Summary

Methods

Modifier and Type	Method and Description
ObjectName	getObjectName()
static org.infinispan.protostream.SerializationContext	getSerializationContext(EmbeddedCacheManager cacheManager)
protected void	injectDependencies(ClusterRegistry<String,String,byte[]> clusterRegistry)
<T> void	registerMarshaller(Class<? extends T> clazz, org.infinispan.protostream.BaseMarshaller<T> marshaller)
void	registerProtofile(byte[] descriptorFile)
void	registerProtofile(InputStream descriptorFile)
void	registerProtofile(String classpathResource)
void	setObjectName(ObjectName objectName)
protected void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

OBJECT_NAME

public static final String OBJECT_NAME

See Also:

Constant Field Values

Constructor Detail

ProtobufMetadataManager

public ProtobufMetadataManager(org.infinispan.protostream.SerializationContext serCtx)

Method Detail

injectDependencies

protected void injectDependencies(ClusterRegistry<String,String,byte[]> clusterRegistry)

stop

protected void stop()

getObjectName

public ObjectName getObjectName()

setObjectName

public void setObjectName(ObjectName objectName)

registerMarshaller

public <T> void registerMarshaller(Class<? extends T> clazz,
                          org.infinispan.protostream.BaseMarshaller<T> marshaller)

registerProtofile

public void registerProtofile(byte[] descriptorFile)

Specified by:

registerProtofile in interface ProtobufMetadataManagerMBean

registerProtofile

public void registerProtofile(InputStream descriptorFile)
                       throws IOException,
                              com.google.protobuf.Descriptors.DescriptorValidationException

Throws:

IOException

com.google.protobuf.Descriptors.DescriptorValidationException

registerProtofile

public void registerProtofile(String classpathResource)
                       throws IOException,
                              com.google.protobuf.Descriptors.DescriptorValidationException

Throws:

IOException

com.google.protobuf.Descriptors.DescriptorValidationException

getSerializationContext

public static org.infinispan.protostream.SerializationContext getSerializationContext(EmbeddedCacheManager cacheManager)