com.tibco.messaging.schema.registry

Class SchemaRegistryCache

java.lang.Object

com.tibco.messaging.schema.registry.SchemaRegistryCache

public class SchemaRegistryCache
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	SchemaRegistryCache.Compatibility

Field Summary

Fields

Modifier and Type	Field and Description
static int	LATEST_VERSION

Constructor Summary

Constructors

Constructor and Description
SchemaRegistryCache(java.lang.String[] registryServerURLs)
SchemaRegistryCache(java.lang.String[] registryServerURLs, java.lang.String trustType, java.lang.String trustFile, java.lang.String trustString, java.lang.String userName, java.lang.String userPassword)

Method Summary

Modifier and Type	Method and Description
void	deleteSubject(java.lang.String subject)
org.apache.avro.Schema	getSchema(int id)
org.apache.avro.Schema	getSchema(java.lang.String hash)
org.apache.avro.Schema	getSchema(java.lang.String subject, int version)
java.lang.String	getSchemaHash(org.apache.avro.Schema schema)
java.lang.String	getSchemaHash(org.apache.avro.Schema schema, java.util.List<SchemaReference> references)
int	getSchemaID(java.lang.String subject, int version)
int	getSchemaID(java.lang.String subject, org.apache.avro.Schema schema)
int	putSchema(java.lang.String subject, org.apache.avro.Schema schema)
int	putSchema(java.lang.String subject, org.apache.avro.Schema schema, java.util.List<SchemaReference> references)
int	putSchema(java.lang.String subject, java.lang.String schema)
int	putSchema(java.lang.String subject, java.lang.String schema, java.util.List<SchemaReference> references)

Methods inherited from class java.lang.Object

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

Field Detail

LATEST_VERSION

public static final int LATEST_VERSION

See Also:

Constant Field Values

Constructor Detail

SchemaRegistryCache

public SchemaRegistryCache(java.lang.String[] registryServerURLs)

SchemaRegistryCache

public SchemaRegistryCache(java.lang.String[] registryServerURLs,
                           java.lang.String trustType,
                           java.lang.String trustFile,
                           java.lang.String trustString,
                           java.lang.String userName,
                           java.lang.String userPassword)

Method Detail

getSchema

public org.apache.avro.Schema getSchema(int id)
                                 throws java.io.IOException

Throws:

java.io.IOException

deleteSubject

public void deleteSubject(java.lang.String subject)
                   throws java.io.IOException

Throws:

java.io.IOException

getSchema

public org.apache.avro.Schema getSchema(java.lang.String subject,
                                        int version)
                                 throws java.io.IOException

Throws:

java.io.IOException

getSchemaID

public int getSchemaID(java.lang.String subject,
                       int version)
                throws java.io.IOException

Throws:

java.io.IOException

putSchema

public int putSchema(java.lang.String subject,
                     java.lang.String schema)
              throws java.io.IOException

Throws:

java.io.IOException

putSchema

public int putSchema(java.lang.String subject,
                     java.lang.String schema,
                     java.util.List<SchemaReference> references)
              throws java.io.IOException

Throws:

java.io.IOException

putSchema

public int putSchema(java.lang.String subject,
                     org.apache.avro.Schema schema)
              throws java.io.IOException

Throws:

java.io.IOException

putSchema

public int putSchema(java.lang.String subject,
                     org.apache.avro.Schema schema,
                     java.util.List<SchemaReference> references)
              throws java.io.IOException

Throws:

java.io.IOException

getSchemaID

public int getSchemaID(java.lang.String subject,
                       org.apache.avro.Schema schema)
                throws java.io.IOException

Throws:

java.io.IOException

getSchemaHash

public java.lang.String getSchemaHash(org.apache.avro.Schema schema,
                                      java.util.List<SchemaReference> references)
                               throws java.io.IOException

Throws:

java.io.IOException

getSchemaHash

public java.lang.String getSchemaHash(org.apache.avro.Schema schema)
                               throws java.io.IOException

Throws:

java.io.IOException

getSchema

public org.apache.avro.Schema getSchema(java.lang.String hash)
                                 throws java.io.IOException

Throws:

java.io.IOException