Uses of Class
org.xmlBlaster.util.XmlBlasterException

Packages that use XmlBlasterException

http.dhtml.systemInfo	Demo servlet and publisher for persistent http browser demo.
javaclients	Java examples, start reading the HelloWorld clients.
org.xmlBlaster	This is the main package of the xmlBlaster distribution.
org.xmlBlaster.authentication
org.xmlBlaster.authentication.plugins
org.xmlBlaster.authentication.plugins.demo
org.xmlBlaster.authentication.plugins.htpasswd
org.xmlBlaster.authentication.plugins.ldap
org.xmlBlaster.authentication.plugins.simple
org.xmlBlaster.client	This is the Java client side package.
org.xmlBlaster.client.dispatch
org.xmlBlaster.client.feeder
org.xmlBlaster.client.filepoller
org.xmlBlaster.client.key
org.xmlBlaster.client.protocol
org.xmlBlaster.client.protocol.corba
org.xmlBlaster.client.protocol.email
org.xmlBlaster.client.protocol.http.common
org.xmlBlaster.client.protocol.local
org.xmlBlaster.client.protocol.rmi
org.xmlBlaster.client.protocol.socket
org.xmlBlaster.client.protocol.xmlrpc
org.xmlBlaster.client.qos
org.xmlBlaster.client.queuemsg
org.xmlBlaster.client.reader
org.xmlBlaster.client.script
org.xmlBlaster.contrib
org.xmlBlaster.contrib.dbupdate
org.xmlBlaster.contrib.dbwatcher.mom
org.xmlBlaster.contrib.dbwatcher.plugin
org.xmlBlaster.contrib.dbwriter
org.xmlBlaster.contrib.filewatcher
org.xmlBlaster.contrib.filewriter
org.xmlBlaster.contrib.htmlmonitor
org.xmlBlaster.contrib.jmx
org.xmlBlaster.contrib.mime
org.xmlBlaster.contrib.replication
org.xmlBlaster.contrib.replication.impl
org.xmlBlaster.contrib.scheduler
org.xmlBlaster.contrib.socketgetter
org.xmlBlaster.engine	The core implementation.
org.xmlBlaster.engine.admin
org.xmlBlaster.engine.admin.extern
org.xmlBlaster.engine.admin.intern
org.xmlBlaster.engine.cluster
org.xmlBlaster.engine.cluster.simpledomain
org.xmlBlaster.engine.dispatch
org.xmlBlaster.engine.distributor.plugins
org.xmlBlaster.engine.mime
org.xmlBlaster.engine.mime.demo
org.xmlBlaster.engine.mime.regex
org.xmlBlaster.engine.mime.sql92
org.xmlBlaster.engine.mime.xpath
org.xmlBlaster.engine.msgstore
org.xmlBlaster.engine.msgstore.cache
org.xmlBlaster.engine.msgstore.ram
org.xmlBlaster.engine.persistence
org.xmlBlaster.engine.persistence.filestore
org.xmlBlaster.engine.qos
org.xmlBlaster.engine.query
org.xmlBlaster.engine.query.plugins
org.xmlBlaster.engine.queuemsg
org.xmlBlaster.engine.runlevel
org.xmlBlaster.engine.xml2java
org.xmlBlaster.j2ee.k2
org.xmlBlaster.j2ee.k2.client
org.xmlBlaster.j2ee.util
org.xmlBlaster.jms
org.xmlBlaster.protocol
org.xmlBlaster.protocol.corba
org.xmlBlaster.protocol.email
org.xmlBlaster.protocol.http
org.xmlBlaster.protocol.http.ajax
org.xmlBlaster.protocol.http.appletproxy
org.xmlBlaster.protocol.http.simple
org.xmlBlaster.protocol.jdbc
org.xmlBlaster.protocol.local
org.xmlBlaster.protocol.rmi
org.xmlBlaster.protocol.socket
org.xmlBlaster.protocol.stomp
org.xmlBlaster.protocol.xmlrpc
org.xmlBlaster.test	Tests running xmlBlaster instances with ugly behaving clients.
org.xmlBlaster.test.admin
org.xmlBlaster.test.authentication
org.xmlBlaster.test.classtest	Tests classes of the xmlBlaster distribution.
org.xmlBlaster.test.classtest.queue
org.xmlBlaster.test.client
org.xmlBlaster.test.cluster	Tests xmlBlaster cluster support.
org.xmlBlaster.test.contrib
org.xmlBlaster.test.contrib.filewatcher
org.xmlBlaster.test.qos
org.xmlBlaster.test.util
org.xmlBlaster.util	Java helper classes for server and client programming.
org.xmlBlaster.util.admin
org.xmlBlaster.util.admin.extern
org.xmlBlaster.util.checkpoint
org.xmlBlaster.util.classloader
org.xmlBlaster.util.dispatch
org.xmlBlaster.util.dispatch.plugins
org.xmlBlaster.util.dispatch.plugins.prio
org.xmlBlaster.util.error
org.xmlBlaster.util.http
org.xmlBlaster.util.key
org.xmlBlaster.util.lexical
org.xmlBlaster.util.plugin
org.xmlBlaster.util.pool
org.xmlBlaster.util.property
org.xmlBlaster.util.protocol
org.xmlBlaster.util.protocol.corba
org.xmlBlaster.util.protocol.email
org.xmlBlaster.util.protocol.socket
org.xmlBlaster.util.protocol.xmlrpc
org.xmlBlaster.util.qos
org.xmlBlaster.util.queue
org.xmlBlaster.util.queue.cache
org.xmlBlaster.util.queue.jdbc
org.xmlBlaster.util.queue.ram
org.xmlBlaster.util.queuemsg
org.xmlBlaster.util.servlet
org.xmlBlaster.util.xbformat

Uses of XmlBlasterException in http.dhtml.systemInfo

Methods in http.dhtml.systemInfo that throw XmlBlasterException

private int	SystemInfoPublisher.getCpuload() The Linux way ...
private int	SystemInfoPublisher.getMeminfo() The Linux way ...

Uses of XmlBlasterException in javaclients

Methods in javaclients that throw XmlBlasterException

void	HelloWorldNative.init(Global glob, PluginInfo pluginInfo)
void	HelloWorldNative2.init(Global glob, PluginInfo pluginInfo)
void	ClientPlugin.init(Global glob, PluginInfo pluginInfo)
void	HelloWorldNative.shutdown()
void	ClientPlugin.shutdown()
java.lang.String	HelloWorldSubscribe.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos) Here the messages from xmlBlaster arrive.

Uses of XmlBlasterException in org.xmlBlaster

Methods in org.xmlBlaster with parameters of type XmlBlasterException

void	Main.newException(XmlBlasterException e)

Methods in org.xmlBlaster that throw XmlBlasterException

void	Main.runlevelChange(int from, int to, boolean force) Invoked on run level change, see RunlevelManager.RUNLEVEL_HALTED and RunlevelManager.RUNLEVEL_RUNNING Enforced by I_RunlevelListener

Constructors in org.xmlBlaster that throw XmlBlasterException

MainGUI.GuiQuery(I_Authenticate authenticate, I_XmlBlaster xmlBlasterImpl)
Login to xmlBlaster and get a sessionId.

Uses of XmlBlasterException in org.xmlBlaster.authentication

Fields in org.xmlBlaster.authentication declared as XmlBlasterException

private XmlBlasterException

SessionInfo.transportConnectFail

Methods in org.xmlBlaster.authentication that return XmlBlasterException

XmlBlasterException

SessionInfo.getTransportConnectFail() If the connection failed the reason is stored here, like this cleanup code knows what happened.

Methods in org.xmlBlaster.authentication with parameters of type XmlBlasterException

void	SessionInfo.setTransportConnectFail(XmlBlasterException transportConnectFail)

Methods in org.xmlBlaster.authentication that throw XmlBlasterException

void	Authenticate.changeSecretSessionId(java.lang.String oldSessionId, java.lang.String newSessionId) Replace the old by the new session id
SessionInfo	Authenticate.check(java.lang.String secretSessionId) Use this method to check a clients authentication.
void	SubjectInfo.checkNumberOfSessions(ConnectQosServer qos)
java.lang.String	AuthenticateProtector.connect(AddressServer addressServer, java.lang.String connectQos_literal) helper
java.lang.String	AuthenticateProtector.connect(AddressServer addressServer, java.lang.String connectQos_literal, java.lang.String secretSessionId)
ConnectReturnQosServer	AuthenticateProtector.connect(ConnectQosServer xmlQos) helper
ConnectReturnQosServer	Authenticate.connect(ConnectQosServer xmlQos) Login to xmlBlaster.
ConnectReturnQosServer	AuthenticateProtector.connect(ConnectQosServer xmlQos, java.lang.String secretSessionId) helper
ConnectReturnQosServer	Authenticate.connect(ConnectQosServer connectQos, java.lang.String forcedSecretSessionId) Login to xmlBlaster.
private java.lang.String	Authenticate.createSessionId(java.lang.String loginName) Generate a unique (and secret) resource ID
private I_Queue	SubjectInfo.createSubjectQueue(CbQueueProperty prop)
void	AuthenticateProtector.disconnect(AddressServer addressServer, java.lang.String secretSessionId, java.lang.String qos_literal)
void	Authenticate.disconnect(java.lang.String secretSessionId, java.lang.String qos_literal)
private void	Authenticate.fireClientEvent(SessionInfo sessionInfo, boolean login) Used to fire an event if a client does a login / logout
private void	Authenticate.firePreRemovedClientEvent(SessionInfo sessionInfo)
private int	SubjectInfo.forwardToSessionQueue(MsgQueueEntry entry) Forward the given message to session queue.
MsgUnit[]	SessionInfo.getCallbackQueueEntries(java.lang.String query)
MsgUnit[]	SessionInfoProtector.getCallbackQueueEntries(java.lang.String querySpec)
NodeId	SubjectInfo.getNodeId()
(package private) SessionInfo	SubjectInfo.getOrCreateSessionInfo(SessionName sessionName, ConnectQosServer connectQos) Blocks for existing SessionInfo until it is initialized.
private SessionInfo	Authenticate.getOrCreateSessionInfo(SessionName sessionName, ConnectQosServer connectQos) Blocks for existing SessionInfo until it is initialized.
SubjectInfo	Authenticate.getOrCreateSubjectInfoByName(SessionName subjectName, boolean returnLocked, I_Subject subjectCtx, CbQueueProperty prop) Access a subjectInfo with the unique login name.
java.lang.String[]	SessionInfo.getRootSubscriptions()
I_AdminSubject	AuthenticateProtector.getSubjectInfoByName(SessionName sessionName) Administrative access.
MsgUnit[]	SubjectInfo.getSubjectQueueEntries(java.lang.String querySpec) Query the subject queue, can be peeking or consuming.
MsgUnit[]	SubjectInfoProtector.getSubjectQueueEntries(java.lang.String querySpec)
java.lang.String	SessionInfo.getSubscriptionDump()
java.lang.String	SessionInfoProtector.getSubscriptionDump()
java.lang.String[]	SessionInfo.getSubscriptions()
(package private) void	SessionInfo.init(SubjectInfo subjectInfo, I_Session securityCtx, ConnectQosServer connectQos)
boolean	SubjectInfo.isCluster()
(package private) java.lang.String	SubjectInfo.killClient() Kills all sessions of this client
java.lang.String	SubjectInfoProtector.killClient()
java.lang.String	SessionInfo.killSession()
java.lang.String	SessionInfoProtector.killSession()
java.lang.String	Authenticate.login(java.lang.String loginName, java.lang.String passwd, java.lang.String xmlQoS_literal, java.lang.String secretSessionId)
void	Authenticate.logout(java.lang.String secretSessionId) Logout of a client.
void	SubjectInfo.notifyAboutLogin(SessionInfo sessionInfo) Get notification that the client did a login.
void	SubjectInfo.notifyAboutLogout(java.lang.String absoluteSessionName, boolean clearQueue, boolean forceShutdownEvenIfEntriesExist) Get notification that the client did a logout.
java.lang.String[]	SessionInfo.peekCallbackMessages(int numOfEntries)
java.lang.String[]	SessionInfoProtector.peekCallbackMessages(int numOfEntries)
java.lang.String[]	SubjectInfo.peekSubjectMessages(int numOfEntries)
java.lang.String[]	SubjectInfoProtector.peekSubjectMessages(int numOfEntries)
void	SubjectInfo.queueMessage(MsgQueueEntry entry) PtP mode: If the qos is set to forceQueuing the message is queued.
void	SessionInfo.queueMessage(MsgQueueEntry entry) Put the given message entry into the queue
void	SessionInfo.refreshSession() Call this to reactivate the session expiry to full value
void	SessionInfoProtector.refreshSession()
long	SessionInfo.removeFromCallbackQueue(long numOfEntries)
private void	Authenticate.resetSessionInfo(SessionInfo sessionInfo, boolean clearQueue, boolean forceShutdownEvenIfEntriesExist, boolean isDisconnecting)
void	Authenticate.runlevelChange(int from, int to, boolean force) Invoked on run level change, see RunlevelManager.RUNLEVEL_HALTED and RunlevelManager.RUNLEVEL_RUNNING Enforced by I_RunlevelListener
void	I_ClientListener.sessionAdded(ClientEvent e) Invoked on successful client login
void	I_ClientListener.sessionPreRemoved(ClientEvent e) Invoked before a client does a logout
void	I_ClientListener.sessionRemoved(ClientEvent e) Invoked when client does a logout
void	I_ClientListener.sessionUpdated(ClientEvent e) Invoked on successful client login
void	SubjectInfo.setSubjectQueueProperty(CbQueueProperty prop) Allows to overwrite queue property.
void	I_ClientListener.subjectAdded(ClientEvent e) Invoked on first successful client login, when SubjectInfo is created
void	I_ClientListener.subjectRemoved(ClientEvent e) Invoked when client does its last logout
java.lang.String	SessionInfo.subscribe(java.lang.String url, java.lang.String qos)
java.lang.String	SessionInfoProtector.subscribe(java.lang.String url, java.lang.String qos)
void	SubjectInfo.toAlive(I_Subject securityCtx, CbQueueProperty prop) Initialize SubjectInfo
java.lang.String	AuthenticateProtector.toXml()
SessionInfo	Authenticate.unsecureCreateSession(ConnectQos connectQos) Use this to create a user and session for internal users only.
SessionInfo	AuthenticateProtector.unsecureCreateSession(SessionName loginName) Deprecated. Security hole, currently need by MainGUI.java
java.lang.String[]	SessionInfo.unSubscribe(java.lang.String url, java.lang.String qos)
java.lang.String[]	SessionInfoProtector.unSubscribe(java.lang.String url, java.lang.String qos)
java.lang.String[]	SessionInfo.unSubscribeByIndex(int index, java.lang.String qos)
java.lang.String[]	SessionInfoProtector.unSubscribeByIndex(int index, java.lang.String qos)
void	SessionInfo.updateConnectQos(ConnectQosServer newConnectQos)
private void	Authenticate.updateConnectQos(SessionInfo sessionInfo, ConnectQosServer newConnectQos)
void	SubjectInfo.waitUntilAlive(boolean returnLocked) if state==UNDEF we block until we are ALIVE (or DEAD)

Constructors in org.xmlBlaster.authentication that throw XmlBlasterException

Authenticate(ServerScope global)

AuthenticateProtector(ServerScope global, Authenticate authenticate)

SubjectInfo(ServerScope glob, Authenticate authenticate, SessionName subjectName)

Uses of XmlBlasterException in org.xmlBlaster.authentication.plugins

Fields in org.xmlBlaster.authentication.plugins declared as XmlBlasterException

private XmlBlasterException

DataHolder.exceptionToThrow

Methods in org.xmlBlaster.authentication.plugins that return XmlBlasterException

XmlBlasterException

DataHolder.getExceptionToThrow()

Methods in org.xmlBlaster.authentication.plugins with parameters of type XmlBlasterException

void	DataHolder.setExceptionToThrow(XmlBlasterException exceptionToThrow) Allows a security plugin to throw another exception instead of ErrorCode.USER_SECURITY_AUTHORIZATION_NOTAUTHORIZED when returning false during isAuthorized() call

Methods in org.xmlBlaster.authentication.plugins that throw XmlBlasterException

void	I_Session.changeSecretSessionId(java.lang.String sessionId) The current implementation of the user session handling (especially Authenticate.connect(org.xmlBlaster.engine.qos.ConnectQosServer, String)) cannot provide a real sessionId when this object is created.
MsgUnitRaw	I_MsgSecurityInterceptor.exportMessage(CryptDataHolder dataHolder) Encrypt, sign, seal an outgoing message.
I_Manager	PluginManager.getDummyManager() Tries to return an instance of the default security manager, which simulates the old xmlBlaster behavior.
I_Manager	PluginManager.getManager(SessionInfo sessionInfo) Returns the security manager, responsible for given session.
I_Manager	PluginManager.getManager(java.lang.String sessionId) Returns the security manager, responsible for given session.
I_Manager	PluginManager.getManager(java.lang.String type, java.lang.String version) Return a specific SecurityManager, suitable to handle the requested security mechanisms.
I_Session	I_Manager.getSessionById(java.lang.String id) Get the I_Session which corresponds to the given sessionId.
MsgUnitRaw	I_MsgSecurityInterceptor.importMessage(CryptDataHolder dataHolder) Decrypt, check, unseal etc an incomming message.
ConnectQosServer	I_Session.init(ConnectQosServer connectQos, java.util.Map map) Initialize the session with useful information.
void	I_ClientPlugin.init(Global glob, PluginInfo pluginInfo)
java.lang.String	I_Session.init(I_SecurityQos securityQos) Initialize a new session and do the credential check.
void	I_SecurityQos.parse(java.lang.String xml) Parse the given xml string which contains the userId and credentials.
void	I_Manager.releaseSession(java.lang.String sessionId, java.lang.String qos_literal) Releases a reserved I_Session.
I_Session	I_Manager.reserveSession(java.lang.String sessionId) The session handling.
boolean	I_Session.verify(I_SecurityQos securityQos) Allows to check the given securityQos again.

Uses of XmlBlasterException in org.xmlBlaster.authentication.plugins.demo

Methods in org.xmlBlaster.authentication.plugins.demo that throw XmlBlasterException

(package private) void	Subject.authenticate(java.lang.String passwd) Authenticate the user
void	Session.changeSecretSessionId(java.lang.String sessionId)
(package private) void	Manager.changeSecretSessionId(java.lang.String oldSessionId, java.lang.String newSessionId)
private Subject	Session.determineSubject(java.lang.String user, java.lang.String passwd) Determine which subject is specified by user/passwd
private byte[]	Session.exportMessage(byte[] byteArr)
private byte[]	ClientPlugin.exportMessage(byte[] byteArr)
MsgUnitRaw	Session.exportMessage(CryptDataHolder dataHolder) encrypt, sign, seal an outgoing message.
MsgUnitRaw	ClientPlugin.exportMessage(CryptDataHolder dataHolder) encrypt, sign, seal an outgoing message.
private java.lang.String	Session.exportMessage(java.lang.String xmlMsg)
(package private) Subject	Manager.getSubject(java.lang.String name)
private byte[]	Session.importMessage(byte[] byteArr)
private byte[]	ClientPlugin.importMessage(byte[] byteArr)
MsgUnitRaw	Session.importMessage(CryptDataHolder dataHolder) decrypt, check, unseal an incoming message.
MsgUnitRaw	ClientPlugin.importMessage(CryptDataHolder dataHolder) decrypt, check, unseal an incomming message.
private java.lang.String	Session.importMessage(java.lang.String xmlMsg)
private java.lang.String	ClientPlugin.importMessage(java.lang.String xmlMsg) decrypt, check, unseal etc an incomming message.
ConnectQosServer	Session.init(ConnectQosServer connectQos, java.util.Map map)
java.lang.String	Session.init(I_SecurityQos securityQos) Initialize the Session for a login or connect call.
void	SecurityQos.parse(java.lang.String xmlQos_literal)
void	Manager.shutdown()

Uses of XmlBlasterException in org.xmlBlaster.authentication.plugins.htpasswd

Methods in org.xmlBlaster.authentication.plugins.htpasswd that throw XmlBlasterException

void	Session.changeSecretSessionId(java.lang.String sessionId)
void	Manager.changeSecretSessionId(java.lang.String oldSessionId, java.lang.String newSessionId)
boolean	HtPasswd.checkPassword(java.lang.String userName, java.lang.String userPassword) Check password
MsgUnitRaw	Session.exportMessage(CryptDataHolder dataHolder)
MsgUnitRaw	ClientPlugin.exportMessage(CryptDataHolder dataHolder) encrypt, sign, seal an outgoing message.
MsgUnitRaw	Session.importMessage(CryptDataHolder dataHolder)
MsgUnitRaw	ClientPlugin.importMessage(CryptDataHolder dataHolder) decrypt, check, unseal an incomming message.
ConnectQosServer	Session.init(ConnectQosServer connectQos, java.util.Map map)
java.lang.String	Session.init(I_SecurityQos securityQos) Initialize the Session for a login or connect call.
void	SecurityQos.parse(java.lang.String xmlQos_literal)
(package private) boolean	HtPasswd.readHtpasswordFile(java.lang.String htpasswdFilename) Read passwords file 16/11/01 20:42 mad@ktaland.com
I_Session	Manager.reserveSession(java.lang.String sessionId)
void	Manager.shutdown()

Constructors in org.xmlBlaster.authentication.plugins.htpasswd that throw XmlBlasterException

HtPasswd(Global glob)
Check password 16/11/01 19:36 mad@ktaland.com

SecurityQos(Global glob, java.lang.String xmlQos_literal)

Session(Manager sm, java.lang.String sessionId)

Uses of XmlBlasterException in org.xmlBlaster.authentication.plugins.ldap

Methods in org.xmlBlaster.authentication.plugins.ldap that throw XmlBlasterException

void	Session.changeSecretSessionId(java.lang.String sessionId)
(package private) void	Manager.changeSecretSessionId(java.lang.String oldSessionId, java.lang.String newSessionId)
boolean	LdapGateway.checkPassword(java.lang.String loginName, java.lang.String userPassword) Check password
MsgUnitRaw	Session.exportMessage(CryptDataHolder dataHolder)
MsgUnitRaw	ClientPlugin.exportMessage(CryptDataHolder dataHolder)
java.util.Hashtable	LdapGateway.getAllAttributes(java.lang.String loginName, java.lang.String password, java.lang.String lookupUserId) Get all attributes of this 'Person' objectclass
java.lang.String	LdapGateway.getPassword(javax.naming.directory.Attributes result) We assume that only one password is specified.
javax.naming.directory.DirContext	LdapGateway.getRootContext()
private javax.naming.directory.DirContext	LdapGateway.getUserContext(java.lang.String loginName, java.lang.String userPassword) Please close the given Context after usage.
private java.lang.String	LdapGateway.getUserDN(java.lang.String loginName) Searches the loginName in LDAP and returns its distinguishable name DN, e.g.
MsgUnitRaw	Session.importMessage(CryptDataHolder dataHolder)
MsgUnitRaw	ClientPlugin.importMessage(CryptDataHolder dataHolder)
ConnectQosServer	Session.init(ConnectQosServer connectQos, java.util.Map map)
java.lang.String	Session.init(I_SecurityQos securityQos)
void	SecurityQos.parse(java.lang.String xmlQos_literal)
I_Session	Manager.reserveSession(java.lang.String sessionId)
private javax.naming.NamingEnumeration	LdapGateway.search(javax.naming.directory.DirContext ctx, java.lang.String filter) Do a ldap query.
void	Manager.shutdown()
boolean	LdapGateway.userExists(java.lang.String loginName, java.lang.String password, java.lang.String loginNameToCheck) Check if given user exists

Constructors in org.xmlBlaster.authentication.plugins.ldap that throw XmlBlasterException

LdapGateway(Global glob, java.lang.String serverUrl, java.lang.String rootDN, java.lang.String rootPwd, java.lang.String loginFieldName)
Connects to the LDAP server.

SecurityQos(Global glob, java.lang.String xmlQos_literal)

Session(Manager sm, java.lang.String sessionId)

Uses of XmlBlasterException in org.xmlBlaster.authentication.plugins.simple

Methods in org.xmlBlaster.authentication.plugins.simple that throw XmlBlasterException

(package private) void	Subject.authenticate(java.lang.String passwd) Authenticate the user
void	Session.changeSecretSessionId(java.lang.String sessionId)
(package private) void	Manager.changeSecretSessionId(java.lang.String oldSessionId, java.lang.String newSessionId)
private Subject	Session.determineSubject(java.lang.String user, java.lang.String passwd) Determine which subject is specified by user/passwd
MsgUnitRaw	Session.exportMessage(CryptDataHolder dataHolder)
MsgUnitRaw	ClientPlugin.exportMessage(CryptDataHolder dataHolder)
(package private) Subject	Manager.getSubject(java.lang.String name)
MsgUnitRaw	Session.importMessage(CryptDataHolder dataHolder)
MsgUnitRaw	ClientPlugin.importMessage(CryptDataHolder dataHolder)
ConnectQosServer	Session.init(ConnectQosServer connectQos, java.util.Map map)
java.lang.String	Session.init(I_SecurityQos securityQos) Initialize the Session for a login or connect call.
void	SecurityQos.parse(java.lang.String xmlQoS_literal)
void	Manager.shutdown()

Constructors in org.xmlBlaster.authentication.plugins.simple that throw XmlBlasterException

SecurityQos(Global glob, java.lang.String xmlQoS_literal)

Uses of XmlBlasterException in org.xmlBlaster.client

Fields in org.xmlBlaster.client declared as XmlBlasterException

private XmlBlasterException	StreamingCallback.ex
private XmlBlasterException	XmlBlasterAccess.toDeadXmlBlasterException

Methods in org.xmlBlaster.client that return XmlBlasterException

XmlBlasterException

XmlBlasterAccess.getToDeadXmlBlasterException() Workaround to transport the reason for the toDead() transition as the interface {@link I_ConnectionStateListener#reachedDead(ConnectionStateEnum, I_XmlBlasterAccess) is missing to pass the exception to the client.

Methods in org.xmlBlaster.client with parameters of type XmlBlasterException

void	XmlBlasterAccess.lostConnection(XmlBlasterException xmlBlasterException) For example called by SOCKET layer (SocketCallbackImpl.java) on EOF.
boolean	XmlBlasterAccess.sendingFailed(MsgQueueEntry[] entries, XmlBlasterException exception)
void	XmlBlasterAccess.toDead(I_DispatchManager dispatchManager, ConnectionStateEnum oldState, XmlBlasterException xmlBlasterException) Call by DispatchManager on connection state transition.

Methods in org.xmlBlaster.client that throw XmlBlasterException

void	StreamingCallback.Writer.close(java.io.OutputStream outStream)
ConnectReturnQos	XmlBlasterAccess.connect(ConnectQos qos, I_Callback updateListener)
ConnectReturnQos	I_XmlBlasterAccess.connect(ConnectQos qos, I_Callback updateListener) Login to xmlBlaster.
ConnectReturnQos	XmlBlasterAccess.connect(ConnectQos qos, I_StreamingCallback streamingUpdateListener, boolean withQueue)
private void	StreamingCallback.consumeExceptionIfNotNull() returns the exception (if any) and resets it.
private void	XmlBlasterAccess.createDefaultCbServer() Extracts address data from ConnectQos (or adds default if missing) and instantiate a callback server as specified in ConnectQos
PublishReturnQos	XmlBlasterAccess.createTemporaryTopic(long destroyDelay, int historyMaxMsg)
PublishReturnQos	XmlBlasterAccess.createTemporaryTopic(java.lang.String uniqueTopicId, long destroyDelay, int historyMaxMsg)
PublishReturnQos	XmlBlasterAccess.createTemporaryTopic(TopicProperty topicProperty) Create a temporay topic.
EraseReturnQos[]	XmlBlasterAccess.erase(EraseKey eraseKey, EraseQos eraseQos)
EraseReturnQos[]	I_XmlBlasterAccess.erase(EraseKey eraseKey, EraseQos eraseQos)
EraseReturnQos[]	XmlBlasterAccess.erase(java.lang.String xmlKey, java.lang.String qos)
private java.lang.String[]	PluginLoader.fetchClassnameAndParam(java.lang.String mechanism, java.lang.String version) Resolve a class name of a plugin, specified by its type (mechanism) and version.
MsgUnit[]	XmlBlasterAccess.get(GetKey getKey, GetQos getQos)
MsgUnit[]	I_XmlBlasterAccess.get(GetKey getKey, GetQos getQos) Get synchronous messages.
MsgUnit[]	SynchronousCache.get(GetKey getKey, GetQos getQos) Access messages from cache
MsgUnit[]	XmlBlasterAccess.get(java.lang.String xmlKey, java.lang.String qos)
MsgUnit[]	XmlBlasterAccess.getCached(GetKey getKey, GetQos getQos)
MsgUnit[]	I_XmlBlasterAccess.getCached(GetKey getKey, GetQos getQos) Access synchronously messages.
I_ClientPlugin	PluginLoader.getClientPlugin(java.lang.String mechanism, java.lang.String version) Load another plugin.
I_ClientPlugin	PluginLoader.getCurrentClientPlugin() Get the currently used plugin
FileDumper	XmlBlasterAccess.getFileDumper()
java.lang.String	ClientErrorHandler.handleErrorSync(I_MsgErrorInfo msgErrorInfo)
I_CallbackServer	XmlBlasterAccess.initCbServer(java.lang.String loginName, CallbackAddress callbackAddress)
I_CallbackServer	I_XmlBlasterAccess.initCbServer(java.lang.String loginName, CallbackAddress callbackAddress) Create a new instance of the desired protocol driver like CORBA or RMI driver using the plugin loader.
boolean	XmlBlasterAccess.isCallbackDispatcherActive()
private I_ClientPlugin	PluginLoader.loadPlugin(java.lang.String[] param) Handels the process of loading a plugin.
boolean	SynchronousCache.newEntry(java.lang.String subId, GetKey getKey, MsgUnit[] units) Creates an new entry in the cache
PublishReturnQos	XmlBlasterAccess.publish(MsgUnit msgUnit)
PublishReturnQos	I_XmlBlasterAccess.publish(MsgUnit msgUnit)
PublishReturnQos[]	XmlBlasterAccess.publishArr(MsgUnit[] msgUnitArr)
void	XmlBlasterAccess.publishOneway(MsgUnit[] msgUnitArr)
void	I_XmlBlasterAccess.publishOneway(MsgUnit[] msgUnitArr) Publish messages.
private PublishReturnQos	XmlBlasterAccess.publishSingleChunk(MsgKeyData keyData, MsgQosData chunkQosData, byte[] buf, int length, boolean isLastChunk, long count, java.lang.Exception ex)
PublishReturnQos[]	XmlBlasterAccess.publishStream(java.io.InputStream is, MsgKeyData keyData, MsgQosData qosData, int maxBufSize, I_ReplaceContent contentReplacer)
PublishReturnQos[]	I_XmlBlasterAccess.publishStream(java.io.InputStream is, MsgKeyData keyData, MsgQosData qosData, int maxBufSize, I_ReplaceContent contentReplacer) Publishes one message in streaming manner, if the message content is too big to fit in one single chunk, the message is split in several smaller messages (called chunks) and these are published.
private java.lang.Object	XmlBlasterAccess.queueMessage(MsgQueueEntry entry) Put the given message entry into the queue
MsgUnit[]	XmlBlasterAccess.receive(java.lang.String oid, int maxEntries, long timeout, boolean consumable)
MsgUnit[]	I_XmlBlasterAccess.receive(java.lang.String oid, int maxEntries, long timeout, boolean consumable) This method synchronously accesses maxEntries messages from any xmlBlaster server side queue.
void	XmlBlasterAccess.refreshSession()
void	I_XmlBlasterAccess.refreshSession() Send an event to xmlBlaster to refresh the login session life time.
void	XmlBlasterAccessMBean.refreshSession() Send an event to xmlBlaster to refresh the login session life time.
MsgUnit[]	XmlBlasterAccess.request(MsgUnit msgUnit, long timeout, int maxEntries)
MsgUnit[]	I_XmlBlasterAccess.request(MsgUnit msgUnit, long timeout, int maxEntries) Implements the blocking request/reply pattern.
private void	StreamingCallback.reset()
java.lang.String	XmlBlasterAccess.sendAdministrativeCommand(java.lang.String command)
java.lang.String	I_XmlBlasterAccess.sendAdministrativeCommand(java.lang.String command) Convenience method to send an administrative command to xmlBlaster.
private void	XmlBlasterAccess.sendConnectQos() Sends the current connectQos to xmlBlaster and stores the connectReturnQos.
int	StreamingCallback.sendInitialQueueEntries()
void	XmlBlasterAccess.setCallbackDispatcherActive(boolean activate)
void	I_XmlBlasterAccess.setCallbackDispatcherActive(boolean activate) Switch callback dispatcher on/off.
private void	StreamingCallback.storeEntry(java.lang.String cbSessId, UpdateKey key, byte[] cont, UpdateQos qos)
SubscribeReturnQos	XmlBlasterAccess.subscribe(java.lang.String xmlKey, java.lang.String qos)
SubscribeReturnQos	XmlBlasterAccess.subscribe(java.lang.String xmlKey, java.lang.String qos, I_Callback cb)
SubscribeReturnQos	I_XmlBlasterAccess.subscribe(java.lang.String xmlKey, java.lang.String xmlQos, I_Callback cb) Subscribe to messages.
SubscribeReturnQos	XmlBlasterAccess.subscribe(SubscribeKey subscribeKey, SubscribeQos subscribeQos)
SubscribeReturnQos	I_XmlBlasterAccess.subscribe(SubscribeKey subscribeKey, SubscribeQos subscribeQos) Subscribe to messages.
SubscribeReturnQos	XmlBlasterAccess.subscribe(SubscribeKey subscribeKey, SubscribeQos subscribeQos, I_Callback cb)
SubscribeReturnQos	I_XmlBlasterAccess.subscribe(SubscribeKey subscribeKey, SubscribeQos subscribeQos, I_Callback cb) This subscribe variant allows to specify a specialized callback for updated messages.
MsgUnit	XmlDbMessageWrapper.toMessage() Creates the complete message for you, which you can publish to xmlBlaster.
java.lang.String	XmlDbMessageWrapper.toXml() Returns the 'message content' which is the SQL request coded in XML.
UnSubscribeReturnQos[]	XmlBlasterAccess.unSubscribe(java.lang.String xmlKey, java.lang.String qos)
UnSubscribeReturnQos[]	XmlBlasterAccess.unSubscribe(UnSubscribeKey unSubscribeKey, UnSubscribeQos unSubscribeQos)
UnSubscribeReturnQos[]	I_XmlBlasterAccess.unSubscribe(UnSubscribeKey unSubscribeKey, UnSubscribeQos unSubscribeQos) Cancel subscription.
java.lang.String[]	I_CallbackRaw.update(java.lang.String cbSessionId, MsgUnitRaw[] msgUnitArr) This is the callback method invoked from xmlBlaster server informing the client in an asynchronous mode about a new message.
java.lang.String	I_Callback.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos) This is the callback method invoked from I_XmlBlasterAccess informing the client in an asynchronous mode about a new message.
java.lang.String	StreamingCallback.update(java.lang.String cbSessId, UpdateKey updKey, byte[] cont, UpdateQos updQos)
java.lang.String	XmlBlasterAccess.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos) This is the callback method invoked from xmlBlaster delivering us a new asynchronous message.
java.lang.String	JavascriptCallback.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos) This is the callback method invoked from xmlBlaster delivering us a new asynchronous message.
boolean	SynchronousCache.update(java.lang.String subId, UpdateKey updateKey, byte[] content, UpdateQos updateQos) Updated the cache (add a new entry or replaces an existing or removes one).
java.lang.String	I_StreamingCallback.update(java.lang.String cbSessionId, UpdateKey updateKey, java.io.InputStream contentStream, UpdateQos updateQos) This is the callback method invoked from I_XmlBlasterAccess informing the client in an asynchronous mode about a new message.
private java.lang.String	StreamingCallback.updateInternal(java.lang.String cbSessId, UpdateKey updKey, byte[] cont, UpdateQos updQos, boolean isExternal)
java.lang.String	StreamingCallback.updateNewMessage(java.lang.String cbSessId, UpdateKey updKey, byte[] cont, UpdateQos updQos)
java.lang.String	StreamingCallback.updateStraight(java.lang.String cbSessId, UpdateKey updKey, byte[] cont, UpdateQos updQos)
void	StreamingCallback.Writer.write(java.io.OutputStream outStream, byte[] buf)

Constructors in org.xmlBlaster.client that throw XmlBlasterException

StreamingCallback(Global global, I_StreamingCallback callback)

StreamingCallback(Global global, I_StreamingCallback callback, long waitForChunksTimeout, long waitForClientReturnTimeout, boolean useQueue)

Uses of XmlBlasterException in org.xmlBlaster.client.dispatch

Methods in org.xmlBlaster.client.dispatch with parameters of type XmlBlasterException

private void	ClientDispatchManager.givingUpDelivery(XmlBlasterException ex)
boolean	ClientDispatchManager.sendingFailedNotification(MsgQueueEntry[] entries, XmlBlasterException ex) Notify I_PostSendListener about problem.
void	ClientDispatchManager.shutdownFomAnyState(ConnectionStateEnum oldState, XmlBlasterException ex) Call by DispatchConnectionsHandler on state transition
void	ClientDispatchManager.toDead(XmlBlasterException ex)

Methods in org.xmlBlaster.client.dispatch that throw XmlBlasterException

private void	ClientDispatchConnection.connect(MsgQueueEntry entry) Encrypt and send a connect request, decrypt the returned data
void	ClientDispatchConnection.connectLowlevel()
DispatchConnection	ClientDispatchConnectionsHandler.createDispatchConnection(AddressBase address)
void	ClientDispatchConnectionsHandler.createFakedReturnObjects(I_QueueEntry[] entries, java.lang.String state, java.lang.String stateInfo) If no connection is available but the message is for example save queued, we can generate here valid return objects
private void	ClientDispatchConnection.disconnect(MsgQueueEntry entry) Encrypt and send a disconnect request, decrypt the returned data
java.lang.String	ClientDispatchConnection.doPing(java.lang.String data)
void	ClientDispatchConnection.doSend(MsgQueueEntry[] msgArr_, boolean isAsyncMode) Send the messages to xmlBlaster.
private void	ClientDispatchConnection.erase(MsgQueueEntry entry) Encrypt and send a erase request, decrypt the returned data
private void	ClientDispatchConnection.get(MsgQueueEntry entry) Encrypt and send a synchronous get request, decrypt the returned data
private java.lang.String	ClientDispatchConnection.getEncryptedConnectQos(ConnectQosData cqd) Remember the cqd in this.connectQosData and return the encrypted string.
void	ClientDispatchManager.handleSyncWorkerException(java.util.List<I_Entry> entryList, java.lang.Throwable throwable) Called by DispatchWorker if an Exception occured in sync mode Only on client side
void	ClientDispatchManager.handleWorkerException(java.util.List<I_Entry> entryList, java.lang.Throwable throwable) Called by DispatchWorker if an Exception occurred in async mode.
void	ClientDispatchConnection.loadPlugin() Load the appropriate protocol driver, e.g the CORBA protocol plugin.
private void	ClientDispatchConnection.publish(MsgQueueEntry[] msgArr_)
void	ClientDispatchManager.putPost(I_QueueEntry queueEntry)
void	ClientDispatchManager.putPost(I_QueueEntry[] queueEntries)
boolean	ClientDispatchManager.putPre(I_QueueEntry queueEntry)
boolean	ClientDispatchManager.putPre(I_QueueEntry[] queueEntries)
protected void	ClientDispatchConnection.reconnect() On reconnect polling try to establish the connection.
void	ClientDispatchManager.removeFromQueue(MsgQueueEntry[] entries, boolean postSendNotify) Messages are successfully sent, remove them now from queue (sort of a commit()): We remove filtered/destroyed messages as well (which doen't show up in entryListChecked)
void	ClientDispatchManager.setAddresses(AddressBase[] addr) Set new callback addresses, typically after a session login/logout
void	ClientDispatchConnection.shutdown(boolean delayed) Stop all callback drivers of this client.
private void	ClientDispatchConnection.subscribe(MsgQueueEntry entry) Encrypt and send a subscribe request, decrypt the returned data
private void	ClientDispatchConnection.unSubscribe(MsgQueueEntry entry) Encrypt and send a unSubscribe request, decrypt the returned data
void	ClientDispatchManager.updateProperty(CallbackAddress[] addressArr) Reconfigure dispatcher with given properties.

Constructors in org.xmlBlaster.client.dispatch that throw XmlBlasterException

ClientDispatchConnection(Global glob, ClientDispatchConnectionsHandler connectionsHandler, AddressBase address)

ClientDispatchConnectionsHandler(Global glob, ClientDispatchManager dispatchManager)

ClientDispatchManager(Global glob, I_MsgErrorHandler failureListener, I_MsgSecurityInterceptor securityInterceptor, I_Queue msgQueue, I_ConnectionStatusListener connectionStatusListener, AddressBase[] addrArr, SessionName sessionName)

Uses of XmlBlasterException in org.xmlBlaster.client.feeder

Constructors in org.xmlBlaster.client.feeder that throw XmlBlasterException

PublishFile(java.lang.String[] args)
Constructs the PublishFile object.

Uses of XmlBlasterException in org.xmlBlaster.client.filepoller

Methods in org.xmlBlaster.client.filepoller that throw XmlBlasterException

private void	Publisher.createDirectoryManager() Create the file checker instance with the current configuration.
(package private) void	DirectoryManager.deleteOrMoveEntry(java.lang.String entryName, boolean success) Removes the specified entry from the map.
private FileInfo[]	Publisher.doPublish() Publish file to xmlBlaster.
byte[]	DirectoryManager.getContent(FileInfo info) Gets the content from the specified file as a byte[].
(package private) java.util.Set	DirectoryManager.getEntries() Gets all entries which are ready to be sent (i.e.
private java.util.Map	DirectoryManager.getNewFiles(java.io.File directory) Retrieves all files from the specified directory
void	Publisher.init() Connects to the xmlBlaster.
void	FilePollerPlugin.init(Global global, PluginInfo pluginInfo)
private java.io.File	DirectoryManager.initDirectory(java.io.File parent, java.lang.String propNameForLogging, java.lang.String dirName) Returns the specified directory or null or if needed it will create one
private void	DirectoryManager.moveTo(java.io.File file, java.lang.String origName, java.io.File destinationDirectory)
void	FilenameFilter.setPattern(java.lang.String globPattern, boolean trueRegex)
void	Publisher.shutdown() If an exception occurs it means it could not publish the entry
void	FilePollerPlugin.shutdown()

Constructors in org.xmlBlaster.client.filepoller that throw XmlBlasterException

DirectoryManager(Global global, java.lang.String name, java.lang.String directoryName, long delaySinceLastFileChange, java.lang.String filter, java.lang.String sent, java.lang.String discarded, java.lang.String lockExtention, boolean trueRegex, boolean copyOnMove)

FilenameFilter(java.lang.String pattern, boolean trueRegex)

Publisher(Global globOrig, java.lang.String name, I_PluginConfig pluginConfig)

Uses of XmlBlasterException in org.xmlBlaster.client.key

Constructors in org.xmlBlaster.client.key that throw XmlBlasterException

EraseKey(Global glob, java.lang.String queryString, java.lang.String queryType)
Constructor with given oid.

GetKey(Global glob, java.lang.String queryString, java.lang.String queryType)
Constructor for XPath query.

GetReturnKey(Global glob, java.lang.String xmlKey)
Parse the given xml data.

SubscribeKey(Global glob, java.lang.String queryString, java.lang.String queryType)
Constructor for XPath query.

UnSubscribeKey(Global glob, java.lang.String queryString, java.lang.String queryType)
Constructor with query parameters.

UpdateKey(Global glob, java.lang.String xmlKey)
Parse the given xml data.

Uses of XmlBlasterException in org.xmlBlaster.client.protocol

Methods in org.xmlBlaster.client.protocol with parameters of type XmlBlasterException

void	I_CallbackExtended.lostConnection(XmlBlasterException xmlBlasterException) For example called by socket layer on EOF

Methods in org.xmlBlaster.client.protocol that throw XmlBlasterException

void	ProtocolPluginManager.activateDrivers()
void	CbServerPluginManager.activateDrivers()
java.lang.String	I_XmlBlasterConnection.connect(java.lang.String connectQos) Login and authenticate, the authentication schema is transported in the qos.
void	I_XmlBlasterConnection.connectLowlevel(Address address) Initialize the driver and verify if the remote side is reachable on the low-level protocol layer.
boolean	I_XmlBlasterConnection.disconnect(java.lang.String disconnectQos) Logout from xmlBlaster.
EraseReturnQos[]	I_XmlBlaster.erase(java.lang.String xmlKey, java.lang.String qos)
java.lang.String[]	I_XmlBlasterConnection.erase(java.lang.String xmlKey, java.lang.String qos)
MsgUnit[]	I_XmlBlaster.get(java.lang.String xmlKey, java.lang.String qos)
MsgUnitRaw[]	I_XmlBlasterConnection.get(java.lang.String xmlKey, java.lang.String qos)
java.lang.String	I_CallbackServer.getCbAddress() Returns the current callback address.
I_XmlBlasterConnection	ProtocolPluginManager.getNewProtocolDriverInstance(java.lang.String driverType) Creates a new instance of the given protocol driver type.
I_CallbackServer	CbServerPluginManager.getNewProtocolDriverInstance(java.lang.String driverType) Creates a new instance of the given protocol driver type.
I_XmlBlasterConnection	ProtocolPluginManager.getPlugin(java.lang.String type, java.lang.String version) Return a specific plugin, every call will create a new plugin instance.
I_CallbackServer	CbServerPluginManager.getPlugin(java.lang.String type, java.lang.String version) Return a specific plugin, every call will create a new plugin instance.
void	I_CallbackServer.initialize(Global glob, java.lang.String name, CallbackAddress callbackAddress, I_CallbackExtended client) Initialize and start the callback server.
java.lang.String	I_XmlBlasterConnection.ping(java.lang.String qos) Ping the server on physical level and/or application level (see AvailabilityChecker).
PublishReturnQos	I_XmlBlaster.publish(MsgUnit msgUnit)
java.lang.String	I_XmlBlasterConnection.publish(MsgUnitRaw msgUnit)
PublishReturnQos[]	I_XmlBlaster.publishArr(MsgUnit[] msgUnitArr)
java.lang.String[]	I_XmlBlasterConnection.publishArr(MsgUnitRaw[] msgUnitArr)
void	I_XmlBlaster.publishOneway(MsgUnit[] msgUnitArr)
void	I_XmlBlasterConnection.publishOneway(MsgUnitRaw[] msgUnitArr)
void	I_XmlBlasterConnection.setConnectReturnQos(ConnectReturnQos connectReturnQos) Pass the driver the decrypted and parsed ConnectReturnQos directly after a connect.
void	I_XmlBlasterConnection.shutdown()
void	I_CallbackServer.shutdown() Stop the server
void	ProtocolPluginManager.shutdownDrivers(boolean force)
void	CbServerPluginManager.shutdownDrivers(boolean force)
SubscribeReturnQos	I_XmlBlaster.subscribe(java.lang.String xmlKey, java.lang.String qos)
java.lang.String	I_XmlBlasterConnection.subscribe(java.lang.String xmlKey, java.lang.String qos)
UnSubscribeReturnQos[]	I_XmlBlaster.unSubscribe(java.lang.String xmlKey, java.lang.String qos)
java.lang.String[]	I_XmlBlasterConnection.unSubscribe(java.lang.String xmlKey, java.lang.String qos)
java.lang.String[]	AbstractCallbackExtended.update(java.lang.String cbSessionId, MsgUnitRaw[] msgUnitArr) This is the callback method invoked natively informing the client in an asynchronous mode about new messages.
java.lang.String	AbstractCallbackExtended.update(java.lang.String cbSessionId, java.lang.String updateKeyLiteral, byte[] content, java.lang.String updateQosLiteral) It parses the string literals passed in the argument list and calls subsequently the update method with the signature defined in I_Callback.
java.lang.String	I_CallbackExtended.update(java.lang.String cbSessionId, java.lang.String updateKeyLiteral, byte[] content, java.lang.String updateQosLiteral) This is the callback method invoked when using certain callback protocols (for example xml-rpc) which informs the client in an asynchronous mode about a new message.
abstract java.lang.String	AbstractCallbackExtended.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos) The class which extends AbstractCallbackExtended must implement this method.

Uses of XmlBlasterException in org.xmlBlaster.client.protocol.corba

Methods in org.xmlBlaster.client.protocol.corba that throw XmlBlasterException

java.lang.String	CorbaConnection.connect(java.lang.String connectQos) Login to the server.
void	CorbaConnection.connectLowlevel(Address address)
private void	CorbaCallbackServer.createCallbackServer() Building a Callback server, using the tie approach.
java.lang.String[]	CorbaConnection.erase(java.lang.String xmlKey, java.lang.String qos)
MsgUnitRaw[]	CorbaConnection.get(java.lang.String xmlKey, java.lang.String qos)
AuthServer	CorbaConnection.getAuthenticationService(Address address) Access the authentication service.
java.lang.String	CorbaCallbackServer.getCbAddress()
(package private) org.omg.CosNaming.NamingContextExt	CorbaConnection.getNamingService() Locate the CORBA Name Service.
private Server	CorbaConnection.getXmlBlaster() Accessing the xmlBlaster handle.
void	CorbaCallbackServer.initialize(Global glob, java.lang.String name, CallbackAddress callbackAddress, I_CallbackExtended boss) Construct a CORBA callback server for xmlBlaster, used by java/corba clients.
java.lang.String	CorbaConnection.ping(java.lang.String qos)
java.lang.String	CorbaConnection.publish(MsgUnitRaw msgUnit) Publish fault-tolerant the given message.
java.lang.String[]	CorbaConnection.publishArr(MsgUnitRaw[] msgUnitArr)
void	CorbaConnection.publishOneway(MsgUnitRaw[] msgUnitArr)
void	CorbaConnection.setConnectReturnQos(ConnectReturnQos connectReturnQos)
void	CorbaConnection.shutdown() Shut down the callback server.
java.lang.String	CorbaConnection.subscribe(java.lang.String xmlKey, java.lang.String qos) Enforced by I_XmlBlasterConnection interface (failsafe mode).
java.lang.String[]	CorbaConnection.unSubscribe(java.lang.String xmlKey, java.lang.String qos) Enforced by I_XmlBlasterConnection interface (failsafe mode)

Constructors in org.xmlBlaster.client.protocol.corba that throw XmlBlasterException

CorbaCallbackServer(Global glob, java.lang.String name, CallbackAddress callbackAddress, I_CallbackExtended boss, org.omg.CORBA.ORB orb_)
Construct a CORBA callback server for xmlBlaster, used by java/corba clients.

Uses of XmlBlasterException in org.xmlBlaster.client.protocol.email

Methods in org.xmlBlaster.client.protocol.email that throw XmlBlasterException

java.lang.String	EmailConnection.connect(java.lang.String connectQos) Login to the server.
void	EmailConnection.connectLowlevel(Address address) Connects to xmlBlaster with one email connection.
boolean	EmailConnection.disconnect(java.lang.String qos) Does a logout and removes the callback server.
java.lang.String[]	EmailConnection.erase(java.lang.String xmlKey_literal, java.lang.String qos_literal) Delete messages.
MsgUnitRaw[]	EmailConnection.get(java.lang.String xmlKey_literal, java.lang.String qos_literal) Synchronous access a message.
java.lang.String	EmailCallbackImpl.getCbAddress()
void	EmailConnection.init(Global glob, PluginInfo pluginInfo) This method is called by the PluginManager (enforced by I_Plugin).
void	EmailCallbackImpl.initialize(Global glob, java.lang.String loginName, CallbackAddress callbackAddress, I_CallbackExtended cbClient) Initialize and start the callback server A thread receiving all messages from xmlBlaster, and delivering them back to the client code.
java.lang.String	EmailConnection.ping(java.lang.String qos) Check server.
java.lang.String	EmailConnection.publish(MsgUnitRaw msgUnit) Publish a message.
java.lang.String[]	EmailConnection.publishArr(MsgUnitRaw[] msgUnitArr) Publish multiple messages in one sweep.
void	EmailConnection.publishOneway(MsgUnitRaw[] msgUnitArr) Publish multiple messages in one sweep.
java.lang.String	EmailConnection.subscribe(java.lang.String xmlKey_literal, java.lang.String qos_literal) Enforced by I_XmlBlasterConnection interface (failsafe mode).
java.lang.String[]	EmailConnection.unSubscribe(java.lang.String xmlKey_literal, java.lang.String qos_literal) Unsubscribe from messages.

Uses of XmlBlasterException in org.xmlBlaster.client.protocol.http.common

Methods in org.xmlBlaster.client.protocol.http.common that throw XmlBlasterException

java.lang.String

Msg.getContentStr() Get the raw content, never null

Uses of XmlBlasterException in org.xmlBlaster.client.protocol.local

Methods in org.xmlBlaster.client.protocol.local that throw XmlBlasterException

java.lang.String	LocalConnection.connect(java.lang.String connectQos) Login to the server.
void	LocalConnection.connectLowlevel(Address address)
java.lang.String[]	LocalConnection.erase(java.lang.String xmlKey_literal, java.lang.String qos_literal) Delete messages.
MsgUnitRaw[]	LocalConnection.get(java.lang.String xmlKey_literal, java.lang.String qos_literal) Synchronous access a message.
java.lang.String	LocalCallbackImpl.getCbAddress() Returns the callback address.
void	LocalConnection.init(Global glob_, PluginInfo pluginInfo) This method is called by the PluginManager (enforced by I_Plugin).
void	LocalCallbackImpl.initialize(Global glob, java.lang.String loginName, CallbackAddress callbackAddress, I_CallbackExtended cbClient) Initialize the callback server.
java.lang.String	LocalConnection.ping(java.lang.String str) Check server.
java.lang.String	LocalConnection.publish(MsgUnitRaw msgUnit) Publish a message.
java.lang.String[]	LocalConnection.publishArr(MsgUnitRaw[] msgUnitArr) Publish multiple messages in one sweep.
void	LocalConnection.publishOneway(MsgUnitRaw[] msgUnitArr) Publish multiple messages in one sweep.
void	LocalConnection.shutdown() Shut down.
java.lang.String	LocalConnection.subscribe(java.lang.String xmlKey_literal, java.lang.String qos_literal) Enforced by I_XmlBlasterConnection interface (failsafe mode).
java.lang.String	LocalConnection.toXml()
java.lang.String	LocalConnection.toXml(java.lang.String extraOffset) Dump of the server, remove in future.
java.lang.String[]	LocalConnection.unSubscribe(java.lang.String xmlKey_literal, java.lang.String qos_literal) Unsubscribe from messages.

Uses of XmlBlasterException in org.xmlBlaster.client.protocol.rmi

Methods in org.xmlBlaster.client.protocol.rmi that throw XmlBlasterException

private void	RmiCallbackServer.bindToRegistry(I_XmlBlasterCallback callbackRmiServer) Publish the RMI xmlBlaster server to rmi registry.
java.lang.String	RmiConnection.connect(java.lang.String connectQos) Login to the server.
void	RmiConnection.connectLowlevel(Address address) Connect to RMI server.
void	RmiCallbackServer.createCallbackServer(I_XmlBlasterCallback callbackRmiServer) Building a Callback server, using the tie approach.
java.lang.String[]	RmiConnection.erase(java.lang.String xmlKey, java.lang.String qos)
MsgUnitRaw[]	RmiConnection.get(java.lang.String xmlKey, java.lang.String qos)
java.lang.String	RmiCallbackServer.getCbAddress()
private I_XmlBlaster	RmiConnection.getXmlBlaster() Accessing the xmlBlaster handle.
void	RmiConnection.init(Global glob, PluginInfo pluginInfo) This method is called by the PluginManager (enforced by I_Plugin).
void	RmiCallbackServer.initialize(Global glob, java.lang.String name, CallbackAddress callbackAddress, I_CallbackExtended client) Construct the callback server.
private java.rmi.Remote	RmiConnection.lookup(java.lang.String addr) Connect to RMI server.
java.lang.String	RmiConnection.ping(java.lang.String str) Check server.
java.lang.String	RmiConnection.publish(MsgUnitRaw msgUnit) Publish fault-tolerant the given message.
java.lang.String[]	RmiConnection.publishArr(MsgUnitRaw[] msgUnitArr)
void	RmiConnection.publishOneway(MsgUnitRaw[] msgUnitArr) RMI does not support oneway messages.
void	RmiConnection.shutdown() Shut down.
java.lang.String	RmiConnection.subscribe(java.lang.String xmlKey, java.lang.String qos) Enforced by I_XmlBlasterConnection interface (failsafe mode).
java.lang.String[]	RmiConnection.unSubscribe(java.lang.String xmlKey, java.lang.String qos) Enforced by I_XmlBlasterConnection interface (failsafe mode)
java.lang.String[]	RmiCallbackServer.update(java.lang.String cbSessionId, MsgUnitRaw[] msgUnitArr) This is the callback method invoked from xmlBlaster informing the client in an asynchronous mode about new messages.

Constructors in org.xmlBlaster.client.protocol.rmi that throw XmlBlasterException

RmiConnection(Global glob)
RMI client access to xmlBlaster for normal client applications.

RmiConnection(Global glob, java.applet.Applet ap)
RMI client access to xmlBlaster for applets.

Uses of XmlBlasterException in org.xmlBlaster.client.protocol.socket

Methods in org.xmlBlaster.client.protocol.socket that throw XmlBlasterException

java.lang.String	SocketConnection.connect(java.lang.String connectQos) Login to the server.
void	SocketConnection.connectLowlevel(Address address) Connects to xmlBlaster with one socket connection.
boolean	SocketConnection.disconnect(java.lang.String qos) Does a logout and removes the callback server.
java.lang.String[]	SocketConnection.erase(java.lang.String xmlKey_literal, java.lang.String qos_literal) Delete messages.
MsgUnitRaw[]	SocketConnection.get(java.lang.String xmlKey_literal, java.lang.String qos_literal) Synchronous access a message.
java.lang.String	SocketCallbackImpl.getCbAddress() Returns the callback address.
java.net.Socket	SocketConnection.getSocket() Get the raw socket handle
void	SocketConnection.init(Global glob, PluginInfo pluginInfo) This method is called by the PluginManager (enforced by I_Plugin).
void	SocketCallbackImpl.initialize(Global glob, java.lang.String loginName, CallbackAddress callbackAddress, I_CallbackExtended cbClient) Initialize and start the callback server A thread receiving all messages from xmlBlaster, and delivering them back to the client code.
java.lang.String	SocketConnection.ping(java.lang.String qos) Check server.
java.lang.String	SocketConnection.publish(MsgUnitRaw msgUnit) Publish a message.
java.lang.String[]	SocketConnection.publishArr(MsgUnitRaw[] msgUnitArr) Publish multiple messages in one sweep.
void	SocketConnection.publishOneway(MsgUnitRaw[] msgUnitArr) Publish multiple messages in one sweep.
void	SocketConnection.shutdown() Shut down the callback server.
java.lang.String	SocketConnection.subscribe(java.lang.String xmlKey_literal, java.lang.String qos_literal) Enforced by I_XmlBlasterConnection interface (failsafe mode).
java.lang.String	SocketConnection.toXml() Dump of the state, remove in future.
java.lang.String	SocketConnection.toXml(java.lang.String extraOffset) Dump of the state, remove in future.
java.lang.String[]	SocketConnection.unSubscribe(java.lang.String xmlKey_literal, java.lang.String qos_literal) Unsubscribe from messages.

Constructors in org.xmlBlaster.client.protocol.socket that throw XmlBlasterException

SocketConnection(Global glob)
Connect to xmlBlaster using plain socket with native message format.

SocketConnection(Global glob, java.applet.Applet ap)
Connect to xmlBlaster using plain socket messaging.

Uses of XmlBlasterException in org.xmlBlaster.client.protocol.xmlrpc

Methods in org.xmlBlaster.client.protocol.xmlrpc that return XmlBlasterException

static XmlBlasterException	XmlRpcConnection.extractXmlBlasterException(Global glob, org.apache.xmlrpc.XmlRpcException e, ErrorCode fallback, java.lang.String txt) Helma XmlRpc does in XmlRpcServer.java:314 an exception.toString() which is sent back to the client.
static XmlBlasterException	XmlRpcConnection.extractXmlBlasterException(Global glob, org.apache.xmlrpc.XmlRpcException e, java.lang.String txt)

Methods in org.xmlBlaster.client.protocol.xmlrpc that throw XmlBlasterException

java.lang.String	XmlRpcConnection.connect(java.lang.String connectQos) Login to the server.
void	XmlRpcConnection.connectLowlevel(Address address)
private void	XmlRpcCallbackServer.createCallbackServer(boolean useCDATA) Building a Callback server, using the tie approach.
java.lang.String[]	XmlRpcConnection.erase(java.lang.String xmlKey_literal, java.lang.String qos_literal) Delete messages.
MsgUnitRaw[]	XmlRpcConnection.get(java.lang.String xmlKey_literal, java.lang.String qos_literal) Synchronous access a message.
java.lang.String	XmlRpcCallbackServer.getCbAddress() Returns the current callback address.
java.lang.String	XmlScriptSerializer.getConnect(java.lang.String connectQos) Login to the server.
XmlRpcConnection	XmlRpcConnection.getCopy()
java.lang.String	XmlScriptSerializer.getDisconnect(java.lang.String qos) Does a logout and removes the callback server.
java.lang.String	XmlScriptSerializer.getErase(java.lang.String xmlKey_literal, java.lang.String qos_literal)
java.lang.String	XmlScriptSerializer.getGet(java.lang.String xmlKey_literal, java.lang.String qos_literal) Synchronous access a message.
private java.lang.String	XmlScriptSerializer.getLiteral(MsgUnitRaw[] msgArr, MethodName methodName, byte typeByte)
private java.lang.String	XmlScriptSerializer.getLiteral(MsgUnitRaw msgUnit, MethodName methodName)
private java.lang.String	XmlScriptSerializer.getLiteral(java.lang.String qos, MethodName methodName, byte typeByte)
private java.lang.String	XmlScriptSerializer.getLiteral(java.lang.String key, java.lang.String qos, MethodName methodName)
java.lang.String	XmlScriptSerializer.getPing(java.lang.String qos) Check server.
java.lang.String	XmlScriptSerializer.getPingResponse(java.lang.String qos)
java.lang.String	XmlScriptSerializer.getPublish(MsgUnitRaw msgUnit)
java.lang.String	XmlScriptSerializer.getPublishArr(MsgUnitRaw[] msgUnitArr)
java.lang.String	XmlScriptSerializer.getPublishOneway(MsgUnitRaw[] msgUnitArr)
java.lang.String	XmlScriptSerializer.getSubscribe(java.lang.String xmlKey_literal, java.lang.String qos_literal)
java.lang.String	XmlScriptSerializer.getUnSubscribe(java.lang.String xmlKey_literal, java.lang.String qos_literal)
java.lang.String	XmlScriptSerializer.getUpdateException(java.lang.String ex)
java.lang.String	XmlScriptSerializer.getUpdateResponse(java.lang.String ok)
void	XmlRpcConnection.getUpdates(I_CallbackExtended cb) Publish multiple messages in one sweep.
private org.apache.xmlrpc.client.XmlRpcClient	XmlRpcConnection.getXmlRpcClient()
void	XmlRpcConnection.init(Global global, PluginInfo plInfo) This method is called by the PluginManager (enforced by I_Plugin).
void	XmlRpcCallbackServer.initialize(Global glob, java.lang.String name, CallbackAddress callbackAddress, I_CallbackExtended client) Construct a persistently named object.
java.lang.String	XmlRpcConnection.ping(java.lang.String str) Check server.
void	XmlRpcCallbackServer.postInitialize()
java.lang.String	XmlRpcConnection.publish(MsgUnitRaw msgUnit) Publish a message.
java.lang.String[]	XmlRpcConnection.publishArr(MsgUnitRaw[] msgUnitArr) Publish multiple messages in one sweep.
void	XmlRpcConnection.publishOneway(MsgUnitRaw[] msgUnitArr) Publish multiple messages in one sweep.
private java.lang.Object	XmlRpcConnection.sendXmlScript(java.lang.String literal, java.lang.String prefix, boolean singleChannel)
void	XmlRpcConnection.setConnectReturnQos(ConnectReturnQos connectReturnQos)
void	XmlRpcConnection.shutdown() Shut down.
java.lang.String	XmlRpcConnection.subscribe(java.lang.String xmlKey_literal, java.lang.String qos_literal) Enforced by I_XmlBlasterConnection interface (failsafe mode).
java.lang.String	XmlRpcConnection.toXml()
java.lang.String	XmlRpcConnection.toXml(java.lang.String extraOffset) Dump of the server, remove in future.
java.lang.String[]	XmlRpcConnection.unSubscribe(java.lang.String xmlKey_literal, java.lang.String qos_literal) Unsubscribe from messages.
java.lang.String	XmlRpcCallbackImpl.update(java.lang.String cbSessionId, java.lang.String updateKey, byte[] content, java.lang.String updateQos) The update method.
java.lang.String	XmlRpcCallbackServer.update(java.lang.String cbSessionId, java.lang.String updateKey, byte[] content, java.lang.String updateQos) The update method.
java.lang.String	XmlRpcCallbackImpl.update(java.lang.String cbSessionId, java.lang.String updateKey, java.lang.String contentAsString, java.lang.String updateQos) The update method.

Constructors in org.xmlBlaster.client.protocol.xmlrpc that throw XmlBlasterException

XmlRpcCallbackImpl(XmlRpcCallbackServer server, boolean inhibitCbExceptions)
Construct a persistently named object.

XmlRpcCallbackServer.CbRunner()

XmlRpcConnection(Global glob)
Connect to xmlBlaster using XMLRPC.

XmlRpcConnection(Global glob, java.applet.Applet ap)
Connect to xmlBlaster using XMLRPC.

XmlScriptSerializer(Global glob, PluginInfo pluginInfo)
Called by plugin loader which calls init(Global, PluginInfo) thereafter.

Uses of XmlBlasterException in org.xmlBlaster.client.qos

Methods in org.xmlBlaster.client.qos that throw XmlBlasterException

java.lang.String	UpdateQos.getContentStr(byte[] msgContent) Convenience method to get the raw content as a string, the encoding is UTF-8 if not specified by clientProperty Constants.CLIENTPROPERTY_CONTENT_CHARSET
I_ClientPlugin	ConnectQos.loadClientPlugin(java.lang.String type, java.lang.String version, java.lang.String userId, java.lang.String credential) Allows to set or overwrite the client side security plugin.
static void	ConnectQos.main(java.lang.String[] args) For testing invoke: java org.xmlBlaster.client.qos.ConnectQos
static void	PublishQos.main(java.lang.String[] args) For testing invoke: java org.xmlBlaster.client.PublishQos
void	ConnectQos.setUserId(java.lang.String loginName) Allows to set or overwrite the login name for I_SecurityQos.

Constructors in org.xmlBlaster.client.qos that throw XmlBlasterException

ConnectQos(Global glob)
Default constructor.

ConnectQos(Global glob, java.lang.String userId, java.lang.String passwd)
Login with the default security plugin as given by -Security.Client.DefaultPlugin htpasswd,1.0

ConnectReturnQos(Global glob, ConnectQosData connectQosData)

ConnectReturnQos(Global glob, java.lang.String xmlQos)

EraseReturnQos(Global glob, java.lang.String xmlQos)
Constructor which parses XML string.

GetReturnQos(Global glob, java.lang.String xmlQos)
Constructs the specialized quality of service object for a get() call.

PublishReturnQos(Global glob, java.lang.String xmlQos)
Constructor which parses XML string.

SubscribeReturnQos(Global glob, java.lang.String xmlQos)
Constructor which parses XML string.

SubscribeReturnQos(Global glob, java.lang.String xmlQos, boolean isFakedReturn)
Constructor which parses XML string.

UnSubscribeReturnQos(Global glob, java.lang.String xmlQos)
Constructor which parses XML string.

UpdateQos(Global glob, java.lang.String xmlQos)
Constructs the specialized quality of service object for a update() call.

Uses of XmlBlasterException in org.xmlBlaster.client.queuemsg

Methods in org.xmlBlaster.client.queuemsg that throw XmlBlasterException

I_Entry	ClientEntryFactory.createEntry(int priority, long timestamp, java.lang.String type, boolean persistent, long sizeInBytes, java.io.InputStream is, StorageId storageId) Parses back the raw data to a I_Entry (deserializing)
I_Entry	ClientEntryFactory.createEntry(XBStore store, XBMeat meat, XBRef ref)
byte[]	ClientEntryFactory.toBlob(I_Entry entry) Parses the specified entry to a byte array (serializing).

Constructors in org.xmlBlaster.client.queuemsg that throw XmlBlasterException

MsgQueueConnectEntry(Global glob, StorageId storageId, ConnectQosData connectQosData)
Use this constructor if a new message object is fed by method connect().

MsgQueueDisconnectEntry(Global glob, StorageId storageId, DisconnectQos disconnectQos)
Use this constructor if a new message object is fed by method disconnect().

MsgQueueEraseEntry(Global glob, StorageId storageId, EraseKey eraseKey, EraseQos eraseQos)
Use this constructor if a new message object is fed by method erase().

MsgQueueGetEntry(Global glob, StorageId storageId, GetKey getKey, GetQos getQos)
Use this constructor for a get() request.

MsgQueuePublishEntry(Global glob, MsgUnit msgUnit, StorageId storageId)
Use this constructor if a new message object is fed by method publish() (not oneway).

MsgQueuePublishEntry(Global glob, MsgUnit msgUnit, StorageId storageId, boolean oneway)

MsgQueueSubscribeEntry(Global glob, StorageId storageId, QueryKeyData subscribeKeyData, QueryQosData subscribeQosData)
Use this constructor if a new message object is fed by method subscribe().

MsgQueueUnSubscribeEntry(Global glob, StorageId storageId, UnSubscribeKey unSubscribeKey, UnSubscribeQos unSubscribeQos)
Use this constructor if a new message object is fed by method unSubscribe().

Uses of XmlBlasterException in org.xmlBlaster.client.reader

Constructors in org.xmlBlaster.client.reader that throw XmlBlasterException

SubscribeMessage(Global glob)
Constructs the SubscribeMessage object.

Uses of XmlBlasterException in org.xmlBlaster.client.script

Methods in org.xmlBlaster.client.script that throw XmlBlasterException

protected MsgUnit	XmlScriptInterpreter.buildMsgUnit()
static java.lang.String	XmlScriptInterpreter.dumpToFile(java.lang.String path, java.lang.String fn, java.lang.String xml)
private void	XmlScriptInterpreter.fireCommand(java.lang.String qName) Fires the given xmlBlaster command and sends the response to the output stream
boolean	XmlScriptClient.fireMethod(MethodName methodName, java.lang.String sessionId, java.lang.String requestId, byte type)
abstract boolean	XmlScriptInterpreter.fireMethod(MethodName methodName, java.lang.String sessionId, java.lang.String requestId, byte type) On each remote method invocation this function is called.
protected void	XmlScriptInterpreter.flushResponse()
void	XmlScriptInterpreter.parse(java.io.Reader in) Parses the given reader and executes the specified commands.
void	XmlScriptClient.setProperty(java.lang.String key, java.lang.String value)
abstract void	XmlScriptInterpreter.setProperty(java.lang.String key, java.lang.String value) Set a property into Global scope.
java.lang.String	XmlScriptClient.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos)
java.lang.String	StreamCallback.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos) Enforced by I_Callback
java.lang.String	XmlScriptInterpreter.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos) If a callback handler was registered, we will be notified here about updates as well
private void	XmlScriptClient.writeResponse(MethodName methodName, java.lang.String message) Write respone message to OutputStream.
private void	XmlScriptClient.writeResponse(MethodName methodName, java.lang.String[] messages)

Uses of XmlBlasterException in org.xmlBlaster.contrib

Methods in org.xmlBlaster.contrib that throw XmlBlasterException

protected abstract void	GlobalInfo.doInit(Global global, PluginInfo pluginInfo)
void	GlobalInfo.init(Global global_, PluginInfo pluginInfo)
void	GlobalInfo.shutdown()
java.lang.String	MomEventEngine.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos)

Constructors in org.xmlBlaster.contrib that throw XmlBlasterException

GlobalInfo(Global otherGlobal, I_Info additionalInfo)
Additional infos are added on top of the initial Global configuration.

GlobalInfo(GlobalInfo baseInfo, I_Info additionalInfo)

Uses of XmlBlasterException in org.xmlBlaster.contrib.dbupdate

Methods in org.xmlBlaster.contrib.dbupdate that throw XmlBlasterException

XBStore	OneToThree.getXBStore(XBDatabaseAccessor accessor, Global glob, StorageId oldStorageId)
private java.util.Properties	OneToThree.parsePropertyValue(java.lang.String rawString)

Constructors in org.xmlBlaster.contrib.dbupdate that throw XmlBlasterException

OneToThree(ServerScope serverScopeOne, ServerScope serverScopeThree, Global globalOne, Global globalThree)

Uses of XmlBlasterException in org.xmlBlaster.contrib.dbwatcher.mom

Methods in org.xmlBlaster.contrib.dbwatcher.mom that throw XmlBlasterException

java.lang.String

XmlBlasterPublisher.update(java.lang.String s, UpdateKey k, byte[] content, UpdateQos q) Dummy implementation, PtP messages could arrive here which are ignored.

Uses of XmlBlasterException in org.xmlBlaster.contrib.dbwatcher.plugin

Methods in org.xmlBlaster.contrib.dbwatcher.plugin that throw XmlBlasterException

protected void	DbWatcherPlugin.doInit(Global global_, PluginInfo pluginInfo)
void	DbWatcherPlugin.shutdown()

Uses of XmlBlasterException in org.xmlBlaster.contrib.dbwriter

Methods in org.xmlBlaster.contrib.dbwriter that throw XmlBlasterException

protected void	DbWriterPlugin.doInit(Global global_, PluginInfo pluginInfo)
void	DbWriterPluginMBean.shutdown()
void	DbWriterPlugin.shutdown()

Uses of XmlBlasterException in org.xmlBlaster.contrib.filewatcher

Methods in org.xmlBlaster.contrib.filewatcher that throw XmlBlasterException

private void	Publisher.createDirectoryManagers() Create the file checker instance with the current configuration.
(package private) void	DirectoryManager.deleteOrMoveEntry(java.lang.String entryName, boolean success) Removes the specified entry from the map.
void	FileWatcherPlugin.doInit(Global global_, PluginInfo pluginInfo_)
private FileInfo[]	Publisher.doPublish(DirectoryManager directoryManager) Publish file or files to xmlBlaster.
byte[]	DirectoryManager.getContent(FileInfo info) Gets the content from the specified file as a byte[].
java.io.FileInputStream	DirectoryManager.getContentStream(FileInfo info)
(package private) java.util.Set	DirectoryManager.getEntries() Gets all entries which are ready to be sent (i.e.
private java.util.Map	DirectoryManager.getNewFiles(java.io.File directory) Retrieves all files from the specified directory
void	Publisher.init() Connects to the xmlBlaster.
private java.io.File	DirectoryManager.initDirectory(java.io.File parent, java.lang.String propNameForLogging, java.lang.String dirName) Returns the specified directory or null or if needed it will create one
private void	DirectoryManager.moveTo(java.io.File file, java.lang.String origName, java.io.File destinationDirectory)
private java.lang.String	Publisher.preparePubQos(java.lang.String origQos)
private void	Publisher.prepareReplSource(boolean doFill)
void	FilenameFilter.setPattern(java.lang.String globPattern, boolean trueRegex)
void	Publisher.shutdown() If an exception occurs it means it could not publish the entry
void	FileWatcherPlugin.shutdown()

Constructors in org.xmlBlaster.contrib.filewatcher that throw XmlBlasterException

DirectoryManager(Global global, java.lang.String name, java.lang.String directoryName, java.lang.String subDir, long delaySinceLastFileChange, java.lang.String filter, java.lang.String sent, java.lang.String discarded, java.lang.String lockExtention, boolean trueRegex, boolean copyOnMove)

FilenameFilter(java.lang.String pattern, boolean trueRegex)

Publisher(Global globOrig, java.lang.String name, I_Info info)

Uses of XmlBlasterException in org.xmlBlaster.contrib.filewriter

Methods in org.xmlBlaster.contrib.filewriter that throw XmlBlasterException

void	FileWriter.doInit(Global glob, PluginInfo info)
private void	FileWriter.initConnection() Connects to the xmlBlaster.
private void	FileWriter.prepareInit(Global globOrig, I_PluginConfig config)
void	FileWriter.shutdown() If an exception occurs it means it could not publish the entry
java.lang.String	FileWriter.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos)

Constructors in org.xmlBlaster.contrib.filewriter that throw XmlBlasterException

FileWriter(Global globOrig, java.lang.String name, I_PluginConfig config)

Uses of XmlBlasterException in org.xmlBlaster.contrib.htmlmonitor

Methods in org.xmlBlaster.contrib.htmlmonitor that throw XmlBlasterException

void	HtmlMonitorPlugin.init(Global global_, PluginInfo pluginInfo)
private java.lang.String	HtmlMonitorPlugin.lookup(java.lang.String query) Lookup the given administrative command.
private java.lang.String	HtmlMonitorPlugin.replaceAllVariables(java.lang.String template) Replace ${...} occurrences.
void	HtmlMonitorPlugin.shutdown()

Uses of XmlBlasterException in org.xmlBlaster.contrib.jmx

Methods in org.xmlBlaster.contrib.jmx that throw XmlBlasterException

protected void	MX4JAdaptor.doInit(Global global, PluginInfo pluginInfo)
void	MX4JAdaptor.shutdown()

Uses of XmlBlasterException in org.xmlBlaster.contrib.mime

Methods in org.xmlBlaster.contrib.mime with parameters of type XmlBlasterException

void	DropIfNotDeliverableUniqueOnly.toDead(I_DispatchManager dispatchManager, ConnectionStateEnum oldState, XmlBlasterException xmlBlasterException)
void	DropIfNotDeliverable.toDead(I_DispatchManager dispatchManager, ConnectionStateEnum oldState, XmlBlasterException xmlBlasterException)

Methods in org.xmlBlaster.contrib.mime that throw XmlBlasterException

void	DropIfNotDeliverableUniqueOnly.init(Global glob, PluginInfo pluginInfo) This method is called by the PluginManager (enforced by I_Plugin).
void	DropIfNotDeliverable.init(Global glob, PluginInfo pluginInfo) This method is called by the PluginManager (enforced by I_Plugin).
boolean	DropIfNotDeliverableUniqueOnly.match(SessionInfo receiver, MsgUnit msgUnit, Query query)
boolean	DropIfNotDeliverable.match(SessionInfo receiver, MsgUnit msgUnit, Query query)

Uses of XmlBlasterException in org.xmlBlaster.contrib.replication

Methods in org.xmlBlaster.contrib.replication that throw XmlBlasterException

protected void

ReplicationAgent.OwnGlobalInfo.doInit(Global global, PluginInfo pluginInfo)

Constructors in org.xmlBlaster.contrib.replication that throw XmlBlasterException

ReplSlave(Global global, ReplManagerPlugin manager, java.lang.String slaveSessionId, ConnectQosData connQosData)

Uses of XmlBlasterException in org.xmlBlaster.contrib.replication.impl

Methods in org.xmlBlaster.contrib.replication.impl with parameters of type XmlBlasterException

void	ReplManagerPlugin.toDead(I_DispatchManager dispatchManager, ConnectionStateEnum oldState, XmlBlasterException xmlBlasterException)

Methods in org.xmlBlaster.contrib.replication.impl that throw XmlBlasterException

protected void	ReplManagerPlugin.doInit(Global global, PluginInfo pluginInfo)
java.util.List<I_Entry>	ReplManagerPlugin.handleNextMessages(I_DispatchManager dispatchManager, java.util.List<I_Entry> pushEntries)
void	ReplManagerPlugin.initialize(Global glob, java.lang.String typeVersion)
java.lang.String	ReplManagerPlugin.intercept(SubjectInfo publisher, MsgUnit msgUnit) Is only invoked when it is configured as a MimePlugin (to count messages containing several transactions).
void	ReplManagerPlugin.postHandleNextMessages(I_DispatchManager dispatchManager, MsgUnit[] processedEntries) Does cleanup, particularly it sets the status and counters.
void	ReplManagerPlugin.sessionAdded(ClientEvent e) The part of this code inherent to the slave could be moved to the addDispatchManager since that method would always invoked too.
void	ReplManagerPlugin.sessionPreRemoved(ClientEvent e)
void	ReplManagerPlugin.sessionRemoved(ClientEvent e)
void	ReplManagerPlugin.sessionUpdated(ClientEvent e) Invoked on successful client re-login (interface I_ClientListener)
void	ReplManagerPlugin.shutdown(I_DispatchManager dispatchManager)
void	ReplManagerPlugin.subjectAdded(ClientEvent e)
void	ReplManagerPlugin.subjectRemoved(ClientEvent e)
void	ReplManagerPlugin.subscriptionAdd(SubscriptionEvent e) To make it simpler one could think to put this method together with sessionAdded.
void	ReplManagerPlugin.subscriptionRemove(SubscriptionEvent e)
java.lang.String	ReplManagerPlugin.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos) It receives events from all ReplicationConverter instances which want to register themselves for administration of initial updates.

Uses of XmlBlasterException in org.xmlBlaster.contrib.scheduler

Methods in org.xmlBlaster.contrib.scheduler that throw XmlBlasterException

private SchedulerPlugin.CronData	SchedulerPlugin.addSchedulerWithEx(java.lang.String name, java.lang.String value)
protected void	SchedulerPlugin.doInit(Global glob, PluginInfo plugInfo)
void	SchedulerPlugin.CronData.parse(java.lang.String txt)
void	SchedulerPluginMBean.shutdown()
void	SchedulerPlugin.shutdown()
private void	SchedulerPlugin.startSchedule(org.quartz.Scheduler sched, java.lang.String name, SchedulerPlugin.CronData data)

Uses of XmlBlasterException in org.xmlBlaster.contrib.socketgetter

Methods in org.xmlBlaster.contrib.socketgetter that throw XmlBlasterException

protected void	SocketGetterPlugin.doInit(Global global_, PluginInfo pluginInfo)
void	SocketGetterPlugin.shutdown()

Uses of XmlBlasterException in org.xmlBlaster.engine

Methods in org.xmlBlaster.engine that return XmlBlasterException

XmlBlasterException

AvailabilityChecker.checkException(MethodName action, java.lang.Throwable origEx) Checks the given exception and depending on the current run level it is converted into a communication exception (with the original embedded).

Methods in org.xmlBlaster.engine with parameters of type XmlBlasterException

void	EventPlugin.toDead(I_DispatchManager dispatchManager, ConnectionStateEnum oldState, XmlBlasterException xmlBlasterException)

Methods in org.xmlBlaster.engine that throw XmlBlasterException

private void	SessionPersistencePlugin.addOrUpdateSession(SessionInfo sessionInfo) A new session is added, checks if it shall be persisted.
int	RequestBroker.addPersistentTopicHandler(TopicEntry topicEntry) Make the topicHandler persistent for crash recovery and shutdown/startup cycle.
void	TopicHandler.addSubscriber(SubscriptionInfo sub, boolean calleeIsXPathMatchCheck) A client subscribed to this message, multiple subscriptions from the same client are OK.
private void	TopicHandler.addToBigDom() Merge the message DOM tree into the big xmlBlaster DOM tree
private void	TopicHandler.administrativeInitialize(MsgKeyData msgKeyData, MsgQosData publishQos, PublishQosServer publishQosServer) Initialize the messageUnit cache and the history queue for this topic
(package private) void	TopicHandler.change(MsgUnitWrapper msgUnitWrapper)
void	I_TopicListener.changed(TopicEvent e) Invoked on topic lifecycle change.
void	EventPlugin.changed(TopicEvent topicEvent)
void	TopicAccessor.changeDirtyRead(MsgUnitWrapper msgUnitWrapper)
I_MapEntry	MsgUnitWrapper.changeEntry(I_MapEntry entry) Callback invoked by I_Map.change inside the synchronization point.
int	RequestBroker.changePersistentTopicHandler(TopicEntry topicEntry) Remove the persistent TopicHandler entry.
(package private) void	RequestBroker.checkExistingSubscriptions(SessionInfo sessionInfo, TopicHandler topicHandler, PublishQosServer xmlQoS) This helper method checks for a published message which didn't exist before if there are any XPath subscriptions pending which match.
boolean	TopicHandler.checkFilter(SessionInfo publisherSessionInfo, SubscriptionInfo sub, MsgUnitWrapper msgUnitWrapper, boolean handleException) Checks if the filters allow this message to be sent to the specified session
void	AvailabilityChecker.checkServerIsReady(SessionName sessionName, AddressServer addressServer, MsgUnit msgUnit, MethodName action) The extended check when the message is imported/decrypted.
static MsgQueueUpdateEntry	TopicHandler.createEntryFromWrapper(MsgUnitWrapper msgUnitWrapper, SubscriptionInfo sub)
DispatchConnectionsHandler	ServerScope.createServerDispatchConnectionsHandler(ServerDispatchManager dispatchManager) Returns the callback layer implementation 'CbDispatchConnectionsHandler' on server side.
java.lang.String	RequestBroker.dump()
java.lang.String[]	XmlBlasterImpl.erase(AddressServer addressServer, java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal) Delete messages.
(package private) java.lang.String[]	RequestBroker.erase(SessionInfo sessionInfo, QueryKeyData xmlKey, EraseQosServer eraseQos) Client wants to erase a message.
private java.lang.String[]	RequestBroker.erase(SessionInfo sessionInfo, QueryKeyData xmlKey, EraseQosServer eraseQos, boolean isClusterUpdate) Client wants to erase a message.
void	TopicAccessor.erase(java.lang.String oid) Remove the given topic
long	TopicHandler.eraseFromHistoryQueue(SessionInfo sessionInfo, HistoryQos historyQos) Erase message instances but not the topic itself.
(package private) void	TopicHandler.eraseRequest(SessionInfo sessionInfo, QueryKeyData eraseKey, EraseQosServer eraseQos) Notify all Listeners that a topic is erased.
java.lang.String	TopicHandler.eraseTopic() JMX
private void	StartupTasks.excuteStartupTasks() On startup execute given script.
void	RequestBroker.exit()
TopicHandler	TopicAccessor.findOrCreate(SessionInfo sessionInfo, java.lang.String oid) Access a topicHandler by its unique oid or create it if not known.
(package private) void	RequestBroker.fireSubscribeEvent(SubscriptionInfo subscriptionInfo)
private void	RequestBroker.fireSubscriptionEvent(SubscriptionInfo subscriptionInfo, boolean subscribe) Is fired on subscribe(), unSubscribe() and several times on erase().
(package private) void	RequestBroker.fireUnSubscribeEvent(SubscriptionInfo subscriptionInfo)
PublishReturnQos	RequestBroker.forwardPtpPublish(SessionInfo sessionInfo, MsgUnit msgUnit, boolean isClusterUpdate, Destination destination) Rorward a message to another cluster node.
private void	TopicHandler.forwardToDestinations(SessionInfo publisherSessionInfo, MsgUnitWrapper cacheEntry, PublishQosServer publishQos) Forward PtP messages.
private static java.lang.String	SubscriptionInfo.generateUniqueKey(KeyData keyData, QueryQosData xmlQos, boolean clusterWideUnique) This static method may be used from external objects to get the unique key of a subscription.
MsgUnitRaw[]	XmlBlasterImpl.get(AddressServer addressServer, java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal) Synchronous access a message.
MsgUnit[]	RequestBroker.get(SessionInfo sessionInfo, QueryKeyData xmlKey, GetQosServer getQos) Invoked by a client, to access one/many MsgUnit.
CbProtocolManager	ServerScope.getCbProtocolManager() Initialize cb protocol manager.
ClusterManager	ServerScope.getClusterManager() Access instance which manages myself in a cluster environment.
ClusterManager	ServerScope.getClusterManager(SessionInfo sessionInfo) Initialize the instance which manages myself in a cluster environment.
CommandManager	ServerScope.getCommandManager() Access instance of remote command administration manager.
CommandManager	ServerScope.getCommandManager(SessionInfo sessionInfo) Initialize instance of remote command administration manager.
java.lang.String	ServerScope.getDump()
void	ServerScope.getDump(java.io.OutputStream out)
MsgUnit[]	TopicHandler.getHistoryMsgUnitArr(int num, boolean newestFirst) Returns a snapshot of all entries in the history
MsgUnit[]	TopicHandler.getHistoryQueueEntries(java.lang.String querySpec) Query the history queue, can be peeking or consuming.
(package private) java.lang.String	EventPlugin.JmxDestinationHelper.getMessage(java.lang.String summary, java.lang.String description, java.lang.String eventType, java.lang.String errorCode, SessionName sessionName)
MsgFileDumper	ServerScope.getMsgFileDumper() A helper to dump a message to a file.
(package private) MsgUnit	EventPlugin.PublishDestinationHelper.getMsgUnit(java.lang.String summary, java.lang.String description, java.lang.String eventType, java.lang.String errorCode, SessionName sessionName)
MsgUnitWrapper	TopicHandler.getMsgUnitWrapper(long uniqueId)
MsgUnitWrapper[]	TopicHandler.getMsgUnitWrapperArr(int num, boolean newestFirst) Returns a snapshot of all entries in the history
PluginHolder	ServerScope.getPluginHolder() gets the object holding all configuration information for the plugins (both for statically loaded plugins (by the run level manager) and dynamically loaded plugins (such plugins loaded on client request).
(package private) MsgKeyData	EventPlugin.PublishDestinationHelper.getPublishKey(java.lang.String summary, java.lang.String description, java.lang.String eventType, java.lang.String errorCode)
(package private) MsgQosData	EventPlugin.PublishDestinationHelper.getPublishQos(java.lang.String summary, java.lang.String description, java.lang.String eventType, java.lang.String errorCode, SessionName sessionName)
org.w3c.dom.Node	TopicHandler.getRootNode()
SmtpClient	EventPlugin.getSmtpClient() TODO: Put into engine.Global and util.Global (see EmailExecutor.java)
java.util.ArrayList<SubscriptionInfo>	ClientSubscriptions.getSubscription(SessionInfo sessionInfo, QueryKeyData queryKey)
SubscriptionInfo	ClientSubscriptions.getSubscription(SessionInfo sessionInfo, java.lang.String subscriptionInfoUniqueKey) If you have the unique id of a subscription, you may access the SubscriptionInfo object here.
java.util.Vector<SubscriptionInfo>	ClientSubscriptions.getSubscriptionByOid(SessionInfo sessionInfo, java.lang.String keyOid, boolean exactOnly)
java.util.Vector	ClientSubscriptions.getSubscriptionByOid(java.lang.String keyOid, boolean exactOnly)
java.lang.String	SubscriptionInfo.getSubSourceSubscriptionId() Accessing the unique subscription id from method subscribe(), which was the reason for this SubscriptionInfo
java.lang.String	TopicHandler.getTopicXml()
XmlKey	TopicHandler.getXmlKey() Accessing the DOM parsed key of this topic.
void	TopicHandler.handleCallbackFailed(java.util.Set removeSet) If a callback fails, we remove it from the subscription.
java.lang.String	MsgErrorHandler.handleErrorSync(I_MsgErrorInfo msgErrorInfo) This should never happen on server side, so we just call handleError(I_MsgErrorInfo).
private MsgUnit	XmlBlasterImpl.importAndAuthorize(SessionInfo sessionInfo, AddressServer addressServer, MsgUnitRaw msgUnitRaw, MethodName action) Check message via security plugin.
void	MsgUnitWrapper.incrementReferenceCounter(int count, StorageId storageId) Invoked by ReferenceEntry.java and TopicHandler.java to support reference counting
void	SessionPersistencePlugin.init(Global glob, PluginInfo pluginInfo) Initializes the plugin
void	StartupTasks.init(Global glob, PluginInfo pluginInfo) Initializes the plugin
void	DeadMessageDumper.init(Global glob, PluginInfo pluginInfo) Initializes the plugin
void	EventPlugin.init(Global utilGlob, PluginInfo pluginInfo) Initializes the plugin
private void	SubscriptionInfo.init(ServerScope glob, SessionInfo sessionInfo, KeyData keyData, SubscribeQosServer qos)
private java.io.File	DeadMessageDumper.initDirectory(java.io.File parent, java.lang.String propName, java.lang.String dirName) Returns the specified directory or null or if needed it will create one
private void	RequestBroker.initHelperQos() Put this code in a generic internal message producer class (future release)
private void	TopicHandler.initMsgDistributorPlugin() instantiates and initializes a MsgDistributorPlugin if the topic property requires so.
private I_Queue	TopicHandler.initQueue(I_Queue queue, java.lang.String queueName) Creates a queue with the properties specified in the historyQueueProperty
private void	SubscriptionInfo.initSubscriptionId() For JMX the uniqueKey may not contain commas ','.
private void	TopicHandler.invokeCallbackAndHandleFailure(SessionInfo publisherSessionInfo, MsgUnitWrapper msgUnitWrapper) Send updates to all subscribed clients.
boolean	ServerScope.isAdministrationCommand(XmlKey xmlKey)
static boolean	TopicHandler.isDirtyRead(SubscriptionInfo sub, MsgUnitWrapper msgUnitWrapper) Checks if the subscriber is a cluster and the message has the 'dirtyRead' flag set.
MsgUnitWrapper	TopicAccessor.lookupDirtyRead(java.lang.String topicId, long msgUnitWrapperUniqueId) Access the message meat without a lock.
void	BigXmlKeyDOM.messageErase(TopicHandler topicHandler) Invoked on message erase() invocation.
java.lang.String[]	TopicHandler.peekHistoryMessages(int numOfEntries)
java.lang.String[]	ServerScope.peekMessages(I_Queue queue, int numOfEntries, java.lang.String label, boolean forceReadableTimestamp, boolean forceReadableBase64)
java.lang.String[]	ServerScope.peekQueueMessagesToFile(I_Queue queue, int numOfEntries, java.lang.String path, java.lang.String label) Dumps given amount of messages from queue to file.
private TopicEntry	TopicHandler.persistTopicEntry() Create or access the cached persistence storage entry of this topic.
java.lang.String	XmlBlasterImpl.ping(AddressServer addressServer, java.lang.String qos) ping xmlBlaster if everything is OK and if xmlBlaster is willing to accept requests.
private java.lang.String	XmlBlasterImpl.publish(AddressServer addressServer, SessionInfo sessionInfo, MsgUnitRaw msgUnitRaw, MethodName methodName)
java.lang.String	XmlBlasterImpl.publish(AddressServer addressServer, java.lang.String sessionId, MsgUnitRaw msgUnitRaw) Publish a message.
java.lang.String	RequestBroker.publish(SessionInfo sessionInfo, MsgUnit msgUnit) Internal publishing helper.
private java.lang.String	RequestBroker.publish(SessionInfo sessionInfo, MsgUnit msgUnit, boolean isClusterUpdate)
PublishReturnQos	TopicHandler.publish(SessionInfo publisherSessionInfo, MsgUnit msgUnit, PublishQosServer publishQosServer) A new publish event (PubSub or PtP) arrives.
private java.lang.String	RequestBroker.publish(SessionInfo sessionInfo, MsgUnit msgUnit, PublishQosServer publishQos) Write-Access method to publish a new message from a data source.
java.lang.String[]	XmlBlasterImpl.publishArr(AddressServer addressServer, java.lang.String sessionId, MsgUnitRaw[] msgUnitArr) Publish messages.
java.lang.String	RequestBroker.publishDeadMessage(MsgUnit origMsgUnit, java.lang.String text, java.lang.String clientPropertyKey, SessionName receiver)
java.lang.String	RequestBroker.publishDeadMessageRaw(SessionName sender, MsgUnitRaw origMsgUnit, java.lang.String text, SessionName receiver)
private KeyData[]	RequestBroker.queryMatchingKeys(SessionInfo sessionInfo, QueryKeyData queryKeyData, QueryQosData qos) This method does the query (queryType = "XPATH" | "EXACT").
private java.lang.String[]	RequestBroker.queryMatchingTopics(SessionInfo sessionInfo, QueryKeyData queryKeyData, QueryQosData qos) This method does the query (queryType = "XPATH" | "EXACT").
private java.util.HashMap	SessionPersistencePlugin.recoverSessions()
private void	SessionPersistencePlugin.recoverSubscriptions(java.util.HashMap sessionIds) When recovering due to a run level change (without shutti