Uses of Class
com.streambase.liveview.client.LiveViewException
Packages that use LiveViewException
Package
Description
Provides classes and interfaces fundamental to the LiveView Java API.
Provides classes and interfaces to set Alerts.
Provides classes and interfaces to control user's interaction with LiveView.
Provides classes and interfaces to fetch LiveView server's utility data.
Provides classes and interfaces to add custom table providers for LiveView.
-
Uses of LiveViewException in com.streambase.liveview.client
Subclasses of LiveViewException in com.streambase.liveview.clientModifier and TypeClassDescriptionfinal classException throws when the LiveView connection call is cancelled by the clientfinal classSpecific LiveViewException thrown when query syntax error occursMethods in com.streambase.liveview.client that return LiveViewExceptionModifier and TypeMethodDescriptionstatic LiveViewExceptionWraps any throwable into a LiveViewException of type LiveViewExceptionType.UNEXPECTEDDynamicTableState.getException()PublisherExceptionEvent.getException()Get the correspondingLiveViewException.QueryExceptionEvent.getException()Get the exceptionMethods in com.streambase.liveview.client with parameters of type LiveViewExceptionMethods in com.streambase.liveview.client that throw LiveViewExceptionModifier and TypeMethodDescriptionvoidTableAdminManager.addTableProvider(String id, com.streambase.liveview.internal.protocol.jaxb.ExternalConnectionTypeType externalConnectionType, String javaClassName, com.streambase.liveview.internal.protocol.jaxb.ExternalServerConnectionType.Parameters parameters, com.streambase.liveview.internal.protocol.jaxb.ExternalServerConnectionType.Mappings mappings, int maxFailAttempts, int waitSeconds) Connect to a TableProvider, which then allows for remote connections to behave as if they were LiveView Tables.booleanLiveViewConnection.checkPermission(LiveViewPermission permission) Checks whether the authenticated user has the specified permission.LiveViewConnection.checkPermissions(List<LiveViewPermission> permissions) Checks whether the authenticated user has the specified permissions.voidTableAdminManager.createAggregateTable(String tablename, String descripton, QueryConfig aggregateQuery, List<List<String>> indices) Create a table that is based on an aggregate query against an existing table.voidTableAdminManager.createTable(TableConfig tableConfig) Create a table using a TableConfigvoidTableAdminManager.createTable(String tableName, String description, Schema schema, String... primaryKeyFields) Convenience form of the previous method, used if there is only a primary key.voidTableAdminManager.createTable(String tableName, String description, Schema schema, List<List<String>> indices) Create a table on the server without any LVConf which represents it.voidTableAdminManager.createTable(String tableName, String description, String schema, String... primaryKeyFields) Convenience form of the previous method, used if there is only a primary key.voidTableAdminManager.createTable(String tableName, String description, String schema, List<List<String>> indices) Create a table on the server without any LVConf which represents it.voidLiveViewConnection.deleteRows(QueryConfig config) Delete rows based on the suppliedQueryConfig.LiveViewConnection.describeQuery(QueryConfig config) Get information about a query, such as its result schema, without actually running itvoidTableAdminManager.dropTables(String... tables) This will drop the tables in the list.LiveViewConnection.executeSnapshotQuery(QueryConfig config) This method makes it easy to run a snapshot-only query where the results come back in an object that can be iterated over to retrieve the snapshot tuples.voidTablePublisher.flush()Force the currently buffered tuples to be sent to the server.static ConnectionConfigConnectionConfig.fromTcdsAuthUri(String uri, LiveViewAuth lvauth) Creates a connection config from a TCDS URI and authentication (optional).LiveViewConnection.getAlertManager()<T extends LiveViewServerCapability>
TLiveViewConnection.getCapability(Class<T> typeOfCapability) Returns the object that represents a capability of the connected server, or throws NoSuchCapabilityException if the type of capability is not supported by the server.LiveViewConnection.getClientController()A ClientController is used to perform actions to control clients.static LiveViewConnectionLiveViewConnectionFactory.getConnection(ConnectionConfig config) Retrieves aLiveViewConnectionbased on theConnectionConfigstatic LiveViewMultiConnectionLiveViewConnectionFactory.getConnection(MultiConnectionConfig config, boolean waitForConnection) Retrieves aLiveViewMultiConnectionbased on the givenMultiConnectionConfig.static LiveViewConnectionLiveViewConnectionFactory.getConnection(String uri) Retrieves aLiveViewConnectionbased on a valid URI.DeleteQueryListener.getFields()Retrieves the fields describing the tuples that will be returned.SnapshotQueryListener.getFields()Retrieves the fields describing the tuples that will be returned.SnapshotResult.getFields()Retrieves the fields describing the tuples that will be returned.TablePublisher.getPublisherListener()Gets thePublisherListenerassociated with thisTablePublisherLiveViewConnection.getSendTupleInfo(StreamBaseURI sbUri, String targetInputStreamName, String responseOutputStreamName) Gets the schemas associated with streams, for the purposes of using SendTupleAction.LiveViewConnection.getServerUtilityDataProvider()TablePublisher.getStatus()Gets the latestPublisherStatusfor the currentTablePublisherRetrieve a specific table from the serverLiveViewConnection.getTableAdminManager()Get the TableAdminManager, which provides an API to administer tables in the server.Table.getTablePublisher(String publisherName, int bufferSize, long flushInterval, TimeUnit flushIntervalUnit, PublisherListener pubListener, PubListenerConfig pubListenerConfig) Retrieve aTablePublisherpublisher instance allowing the client to publish data to the table.Table.getTablePublisher(String publisherName, PublisherListener pubListener, PubListenerConfig pubListenerConfig) Retrieve aTablePublisherinstance allowing a client to publish data to this table with the default buffer sizeTablePublisher.PUBLISH_BUFFER_SIZE_DEFAULTand flush intervalTablePublisher.PUBLISH_INTERVAL_DEFAULT.booleanDeleteQueryListener.hasNext()See if there are more tuples to retrieve.booleanSnapshotQueryListener.hasNext()See if there are more tuples to retrieve.booleanSnapshotResult.hasNext()See if there are more tuples to retrieve.LiveViewConnection.listTables()Lists the available tables for queryingLiveViewConnection.listTables(boolean includeSystemTables) List the available tables for queryingDeleteQueryListener.next()Retrieves the next tuple in the result.SnapshotQueryListener.next()Retrieves the next tuple in the result.SnapshotResult.next()Retrieves the next tuple in the result.voidPublish a tuple with a sequenceNumber.voidPublish a tuple with a sequenceNumber.voidPublish a tuple without regard for recovering since no sequence number is specified.voidPublish a tuple without regard for recovering since no sequence number is specified.voidLiveViewConnection.registerTableListListener(TableListListener listener, boolean includeSnapshot) If you want to be informed of changes to the Table List, then register a Listener with this method.voidTableAdminManager.removeTableProvider(String id) Disconnect a previously-connected TableProviderLiveViewConnection.sendTupleAction(StreamBaseURI sbUri, String targetInputStreamName, Tuple tuple, String responseOutputStreamName, Schema expectedResponseSchema, long timeout, TimeUnit unit) Sends a tuple to an existing StreamBase application.ConnectionConfig.setPassword(String password) Deprecated.Use get/setAuthentication instead.Set the uri to connect with.ConnectionConfig.setUsername(String username) Deprecated.Use get/setAuthentication instead.voidTableAdminManager.startTables(String... tables) This will start all the tables in the list AND any applications or elements upon which they depend.Constructors in com.streambase.liveview.client with parameters of type LiveViewExceptionModifierConstructorDescriptionPublisherExceptionEvent(Object source, LiveViewException exception) QueryExceptionEvent(Object source, LiveViewException exception) Constructors in com.streambase.liveview.client that throw LiveViewExceptionModifierConstructorDescriptionAbstractTable(Schema schema, String keyFieldNamesCSV) AbstractTable(Schema schema, List<String> keyFieldNames) MultiConnectionConfig(List<String> uris, String username, String password, MultiConnectionListener listener) Use this constructor if the servers all use the same username and password (which can be null) -
Uses of LiveViewException in com.streambase.liveview.client.alert
Methods in com.streambase.liveview.client.alert that throw LiveViewExceptionModifier and TypeMethodDescriptionbooleanIExecJavaAction.action(com.streambase.liveview.internal.protocol.jaxb.AlertRule actionRule, com.streambase.liveview.internal.protocol.jaxb.AlertRule.Actions.Action action, TupleAddedEvent event) Deprecated.Use ExecJavaActionClassvoidAlertManager.deleteAlertRule(String guid) Deletes theAlertRulefrom the server that matches the given GUID.AlertManager.getAlertRule(String guid) Gets the alert rule specified by the GUID.AlertManager.getAlertRules(String user) Gets all available alert rules from the server for the given user.AlertManager.getKnownSettableAlertGroups()Gets all the alert groups that the server knows about that you have permission to setAlertManager.setAlertRule(AlertRule rule) Adds if it does not previously exist, or overwrites if it does (matching by id), the given alert rule onto the server.voidAlertManager.validateAlertRule(AlertRule rule) Validates the given alert rule. -
Uses of LiveViewException in com.streambase.liveview.client.clientcontrol
Methods in com.streambase.liveview.client.clientcontrol that throw LiveViewExceptionModifier and TypeMethodDescriptionvoidClientController.killPublisher(String sessionID, String publisherID) Kills the specific publisher based on ID from the server.ClientController.killPublishersWithPredicate(String predicate) Kills publishers referring to the rows in the LVSessionPublishers Table that satisfy the predicate against LVSessionPublishers Table.ClientController.killQueriesWithPredicate(String predicate) Kills queries referring to the rows in the LVSessionQueries Table that satisfy the predicate against LVSessionQueries Table.voidKills the specific query based on ID from the server.voidClientController.killSession(String sessionID) Kills the specific session based on ID from the server.ClientController.killSessionsWithPredicate(String predicate) Kills sessions referring to the rows in the LVSessions Table that satisfy the predicate against LVSessions Table.voidClientController.stopNewSessions(boolean stopNewSession) Stops accepting new sessions -
Uses of LiveViewException in com.streambase.liveview.client.serverdatautility
Methods in com.streambase.liveview.client.serverdatautility that throw LiveViewExceptionModifier and TypeMethodDescriptionvoidServerUtilityDataProvider.exportMetadata(File file, String... resources) utility to export LiveView metadata.voidServerUtilityDataProvider.exportMetadata(OutputStream outputStream, String... resources) Utility to export LiveView metadata.ServerUtilityDataProvider.DATA_POLICY.getPolicyFromValue(String value) ServerUtilityDataProvider.getStreambaseStreams(String sbUri) Utility to get all the input streams and output streams for a given Streambase URI.ServerUtilityDataProvider.importMetadata(File file, ServerUtilityDataProvider.DATA_POLICY dataPolicy, String... resources) Utility to import LiveView metadata.ServerUtilityDataProvider.importMetadata(InputStream inputstream, ServerUtilityDataProvider.DATA_POLICY dataPolicy, String... resources) Utility to import LiveView metadata. -
Uses of LiveViewException in com.streambase.liveview.server.table.plugin
Methods in com.streambase.liveview.server.table.plugin that throw LiveViewExceptionModifier and TypeMethodDescriptionvoidTableProviderManager.addTableProvider(com.streambase.liveview.internal.protocol.jaxb.ExternalServerConnectionType externalServer, int retryCount) Connect to a TableProvider, which then allows for remote connections as if they were LiveView TablesTableProviderManager.compileLVConfs(List<File> tableFiles, boolean buildYaml) voidTableProviderManager.dropTables(List<String> tables) voidTableProvider.initialize(String id, TableProviderControl helper, TableProviderParameters parameters, TableNameMapper mapper) An instance of your class will be initialized with the parameters that were defined in the LVConf.TableProviderControl.locateFile(String filename, boolean required) This will attempt to locate a file within the project.TableProviderControlImpl.locateFile(String filename, boolean required) voidTableProviderManager.registerDependentTables(com.streambase.liveview.config.model.lvconf.TableType tableInfo, com.streambase.liveview.server.table.CatalogedTable baseCatalogedTable, boolean useDynamicStates) voidTableProviderManager.registerNewDynamicTable(String name, com.streambase.liveview.config.model.lvconf.LiveviewConfiguration.DataTable dataTable, Table.TableStatus initialStatus, String statusMessage) voidTableProviderManager.removeTableProvider(String id) Disconnect a previously-connected TableProvider.voidTableProviderManager.saveLVConf(String name, com.streambase.liveview.config.model.lvconf.LiveviewConfiguration conf, boolean saveInProject) voidTableProviderControl.setEnabled(String tableId, boolean enabled) Change the enabled state of an existing table.voidTableProviderControlImpl.setEnabled(String tableId, boolean enabled) voidTableProviderManager.shutdown()voidTableProvider.start()You should connect to your server successfully before returning from this call.voidTableProviderManager.startTables(List<String> tables) voidTableProviderManager.validateDependentTables(com.streambase.liveview.config.model.lvconf.LiveviewConfiguration conf)