public abstract class AbstractCommunicationChannelServer extends Object implements CommunicationChannelServer
An Abstract Communication Channel Server Interface that automatically handles throw exceptions
Modifier and Type | Field and Description |
---|---|
protected CatalogService |
catalogService |
protected int |
port |
protected Serializer |
serializer |
Constructor and Description |
---|
AbstractCommunicationChannelServer() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
startup
protected CatalogService catalogService
protected int port
protected Serializer serializer
public void setCatalogService(CatalogService catalogService)
setCatalogService
in interface CommunicationChannelServer
public void setPort(int port)
setPort
in interface CommunicationChannelServer
public int getPort()
getPort
in interface CommunicationChannelServer
public void shutdown() throws Exception
shutdown
in interface CommunicationChannelServer
Exception
public boolean isRestrictQueryPermissions() throws Exception
isRestrictQueryPermissions
in interface CommunicationChannelServer
Exception
public boolean isRestrictIngestPermissions() throws Exception
isRestrictIngestPermissions
in interface CommunicationChannelServer
Exception
public void addCatalog(Catalog catalog) throws Exception
addCatalog
in interface CommunicationChannelServer
Exception
public void replaceCatalog(Catalog catalog) throws Exception
replaceCatalog
in interface CommunicationChannelServer
Exception
public void addCatalog(String catalogId, Index index) throws Exception
addCatalog
in interface CommunicationChannelServer
Exception
public void addCatalog(String catalogId, Index index, List<Dictionary> dictionaries) throws Exception
addCatalog
in interface CommunicationChannelServer
Exception
public void addCatalog(String catalogId, Index index, List<Dictionary> dictionaries, boolean restrictQueryPermission, boolean restrictIngestPermission) throws Exception
addCatalog
in interface CommunicationChannelServer
Exception
public void addDictionary(String catalogId, Dictionary dictionary) throws Exception
addDictionary
in interface CommunicationChannelServer
Exception
public void replaceDictionaries(String catalogId, List<Dictionary> dictionaries) throws Exception
replaceDictionaries
in interface CommunicationChannelServer
Exception
public void replaceIndex(String catalogId, Index index) throws Exception
replaceIndex
in interface CommunicationChannelServer
Exception
public void modifyIngestPermission(String catalogId, boolean restrictIngestPermission) throws Exception
modifyIngestPermission
in interface CommunicationChannelServer
Exception
public void modifyQueryPermission(String catalogId, boolean restrictQueryPermission) throws Exception
modifyQueryPermission
in interface CommunicationChannelServer
Exception
public void removeCatalog(String catalogId) throws Exception
removeCatalog
in interface CommunicationChannelServer
Exception
public List<PluginURL> getPluginUrls() throws Exception
getPluginUrls
in interface CommunicationChannelServer
Exception
public void addPluginUrls(List<PluginURL> pluginURLs) throws Exception
addPluginUrls
in interface CommunicationChannelServer
Exception
public URL getPluginStorageDir() throws Exception
getPluginStorageDir
in interface CommunicationChannelServer
Exception
public Set<String> getCurrentCatalogIds() throws Exception
getCurrentCatalogIds
in interface CommunicationChannelServer
Exception
public TransactionReceipt ingest(Metadata metadata) throws Exception
ingest
in interface CommunicationChannelServer
Exception
public void delete(Metadata metadata) throws Exception
delete
in interface CommunicationChannelServer
Exception
public List<String> getProperty(String key) throws Exception
getProperty
in interface CommunicationChannelServer
Exception
public Properties getCalalogProperties() throws Exception
getCalalogProperties
in interface CommunicationChannelServer
Exception
public Properties getCalalogProperties(String catalogId) throws Exception
getCalalogProperties
in interface CommunicationChannelServer
Exception
public Page getNextPage(Page page) throws Exception
getNextPage
in interface CommunicationChannelServer
Exception
public Page getPage(PageInfo pageInfo, QueryExpression queryExpression) throws Exception
getPage
in interface CommunicationChannelServer
Exception
public Page getPage(PageInfo pageInfo, QueryExpression queryExpression, Set<String> catalogIds) throws Exception
getPage
in interface CommunicationChannelServer
Exception
public List<TransactionalMetadata> getMetadata(Page page) throws Exception
getMetadata
in interface CommunicationChannelServer
Exception
public QueryPager query(QueryExpression queryExpression) throws Exception
query
in interface CommunicationChannelServer
Exception
public QueryPager query(QueryExpression queryExpression, Set<String> catalogIds) throws Exception
query
in interface CommunicationChannelServer
Exception
public List<TransactionalMetadata> getNextPage(QueryPager queryPager) throws Exception
getNextPage
in interface CommunicationChannelServer
Exception
public List<TransactionalMetadata> getAllPages(QueryPager queryPager) throws Exception
getAllPages
in interface CommunicationChannelServer
Exception
public List<TransactionalMetadata> getMetadataFromTransactionIdStrings(List<String> catalogServiceTransactionIdStrings) throws Exception
getMetadataFromTransactionIdStrings
in interface CommunicationChannelServer
Exception
public List<TransactionalMetadata> getMetadataFromTransactionIds(List<TransactionId<?>> catalogServiceTransactionIds) throws Exception
getMetadataFromTransactionIds
in interface CommunicationChannelServer
Exception
public List<TransactionId<?>> getCatalogServiceTransactionIds(List<TransactionId<?>> catalogTransactionIds, String catalogId) throws Exception
getCatalogServiceTransactionIds
in interface CommunicationChannelServer
Exception
public TransactionId<?> getCatalogServiceTransactionId(TransactionId<?> catalogTransactionId, String catalogId) throws Exception
getCatalogServiceTransactionId
in interface CommunicationChannelServer
Exception
public TransactionId<?> getCatalogServiceTransactionId(CatalogReceipt catalogReceipt, boolean generateNew) throws Exception
getCatalogServiceTransactionId
in interface CommunicationChannelServer
Exception
Copyright © 1999-2014 Apache OODT. All Rights Reserved.