COM.activesw.api.client
Class BrokerServerClient

java.lang.Object
  COM.activesw.api.client.BrokerServerClient

public class BrokerServerClient
extends java.lang.Object

Representation of an Broker Server client.

Many calls say they can throw a "communications exception". These exceptions are:

BrokerCommFailureException

If a networking error occurs.

BrokerConnectionClosedException

If the broker disconnects from the application.

BrokerFailureException

If an error occurs on the broker which prevents the operation from being completed.

BrokerProtocolException

If an error occurs in communication between the broker and the application.

BrokerTimeoutException

If the request was not handled in a reasonable time. Most operations use the default timeout of 30 seconds.

Field Summary

static int	BROKER_SERVER_DEFAULT_PORT
static int	PUBLISH_PROCESSING_ACTIVE
static int	PUBLISH_PROCESSING_PAUSE
static int	SERVER_LOG_ALL_ENTRIES
static int	SERVER_STATUS_ERROR
static int	SERVER_STATUS_RUNNING
static int	SERVER_STATUS_STARTING
static int	SERVER_STATUS_STOPPED
static int	SERVER_STATUS_STOPPING
static int	SSL_STATUS_DISABLED
static int	SSL_STATUS_ENABLED
static int	SSL_STATUS_ERROR
static int	SSL_STATUS_NOT_SUPPORTED

Constructor Summary

BrokerServerClient(java.lang.String broker_host, BrokerConnectionDescriptor desc)
Create a Broker server client.

Method Summary

boolean	checkMetaDataBackup() Verifies that the backup of the meta-data is still OK to proceed.
void	createBroker(java.lang.String broker_name, java.lang.String description, boolean is_default) Create a Broker.
void	destroy() Destroy the server client.
void	endMetaDataBackup() Notifies the broker that backup of the meta-data is complete.
java.util.Locale	getActiveFilterCollationLocale() Returns the active Broker Server Filter Collation locale.
int	getActivePort() Get the base port currently being used by the Broker server.
BrokerProcessInfo	getActiveProcessInfo() Get the process information currently in use by the Broker server.
BrokerSSLConfig	getActiveSSLConfig() Get the SSL configuration currently in use on by the Broker server.
COM.activesw.api.client.BrokerSSLConfigV2	getActiveSSLConfigV2() Get the SSL configuration currently in use on by the Broker server.
COM.activesw.api.client.BrokerSSLIdentity	getActiveSSLIdentity() Get the BrokerServer's SSL identity that is currently in use on by the Broker server.
BrokerAccessControlList	getAdminACL() Get the Broker server's administrative access control list (ACL).
int	getAuditOnErrorState()
short[]	getAuditOperations()
COM.activesw.api.client.BrokerAuditLogEntry[]	getAuditRecords(java.lang.Integer noRecords, java.lang.Integer AckId, int msecs)
int	getAuditState()
BrokerInfo[]	getBrokers() Get the list of Brokers in a given server.
java.lang.String	getDefaultBrokerName() Get the name of the default Broker in the server.
java.lang.String	getDescription() Get the Broker server description.
java.lang.String	getDNFromKeystore(java.lang.String keystore, java.lang.String password, COM.activesw.api.client.BrokerSSLConfigV2.KeystoreType keystoreType) Get the distinguished name in the given keystore on the broker server.
java.lang.String[]	getDNsFromCertFile(java.lang.String certificate_file, java.lang.String password) Get the list of distinguished names available in the given certificate file on the broker server.
protected java.util.Locale	getFilterCollationLocaleInternal(boolean saved)
java.lang.String	getHostName() Get the host name of the Broker server.
java.lang.String	getIssuerDNFromKeystore(java.lang.String keystore, java.lang.String password, COM.activesw.api.client.BrokerSSLConfigV2.KeystoreType keystoreType) Get the issuer distinguished name in the given keystore on the broker server.
java.lang.String	getLicense() Get the Broker server license string.
BrokerLogConfig	getLogConfig() Get the Broker server logging configuration.
java.lang.String[]	getMetaDataStorageFiles() Get the path names for the MetaData storage files.
int	getMonitorPort() Get the broker monitor port managing the current Broker Server.
int	getPublicationProcessingState() Get the broker server publication processing state.
java.lang.String[]	getRootDNsFromCertFile(java.lang.String certificate_file, java.lang.String password) Get the list of trusted root distinguished names available in the given certificate file on the broker server.
java.lang.String[]	getRootDNsFromTruststore(java.lang.String truststore, COM.activesw.api.client.BrokerSSLConfigV2.TruststoreType truststoreType) Get the list of trusted root distinguished names available in the given truststore on the broker server.
java.util.Locale	getSavedFilterCollationLocale() Returns the saved Broker Server Filter Collation locale.
BrokerSSLConfig	getSavedSSLConfig() Get the SSL configuration to be used next time the Broker server is started.
COM.activesw.api.client.BrokerSSLConfigV2	getSavedSSLConfigV2() Get the SSL configuration to be used next time the Broker server is started.
COM.activesw.api.client.BrokerSSLIdentity	getSavedSSLIdentity() Get the BrokerServer's SSL identity that will be used the next time the Broker server is restarted.
COM.activesw.api.client.BrokerServerLogEntry[]	getServerLogEntries(BrokerDate first_entry, java.lang.String locale, int num_entries)
COM.activesw.api.client.BrokerServerLogInfo	getServerLogStatus() Get the server log status.
static int	getServerProcessRunStatus(java.lang.String broker_host) Determine whether the Broker server process is running or stopped.
static int	getServerProcessRunStatus(java.lang.String broker_monitor_host, int monitorPort, int brokerPort)
BrokerSSLStatus	getSSLStatus() Get the current status of the Broker server SSL configuration.
BrokerEvent	getStats() Get the Broker server statistics.
BrokerEvent	getStorageStats() Get the Broker server storage statistics.
BrokerEvent	getUsageStats() Get the Broker server system usage statistics.
java.lang.String	getVersion() Get the Broker server version string.
int	getVersionNumber() Get the broker server's version number.
void	pausePublishProcessing() pause broker server publication processing.
void	pruneServerLog(BrokerDate older_than) Delete entries from the server log.
void	registerConnectionCallback(BrokerServerConnectionCallback obj, java.lang.Object client_data) Register a connection callback for this client.
void	resumePublishProcessing() resume broker server publication processing.
void	setAdminACL(BrokerAccessControlList acl) Set the Broker server's administrative access control list (ACL).
void	setAuditOnErrorState(int state)
void	setAuditOperations(short[] ops)
void	setAuditState(int state)
void	setDefaultBrokerName(java.lang.String broker_name) Set the name of the default Broker in the server.
void	setDescription(java.lang.String description) Set the Broker server description.
void	setFilterCollationLocale(java.util.Locale locale) Set the Broker Server Filter Collation locale.
void	setLicense(java.lang.String license) Set the Broker server license string.
void	setLogConfig(BrokerLogConfig log_config) Set the Broker server logging configuration.
void	setSSLConfig(BrokerSSLConfig new_config) Set the SSL configuration to be used next time the Broker server is started.
void	setSSLConfig(java.lang.String certificate_file, java.lang.String password, java.lang.String distinguished_name) Set the SSL configuration to be used next time the Broker server is started.
void	setSSLConfigV2(COM.activesw.api.client.BrokerSSLConfigV2 new_config) Set the SSL configuration to be used next time the Broker server is started.
boolean	startMetaDataBackup() Notifies the broker that backup of the meta-data is going to start.
static void	startServerProcess(java.lang.String broker_host) Start the Broker server process (if it is not already started).
static void	startServerProcess(java.lang.String broker_monitor_host, int monitorPort, int brokerPort)
void	stopProcess() Stop the Broker server process.
java.lang.String	toString() Get a string with the server client information in a form suitable for human viewing.

Methods inherited from class java.lang.Object

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

Field Detail

BROKER_SERVER_DEFAULT_PORT

public static final int BROKER_SERVER_DEFAULT_PORT

See Also:

Constant Field Values

SERVER_STATUS_STARTING

public static final int SERVER_STATUS_STARTING

See Also:

Constant Field Values

SERVER_STATUS_RUNNING

public static final int SERVER_STATUS_RUNNING

See Also:

Constant Field Values

SERVER_STATUS_STOPPING

public static final int SERVER_STATUS_STOPPING

See Also:

Constant Field Values

SERVER_STATUS_STOPPED

public static final int SERVER_STATUS_STOPPED

See Also:

Constant Field Values

SERVER_STATUS_ERROR

public static final int SERVER_STATUS_ERROR

See Also:

Constant Field Values

SSL_STATUS_ENABLED

public static final int SSL_STATUS_ENABLED

See Also:

Constant Field Values

SSL_STATUS_ERROR

public static final int SSL_STATUS_ERROR

See Also:

Constant Field Values

SSL_STATUS_DISABLED

public static final int SSL_STATUS_DISABLED

See Also:

Constant Field Values

SSL_STATUS_NOT_SUPPORTED

public static final int SSL_STATUS_NOT_SUPPORTED

See Also:

Constant Field Values

SERVER_LOG_ALL_ENTRIES

public static final int SERVER_LOG_ALL_ENTRIES

See Also:

Constant Field Values

PUBLISH_PROCESSING_ACTIVE

public static final int PUBLISH_PROCESSING_ACTIVE

See Also:

Constant Field Values

PUBLISH_PROCESSING_PAUSE

public static final int PUBLISH_PROCESSING_PAUSE

See Also:

Constant Field Values

Constructor Detail

BrokerServerClient

public BrokerServerClient(java.lang.String broker_host,
                          BrokerConnectionDescriptor desc)
                   throws BrokerException

Create a Broker server client. A server client is used to by administration applications to manage broker and system functions of brokers in that server. A Broker server client is said to have "limited access" if it is not authorized under the host's ACL. Some operations will give BrokerNoPermissionExceptions to clients with limited access. The shared state flag of the BrokerConnectionDescriptor is always ignored.

Throws:

BrokerCommFailureException - If problems occur establishing the connection.

BrokerHostNotFoundException - If the specified host does not exist.

BrokerNotRunningException - If the host exists but no broker server is running on that host.

BrokerNullParameterException - If broker_host is null.

BrokerSecurityException - If a secure connection is attempted but is rejected by the broker server.

BrokerException

Method Detail

destroy

public void destroy()
             throws BrokerException

Destroy the server client. Disconnects from the broker server. May throw any communications exception, but the local client object is marked as disconnected even if an exception is thrown.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerException

getAdminACL

public BrokerAccessControlList getAdminACL()
                                    throws BrokerException

Get the Broker server's administrative access control list (ACL).

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the client has limited access.

BrokerException

setAdminACL

public void setAdminACL(BrokerAccessControlList acl)
                 throws BrokerException

Set the Broker server's administrative access control list (ACL).

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the client has limited access.

BrokerNullParameterException - If acl is null.

BrokerException

getDNFromKeystore

public java.lang.String getDNFromKeystore(java.lang.String keystore,
                                          java.lang.String password,
                                          COM.activesw.api.client.BrokerSSLConfigV2.KeystoreType keystoreType)
                                   throws BrokerException

Get the distinguished name in the given keystore on the broker server.

The keystoreType parameter specifies the type of keystore: either PKCS12 or PEM. If the keystoreType is null, the type is assumed to be PKCS12.

Throws:

BrokerFileNotFoundException - If the keystore is not found or cannot be read.

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the password is invalid or if the file is not a keystore, or if the client has limited access.

BrokerNullParameterException - If keystore is null.

BrokerSSLConfigException - If the keystoreType is invalid.

BrokerException

getIssuerDNFromKeystore

public java.lang.String getIssuerDNFromKeystore(java.lang.String keystore,
                                                java.lang.String password,
                                                COM.activesw.api.client.BrokerSSLConfigV2.KeystoreType keystoreType)
                                         throws BrokerException

Get the issuer distinguished name in the given keystore on the broker server.

The keystoreType parameter specifies the type of keystore: either PKCS12 or PEM. If the keystoreType is null, the type is assumed to be PKCS12.

Throws:

BrokerFileNotFoundException - If the keystore is not found or cannot be read.

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the password is invalid or if the file is not a keystore, or if the client has limited access.

BrokerNullParameterException - If keystore is null.

BrokerSSLConfigException - If the keystoreType is invalid.

BrokerException

getRootDNsFromTruststore

public java.lang.String[] getRootDNsFromTruststore(java.lang.String truststore,
                                                   COM.activesw.api.client.BrokerSSLConfigV2.TruststoreType truststoreType)
                                            throws BrokerException

Get the list of trusted root distinguished names available in the given truststore on the broker server.

The truststoreType parameter specifies the type of truststore: either PEM or DIR. If the truststoreType is null, the type is assumed to be PEM.

Throws:

BrokerFileNotFoundException - If the certificate file is not found or cannot be read.

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the password is invalid or if the file is not a certificate file, or if the client has limited access.

BrokerNullParameterException - If certificate_file is null.

BrokerException

getDNsFromCertFile

public java.lang.String[] getDNsFromCertFile(java.lang.String certificate_file,
                                             java.lang.String password)
                                      throws BrokerException

Get the list of distinguished names available in the given certificate file on the broker server. The password parameter may be null if the certificate_file is the same as the Broker's active certificate file. In these cases, the Broker's active certificate file and password are used. If the broker does not currently have an active SSL setup, then null parameter exceptions will be returned as appropriate.

Throws:

BrokerFileNotFoundException - If the certificate file is not found or cannot be read.

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the password is invalid or if the file is not a certificate file, or if the client has limited access.

BrokerNullParameterException - If certificate_file is null.

BrokerException

getRootDNsFromCertFile

public java.lang.String[] getRootDNsFromCertFile(java.lang.String certificate_file,
                                                 java.lang.String password)
                                          throws BrokerException

Get the list of trusted root distinguished names available in the given certificate file on the broker server. The password parameter may be null if the certificate_file is the same as the Broker's active certificate file. In these cases, the Broker's active certificate file and password are used. If the broker does not currently have an active SSL setup, then null parameter exceptions will be returned as appropriate.

Throws:

BrokerFileNotFoundException - If the certificate file is not found or cannot be read.

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the password is invalid or if the file is not a certificate file, or if the client has limited access.

BrokerNullParameterException - If certificate_file is null.

BrokerException

getActiveSSLConfigV2

public COM.activesw.api.client.BrokerSSLConfigV2 getActiveSSLConfigV2()
                                                               throws BrokerException

Get the SSL configuration currently in use on by the Broker server. This may not be the same as the most recently set configuration. See setSSLConfig() for more information.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the client has limited access.

BrokerIncompatibleVersionException - If the Broker does not support the old form of SSL configuration.

BrokerException

getSavedSSLConfigV2

public COM.activesw.api.client.BrokerSSLConfigV2 getSavedSSLConfigV2()
                                                              throws BrokerException

Get the SSL configuration to be used next time the Broker server is started. This may not be the same as the active configuration. See setSSLConfig() for more information.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the client has limited access.

BrokerIncompatibleVersionException - If the Broker does not support the old form of SSL configuration.

BrokerException

setSSLConfigV2

public void setSSLConfigV2(COM.activesw.api.client.BrokerSSLConfigV2 new_config)
                    throws BrokerException

Set the SSL configuration to be used next time the Broker server is started. To disable SSL, set the keystore to null. Note that the broker keeps both its active SSL configuration and a saved configuration to use on the next startup. This is because the broker must be restarted to change its SSL configuration. When the configuration is first made, the broker will immediately adopt it, but all future changes are merely saved away for the next restart. Thus, the active and saved configurations may not match.

Throws:

BrokerFileNotFoundException - If the certificate file is not found or cannot be read.

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the password is invalid or if the file is not a certificate file, or if the client has limited access.

BrokerNullParameterException - If distinguished_name is null when certificate_file is non-null.

BrokerUnknownNameException - If a distinguished name is specified but does not exist in the certificate file.

BrokerIncompatibleVersionException - If the Broker does not support the new form of SSL configuration.

BrokerSSLConfigurationException - If there is a problem with the SSL configuration.

BrokerException

getActiveSSLConfig

public BrokerSSLConfig getActiveSSLConfig()
                                   throws BrokerException

Get the SSL configuration currently in use on by the Broker server. This may not be the same as the most recently set configuration. See setSSLConfig() for more information.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the client has limited access.

BrokerIncompatibleVersionException - If the Broker does not support the old form of SSL configuration.

BrokerException

getSavedSSLConfig

public BrokerSSLConfig getSavedSSLConfig()
                                  throws BrokerException

Get the SSL configuration to be used next time the Broker server is started. This may not be the same as the active configuration. See setSSLConfig() for more information.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the client has limited access.

BrokerIncompatibleVersionException - If the Broker does not support the old form of SSL configuration.

BrokerException

setSSLConfig

public void setSSLConfig(java.lang.String certificate_file,
                         java.lang.String password,
                         java.lang.String distinguished_name)
                  throws BrokerException

Set the SSL configuration to be used next time the Broker server is started. To disable SSL, set the certificate_file to null. To change the distinguished name within the same file without giving the password again, pass the current certificate_file with the password as null. Note that the broker keeps both its active SSL configuration and a saved configuration to use on the next startup. This is because the broker must be restarted to change its SSL configuration. When the configuration is first made, the broker will immediately adopt it, but all future changes are merely saved away for the next restart. Thus, the active and saved configurations may not match.

Throws:

BrokerFileNotFoundException - If the certificate file is not found or cannot be read.

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the password is invalid or if the file is not a certificate file, or if the client has limited access.

BrokerNullParameterException - If distinguished_name is null when certificate_file is non-null.

BrokerUnknownNameException - If a distinguished name is specified but does not exist in the certificate file.

BrokerIncompatibleVersionException - If the Broker does not support the old form of SSL configuration.

BrokerException

setSSLConfig

public void setSSLConfig(BrokerSSLConfig new_config)
                  throws BrokerException

Set the SSL configuration to be used next time the Broker server is started. To disable SSL, set the certificate_file to null. To change the distinguished name within the same file without giving the password again, pass the current certificate_file with the password as null. Note that the broker keeps both its active SSL configuration and a saved configuration to use on the next startup. This is because the broker must be restarted to change its SSL configuration. When the configuration is first made, the broker will immediately adopt it, but all future changes are merely saved away for the next restart. Thus, the active and saved configurations may not match.

Throws:

BrokerFileNotFoundException - If the certificate file is not found or cannot be read.

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the password is invalid or if the file is not a certificate file, or if the client has limited access.

BrokerNullParameterException - If distinguished_name is null when certificate_file is non-null.

BrokerUnknownNameException - If a distinguished name is specified but does not exist in the certificate file.

BrokerIncompatibleVersionException - If the Broker does not support the old form of SSL configuration.

BrokerException

getActiveSSLIdentity

public COM.activesw.api.client.BrokerSSLIdentity getActiveSSLIdentity()
                                                               throws BrokerException

Get the BrokerServer's SSL identity that is currently in use on by the Broker server. This may not be the same as the one most recently set.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the client has limited access.

BrokerIncompatibleVersionException - If the Broker does not support this call.

BrokerException

getSavedSSLIdentity

public COM.activesw.api.client.BrokerSSLIdentity getSavedSSLIdentity()
                                                              throws BrokerException

Get the BrokerServer's SSL identity that will be used the next time the Broker server is restarted. This may not be the same as the active identity.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the client has limited access.

BrokerIncompatibleVersionException - If the Broker does not support this call.

BrokerException

getSSLStatus

public BrokerSSLStatus getSSLStatus()
                             throws BrokerException

Get the current status of the Broker server SSL configuration. This operation is open to all users. The level value can be any of the BrokerConnectionDescriptor.ENCRYPT_LEVEL_* values. The status value can be any of the SSL_STATUS_* values. If the value is SSL_STATUS_ERROR, then the error string is set to a description of the failure, otherwise it is null.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerException

getHostName

public java.lang.String getHostName()

Get the host name of the Broker server.

getActivePort

public int getActivePort()
                  throws BrokerException

Get the base port currently being used by the Broker server. This operation is open to all users.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerException

getMonitorPort

public int getMonitorPort()
                   throws BrokerException

Get the broker monitor port managing the current Broker Server. This operation is open to all users.

Returns:

the Monitor port managing this server

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerException

getActiveProcessInfo

public BrokerProcessInfo getActiveProcessInfo()
                                       throws BrokerException

Get the process information currently in use by the Broker server.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the client has limited access.

BrokerException

getLogConfig

public BrokerLogConfig getLogConfig()
                             throws BrokerException

Get the Broker server logging configuration. This operation is open to all users.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerException

setLogConfig

public void setLogConfig(BrokerLogConfig log_config)
                  throws BrokerException

Set the Broker server logging configuration. Any log config entries which have the 'value' parameter set, when the value is not required by the config entry will simply cause the value to be ignored.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerInvalidLogConfigException - If one or more log configuration entries are not valid. If this exception is thrown, all valid entries are still set.

BrokerNoPermissionException - If the client has limited access.

BrokerException

getServerLogStatus

public COM.activesw.api.client.BrokerServerLogInfo getServerLogStatus()
                                                               throws BrokerException

Get the server log status.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerIncompatibleVersionException - If the version of the broker is known not to this operation.

BrokerNoPermissionException - If the client has limited access.

BrokerException

getServerLogEntries

public COM.activesw.api.client.BrokerServerLogEntry[] getServerLogEntries(BrokerDate first_entry,
                                                                          java.lang.String locale,
                                                                          int num_entries)
                                                                   throws BrokerException

Throws:

BrokerException

pruneServerLog

public void pruneServerLog(BrokerDate older_than)
                    throws BrokerException

Delete entries from the server log. Deletes all entries from the given date (inclusive) and older.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerIncompatibleVersionException - If the version of the broker is known not to this operation.

BrokerNullParameterException - If older_than is null.

BrokerNoPermissionException - If the client has limited access.

BrokerException

getLicense

public java.lang.String getLicense()
                            throws BrokerException

Get the Broker server license string.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the client has limited access.

BrokerException

setLicense

public void setLicense(java.lang.String license)
                throws BrokerException

Set the Broker server license string.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerInvalidLicenseException - If the license string is not a valid license.

BrokerNoPermissionException - If the client has limited access.

BrokerNullParameterException - If license is null.

BrokerException

getDescription

public java.lang.String getDescription()
                                throws BrokerException

Get the Broker server description. This operation is open to all users.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerException

setDescription

public void setDescription(java.lang.String description)
                    throws BrokerException

Set the Broker server description.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the client has limited access.

BrokerNullParameterException - If description is null.

BrokerException

getVersionNumber

public int getVersionNumber()

Get the broker server's version number. Returns one of the BrokerClient.VERSION_* contant values.

If the broker server is newer than the client's version, the client's version is reported.

getVersion

public java.lang.String getVersion()
                            throws BrokerException

Get the Broker server version string. This operation is open to all users.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerException

getServerProcessRunStatus

public static int getServerProcessRunStatus(java.lang.String broker_host)
                                     throws BrokerException

Determine whether the Broker server process is running or stopped. The state can be any of the SERVER_STATUS_* values. This operation is open to all users.

Throws:

BrokerHostNotFoundException - If the specified host does not exist.

BrokerInvalidClientException - If the client has been destroyed.

BrokerNotRunningException - If the host exists but no broker monitor is running on that host.

BrokerNullParameterException - If broker_host is null.

BrokerUnknownServerException - If the specified host has a monitor running, but no server is configured on the specified port.

BrokerException

getServerProcessRunStatus

public static int getServerProcessRunStatus(java.lang.String broker_monitor_host,
                                            int monitorPort,
                                            int brokerPort)
                                     throws BrokerException

Throws:

BrokerException

startServerProcess

public static void startServerProcess(java.lang.String broker_host)
                               throws BrokerException

Start the Broker server process (if it is not already started).

Throws:

BrokerCommFailureException - If problems occur establishing the connection.

BrokerHostNotFoundException - If the specified host does not exist.

BrokerNotRunningException - If the host exists but no broker server is running on that host.

BrokerNullParameterException - If broker_host is null.

BrokerUnknownServerException - If the specified host has a monitor running, but no server is configured on the specified port.

BrokerException

startServerProcess

public static void startServerProcess(java.lang.String broker_monitor_host,
                                      int monitorPort,
                                      int brokerPort)
                               throws BrokerException

Throws:

BrokerException

stopProcess

public void stopProcess()
                 throws BrokerException

Stop the Broker server process. This operation will also destroy() this client.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the client has limited access.

BrokerException

getStats

public BrokerEvent getStats()
                     throws BrokerException

Get the Broker server statistics. Each statistic is stored as a field in the event object. The statistics are:

• now -- (date) Current time on the broker server's host.
• createTime -- (date) Time when the server was first started.
• serverStartTime -- (date) Time when the server was most recently started.
• numConnections -- (int) Current number of non-SSL connections.
• numSSLConnections -- (int) Current number of SSL connections.
• highestNumConnections -- (int) Highest number of non-SSL connections since the last time the server was started.
• highestNumSSLConnections -- (int) Highest number of SSL connections since the last time the server was started.
• highestNumConnectionsTime -- (date) Time when highestNumConnections last changed. Forever (zero date and time) if never had a non-SSL connect since the last time the server started.
• highestNumSSLConnectionsTime -- (date) Time when highestNumSSLConnections last changed. Forever (zero date and time) if never had an SSL connect since the last time the server started.
• licensedConections -- (int) Licensed number of total SSL and non-SSL connections. -1 if not limited.
• licensedSSLConections -- (int) Licensed number of SSL connections. -1 if not limited.
• isLicenseExpiringSoon -- (boolean) True if expiring within a week.
• isLicenseExpired -- (boolean) True if expired already.
• licenseExpirationTime -- (date) When the license expires. Forever (zero date and time) if will not expire.
• licenseTimeRemaining -- (int) Number of seconds until license expires. Forever (zero date and time) if will not expire.
• isDiskSpaceLow -- (boolean) True if disk free < 1 Meg.
• isDiskSpaceVeryLow -- (boolean) True if disk free < 100k.

This operation is open to all users.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerException

getUsageStats

public BrokerEvent getUsageStats()
                          throws BrokerException

Get the Broker server system usage statistics. Each statistic is stored as a field in the event object.

• now -- (date) Current time on the broker server's host.
• userTimeUsed -- (double) Number of seconds (or fractions thereof) of CPU user time used by the broker since it started.
• systemTimeUsed -- (double) Number of seconds (or fractions thereof) of CPU system time used by the broker since it started.
• percentageCPUUsed -- (double) Percentage of host CPU used by broker. This is an instantaneous value, not a long term one. Note: this is not set at all on the Windows platform.
• guaranteedSpaceUsed -- (long) Number of kbytes the guaranteed storage is using on the disk.
• guaranteedSpaceReserved -- (long) Number of kbytes the reserved for guaranteed storage on the disk. If zero, then storage will be resized as needed. If non-zero, then storage will be fixed at this size.
• guaranteedSpaceMax -- (long) The maximum number of kbytes the guaranteed storage can grow to due to system limits, if disk space or reservation limits are not hit first.
• guaranteedDiskSize -- (long) Size of the guaranteed store disk in kbytes.
• guaranteedDiskFree -- (long) Amount of free space on the disk in kbytes.
• guaranteedDiskName -- (unicode string) Name of the guaranteed disk partition.
• persistentSpaceUsed -- (long) Number of kbytes the persistent storage is using on the disk.
• persistentSpaceMax -- (long) The maximum number of kbytes the persistent storage can grow to due to system limits, if disk space or reservation limits are not hit first.
• persistentDiskSize -- (long) Size of the persistent store disk in kbytes.
• persistentDiskFree -- (long) Amount of free space on the disk in kbytes.
• persistentDiskName -- (unicode string) Name of the persistent disk partition.
• swapSpaceFree -- (long) Number of kbytes of free swap space.
• swapSpaceMax -- (long) Total number of kbytes of swap space.

This operation is open to all users.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerException

getStorageStats

public BrokerEvent getStorageStats()
                            throws BrokerException

Get the Broker server storage statistics. Each statistic is stored as a field in the event object.

• now -- (date) Current time on the broker server's host.
• sessions -- (structure array) An array of structures describing statistics of each of the storage files used.
• sessions[].session_url -- (unicode string) url describing the storage file name.
• sessions[].stats[] -- (structure array) An array of structures describing statistics of each of the storage files employed by the specified session.
• sessions[].stats[].filename -- (unicode string) Storage file name
• sessions[].stats[].max_kbytes_available -- (long) Maximum storage size available.
• sessions[].stats[].current_kbytes_reserved -- (long) Current storage size reserved.
• sessions[].stats[].current_kbytes_inuse -- (long) Current storage size in use.

This operation is open to all users.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerException

setFilterCollationLocale

public void setFilterCollationLocale(java.util.Locale locale)
                              throws BrokerException

Set the Broker Server Filter Collation locale. Effective the next time the server restarts.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the client has limited access.

BrokerNullParameterException - If description is null.

BrokerInvalidNameException - If the locale name is invalid.

BrokerException

getActiveFilterCollationLocale

public java.util.Locale getActiveFilterCollationLocale()
                                                throws BrokerException

Returns the active Broker Server Filter Collation locale.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the client has limited access.

BrokerNullParameterException - If description is null.

BrokerInvalidNameException - If the locale name is invalid.

BrokerException

getSavedFilterCollationLocale

public java.util.Locale getSavedFilterCollationLocale()
                                               throws BrokerException

Returns the saved Broker Server Filter Collation locale.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the client has limited access.

BrokerNullParameterException - If description is null.

BrokerInvalidNameException - If the locale name is invalid.

BrokerException

getFilterCollationLocaleInternal

protected java.util.Locale getFilterCollationLocaleInternal(boolean saved)
                                                     throws BrokerException

Throws:

BrokerException

createBroker

public void createBroker(java.lang.String broker_name,
                         java.lang.String description,
                         boolean is_default)
                  throws BrokerException

Create a Broker. It can optionally be created as the default broker.

Throws:

BrokerExistsException - If a broker with the given name already exists.

BrokerInvalidBrokerNameException - If the broker name is not valid.

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the client has limited access.

BrokerNullParameterException - If broker_name or description are is null.

BrokerException

getBrokers

public BrokerInfo[] getBrokers()
                        throws BrokerException

Get the list of Brokers in a given server. This operation is open to all users.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerException

getDefaultBrokerName

public java.lang.String getDefaultBrokerName()
                                      throws BrokerException

Get the name of the default Broker in the server. Returns null if there is no default broker. This operation is open to all users.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerException

setDefaultBrokerName

public void setDefaultBrokerName(java.lang.String broker_name)
                          throws BrokerException

Set the name of the default Broker in the server. If broker_name is null, then there will be no default broker.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerNoPermissionException - If the client has limited access.

BrokerUnknownBrokerNameException - If the broker does not exist in the server.

BrokerException

registerConnectionCallback

public void registerConnectionCallback(BrokerServerConnectionCallback obj,
                                       java.lang.Object client_data)
                                throws BrokerException

Register a connection callback for this client. Calling this on a client which already has an existing callback will replace that callback. 'obj' may be null to clear the callback. 'client_data' may be null. The callback method will be called with connect_state set to BrokerClient.CONNECT_STATE_DISCONNECTED if the client is disconnected. It will be called with BrokerClient.CONNECT_STATE_CONNECTED if the client connection is re-established (only happens if automatic reconnect is enabled). It will be called with BrokerClient.CONNECT_STATE_RECONNECTED if the disconnect is discovered, but the connection is re-established immediately (only happens if automatic reconnect is enabled).

Throws:

BrokerInvalidClientException - If the client has been disconnected or destroyed.

BrokerException

startMetaDataBackup

public boolean startMetaDataBackup()
                            throws BrokerException

Notifies the broker that backup of the meta-data is going to start.

Returns:

True if it is safe to proceed with the backup

Throws:

BrokerInvalidClientException - If the client has been destroyed or disconnected.

BrokerIncompatibleVersionException - If the broker does not support changelocks.

BrokerException

endMetaDataBackup

public void endMetaDataBackup()
                       throws BrokerException

Notifies the broker that backup of the meta-data is complete.

Throws:

BrokerInvalidClientException - If the client has been destroyed or disconnected.

BrokerIncompatibleVersionException - If the broker does not support changelocks.

BrokerException

checkMetaDataBackup

public boolean checkMetaDataBackup()
                            throws BrokerException

Verifies that the backup of the meta-data is still OK to proceed.

Throws:

BrokerInvalidClientException - If the client has been destroyed or disconnected.

BrokerIncompatibleVersionException - If the broker does not support changelocks.

BrokerException

getMetaDataStorageFiles

public java.lang.String[] getMetaDataStorageFiles()
                                           throws BrokerException

Get the path names for the MetaData storage files.

Throws:

BrokerInvalidClientException - If the client has been destroyed or disconnected.

BrokerIncompatibleVersionException - If the broker does not support changelocks.

BrokerException

toString

public java.lang.String toString()

Get a string with the server client information in a form suitable for human viewing. Returns null if the server client is not valid.

Overrides:

toString in class java.lang.Object

getPublicationProcessingState

public int getPublicationProcessingState()
                                  throws BrokerException

Get the broker server publication processing state. This operation is open to all users.

Returns:

the publication processing state of this server. PUBLISH_PROCESSING_ACTIVE (0) - event publication is active PUBLISH_PROCESSING_PAUSE (1) - event publication is paused

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerException

pausePublishProcessing

public void pausePublishProcessing()
                            throws BrokerException

pause broker server publication processing. This operation is open to all users.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerException

resumePublishProcessing

public void resumePublishProcessing()
                             throws BrokerException

resume broker server publication processing. This operation is open to all users.

Throws:

BrokerInvalidClientException - If the client has been destroyed.

BrokerException

getAuditRecords

public COM.activesw.api.client.BrokerAuditLogEntry[] getAuditRecords(java.lang.Integer noRecords,
                                                                     java.lang.Integer AckId,
                                                                     int msecs)
                                                              throws BrokerException

Throws:

BrokerException

setAuditOperations

public void setAuditOperations(short[] ops)
                        throws BrokerException

Throws:

BrokerException

setAuditState

public void setAuditState(int state)
                   throws BrokerException

Throws:

BrokerException

getAuditState

public int getAuditState()
                  throws BrokerException

Throws:

BrokerException

setAuditOnErrorState

public void setAuditOnErrorState(int state)
                          throws BrokerException

Throws:

BrokerException

getAuditOnErrorState

public int getAuditOnErrorState()
                         throws BrokerException

Throws:

BrokerException

getAuditOperations

public short[] getAuditOperations()
                           throws BrokerException

Throws:

BrokerException