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.event
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	HelloWorldNative2.init(Global glob, PluginInfo pluginInfo)
void	HelloWorldNative.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	SessionInfo.queueMessage(MsgQueueEntry entry) Put the given message entry into the queue
void	SubjectInfo.queueMessage(MsgQueueEntry entry) PtP mode: If the qos is set to forceQueuing the message is queued.
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[]	ClientPlugin.exportMessage(byte[] byteArr)
private byte[]	Session.exportMessage(byte[] byteArr)
MsgUnitRaw	ClientPlugin.exportMessage(CryptDataHolder dataHolder) encrypt, sign, seal an outgoing message.
MsgUnitRaw	Session.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[]	ClientPlugin.importMessage(byte[] byteArr)
private byte[]	Session.importMessage(byte[] byteArr)
MsgUnitRaw	ClientPlugin.importMessage(CryptDataHolder dataHolder) decrypt, check, unseal an incomming message.
MsgUnitRaw	Session.importMessage(CryptDataHolder dataHolder) decrypt, check, unseal an incoming message.
private java.lang.String	ClientPlugin.importMessage(java.lang.String xmlMsg) decrypt, check, unseal etc an incomming message.
private java.lang.String	Session.importMessage(java.lang.String xmlMsg)
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	ClientPlugin.exportMessage(CryptDataHolder dataHolder) encrypt, sign, seal an outgoing message.
MsgUnitRaw	Session.exportMessage(CryptDataHolder dataHolder)
MsgUnitRaw	ClientPlugin.importMessage(CryptDataHolder dataHolder) decrypt, check, unseal an incomming message.
MsgUnitRaw	Session.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)
(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	ClientPlugin.exportMessage(CryptDataHolder dataHolder)
MsgUnitRaw	Session.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	ClientPlugin.importMessage(CryptDataHolder dataHolder)
MsgUnitRaw	Session.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	ClientPlugin.exportMessage(CryptDataHolder dataHolder)
MsgUnitRaw	Session.exportMessage(CryptDataHolder dataHolder)
(package private) Subject	Manager.getSubject(java.lang.String name)
MsgUnitRaw	ClientPlugin.importMessage(CryptDataHolder dataHolder)
MsgUnitRaw	Session.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	XmlBlasterAccessMBean.refreshSession() Send an event to xmlBlaster to refresh the login session life time.
void	I_XmlBlasterAccess.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	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	StreamingCallback.update(java.lang.String cbSessId, UpdateKey updKey, byte[] cont, UpdateQos updQos)
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.
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	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.
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	CbServerPluginManager.activateDrivers()
void	ProtocolPluginManager.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.
java.lang.String[]	I_XmlBlasterConnection.erase(java.lang.String xmlKey, java.lang.String qos)
EraseReturnQos[]	I_XmlBlaster.erase(java.lang.String xmlKey, java.lang.String qos)
MsgUnitRaw[]	I_XmlBlasterConnection.get(java.lang.String xmlKey, java.lang.String qos)
MsgUnit[]	I_XmlBlaster.get(java.lang.String xmlKey, java.lang.String qos)
java.lang.String	I_CallbackServer.getCbAddress() Returns the current callback address.
I_CallbackServer	CbServerPluginManager.getNewProtocolDriverInstance(java.lang.String driverType) Creates a new instance of the given protocol driver type.
I_XmlBlasterConnection	ProtocolPluginManager.getNewProtocolDriverInstance(java.lang.String driverType) Creates a new instance of the given protocol driver type.
I_CallbackServer	CbServerPluginManager.getPlugin(java.lang.String type, java.lang.String version) Return a specific plugin, every call will create a new plugin instance.
I_XmlBlasterConnection	ProtocolPluginManager.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	CbServerPluginManager.shutdownDrivers(boolean force)
void	ProtocolPluginManager.shutdownDrivers(boolean force)
java.lang.String	I_XmlBlasterConnection.subscribe(java.lang.String xmlKey, java.lang.String qos)
SubscribeReturnQos	I_XmlBlaster.subscribe(java.lang.String xmlKey, java.lang.String qos)
java.lang.String[]	I_XmlBlasterConnection.unSubscribe(java.lang.String xmlKey, java.lang.String qos)
UnSubscribeReturnQos[]	I_XmlBlaster.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.
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	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, 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	StreamCallback.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos) Enforced by I_Callback
java.lang.String	XmlScriptClient.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos)
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	DbWriterPlugin.shutdown()
void	DbWriterPluginMBean.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	DropIfNotDeliverable.toDead(I_DispatchManager dispatchManager, ConnectionStateEnum oldState, XmlBlasterException xmlBlasterException)
void	DropIfNotDeliverableUniqueOnly.toDead(I_DispatchManager dispatchManager, ConnectionStateEnum oldState, XmlBlasterException xmlBlasterException)

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

void	DropIfNotDeliverable.init(Global glob, PluginInfo pluginInfo) This method is called by the PluginManager (enforced by I_Plugin).
void	DropIfNotDeliverableUniqueOnly.init(Global glob, PluginInfo pluginInfo) This method is called by the PluginManager (enforced by I_Plugin).
boolean	DropIfNotDeliverable.match(SessionInfo receiver, MsgUnit msgUnit, Query query)
boolean	DropIfNotDeliverableUniqueOnly.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.
MsgFileDumper	ServerScope.getMsgFileDumper() A helper to dump a message to a file.
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).
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, QueryQosData queryQos)
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	DeadMessageDumper.init(Global glob, PluginInfo pluginInfo) Initializes the plugin
void	SessionPersistencePlugin.init(Global glob, PluginInfo pluginInfo) Initializes the plugin
void	EventPlugin.init(Global utilGlob, PluginInfo pluginInfo) Initializes the plugin
void	StartupTasks.init(Global glob, 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.
MsgUnitWrapper	TopicAccessor.lookupNewest(java.lang.String topicId) Access the newest entry.
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 shutting down the application) this will not work.
private void	EventPlugin.registerEventTypes(java.lang.String eventTypes) Find out which events to listen.
private void	SessionPersistencePlugin.removeAssociatedSubscriptions(SessionInfo sessionInfo)
private void	ClientSubscriptions.removeFromClientSubscriptionMap(SessionInfo sessionInfo, java.lang.String subscriptionInfoUniqueKey)
private int	ClientSubscriptions.removeFromQuerySubscribeRequestsSet(SessionInfo sessionInfo, java.lang.String subscriptionInfoUniqueKey)
int	RequestBroker.removePersistentTopicHandler(TopicEntry topicEntry) Remove the persistent TopicHandler entry.
void	AvailabilityChecker.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	RequestBroker.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	ServerScope.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	ClientSubscriptions.sessionAdded(ClientEvent e) Invoked on successful client login (interface I_ClientListener)
void	RequestBroker.sessionAdded(ClientEvent e) Event invoked on successful client login (interface I_ClientListener).
void	SessionPersistencePlugin.sessionAdded(ClientEvent e)
void	EventPlugin.sessionAdded(ClientEvent clientEvent)
void	ClientSubscriptions.sessionPreRemoved(ClientEvent e)
void	RequestBroker.sessionPreRemoved(ClientEvent e)
void	SessionPersistencePlugin.sessionPreRemoved(ClientEvent e)
void	EventPlugin.sessionPreRemoved(ClientEvent clientEvent)
void	ClientSubscriptions.sessionRemoved(ClientEvent e) Invoked when client does a logout (interface I_ClientListener)
void	RequestBroker.sessionRemoved(ClientEvent e) Event invoked when client does a logout (interface I_ClientListener).
void	SessionPersistencePlugin.sessionRemoved(ClientEvent e)
void	EventPlugin.sessionRemoved(ClientEvent clientEvent)
void	ClientSubscriptions.sessionUpdated(ClientEvent e) Invoked on successful client re-login (interface I_ClientListener)
void	RequestBroker.sessionUpdated(ClientEvent e) Invoked on successful client re-login (interface I_ClientListener)
void	SessionPersistencePlugin.sessionUpdated(ClientEvent e) Invoked on successful client re-login (interface I_ClientListener)
void	EventPlugin.sessionUpdated(ClientEvent e) Invoked on successful client re-login (interface I_ClientListener)
void	RequestBroker.setDump(java.lang.String fn)
void	RequestBroker.setExit(java.lang.String exitValue)
void	RequestBroker.setRunlevel(java.lang.String levelStr)
void	EventPlugin.setupSmtpSink(java.lang.String destination) Initialize email sending.
void	DeadMessageDumper.shutdown() Shutdown the plugin
void	SessionPersistencePlugin.shutdown() Shutsdown the plugin
void	EventPlugin.shutdown() Shutdown the plugin
void	StartupTasks.shutdown() Shutdown the plugin
private void	TopicHandler.startupHistoryQueue() Should be invoked delayed as soon as TopicHandler instance is created an registered everywhere as we ask the msgUnitStore for the real messages if some history entries existed.
private void	TopicHandler.startupMsgstore() This cache stores the 'real meat' (the MsgUnit data struct)
private void	RequestBroker.startupTopicStore() This stores the topics configuration (the publish administrative message - the MsgUnit data struct)
void	ClientSubscriptions.subjectAdded(ClientEvent e) Event invoked on new created SubjectInfo.
void	RequestBroker.subjectAdded(ClientEvent e) Event invoked on new created SubjectInfo.
void	SessionPersistencePlugin.subjectAdded(ClientEvent e) does nothing
void	EventPlugin.subjectAdded(ClientEvent e)
void	ClientSubscriptions.subjectRemoved(ClientEvent e) Event invoked on deleted SubjectInfo.
void	RequestBroker.subjectRemoved(ClientEvent e) Event invoked on deleted SubjectInfo.
void	SessionPersistencePlugin.subjectRemoved(ClientEvent e) does nothing
void	EventPlugin.subjectRemoved(ClientEvent e)
java.lang.String	XmlBlasterImpl.subscribe(AddressServer addressServer, java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal) Subscribe to messages.
java.lang.String	RequestBroker.subscribe(SessionInfo sessionInfo, QueryKeyData xmlKey, SubscribeQosServer subscribeQos)
private void	DeadMessageDumper.subscribeToDeadMessages() On startup subscribe to topic __sys__deadMessage.
private void	RequestBroker.subscribeToOid(SubscriptionInfo subs, boolean calleeIsXPathMatchCheck) Low level subscribe, is called when the to subscribe is exactly known.
void	ClientSubscriptions.subscriptionAdd(SubscriptionEvent e) Event invoked on new subscription (interface SubscriptionListener).
void	SessionPersistencePlugin.subscriptionAdd(SubscriptionEvent e) This event is invoked even by child subscriptions.
void	EventPlugin.subscriptionAdd(SubscriptionEvent subscriptionEvent)
void	I_SubscriptionListener.subscriptionAdd(SubscriptionEvent e) Invoked on successful subscription login
void	ClientSubscriptions.subscriptionRemove(SubscriptionEvent e) Invoked when a subscription is canceled (interface SubscriptionListener).
void	SessionPersistencePlugin.subscriptionRemove(SubscriptionEvent e)
void	EventPlugin.subscriptionRemove(SubscriptionEvent subscriptionEvent)
void	I_SubscriptionListener.subscriptionRemove(SubscriptionEvent e) Invoked when subscription does a logout
private void	TopicHandler.toAlive()
private void	MsgUnitWrapper.toExpired()
void	ClientSubscriptions.topicRemove(TopicHandler topicHandler) Event invoked on message erase() invocation.
private java.util.ArrayList	TopicHandler.toUnreferenced(boolean onAdministrativeCreate, boolean fromPersistenceStore)
java.lang.String	ClientSubscriptions.toXml() Dump state of this object into XML.
java.lang.String	RequestBroker.toXml() Dump state of this object into a XML ASCII string.
java.lang.String	XmlBlasterImpl.toXml() Dump state of RequestBroker into a XML ASCII string.
java.lang.String	BigXmlKeyDOM.toXml() Dump state of this object into XML.
java.lang.String	ClientSubscriptions.toXml(java.lang.String extraOffset) Dump state of this object into XML.
java.lang.String	RequestBroker.toXml(java.lang.String extraOffset) Dump state of this object into a XML ASCII string.
java.lang.String	XmlBlasterImpl.toXml(java.lang.String extraOffset) Dump state of RequestBroker into a XML ASCII string.
java.lang.String	BigXmlKeyDOM.toXml(java.lang.String extraOffset) Dump state of this object into XML.
java.lang.String	TopicAccessor.toXml(java.lang.String extraOffset) Dump all TopicHandler to xml.
java.lang.String[]	XmlBlasterImpl.unSubscribe(AddressServer addressServer, java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal) Unsubscribe from messages.
java.lang.String[]	RequestBroker.unSubscribe(SessionInfo sessionInfo, QueryKeyData xmlKey, UnSubscribeQosServer unSubscribeQos) Incoming unsubscribe request from a client.
private java.lang.String[]	TopicHandler.unSubscribe(SessionInfo sessionInfo, java.lang.String qos) private helper to unSubscribe
java.lang.String[]	TopicHandler.unSubscribeAll(java.lang.String qos)
java.lang.String[]	TopicHandler.unSubscribeByIndex(int index, java.lang.String qos)
java.lang.String[]	TopicHandler.unSubscribeBySessionName(java.lang.String sessionName, java.lang.String qos)
java.lang.String	RequestBroker.update(SessionInfo sessionInfo, UpdateKey updateKey, byte[] content, MsgQosData msgQosData) Used for cluster internal updates.
void	RequestBroker.updateInternalUserList()
void	EventPlugin.verifyInternetAddress(java.lang.String address) Check string addresses if they have valid email syntax.
static void	SubscriptionInfo.verifySubscriptionId(boolean isClusterNode, SessionName sessionName, QueryKeyData xmlKey, SubscribeQosServer subscribeQos)

Constructors in org.xmlBlaster.engine that throw XmlBlasterException

BigXmlKeyDOM(RequestBroker requestBroker, Authenticate authenticate)
A singleton for each xmlBlaster server.

ClientSubscriptions(ServerScope glob, RequestBroker requestBroker, Authenticate authenticate)
Exactly one instance for each xmlBlaster server.

MsgUnitWrapper(ServerScope glob, MsgUnit msgUnit, I_Map ownerCache, int referenceCounter, int historyReferenceCounter, long sizeInBytes)
Used when message is created from TopicHandler.publish

MsgUnitWrapper(ServerScope glob, MsgUnit msgUnit, I_Map ownerCache, StorageId storageId, int referenceCounter, int historyReferenceCounter, java.lang.String embeddedType, long sizeInBytes)
Used when message comes from persistence, the owning I_Map is unknown

MsgUnitWrapper(ServerScope glob, MsgUnit msgUnit, StorageId storageId)
Testsuite

MsgUnitWrapper(ServerScope glob, MsgUnit msgUnit, StorageId storageId, int referenceCounter, int historyReferenceCounter, long sizeInBytes)
Used when message comes from persistence, the owning I_Map is unknown

RequestBroker(Authenticate authenticate)
One instance of this represents one xmlBlaster server.

SubscriptionInfo(ServerScope glob, SessionInfo sessionInfo, KeyData keyData, SubscribeQosServer qos)
Use this constructor for an exact subscription.

SubscriptionInfo(ServerScope glob, SessionInfo sessionInfo, SubscriptionInfo querySub, KeyData keyData)
Use this constructor it the subscription is a result of a XPath subscription

TopicHandler(ServerScope serverScope, SessionInfo publisherSessionInfo, java.lang.String uniqueKey)
Use this constructor if a yet unknown object is fed by method publish().

XmlBlasterImpl(Authenticate authenticate)
One instance of this represents one xmlBlaster server.

Uses of XmlBlasterException in org.xmlBlaster.engine.admin

Methods in org.xmlBlaster.engine.admin that throw XmlBlasterException

java.lang.String	I_AdminNode.dump() Dump the complete internal state of xmlBlaster.
java.lang.String	I_AdminTopic.eraseTopic() Invoke operation to erase the topic
void	I_AdminNode.exit() Shutdown xmlBlaster, exit value is '0'
MsgUnit[]	I_CommandHandler.get(AddressServer addressServer, java.lang.String sessionId, CommandWrapper cmd) Your plugin should process the command.
MsgUnit[]	CommandManager.get(AddressServer addressServer, java.lang.String sessionId, QueryKeyData keyData, java.lang.String querySpec)
MsgUnit[]	CommandManager.get(AddressServer addressServer, java.lang.String sessionId, java.lang.String oid, java.lang.String[] args)
java.lang.String[]	CommandWrapper.getArgs()
MsgUnit[]	I_AdminSession.getCallbackQueueEntries(java.lang.String querySpec) Gets the entries in the callback queue according to what is specified in the querySpec
java.lang.String	CommandWrapper.getCommandStripAssign()
MsgUnit[]	I_AdminTopic.getHistoryQueueEntries(java.lang.String querySpec) Query the history queue, can be peeking or consuming.
java.lang.String	CommandWrapper.getKey()
MsgUnit[]	I_AdminSubject.getSubjectQueueEntries(java.lang.String querySpec) Query the history queue, can be peeking or consuming.
java.lang.String	I_AdminSession.getSubscriptionDump() An XML dump of all subscriptions of this login session
java.lang.String	I_AdminTopic.getTopicXml() Access the topics xml key.
boolean	I_ExternGateway.initialize(ServerScope glob, CommandManager commandManager) This is called after creation of the plugin.
java.lang.String	I_AdminSubject.killClient() Destroy the client with all its sessions.
java.lang.String	I_AdminSession.killSession() Invoke operation to destroy the session (force logout)
private void	CommandWrapper.parse()
private void	CommandWrapper.parseKeyValue() set client/publish/1/?addRemoteProperty=arg1&arg2
java.lang.String[]	I_AdminSession.peekCallbackMessages(int numOfEntries) Peek messages from callback queue, they are not removed
java.lang.String[]	I_AdminTopic.peekHistoryMessages(int numOfEntries) Peek messages from history queue, they are not removed.
java.lang.String[]	I_AdminSubject.peekSubjectMessages(int numOfEntries) Peek point to point messages from subject queue, they are not removed
void	I_AdminSession.refreshSession() Invoke operation to reactivate the session expiry to full value
void	CommandManager.runlevelChange(int from, int to, boolean force) Invoked on run level change, see RunlevelManager.RUNLEVEL_HALTED and RunlevelManager.RUNLEVEL_RUNNING Enforced by I_RunlevelListener
java.lang.String	I_CommandHandler.set(AddressServer addressServer, java.lang.String sessionId, CommandWrapper cmd) Your plugin should process the set command.
SetReturn	CommandManager.set(AddressServer addressServer, java.lang.String sessionId, java.lang.String cmd)
void	I_AdminNode.setDump(java.lang.String fn) Dump the internal xmlBlaster state to the given file.
void	I_AdminNode.setExit(java.lang.String exitValue)
void	I_AdminNode.setRunlevel(java.lang.String level) Change the run level of xmlBlaster.
static java.lang.String	CommandWrapper.stripCommand(ServerScope glob, java.lang.String command) Strips a given command (the oid of a queryKey before any any modification) by removing the starting '__cmd:' subtring.
java.lang.String	I_AdminSession.subscribe(java.lang.String url, java.lang.String qos) Invoke operation to subscribe the topic, given by its oid
java.lang.String[]	I_AdminSession.unSubscribe(java.lang.String url, java.lang.String qos) Invoke operation to unSubscribe one/many topics.
java.lang.String[]	I_AdminTopic.unSubscribeAll(java.lang.String qos) Invoke operation to unSubscribe all clients.
java.lang.String[]	I_AdminSession.unSubscribeByIndex(int index, java.lang.String qos) Invoke operation to unSubscribe one topic by index listed.
java.lang.String[]	I_AdminTopic.unSubscribeByIndex(int index, java.lang.String qos) Invoke operation to unSubscribe one client by index of getSubscribers() listed.
java.lang.String[]	I_AdminTopic.unSubscribeBySessionName(java.lang.String sessionName, java.lang.String qos) Invoke operation to unSubscribe one client by index of getSubscribers() listed.

Constructors in org.xmlBlaster.engine.admin that throw XmlBlasterException

CommandWrapper(ServerScope glob, java.lang.String command)
this constructor is currently used for the get

Uses of XmlBlasterException in org.xmlBlaster.engine.admin.extern

Methods in org.xmlBlaster.engine.admin.extern that throw XmlBlasterException

void	TelnetGateway.connect(java.lang.String loginName, java.lang.String passwd) Login to xmlBlaster server.
private void	TelnetGateway.createRemoteConsole(int port) Creates a server which is accessible with telnet.
MsgUnit[]	MomClientGateway.getCommand(SessionInfo sessionInfo, QueryKeyData keyData, QueryQosData qosData) Called by RequestBroker on get() of command messages.
boolean	MomClientGateway.initialize(ServerScope glob, CommandManager commandManager) Creates the remote console server.
boolean	TelnetGateway.initialize(ServerScope glob, CommandManager commandManager) Creates the remote console server.
boolean	SnmpGateway.initialize(ServerScope glob, CommandManager commandManager) This is called after creation of the plugin.
private boolean	TelnetGateway.initListener()
private boolean	SnmpGateway.initSubagent() Creates a server which is accessible with SNMP.
java.lang.String	MomClientGateway.setCommand(SessionInfo sessionInfo, KeyData xmlKey, MsgUnit msgUnit, PublishQosServer publishQos, boolean isClusterUpdate) Called by RequestBroker on publish() of command messages.

Uses of XmlBlasterException in org.xmlBlaster.engine.admin.intern

Methods in org.xmlBlaster.engine.admin.intern that throw XmlBlasterException

private java.lang.Object[]	CoreHandler.convertMethodArguments(java.lang.Class[] classes, java.lang.String[] args)
private MsgUnit[]	CoreHandler.doGetInvoke(CommandWrapper cmd, java.lang.String property, java.lang.Object impl, java.lang.Class clazz)
MsgUnit[]	MsgHandler.get(AddressServer addressServer, java.lang.String sessionId, CommandWrapper cmd)
MsgUnit[]	PropertyHandler.get(AddressServer addressServer, java.lang.String sessionId, CommandWrapper cmd)
MsgUnit[]	CoreHandler.get(AddressServer addressServer, java.lang.String sessionId, CommandWrapper cmd)
java.lang.String	MsgHandler.set(AddressServer addressServer, java.lang.String sessionId, CommandWrapper cmd) Set a value.
java.lang.String	PropertyHandler.set(AddressServer addressServer, java.lang.String sessionId, CommandWrapper cmd)
java.lang.String	CoreHandler.set(AddressServer addressServer, java.lang.String sessionId, CommandWrapper cmd) Set a value.
private java.lang.Object	CoreHandler.setInvoke(java.lang.String property, java.lang.Object impl, java.lang.Class aClass, java.lang.String[] argValuesAsStrings)

Uses of XmlBlasterException in org.xmlBlaster.engine.cluster

Methods in org.xmlBlaster.engine.cluster that throw XmlBlasterException

private java.lang.String	NodeConnectQos.createCbSessionId() Create a more or less unique sessionId.
EraseReturnQos[]	ClusterManager.forwardErase(SessionInfo publisherSession, QueryKeyData xmlKey, EraseQosServer eraseQos)
MsgUnit[]	ClusterManager.forwardGet(SessionInfo publisherSession, QueryKeyData xmlKey, GetQosServer getQos)
PublishReturnQos	ClusterManager.forwardPtpPublish(SessionInfo publisherSession, MsgUnit msgUnit, Destination destination)
PublishRetQosWrapper	ClusterManager.forwardPublish(SessionInfo publisherSession, MsgUnit msgUnit)
SubscribeReturnQos	ClusterManager.forwardSubscribe(SessionInfo publisherSession, QueryKeyData xmlKey, SubscribeQosServer subscribeQos)
UnSubscribeReturnQos[]	ClusterManager.forwardUnSubscribe(SessionInfo publisherSession, QueryKeyData xmlKey, UnSubscribeQosServer unSubscribeQos)
NodeMasterInfo	I_LoadBalancer.getClusterNode(java.util.Set nodeMasterInfoSet, java.lang.String keyOidForLogging) Your plugin should determine which xmlBlaster node to choose.
NodeMasterInfo	ClusterManager.getConnection(SessionInfo publisherSession, MsgUnit msgUnit)
NodeMasterInfo	ClusterManager.getConnection(SessionInfo publisherSession, MsgUnit msgUnit, Destination destination) Get connection to the master node (or a node at a closer stratum to the master).
int	ClusterNode.getConnectionState() Returns the current connection state to the node.
NodeMasterInfo	I_MapMsgToMasterId.getMasterId(NodeMasterInfo nodeMasterInfo, MsgUnit msgUnit) Find out who is the master of the provided message.
I_LoadBalancer	LoadBalancerPluginManager.getPlugin(java.lang.String type, java.lang.String version) Return a specific plugin.
private I_MapMsgToMasterId	MapMsgToMasterPluginManager.getPlugin(java.lang.String type, java.lang.String version) Return a specific MIME based message plugin from cache (initialize it on first request).
I_XmlBlasterAccess	ClusterNode.getXmlBlasterAccess() On first invocation we connect to the other xmlBlaster cluster node.
void	ClusterManager.init(Global globUtil, PluginInfo pluginInfo) This method is called by the PluginManager (enforced by I_Plugin).
private void	ClusterManager.initConnections() Usually the connection is established on demand (a message wants to travel to a node).
private void	ClusterManager.initMyselfClusterNode() Initialize ClusterNode object, containing all informations about myself.
boolean	ClusterNode.isAlive() Check if we currently have an open connection to this node.
boolean	ClusterNode.isConnected() Check if we have currently a functional connection to this node.
boolean	ClusterNode.isPolling() Check if we are currently polling for a connection to this node.
void	ClusterManager.postInit() To initialize ClusterNode we need the addresses from the protocol drivers.
private void	NodeConnectQos.postInitialize() Force some cluster specific connection settings.
void	ClusterManager.runlevelChange(int from, int to, boolean force) Invoked on run level change, see RunlevelManager.RUNLEVEL_HALTED and RunlevelManager.RUNLEVEL_RUNNING Enforced by I_RunlevelListener
java.lang.String	ClusterNode.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.

Constructors in org.xmlBlaster.engine.cluster that throw XmlBlasterException

ClusterNode(ServerScope glob, NodeId nodeId, SessionInfo sessionInfo)
Create an object holding all informations about a node

NodeConnectQos(Global remoteGlob, NodeId nodeId)
Holds the ConnectQos of a node.

NodeMasterInfo(ServerScope glob, ClusterNode clusterNode)
Create a NodeMasterInfo belonging to the given cluster node.

NodeParser(ServerScope glob, ClusterManager clusterManager, java.lang.String xml, SessionInfo sessionInfo)
Parses the XML markup of exactly one cluster node configuration.

NodeParser(ServerScope glob, ClusterNode clusterNode, java.lang.String xml)
Constructor variant to only parse the <master> part of the XML.

Uses of XmlBlasterException in org.xmlBlaster.engine.cluster.simpledomain

Methods in org.xmlBlaster.engine.cluster.simpledomain that throw XmlBlasterException

NodeMasterInfo	RoundRobin.getClusterNode(java.util.Set nodeMasterInfoSet, java.lang.String keyOidForLogging) We determine which xmlBlaster node to choose with a simple counter.
NodeMasterInfo	DomainToMaster.getMasterId(NodeMasterInfo nodeMasterInfo, MsgUnit msgUnit) Find out who is the master of the provided message.
void	DomainToMaster.shutdown()
void	RoundRobin.shutdown()

Uses of XmlBlasterException in org.xmlBlaster.engine.dispatch

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

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

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

void	CbDispatchConnection.connectLowlevel()
DispatchConnection	CbDispatchConnectionsHandler.createDispatchConnection(AddressBase address)
java.lang.String	CbDispatchConnection.doPing(java.lang.String data)
void	CbDispatchConnection.doSend(MsgQueueEntry[] msgArr_, boolean isAsyncMode) Send the messages back to the client.
private void	CbDispatchConnection.exportCrypt(java.util.ArrayList holderList, MethodName methodName) We export/encrypt the message (call the interceptor)
void	ServerDispatchManager.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	ServerDispatchManager.handleWorkerException(java.util.List<I_Entry> entryList, java.lang.Throwable throwable) Called by DispatchWorker if an Exception occurred in async mode.
void	CbDispatchConnection.loadPlugin() Load the appropriate protocol driver
void	ServerDispatchManager.putPost(I_QueueEntry queueEntry)
void	ServerDispatchManager.putPost(I_QueueEntry[] queueEntries)
boolean	ServerDispatchManager.putPre(I_QueueEntry queueEntry)
boolean	ServerDispatchManager.putPre(I_QueueEntry[] queueEntries)
protected void	CbDispatchConnection.reconnect() On reconnect polling try to establish the connection.
void	ServerDispatchManager.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	CbDispatchConnection.setAddress(AddressBase address)
void	ServerDispatchManager.setAddresses(AddressBase[] addr) Set new callback addresses, typically after a session login/logout
void	CbDispatchConnection.shutdown(boolean delayed) Stop all callback drivers of this client.
void	ServerDispatchManager.updateProperty(CallbackAddress[] addressArr) Reconfigure dispatcher with given properties.

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

CbDispatchConnection(Global glob, CbDispatchConnectionsHandler connectionsHandler, AddressBase address)

CbDispatchConnectionsHandler(Global glob, ServerDispatchManager dispatchManager)

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

Uses of XmlBlasterException in org.xmlBlaster.engine.distributor.plugins

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

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

Methods in org.xmlBlaster.engine.distributor.plugins that throw XmlBlasterException

private UpdateReturnQosServer	ConsumableQueuePlugin.doDistribute(SubscriptionInfo sub, MsgQueueUpdateEntry entry) Enforced by the I_DistributionInterceptor interface.
I_MsgDistributor	MsgDistributorPluginManager.getPlugin(java.lang.String typeVersion, TopicHandler topicHandler) Return a specific msgDistributor plugin.
void	ConsumableQueuePlugin.init(Global global, PluginInfo pluginInfo) Initializes the plugin
void	ConsumableQueuePlugin.shutdown() It removes all subscriptions done on this topic
void	ConsumableQueuePlugin.subscriptionAdd(SubscriptionEvent e) Invoked when a subscriber is added to the TopicHandler
void	ConsumableQueuePlugin.subscriptionRemove(SubscriptionEvent e) Invoked when a subscriber is removed from the TopicHandler

Uses of XmlBlasterException in org.xmlBlaster.engine.event

Methods in org.xmlBlaster.engine.event that throw XmlBlasterException

java.lang.String	JmxDestinationHelper.getMessage(java.lang.String summary, java.lang.String description, java.lang.String eventType, java.lang.String errorCode, SessionName sessionName)
MsgUnit	PublishDestinationHelper.getMsgUnit(java.lang.String summary, java.lang.String description, java.lang.String eventType, java.lang.String errorCode, SessionName sessionName)
MsgKeyData	PublishDestinationHelper.getPublishKey(java.lang.String summary, java.lang.String description, java.lang.String eventType, java.lang.String errorCode)
MsgQosData	PublishDestinationHelper.getPublishQos(java.lang.String summary, java.lang.String description, java.lang.String eventType, java.lang.String errorCode, SessionName sessionName)
void	SmtpDestinationHelper.sendEmail(EmailData emailData)

Constructors in org.xmlBlaster.engine.event that throw XmlBlasterException

ExecHelper(EventPlugin eventPlugin, java.lang.String configuration)

JmxDestinationHelper(EventPlugin eventPlugin, java.lang.String destination)

PublishDestinationHelper(EventPlugin eventPlugin, java.lang.String configuration)

SmtpDestinationHelper(EventPlugin eventPlugin, SmtpClient smtpClient, java.lang.String destination)

Uses of XmlBlasterException in org.xmlBlaster.engine.mime

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

boolean	AccessPluginManager.addAccessFilterPlugin(java.lang.String type, java.lang.String version) Invoked on new subscription or get() invocation, loads plugin.
I_AccessFilter	AccessPluginManager.getPlugin(java.lang.String type, java.lang.String version) Return a specific MIME based message filter plugin.
void	PublishPluginManager.initializePlugins() Instantiate all given plugins from xmlBlaster.properties.
java.lang.String	I_PublishFilter.intercept(SubjectInfo publisher, MsgUnit msgUnit) Add your business code with your implementation of inercept().
boolean	I_AccessFilter.match(SessionInfo receiver, MsgUnit msgUnit, Query query) Check if the filter rule matches for this message.
void	PublishPluginManager.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	AccessPluginManager.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.engine.mime that throw XmlBlasterException

PublishPluginManager(ServerScope glob)

Uses of XmlBlasterException in org.xmlBlaster.engine.mime.demo

Methods in org.xmlBlaster.engine.mime.demo that throw XmlBlasterException

void	PublishDelayer.init(Global glob, PluginInfo pluginInfo) This method is called by the PluginManager (enforced by I_Plugin).
void	ContentLenFilter.init(Global glob, PluginInfo pluginInfo) This method is called by the PluginManager.
java.lang.String	PublishDelayer.intercept(SubjectInfo publisher, MsgUnit msgUnit) Delay the message for the configured amount of time.
java.lang.String	PublishLenChecker.intercept(SubjectInfo publisher, MsgUnit msgUnit) Check if the filter rule matches for this message.
boolean	ContentLenFilter.match(SessionInfo receiver, MsgUnit msgUnit, Query query) Check if the filter rule matches for this message.

Uses of XmlBlasterException in org.xmlBlaster.engine.mime.regex

Methods in org.xmlBlaster.engine.mime.regex that throw XmlBlasterException

boolean

GnuRegexFilter.match(SessionInfo receiver, MsgUnit msgUnit, Query query) Check if the filter rule matches for this message.

Uses of XmlBlasterException in org.xmlBlaster.engine.mime.sql92

Methods in org.xmlBlaster.engine.mime.sql92 that throw XmlBlasterException

boolean

Sql92Filter.match(SessionInfo receiver, MsgUnit msgUnit, Query query) Check if the filter rule matches for this message.

Uses of XmlBlasterException in org.xmlBlaster.engine.mime.xpath

Methods in org.xmlBlaster.engine.mime.xpath that throw XmlBlasterException

private org.w3c.dom.Document	XPathFilter.getDocument(byte[] xml) Create a new dom document.
private org.w3c.dom.Document	XPathFilter.getDocument(MsgUnit msg) Get a dom document for message, from cache or create a new one.
private javax.xml.parsers.DocumentBuilderFactory	XPathFilter.getDocumentBuilderFactory()
void	XPathFilter.init(Global glob, PluginInfo pluginInfo) This method is called by the PluginManager (enforced by I_Plugin).
protected void	XPathFilter.loadXPathExtensionFunctions(java.lang.String extensionClassList) Load xpath extension functions from a semicolon separated list of classes.
boolean	XPathFilter.match(SessionInfo receiver, MsgUnit msgUnit, Query query) Check if the filter rule matches for this message.

Uses of XmlBlasterException in org.xmlBlaster.engine.msgstore

Methods in org.xmlBlaster.engine.msgstore that throw XmlBlasterException

I_MapEntry	I_Map.change(I_MapEntry entry, I_ChangeCallback callback)
I_MapEntry	I_Map.change(long uniqueId, I_ChangeCallback callback) This method is threadsafe because it makes a lookup for the updated entry within the synchronization point.
I_MapEntry	I_ChangeCallback.changeEntry(I_MapEntry entry) Callback invoked by I_Map.change inside the synchronization point.
long	I_Map.clear() Delete all entries
void	I_Map.destroy() destroys all the resources associated to this queue.
I_MapEntry	I_Map.get(long uniqueId) Lookup entry without removing.
I_MapEntry[]	I_Map.getAll(I_EntryFilter entryFilter) Retrieve all entries in the storage, please take care on memory consumption.
I_Map	StoragePluginManager.getPlugin(PluginInfo pluginInfo, StorageId storageId, QueuePropertyBase props)
I_Map	StoragePluginManager.getPlugin(java.lang.String typeVersion, StorageId storageId, QueuePropertyBase props)
I_Map	StoragePluginManager.getPlugin(java.lang.String type, java.lang.String version, StorageId storageId, QueuePropertyBase props) Return a new created storage plugin.
void	I_Map.initialize(StorageId uniqueMapId, java.lang.Object userData) Is called after the instance is created.
int	I_Map.put(I_MapEntry mapEntry) Adds one entry and automatically increments the reference counter.
void	MapEventHandler.registerEventType(I_EventDispatcher dispatcher, java.lang.String eventType) Is called from EventPlugin to register the configured eventTypes
private void	StoragePluginManager.registerOrRemovePlugin(I_Storage plugin, boolean register) Not synchronized since invoked inside the synchronized(this.storagesMap)
int	I_Map.remove(I_MapEntry mapEntry)
int	I_Map.remove(long uniqueId)
I_MapEntry	I_Map.removeOldest() Remove the oldest entry.
boolean	StoragePluginManager.setEventHandler(java.lang.String key, StorageEventHandler handler) Set an EventHandler singleton
void	I_Map.setProperties(java.lang.Object userData) Allows to overwrite properties which where passed on initialize() The properties which support hot configuration are depending on the used implementation
void	I_Map.updateCounters(I_MapEntry entry)

Uses of XmlBlasterException in org.xmlBlaster.engine.msgstore.cache

Methods in org.xmlBlaster.engine.msgstore.cache that return XmlBlasterException

private XmlBlasterException

PersistenceCachePlugin.spaceLeftException(I_MapEntry mapEntry, I_Map map) Check is storage is big enough for entry

Methods in org.xmlBlaster.engine.msgstore.cache that throw XmlBlasterException

private void	PersistenceCachePlugin.assureTransientSpace(I_MapEntry mapEntry) Swap an entry away to hard disk.
I_MapEntry	PersistenceCachePlugin.change(I_MapEntry oldEntry, I_ChangeCallback callback)
I_MapEntry	PersistenceCachePlugin.change(long uniqueId, I_ChangeCallback callback)
void	PersistenceCachePlugin.destroy() destroys all the resources associated to this queue.
I_MapEntry	PersistenceCachePlugin.get(long uniqueId)
I_MapEntry[]	PersistenceCachePlugin.getAll(I_EntryFilter entryFilter) Access all entries.
void	PersistenceCachePlugin.initialize(StorageId uniqueQueueId, java.lang.Object userData) Is called after the instance is created.
int	PersistenceCachePlugin.put(I_MapEntry mapEntry) All entries are stored into the transient queue.
int	PersistenceCachePlugin.remove(I_MapEntry mapEntry)
int	PersistenceCachePlugin.remove(long uniqueId)
private int	PersistenceCachePlugin.removeNoNotify(I_MapEntry mapEntry)
I_MapEntry	PersistenceCachePlugin.removeOldest()
int	PersistenceCachePlugin.removeTransient()
void	PersistenceCachePlugin.setProperties(java.lang.Object userData)
void	PersistenceCachePlugin.updateCounters(I_MapEntry entry)

Uses of XmlBlasterException in org.xmlBlaster.engine.msgstore.ram

Methods in org.xmlBlaster.engine.msgstore.ram that throw XmlBlasterException

I_MapEntry	MapPlugin.change(I_MapEntry entry, I_ChangeCallback callback)
I_MapEntry	MapPlugin.change(long uniqueId, I_ChangeCallback callback)
void	MapPlugin.destroy()
I_MapEntry	MapPlugin.get(long uniqueId)
I_MapEntry[]	MapPlugin.getAll(I_EntryFilter entryFilter)
void	MapPlugin.initialize(StorageId uniqueMapId, java.lang.Object userData) Is called after the instance is created.
int	MapPlugin.put(I_MapEntry entry)
int	MapPlugin.remove(I_MapEntry mapEntry)
int	MapPlugin.remove(long uniqueId)
I_MapEntry	MapPlugin.removeOldest()
int	MapPlugin.removeTransient()
void	MapPlugin.setProperties(java.lang.Object userData)
void	MapPlugin.updateCounters(I_MapEntry entry)

Uses of XmlBlasterException in org.xmlBlaster.engine.persistence

Methods in org.xmlBlaster.engine.persistence that throw XmlBlasterException

void	MsgFileDumper.erase(XmlKey xmlKey) Allows a stored message to be deleted.
void	I_PersistenceDriver.erase(XmlKey xmlKey) Deprecated. Allows a stored message to be deleted.
MsgUnit	I_PersistenceDriver.fetch(java.lang.String oid) Deprecated. Fetches one message by oid from the persistence.
MsgUnit	MsgFileDumper.fetch(java.lang.String oid, long timestamp) Allows to fetch one message by oid and timestamp from the persistence.
java.util.Enumeration	MsgFileDumper.fetchAllOids() Fetches all oid's of the messages from the persistence.
java.util.Enumeration	I_PersistenceDriver.fetchAllOids() Deprecated. Fetches all oid's of the messages from the persistence.
I_PersistenceDriver	PersistencePluginManager.getPlugin(java.lang.String type, java.lang.String version) Return a specific persistence plugin from cache (on first request create it).
void	MsgFileDumper.init(Global glob) Initializes an instance, creates and checks harddisk path
void	MsgFileDumper.init(Global glob, java.lang.String path_) Initializes an instance, creates and checks harddisk path
void	MsgFileDumper.shutdown() Closes the instance of the filedriver plugin
void	I_PersistenceDriver.shutdown() Deprecated. Closes the instance of the persistence plugin The protocol for storing is implemented in the derived class
java.lang.String	MsgFileDumper.store(MsgUnitWrapper msgUnitWrapper) Allows a message to be stored.
void	I_PersistenceDriver.store(MsgUnitWrapper messageWrapper) Deprecated. Allows a message to be stored.
private java.lang.String	MsgFileDumper.store(MsgUnitWrapper msgUnitWrapper, boolean updateOnly)
java.lang.String	MsgFileDumper.update(MsgUnitWrapper msgUnitWrapper) Allows a stored message content to be updated.
void	I_PersistenceDriver.update(MsgUnitWrapper messageWrapper) Deprecated. Allows a stored message content to be updated.

Constructors in org.xmlBlaster.engine.persistence that throw XmlBlasterException

PersistencePluginManager(ServerScope glob)

Uses of XmlBlasterException in org.xmlBlaster.engine.persistence.filestore

Methods in org.xmlBlaster.engine.persistence.filestore that throw XmlBlasterException

void	FileDriver.erase(XmlKey xmlKey) Allows a stored message to be deleted.
MsgUnit	FileDriver.fetch(java.lang.String oid) Allows to fetch one message by oid from the persistence.
java.util.Enumeration	FileDriver.fetchAllOids() Fetches all oid's of the messages from the persistence.
void	FileDriver.init(Global glob, PluginInfo pluginInfo) This method is called by the PluginManager (enforced by I_Plugin).
void	FileDriver.shutdown() Closes the instance of the filedriver plugin
void	FileDriver.store(MsgUnitWrapper messageWrapper) Allows a message to be stored.
void	FileDriver.update(MsgUnitWrapper messageWrapper) Allows a stored message content to be updated.

Constructors in org.xmlBlaster.engine.persistence.filestore that throw XmlBlasterException

FileDriver()
Constructs the FileDriver object (reflection constructor).

Uses of XmlBlasterException in org.xmlBlaster.engine.qos

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

private void	PublishQosServer.completeDestinations() Checks for relative destination names and completes them with our cluster node id
ConnectQosServer	ConnectQosServer.getClone(Global newGlob) Serialize first to have a clone for security reasons (and to guarantee our Global).
I_ClientPlugin	ConnectQosServer.loadClientPlugin(java.lang.String mechanism, java.lang.String version, java.lang.String loginName, java.lang.String passwd) Allows to set or overwrite the parsed security plugin.
void	ConnectQosServer.setUserId(java.lang.String loginName) Allows to set or overwrite the login name for I_SecurityQos.

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

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

ConnectReturnQosServer(Global glob, ConnectQosData connectQosData)

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

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

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

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

PublishQosServer(ServerScope glob, MsgQosData msgQosData, boolean fromPersistenceStore)
Constructor which accepts parsed object.

PublishQosServer(ServerScope glob, QosData msgQosData)
Constructor which accepts parsed object.

PublishQosServer(ServerScope glob, java.lang.String xmlQos)
Constructs the specialized quality of service object for a publish() call, and parses the given XML string.

PublishQosServer(ServerScope glob, java.lang.String xmlQos, boolean fromPersistenceStore)
Constructs the specialized quality of service object for a publish() call.

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

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

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

Uses of XmlBlasterException in org.xmlBlaster.engine.query

Methods in org.xmlBlaster.engine.query that throw XmlBlasterException

MsgUnit[]

I_Query.query(java.lang.Object source, java.lang.String query) Makes a query to the specified source object.

Uses of XmlBlasterException in org.xmlBlaster.engine.query.plugins

Methods in org.xmlBlaster.engine.query.plugins that throw XmlBlasterException

MsgUnit[]

QueueQueryPlugin.query(java.lang.Object source, java.lang.String query) The query to the queue.

Uses of XmlBlasterException in org.xmlBlaster.engine.queuemsg

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

I_Entry	ServerEntryFactory.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	ServerEntryFactory.createEntry(XBStore store, XBMeat meat, XBRef ref)
MsgKeyData	ReferenceEntry.getMsgKeyData()
MsgQosData	ReferenceEntry.getMsgQosData()
MsgUnit	ReferenceEntry.getMsgUnit() Gets the message unit but is for read only (dirty read)
void	ReferenceEntry.setMsgUnitWrapper(MsgUnitWrapper msgUnitWrapper)
byte[]	ServerEntryFactory.toBlob(I_Entry entry) Parses the specified entry to a byte array (serializing).

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

MsgQueueHistoryEntry(ServerScope glob, MsgUnitWrapper msgUnitWrapper, StorageId storageId)
A new message object is fed by method publish().

MsgQueueHistoryEntry(ServerScope glob, PriorityEnum priority, StorageId storageId, Timestamp entryTimestamp, java.lang.String keyOid, long msgUnitWrapperUniqueId, boolean persistent, long sizeInBytes)
For persistence recovery

MsgQueueUpdateEntry(MsgQueueUpdateEntry entry, StorageId storageId)
Copy constructor, used to get a shallow clone, we still reference the original MsgUnitWrapper.

MsgQueueUpdateEntry(ServerScope glob, MsgUnitWrapper msgUnitWrapper, StorageId storageId, SessionName receiver, java.lang.String subscriptionId, boolean wantUpdateOneway, boolean wantNewestOnly)
A new message object is fed by method publish().

MsgQueueUpdateEntry(ServerScope glob, MsgUnitWrapper msgUnitWrapper, Timestamp timestamp, StorageId storageId, SessionName receiver, java.lang.String subscriptionId, boolean wantUpdateOneway, boolean wantNewestOnly)
convenience constructor to allow passing an already given uniqueId (the timestamp)

MsgQueueUpdateEntry(ServerScope glob, PriorityEnum priority, StorageId storageId, Timestamp updateEntryTimestamp, java.lang.String keyOid, long msgUnitWrapperUniqueId, boolean persistent, long sizeInBytes, SessionName receiver, java.lang.String subscriptionId, java.lang.String flag, int redeliverCount, java.lang.String qos, java.lang.String key, byte[] content)
For persistence recovery The params qos, key, content can be null (the unparsed raw message)

ReferenceEntry(java.lang.String ME, ServerScope glob, java.lang.String entryType, MsgUnitWrapper msgUnitWrapper, StorageId storageId)
A new message object is fed by method publish().

ReferenceEntry(java.lang.String ME, ServerScope glob_, java.lang.String entryType, MsgUnitWrapper msgUnitWrapper, Timestamp timestamp, StorageId storageId, SessionName receiver)
A new message object is fed by method update().

ReferenceEntry(java.lang.String ME, ServerScope glob, java.lang.String entryType, PriorityEnum priority, StorageId storageId, Timestamp entryTimestamp, java.lang.String keyOid, long msgUnitWrapperUniqueId, boolean persistent, SessionName receiver, java.lang.String qos, java.lang.String key, byte[] content)
For persistence recovery

TopicEntry(ServerScope glob, MsgUnit msgUnit, StorageId storageId)
Use this constructor if a new message object is fed by method publish().

TopicEntry(ServerScope glob, MsgUnit msgUnit, StorageId storageId, java.lang.String embeddedType, long sizeInBytes)
Used when message comes from persistence, the owning I_Map is unknown

Uses of XmlBlasterException in org.xmlBlaster.engine.runlevel

Fields in org.xmlBlaster.engine.runlevel declared as XmlBlasterException

private XmlBlasterException	PluginHolderSaxFactory.ex
private XmlBlasterException	RunLevelActionSaxFactory.ex
private XmlBlasterException	PluginConfigSaxFactory.ex

Methods in org.xmlBlaster.engine.runlevel that throw XmlBlasterException

private void	RunlevelManager.addPlugin(PluginConfig pluginConfig) Add a new plugin, if it exists remove the old first.
int	RunlevelManager.changeRunlevel(int newRunlevel, boolean force) Change the run level to the given newRunlevel.
int	RunlevelManager.changeRunlevel(java.lang.String newRunlevel, boolean force) Allows to pass the newRunlevel as a String like "RUNLEVEL_STANDBY" or "6"
private int	RunlevelManager.fireRunlevelEvent(int from, int to, boolean force) The static plugins are loaded from (exclusive) to (inclusive) when startup and the same when shutting down.
void	RunlevelManager.initPluginManagers() Incarnate the different managers which handle run levels.
protected void	RunlevelPluginManager.postInstantiate(I_Plugin plugin, PluginInfo pluginInfo) Is called after a plugin in instantiated, allows the base class to do specific actions.
java.lang.String	RunlevelManager.publish(SessionInfo sessionInfo, MsgUnit msgUnit, PublishQosServer publishQos) Called from RequestBroker when a new plugin XML is arriving.
PluginHolder	PluginHolderSaxFactory.readConfigFile() Reads the configuration file xmlBlasterPlugins.xml.
PluginHolder	PluginHolderSaxFactory.readObject(java.lang.String xmlTxt) Parses the given xmlBlasterPlugins.xml returns a PluginHolderData holding the data.
RunLevelAction	RunLevelActionSaxFactory.readObject(java.lang.String xmlTxt) Parses the given xml Qos and returns a RunLevelActionData holding the data.
PluginConfig	PluginConfigSaxFactory.readObject(java.lang.String xmlTxt) Parses the given xml Qos and returns a PluginConfigData holding the data.
void	I_RunlevelListener.runlevelChange(int from, int to, boolean force) Invoked on run level change, see for example RunlevelManager.RUNLEVEL_HALTED and RunlevelManager.RUNLEVEL_RUNNING
private void	RunlevelManager.shutdownPlugins(int from, int to)
private void	RunlevelManager.startupPlugins(int from, int to)

Uses of XmlBlasterException in org.xmlBlaster.engine.xml2java

Methods in org.xmlBlaster.engine.xml2java that throw XmlBlasterException

protected java.lang.String	XmlKeyDom.getKeyOid(org.w3c.dom.Node node) Given a node , extract its attribute oid='...'
org.w3c.dom.Node	XmlKey.getRootNode() Fills the DOM tree, and assures that a valid is used.
boolean	XmlKey.isDeadMessage()
private void	XmlKey.loadDomTree() Fills the DOM tree, and assures that a valid
boolean	XmlKey.match(QueryKeyData queryKey) Allows to check if this xmlKey matches the given query.
boolean	XmlKey.match(java.lang.String xpath) We need this to allow checking if an existing XPath subscription matches this new message type.
org.w3c.dom.Node	XmlKeyDom.mergeNode(org.w3c.dom.Node node) Adding a new <key> node to the xmlBlaster xmlKey tree.
void	XmlKey.mergeRootNode(I_MergeDomNode merger) Should be called by publish() to merge the local XmlKey DOM into the big xmlBlaster DOM tree
java.util.ArrayList	XmlKeyDom.parseKeyOid(SessionInfo sessionInfo, java.lang.String xpathQuery, QueryQosData qos) This method does the XPath query.
java.lang.String	XmlKeyDom.toXml() Dump state of this object into XML.
java.lang.String	XmlKeyDom.toXml(java.lang.String extraOffset, boolean stripDeclaration) Dump state of this object into XML.

Constructors in org.xmlBlaster.engine.xml2java that throw XmlBlasterException

XmlKey(ServerScope glob, java.lang.String xmlKey_literal)
Parses given xml string

XmlKeyDom(RequestBroker requestBroker)
Constructor to handle a DOM with XPath query.

Uses of XmlBlasterException in org.xmlBlaster.j2ee.k2

Methods in org.xmlBlaster.j2ee.k2 that throw XmlBlasterException

private void	BlasterConnectionImpl.checkSanity()
void	BlasterConnectionImpl.close() Close the connection.
EraseReturnQos[]	BlasterConnectionImpl.erase(java.lang.String xmlKey, java.lang.String qos) Erase message(s), I think
MsgUnit[]	BlasterConnectionImpl.get(java.lang.String xmlKey, java.lang.String qos) Fetch a message from server
(package private) I_XmlBlasterAccess	BlasterManagedConnection.getBlasterConnection()
(package private) I_XmlBlasterAccess	BlasterManagedConnection.getFailoverBlasterConnection() This is used both internaly and by handles.
Global	BlasterConnectionImpl.getGlobal() Get Global from connection
PublishReturnQos	BlasterConnectionImpl.publish(MsgUnit msgUnit) Publish one message
PublishReturnQos[]	BlasterConnectionImpl.publishArr(MsgUnit[] msgUnitArr) Publish one or more message

Uses of XmlBlasterException in org.xmlBlaster.j2ee.k2.client

Methods in org.xmlBlaster.j2ee.k2.client that throw XmlBlasterException

void	BlasterConnection.close() Close the connection.
EraseReturnQos[]	BlasterConnection.erase(java.lang.String xmlKey, java.lang.String qos) Erase message(s), I think
MsgUnit[]	BlasterConnection.get(java.lang.String xmlKey, java.lang.String qos) Fetch a message from server
Global	BlasterConnection.getGlobal() The the preconfigured global of the connection, good to have to be able to create Qos and keys for example.
PublishReturnQos	BlasterConnection.publish(MsgUnit msgUnit) Publish one message
PublishReturnQos[]	BlasterConnection.publishArr(MsgUnit[] msgUnitArr) Publish one or more message

Uses of XmlBlasterException in org.xmlBlaster.j2ee.util

Methods in org.xmlBlaster.j2ee.util that throw XmlBlasterException

static void

JacorbUtil.loadJacorbProperties(java.lang.String fileName, Global glob) Load the given jacorb properties file from the context classloader and put it into the given global.

Uses of XmlBlasterException in org.xmlBlaster.jms

Methods in org.xmlBlaster.jms that throw XmlBlasterException

(package private) void	XBSession.activateDispatcher(boolean doActivate) Activates or deactivates the dispatcher associated to this session.
static XBMessage	MessageHelper.convertFromMsgUnit(XBSession session, java.lang.String sender, MsgKeyData keyData, byte[] content, MsgQosData qosData) Used in the message consumer update method.
static XBMessage	MessageHelper.convertFromMsgUnit(XBSession session, java.lang.String sender, MsgUnit msgUnit) Used in the message consumer receive method.
static MsgUnit	MessageHelper.convertToMessageUnit(Global global, javax.jms.Message msg) This method converts a message (which could be from a foreign provider but also an own XBMessage) to a MsgUnit (internal XmlBlaster messages).
private ConnectQos	XBConnectionFactory.getConnectQos(java.lang.String user, java.lang.String password) Takes a clone of the connectQos and fills it with the security data if necessary
private ConnectQos	XBConnectionFactory.parseConnectQos(java.lang.String qosLitteral)
java.lang.String	XBMessageConsumer.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos)
java.lang.String	XBSession.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos)

Constructors in org.xmlBlaster.jms that throw XmlBlasterException

XBConnection(ConnectQos connectQos, javax.jms.ConnectionMetaData metaData, boolean forQueues)

XBConnectionFactory()

XBConnectionFactory(java.lang.String connectQosLitteral, java.lang.String[] args, boolean forQueues)
Creates a factory for creating connections

Uses of XmlBlasterException in org.xmlBlaster.protocol

Methods in org.xmlBlaster.protocol that throw XmlBlasterException

void	I_Driver.activate() Activate xmlBlaster access through this protocol so that a client can contact us.
void	CbProtocolManager.activateCbDrivers()
java.lang.String	I_Authenticate.connect(AddressServer addressServer, java.lang.String qos)
java.lang.String	I_Authenticate.connect(AddressServer addressServer, java.lang.String qos, java.lang.String sessionId)
ConnectReturnQosServer	I_Authenticate.connect(ConnectQosServer qos)
ConnectReturnQosServer	I_Authenticate.connect(ConnectQosServer qos, java.lang.String sessionId)
void	I_Driver.deActivate() Deactivate xmlBlaster access (standby), no clients can connect.
void	I_Authenticate.disconnect(AddressServer addressServer, java.lang.String sessionId, java.lang.String qos_literal)
java.lang.String[]	I_XmlBlaster.erase(AddressServer addressServer, java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String eraseQoS_literal) Delete messages.
MsgUnitRaw[]	I_XmlBlaster.get(AddressServer addressServer, java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String getQoS_literal) Synchronous access a message.
I_CallbackDriver	CbProtocolManager.getNewCbProtocolDriverInstance(java.lang.String driverType) Creates a new instance of the given protocol driver type.
I_CallbackDriver	CbProtocolManager.getPlugin(java.lang.String type, java.lang.String version) Return a specific plugin, every call will create a new plugin instance.
PluginInfo	CbProtocolManager.getPluginInfo(java.lang.String type, java.lang.String version)
I_AdminSubject	I_Authenticate.getSubjectInfoByName(SessionName sessionName) Administrative access.
void	I_CallbackDriver.init(Global glob, CallbackAddress callbackAddress) Intialize the driver.
java.lang.String	I_XmlBlaster.ping(AddressServer addressServer, java.lang.String qos) Ping to check if xmlBlaster is alive.
java.lang.String	I_CallbackDriver.ping(java.lang.String qos) Ping to check if the clients callback server instance is alive.
java.lang.String	I_XmlBlaster.publish(AddressServer addressServer, java.lang.String sessionId, MsgUnitRaw msgUnit) Publish a message.
java.lang.String[]	I_XmlBlaster.publishArr(AddressServer addressServer, java.lang.String sessionId, MsgUnitRaw[] msgUnitArr) Publish messages.
java.lang.String[]	I_CallbackDriver.sendUpdate(MsgUnitRaw[] msgArr) Send the message update to the client.
void	I_CallbackDriver.sendUpdateOneway(MsgUnitRaw[] msgArr) The oneway variant, without return value
void	CbProtocolManager.shutdownCbDrivers(boolean force)
java.lang.String	I_XmlBlaster.subscribe(AddressServer addressServer, java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String subscribeQoS_literal) Subscribe to messages.
java.lang.String	I_Authenticate.toXml()
java.lang.String	I_XmlBlaster.toXml()
java.lang.String	I_XmlBlaster.toXml(java.lang.String extraOffset)
java.lang.String[]	I_XmlBlaster.unSubscribe(AddressServer addressServer, java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String unSubscribeQos_literal) Unsubscribe from messages.

Uses of XmlBlasterException in org.xmlBlaster.protocol.corba

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

void	CorbaDriver.activate() Activate xmlBlaster access through this protocol.
private ConnectReturnQosServer	AuthServerImpl.connectIntern(java.lang.String qos_literal)
private org.omg.CosNaming.NamingContextExt	CorbaDriver.getNamingService() Locate the CORBA Naming Service.
private void	CorbaDriver.init(Global glob, AddressServer addressServer, I_Authenticate authenticate, I_XmlBlaster xmlBlasterImpl) Start xmlBlaster CORBA access.
void	CallbackCorbaDriver.init(Global glob, CallbackAddress callbackAddress) Get callback reference here (== connectLowLevel()).
void	CorbaDriver.init(Global glob, PluginInfo pluginInfo) This method is called by the PluginManager (enforced by I_Plugin).
java.lang.String	CallbackCorbaDriver.ping(java.lang.String qos) Ping to check if callback server is alive.
java.lang.String[]	CallbackCorbaDriver.sendUpdate(MsgUnitRaw[] msgArr) This sends the update to the client.
void	CallbackCorbaDriver.sendUpdateOneway(MsgUnitRaw[] msgArr) The oneway variant, without return value.
void	CorbaDriver.shutdown() Instructs the ORB to shut down, which causes all object adapters to shut down.

Uses of XmlBlasterException in org.xmlBlaster.protocol.email

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

void	EmailDriver.activate() Activate xmlBlaster access through this protocol.
void	EmailDriver.deActivate() Deactivate xmlBlaster access (standby), no clients can connect.
private void	EmailDriver.init(Global glob, AddressServer addressServer, I_Authenticate authenticate, I_XmlBlaster xmlBlasterImpl) Start xmlBlaster EMAIL access.
void	CallbackEmailDriver.init(Global glob, CallbackAddress callbackAddress) This init() is called after the init(Global, PluginInfo)
void	EmailDriver.init(Global glob, PluginInfo pluginInfo) This method is called by the PluginManager (enforced by I_Plugin).
void	CallbackEmailDriver.init(Global glob, PluginInfo pluginInfo) This method is called by the PluginManager (enforced by I_Plugin).
java.lang.String	CallbackEmailDriver.ping(java.lang.String qos) Ping to check if callback server is alive.
boolean	EmailDriver.receiveReply(MsgInfo receiver, boolean udp) Handle connect/disconnect
java.lang.String[]	CallbackEmailDriver.sendUpdate(MsgUnitRaw[] msgArr) This sends the update to the client.
void	CallbackEmailDriver.sendUpdateOneway(MsgUnitRaw[] msgArr) The oneway variant, without return value.

Uses of XmlBlasterException in org.xmlBlaster.protocol.http

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

static void	BlasterHttpProxy.addHttpPushHandler(java.lang.String sessionId, HttpPushHandler httpPushHandler) Gives a proxy connection by a given sessionId.
static HttpPushHandler	BlasterHttpProxy.getHttpPushHandler(java.lang.String sessionId) Gives a proxy connection by a given sessionId.
static I_XmlBlasterAccess	BlasterHttpProxy.getXmlBlasterAccess(java.lang.String sessionId)

Uses of XmlBlasterException in org.xmlBlaster.protocol.http.ajax

Methods in org.xmlBlaster.protocol.http.ajax that throw XmlBlasterException

void	BlasterInstance.execute(byte[] xmlScriptRaw, java.lang.String xmlScript, java.io.Writer out)
private BlasterInstance	AjaxServlet.getBlasterInstance(javax.servlet.http.HttpServletRequest req)
private BlasterInstance	AjaxServlet.hasBlasterInstance(javax.servlet.http.HttpServletRequest req)
void	BlasterInstance.init(javax.servlet.http.HttpServletRequest req, java.util.Properties props)
(package private) void	BlasterInstance.plainGet(javax.servlet.http.HttpServletRequest req, javax.servlet.http.HttpServletResponse res, java.io.StringWriter out)
void	BlasterInstance.put(MsgUnit msgUnit)
int	BlasterInstance.sendUpdates(java.io.Writer out, boolean onlyContent, int numEntries, long timeout) This method gets the entries in the correct form, i.e.
java.lang.String	BlasterInstance.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos)

Uses of XmlBlasterException in org.xmlBlaster.protocol.http.appletproxy

Methods in org.xmlBlaster.protocol.http.appletproxy that throw XmlBlasterException

protected void	AppletServlet.connect(java.lang.String ME, java.util.logging.Logger log, javax.servlet.http.HttpSession session, java.lang.String qos, javax.servlet.http.HttpServletRequest req, javax.servlet.http.HttpServletResponse res)
private PushHandler	AppletServlet.getPushHandler(javax.servlet.http.HttpServletRequest req)
void	PushHandler.ping(java.lang.String state) calls the ping method in the parentframe of the callback frame The data must be Javascript code
void	PushHandler.setPingInterval(long pingInterval) Set or change the ping interval.
void	PushHandler.startPing()
void	PushHandler.stopPing()

Uses of XmlBlasterException in org.xmlBlaster.protocol.http.simple

Methods in org.xmlBlaster.protocol.http.simple that throw XmlBlasterException

private PullServlet.Position	PullServlet.getCurrentPosition(javax.servlet.http.HttpServletRequest req)
private java.lang.String	PullServlet.getFeedback(javax.servlet.http.HttpServletRequest req)
private I_XmlBlasterAccess	PullServlet.getXmlBlaster(javax.servlet.http.HttpServletRequest req)
private boolean	PullServlet.isAction(java.lang.String ME, javax.servlet.http.HttpServletRequest req, javax.servlet.http.HttpServletResponse res)

Uses of XmlBlasterException in org.xmlBlaster.protocol.jdbc

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

void	JdbcDriver.activate() Activate xmlBlaster access through this protocol.
static org.w3c.dom.Document	DBAdapterUtils.createDocument(java.sql.ResultSet rs) Method declaration
static org.w3c.dom.Document	DBAdapterUtils.createDocument(java.lang.String rootnode, java.lang.String rownode, int rowlimit, java.sql.ResultSet rs) Creates a DOM representation of the result set.
private org.w3c.dom.Document	XmlDBAdapter.createEmptyDocument()
private org.w3c.dom.Document	XmlDBAdapter.createUpdateDocument(int rowsAffected, ConnectionDescriptor descriptor)
void	JdbcDriver.deActivate() Deactivate xmlBlaster access (standby), no clients can connect.
(package private) void	NamedConnectionPool.destroy(java.lang.String dbUrl, java.lang.String dbUser, java.lang.String dbPasswd) Destroy the JDBC connection pool from a specific user.
(package private) void	NamedConnectionPool.UnnamedConnectionPool.erase(java.sql.Connection con) Destroy a JDBC connection (from busy or idle to undef).
(package private) void	NamedConnectionPool.eraseConnection(java.lang.String dbUrl, java.lang.String dbUser, java.lang.String dbPasswd, java.sql.Connection con) Use this method to destroy the given JDBC connection.
private void	JdbcDriver.init(Global glob, AddressServer addressServer, I_Authenticate authenticate, I_XmlBlaster xmlBlasterImpl) Start xmlBlaster jdbc access.
void	CallbackJdbcDriver.init(Global glob, CallbackAddress callbackAddress) Get callback reference here.
void	JdbcDriver.init(Global glob, PluginInfo pluginInfo) Enforced by I_Plugin
java.lang.String	CallbackJdbcDriver.ping(java.lang.String qos) Ping to check if callback server is alive.
java.lang.String	JdbcDriver.publish(MsgUnitRaw msgUnit) Send the XML based result set to the client.
java.lang.String	I_Publish.publish(MsgUnitRaw msgUnit)
private org.w3c.dom.Document	XmlDBAdapter.queryDB(ConnectionDescriptor descriptor) Query the database.
(package private) void	NamedConnectionPool.UnnamedConnectionPool.release(java.sql.Connection con) Use this method to release a JDBC connection.
(package private) void	NamedConnectionPool.release(java.lang.String dbUrl, java.lang.String dbUser, java.lang.String dbPasswd, java.sql.Connection con) Use this method to release a JDBC connection.
(package private) java.sql.Connection	NamedConnectionPool.UnnamedConnectionPool.reserve() Use this method to get a JDBC connection.
(package private) java.sql.Connection	NamedConnectionPool.reserve(java.lang.String dbUrl, java.lang.String dbUser, java.lang.String dbPasswd) Use this method to get a JDBC connection.
(package private) java.sql.Connection	NamedConnectionPool.reserve(java.lang.String dbUrl, java.lang.String dbUser, java.lang.String dbPasswd, long eraseUnusedPoolTimeout, int maxInstances, long idleToErase) Use this method to get a JDBC connection.
java.lang.String[]	CallbackJdbcDriver.sendUpdate(MsgUnitRaw[] msgArr) This sends the SQL query to the JDBC service for processing.
void	CallbackJdbcDriver.sendUpdateOneway(MsgUnitRaw[] msgArr) The oneway variant, without return value.
void	JdbcDriver.shutdown() Instructs jdbc driver to shut down.
java.lang.Object	NamedConnectionPool.UnnamedConnectionPool.toCreate(java.lang.String instanceId) Create a new JDBC connection, the driver must be registered already.

Uses of XmlBlasterException in org.xmlBlaster.protocol.local

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

private I_CallbackExtended	CallbackLocalDriver.getCallback()
void	CallbackLocalDriver.init(Global glob, CallbackAddress callbackAddress) Get callback reference here (== connectLowLevel()).
java.lang.String	CallbackLocalDriver.ping(java.lang.String qos) Ping to check if callback server is alive.
java.lang.String[]	CallbackLocalDriver.sendUpdate(MsgUnitRaw[] msgArr) This sends the update to the client.
void	CallbackLocalDriver.sendUpdateOneway(MsgUnitRaw[] msgArr) The oneway variant, without return value.

Uses of XmlBlasterException in org.xmlBlaster.protocol.rmi

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

void	RmiDriver.activate() Activate xmlBlaster access through this protocol.
private void	RmiDriver.bindToRegistry() Publish the RMI xmlBlaster server to rmi registry.
java.lang.String	I_AuthServer.connect(java.lang.String qos_literal)
java.lang.String	AuthServerImpl.connect(java.lang.String qos_literal) Login to xmlBlaster.
private void	RmiUrl.createInetAddress()
void	RmiDriver.deActivate() Deactivate xmlBlaster access (standby), no clients can connect.
void	I_AuthServer.disconnect(java.lang.String sessionId, java.lang.String qos_literal)
void	AuthServerImpl.disconnect(java.lang.String sessionId, java.lang.String qos_literal)
java.lang.String[]	XmlBlasterImpl.erase(java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal)
java.lang.String[]	I_XmlBlaster.erase(java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String eraseQoS_literal) Delete messages.
MsgUnitRaw[]	XmlBlasterImpl.get(java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal) Synchronous access
MsgUnitRaw[]	I_XmlBlaster.get(java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String getQoS_literal) Synchronous access a message.
private I_XmlBlasterCallback	CallbackRmiDriver.getCb()
private void	RmiDriver.init(Global glob, AddressServer addressServer, I_Authenticate authenticate, I_XmlBlaster xmlBlasterImpl) Start xmlBlaster RMI access.
void	CallbackRmiDriver.init(Global glob, CallbackAddress callbackAddress) Get callback reference here.
void	RmiDriver.init(Global glob, PluginInfo pluginInfo) This method is called by the PluginManager (enforced by I_Plugin).
private void	RmiUrl.parse(java.lang.String url)
java.lang.String	CallbackRmiDriver.ping(java.lang.String qos) Ping to check if callback server is alive.
java.lang.String	XmlBlasterImpl.publish(java.lang.String sessionId, MsgUnitRaw msgUnit)
java.lang.String	I_XmlBlaster.publish(java.lang.String sessionId, MsgUnitRaw msgUnit) Publish a message.
java.lang.String[]	XmlBlasterImpl.publishArr(java.lang.String sessionId, MsgUnitRaw[] msgUnitArr)
java.lang.String[]	I_XmlBlaster.publishArr(java.lang.String sessionId, MsgUnitRaw[] msgUnitArr) Publish messages.
java.lang.String[]	CallbackRmiDriver.sendUpdate(MsgUnitRaw[] msgArr) This sends the update to the client.
void	CallbackRmiDriver.sendUpdateOneway(MsgUnitRaw[] msgArr) The oneway variant, without return value.
void	RmiDriver.shutdown() Instructs RMI to shut down.
java.lang.String	XmlBlasterImpl.subscribe(java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal) Subscribe to messages
java.lang.String	I_XmlBlaster.subscribe(java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String subscribeQoS_literal) Subscribe to messages.
java.lang.String[]	XmlBlasterImpl.unSubscribe(java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal)
java.lang.String[]	I_XmlBlaster.unSubscribe(java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String unSubscribeQos_literal) Unsubscribe from messages.
java.lang.String[]	I_XmlBlasterCallback.update(java.lang.String cbSessionId, MsgUnitRaw[] msgUnitArr)

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

RmiUrl(Global glob, AddressBase address)
Extract "hostname" and "port" from environment, if not found use the local host for hostname and the default port 8080.

RmiUrl(Global glob, AddressBase address, boolean isLocal, int defaultServerPort)
Extract hostname and port from environment, if not found use the local host for hostname and the given default port (usually RmiDriver.DEFAULT_REGISTRY_PORT=1099).

RmiUrl(Global glob, java.lang.String url)
Parse the given url.

RmiUrl(Global glob, java.lang.String hostname, int port)

XmlBlasterImpl(Global glob, AddressServer addressServer, I_XmlBlaster blasterNative)

Uses of XmlBlasterException in org.xmlBlaster.protocol.socket

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

void	SocketDriver.activate() Activate xmlBlaster access through this protocol.
void	SocketCbConnection.connectLowlevel(CallbackAddress callbackAddress) Connects to clients callback server with one socket connection.
java.net.Socket	SocketCbConnection.getSocket() Get the raw socket handle
private void	SocketDriver.init(Global glob, AddressServer addressServer, I_Authenticate authenticate, I_XmlBlaster xmlBlasterImpl) Start xmlBlaster SOCKET access.
void	CallbackSocketDriver.init(Global glob, CallbackAddress callbackAddress)
void	SocketDriver.init(Global glob, PluginInfo pluginInfo) This method is called by the PluginManager (enforced by I_Plugin).
java.lang.String	SocketCbConnection.ping(java.lang.String qos) Check the clients cb server.
java.lang.String	CallbackSocketDriver.ping(java.lang.String qos) Ping to check if callback server is alive.
java.lang.String[]	CallbackSocketDriver.sendUpdate(MsgUnitRaw[] msgArr) This sends the update to the client.
void	CallbackSocketDriver.sendUpdateOneway(MsgUnitRaw[] msgArr) The oneway variant, without return value.
void	SocketDriver.shutdown() Close the listener port, the driver shuts down.
java.lang.String	SocketCbConnection.toXml() Dump of the state, remove in future.
java.lang.String	SocketCbConnection.toXml(java.lang.String extraOffset) Dump of the state, remove in future.

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

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

Uses of XmlBlasterException in org.xmlBlaster.protocol.stomp

Fields in org.xmlBlaster.protocol.stomp declared as XmlBlasterException

XmlBlasterException

RequestHolder.xmlBlasterException

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

private void

XbStompInOutBridge.sendExeption(org.codehaus.stomp.StompFrame command, XmlBlasterException e)

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

void	XbStompDriver.activate()
private void	SocketUrl.createInetAddress()
void	XbStompInOutBridge.init(Global glob, CallbackAddress addressConfig)
void	XbStompInOutBridge.init(Global glob, PluginInfo pluginInfo)
void	XbStompDriver.init(Global glob, PluginInfo pluginInfo)
private void	SocketUrl.parse(java.lang.String url)
java.lang.String	XbStompInOutBridge.ping(java.lang.String qos)
private java.lang.String	XbStompInOutBridge.sendFrameAndWait(org.codehaus.stomp.StompFrame frame, MethodName methodName)
private void	XbStompInOutBridge.sendFrameNoWait(org.codehaus.stomp.StompFrame frame)
private void	XbStompInOutBridge.sendResponse(org.codehaus.stomp.StompFrame command)
java.lang.String[]	XbStompInOutBridge.sendUpdate(MsgUnitRaw[] msgArr)
void	XbStompInOutBridge.sendUpdateOneway(MsgUnitRaw[] msgArr)
void	XbStompDriver.shutdown()

Constructors in org.xmlBlaster.protocol.stomp that throw XmlBlasterException

SocketUrl(Global glob, AddressBase address)
Extract "hostname" and "port" from environment, if not found use the local host for hostname and the default port 61613.

SocketUrl(Global glob, AddressBase address, boolean isLocal, int defaultServerPort)
Extract hostname and port from environment, if not found use the local host for hostname and the given default port (usually ExecutorBase.DEFAULT_SERVER_PORT=61613).

SocketUrl(Global glob, java.lang.String url)
Parse the given url.

SocketUrl(Global glob, java.lang.String hostname, int port)

Uses of XmlBlasterException in org.xmlBlaster.protocol.xmlrpc

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

void	XmlRpcDriver.activate() Activate xmlBlaster access through this protocol.
private void	XmlRpcUrl.createInetAddress()
java.util.Vector	XmlBlasterImpl.erase(java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal)
java.util.Vector	XmlBlasterImpl.get(java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal)
java.util.Vector	XmlBlasterImpl.get(java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal, java.lang.String asString) Synchronous access
private void	XmlRpcDriver.init(Global glob, AddressServer addressServer, I_Authenticate authenticate, I_XmlBlaster xmlBlasterImpl) Start xmlBlaster XMLRPC access.
void	CallbackXmlRpcDriverSingleChannel.init(Global global, CallbackAddress cbAddress) Get callback reference here.
void	CallbackXmlRpcDriver.init(Global global, CallbackAddress cbAddress) Get callback reference here.
void	XmlRpcDriver.init(Global glob, PluginInfo pluginInfo) This method is called by the PluginManager (enforced by I_Plugin).
java.lang.String	AuthenticateImpl.login(java.lang.String loginName, java.lang.String passwd, java.lang.String qos_literal, java.lang.String sessionId) Deprecated. Use connect() instead
java.lang.String	AuthenticateImpl.logout(java.lang.String sessionId) Deprecated. Use disconnect() instead
private void	XmlRpcUrl.parse(java.lang.String url)
java.lang.String	CallbackXmlRpcDriverSingleChannel.ping(java.lang.String qos) Ping to check if callback server is alive.
java.lang.String	CallbackXmlRpcDriver.ping(java.lang.String qos) Ping to check if callback server is alive.
java.lang.String	XmlBlasterImpl.ping(java.lang.String qos) Test the xml-rpc connection and if xmlBlaster is available for requests.
void	CallbackXmlRpcDriver.postInit(java.lang.String sessionId, XmlBlasterImpl xblImpl, boolean singleChannel, boolean useCDATA)
java.lang.String	XmlBlasterImpl.publish(java.lang.String sessionId, java.lang.String xmlKey_literal, byte[] content, java.lang.String publishQos_literal)
java.lang.String	XmlBlasterImpl.publish(java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String content, java.lang.String publishQos_literal) This variant allows to publish simple string based messages (the content is a string).
java.lang.String	XmlBlasterImpl.publish(java.lang.String sessionId, java.util.Vector msgUnitWrap)
java.util.Vector	XmlBlasterImpl.publishArr(java.lang.String sessionId, java.lang.Object[] msgUnitArrWrap)
void	CallbackXmlRpcDriverSingleChannel.register(java.lang.String sessionId_, XmlBlasterImpl xblImpl_)
void	XmlBlasterImpl.registerSessionId(java.lang.String sessionId, boolean singleChannel, boolean useCDATA)
void	CallbackXmlRpcDriverSingleChannel.respan(java.lang.String location)
java.lang.String[]	CallbackXmlRpcDriverSingleChannel.sendUpdate(MsgUnitRaw[] msgArr) This sends the update to the client.
java.lang.String[]	CallbackXmlRpcDriver.sendUpdate(MsgUnitRaw[] msgArr) This sends the update to the client.
void	CallbackXmlRpcDriverSingleChannel.sendUpdateOneway(MsgUnitRaw[] msgArr) The oneway variant, without return value.
void	CallbackXmlRpcDriver.sendUpdateOneway(MsgUnitRaw[] msgArr) The oneway variant, without return value.
void	XmlRpcDriver.shutdown() Instructs XMLRPC driver to shut down.
java.lang.String	XmlBlasterImpl.subscribe(java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal) Subscribe to messages.
java.lang.String	XmlBlasterImpl.toXml(java.lang.String extraOffset)
java.util.Vector	XmlBlasterImpl.unSubscribe(java.lang.String sessionId, java.lang.String xmlKey_literal, java.lang.String qos_literal) void return is not allowed so we return an empty string instead
java.lang.Object[]	XmlBlasterImpl.updateRequest(java.lang.String sessionId, java.lang.String waitTimeTxt, java.lang.String asString) Synchronous request for updates (simulates an asynchronous update)
java.lang.Object	AuthenticateImpl.xmlScriptInvoke(java.lang.String literal) invokeSubscribe to messages.
java.lang.Object	XmlBlasterImpl.xmlScriptInvoke(java.lang.String literal) invokeSubscribe to messages.

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

AuthenticateImpl(Global glob, XmlRpcDriver driver, I_Authenticate authenticate, XmlBlasterImpl xblImpl)
Constructor.

XmlBlasterImpl(Global glob, XmlRpcDriver driver, I_XmlBlaster blasterNative)
Constructor.

XmlRpcUrl(Global glob, AddressBase address)
Extract "hostname" and "port" from environment, if not found use the local host for hostname and the default port 8080.

XmlRpcUrl(Global glob, AddressBase address, boolean isLocal, int defaultServerPort)
Extract hostname and port from environment, if not found use the local host for hostname and the given default port (usually XmlRpcDriver.DEFAULT_HTTP_PORT=8080).

XmlRpcUrl(Global glob, java.lang.String url)
Parse the given url.

XmlRpcUrl(Global glob, java.lang.String hostname, int port, java.lang.String path)

Uses of XmlBlasterException in org.xmlBlaster.test

Methods in org.xmlBlaster.test that throw XmlBlasterException

static MsgUnit[]	Util.adminGet(Global glob, java.lang.String command) Do an administrative command to the server with a temporaty login session.
Msg	MsgInterceptor.getMsg(java.lang.String oid, java.lang.String state) Access the updated message filtered by the given oid and state.
java.lang.String	MsgInterceptor.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos) This is the callback method (I_Callback) invoked from xmlBlaster It directly calls the update method from the testsuite (delegation)
java.lang.String	MsgInterceptor.update(java.lang.String cbSessionId, UpdateKey updateKey, java.io.InputStream is, UpdateQos updateQos) This is the callback method (I_StreamingCallback) invoked from xmlBlaster It directly calls the update method from the testsuite (delegation)

Uses of XmlBlasterException in org.xmlBlaster.test.admin

Methods in org.xmlBlaster.test.admin that throw XmlBlasterException

private void	TestAdminGet.doActivateDispatch(boolean doDispatch)
void	TestAdminGet.doPublish(int counter, java.lang.String oid) TEST: Construct a message and publish it.
java.lang.String	TestAdminGet.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos)

Uses of XmlBlasterException in org.xmlBlaster.test.authentication

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

java.lang.String

TestHtpasswdAuthorization.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos)

Uses of XmlBlasterException in org.xmlBlaster.test.classtest

Methods in org.xmlBlaster.test.classtest that throw XmlBlasterException

ConnectReturnQos	XmlScriptInterpreterTest.TestAccessor.connect(ConnectQos qos, I_Callback callback)
EraseReturnQos[]	XmlScriptInterpreterTest.TestAccessor.erase(java.lang.String key, java.lang.String qos)
MsgUnit[]	XmlScriptInterpreterTest.TestAccessor.get(java.lang.String key, java.lang.String qos)
private MsgQosData	RunLevelTest.getQosData(java.lang.String attrVal)
PublishReturnQos	XmlScriptInterpreterTest.TestAccessor.publish(MsgUnit msgUnit)
PublishReturnQos[]	XmlScriptInterpreterTest.TestAccessor.publishArr(MsgUnit[] msgUnits)
SubscribeReturnQos	XmlScriptInterpreterTest.TestAccessor.subscribe(java.lang.String key, java.lang.String qos)
void	FileLocatorTest.testFileAccess()
void	FileLocatorTest.testFileInExternalJarFile() This test must currently be done manually, the file to be found must reside in a jar file outside the jar files normally used by xmlBlaster.
void	FileLocatorTest.testHttpAccess()
java.lang.Object	TestPoolManager.TestPool.toCreate(java.lang.String instanceId)
UnSubscribeReturnQos[]	XmlScriptInterpreterTest.TestAccessor.unSubscribe(java.lang.String key, java.lang.String qos)
java.lang.String	EventPluginTest.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos) here come the updates for the test client.

Uses of XmlBlasterException in org.xmlBlaster.test.classtest.queue

Methods in org.xmlBlaster.test.classtest.queue that throw XmlBlasterException

private int	I_QueueTest.assertCheckForTakeLowest(I_Queue queue, int numEntries, long numBytes, I_QueueEntry refEntry, boolean leaveOne, I_QueueEntry[] origEntries, int entriesLeft, int currentEntries, long size) returns the number of entries left in the queue after this processing operation
void	CacheQueueTest.availability() when queue available: -fill queue with 3 persistent and 2 transient messages -> RAM:5 JDBC:3 - queue is made unavailable - queue is filled with 2 persistent and 3 transient msg -> RAM:10 JDBC:3 (since no comm) - peek and then remove all available entries: -> RAM:0 JDBC:3 (since no comm)
StorageId	CacheQueueTest.config(long maxEntries, long maxEntriesCache, long maxBytes, long maxBytesCache)
protected void	DesignQueues2008InitialTest.TestInfo.doInit(Global glob, PluginInfo plugInfo)
void	QueueServerEntryTest.historyEntry()
void	JdbcQueueTest.initialEntries()
void	JdbcQueueTest.multiplePut()
void	QueueExtendedTest.performanceMultiPut(int numOfQueues, int numOfMsg, int sizeOfMsg)
void	QueueExtendedTest.performancePut(int numOfQueues, int numOfMsg, int sizeOfMsg)
void	QueueThreadingTest.performancePutMultiThread(int numOfQueues, int numOfMsg, int sizeOfMsg)
void	CacheQueueTest.putPeekRemove(I_Queue refQueue)
void	JdbcQueueTest.putWithBreak()
void	CacheQueueDisconnectTest.putWithBreak()
void	QueueServerEntryTest.updateEntry()

Constructors in org.xmlBlaster.test.classtest.queue that throw XmlBlasterException

QueueThread(Global glob, java.lang.String name, I_Queue queue, java.util.logging.Logger log, int sweeps, int sizeOfMsg)

Uses of XmlBlasterException in org.xmlBlaster.test.client

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

void	TestFailSafePing.doPublish() TEST: Construct a message and publish it.
private void	TestStreamMessages.doPublish(byte[] content, int maxChunkSize, boolean doInterrupt, java.lang.String name)
void	TestPersistentSession.doPublish(int counter) TEST: Construct a message and publish it.
void	TestFailSafe.doPublish(int counter) TEST: Construct a message and publish it.
void	TestPtPPersistent.doPublish(int counter, java.lang.String oid, boolean doGc, long sleep) TEST: Construct a message and publish it.
void	TestHistoryZero.doPublish(java.lang.String oid, int counter, long numHistory) TEST: Construct a message and publish it.
MsgUnit	TestXmlBlasterAccessMultiThreaded.doPublish(java.lang.String oid, java.lang.String content) TEST: Construct a message and publish it.
java.lang.String	TestFilePollerPlugin.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos)
java.lang.String	TestCommand.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos)
java.lang.String	TestPersistentSession.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos)
java.lang.String	TestStreamMessages.update(java.lang.String cbSessionId, UpdateKey updateKey, java.io.InputStream is, UpdateQos updateQos)

Uses of XmlBlasterException in org.xmlBlaster.test.cluster

Methods in org.xmlBlaster.test.cluster that throw XmlBlasterException

I_XmlBlasterAccess

ServerHelper.connect(Global glob, I_Callback cb) Connect in fail save mode to a server node (as given in glob.getId())

Uses of XmlBlasterException in org.xmlBlaster.test.contrib

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

protected void

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

Uses of XmlBlasterException in org.xmlBlaster.test.contrib.filewatcher

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

protected void	FileWatcherFeeder.doInit(Global global, PluginInfo pluginInfo)
java.lang.String	TestFileWatcherPlugin.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos)

Uses of XmlBlasterException in org.xmlBlaster.test.qos

Methods in org.xmlBlaster.test.qos with parameters of type XmlBlasterException

void	TestCorbaThreads.lostConnection(XmlBlasterException xmlBlasterException)

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

java.lang.String

TestUpdateClientException.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.

Uses of XmlBlasterException in org.xmlBlaster.test.util

Fields in org.xmlBlaster.test.util declared as XmlBlasterException

private XmlBlasterException

Client.updateException

Methods in org.xmlBlaster.test.util with parameters of type XmlBlasterException

void	Client.setUpdateException(XmlBlasterException ex) Sets an exception to be thrown the next time an update event comes.

Methods in org.xmlBlaster.test.util that throw XmlBlasterException

void	PtPDestination.init(boolean wantsPtP, boolean shutdownCb, long cbMaxEntries, long cbMaxEntriesCache, long subjMaxEntries, long subjMaxEntriesCache)
void	Client.init(java.lang.String publishOid, java.lang.String subscribeOid, boolean consumable, int session) Initializes this client which either can be a publisher, a subscriber or both depending on the parameters passed here.
void	Client.publish(java.lang.String content) Publishes one entry on the oid specified by the init method.
void	Client.shutdown(boolean doEraseTopic) Disconnect the client from xmlBlaster with an optional previous deletion of the publishing topic.
static boolean	Client.shutdownCb(I_XmlBlasterAccess conn, Client.Shutdown whatToDo) Returns true if it shot down, false if it did a leave Server.
java.lang.String	Client.update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos) Enforced by I_Callback.

Uses of XmlBlasterException in org.xmlBlaster.util

Fields in org.xmlBlaster.util declared as XmlBlasterException

(package private) XmlBlasterException	StopParseException.e
private XmlBlasterException	AttributeSaxFactory.ex

Methods in org.xmlBlaster.util that return XmlBlasterException

static XmlBlasterException	XmlBlasterException.convert(Global glob, ErrorCode errorCodeEnum, java.lang.String location, java.lang.String message, java.lang.Throwable throwable)
static XmlBlasterException	XmlBlasterException.convert(Global glob, java.lang.String location, java.lang.String message, java.lang.Throwable throwable) If throwable is of type XmlBlasterException it is just casted (and location/message are ignored) else if throwable is one if IllegalArgumentException, NullpointerException or OutOfMemoryError it is converted to an XmlBlasterException with corresponding ErrorCode otherwise the ErrorCode is INTERNAL_UNKNOWN
XmlBlasterException	StopParseException.getXmlBlasterException()
static XmlBlasterException	XmlBlasterException.parseByteArr(Global glob, byte[] data)
static XmlBlasterException	XmlBlasterException.parseByteArr(Global glob, byte[] data, ErrorCode fallback) Serialize the complete exception.
static XmlBlasterException	XmlBlasterException.parseToString(Global glob, java.lang.String toString, ErrorCode fallback) Parsing what toString() produced
static XmlBlasterException	XmlBlasterException.tranformCallbackException(XmlBlasterException e)

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

void	I_XmlBlasterExceptionHandler.newException(XmlBlasterException e) This will be called from XmlBlasterException constructor.
static XmlBlasterException	XmlBlasterException.tranformCallbackException(XmlBlasterException e)

Methods in org.xmlBlaster.util that throw XmlBlasterException

java.lang.String	Global.accessFromInternalHttpServer(Address address, java.lang.String urlPath, boolean verbose) Access the xmlBlaster internal HTTP server and download the requested path.
Timestamp	I_TimeoutManager.addOrRefreshTimeoutListener(I_Timeout listener, long delay, java.lang.Object userData, Timestamp key) Checks if key is null -> addTimeoutListener else refreshTimeoutListener() in a thread save way.
Timestamp	Timeout.addOrRefreshTimeoutListener(I_Timeout listener, long delay, java.lang.Object userData, Timestamp key) Checks if key is null -> addTimeoutListener else refreshTimeoutListener() in a thread save way.
Timestamp	TimeoutPooled.addOrRefreshTimeoutListener(I_Timeout listener, long delay, java.lang.Object userData, Timestamp key)
static void	FileLocator.appendToFile(java.lang.String outName, java.lang.String str) Append data from into a file.
java.util.logging.Level	Global.changeLogLevel(java.lang.String loggerName, java.util.logging.Level level) Changes the given logger to given level.
int	EmbeddedXmlBlaster.changeRunlevel(int newRunlevel, boolean force) Change the run level to the given newRunlevel.
void	XmlToDom.create(java.lang.String xmlKey_literal) Creates the DOM tree, this is done delayed when the first access is done.
DispatchConnectionsHandler	Global.createClientDispatchConnectionsHandler(ClientDispatchManager dispatchManager) Returns the client access layer implementations 'ClientDispatchConnectionsHandler'
static void	XmlBlasterSecurityManager.createSecurityManager(Global glob) Create and install a security manager.
byte[]	XslTransformer.doXSLTransformation(byte[] xmlLiteral)
java.lang.String	FileLocator.findFile(java.lang.String[] path, java.lang.String filename) Searches in the given path for the specified filename.
java.lang.String	FileLocator.findFile(java.lang.String path, java.lang.String filename) finds the file in the given path.
java.lang.String	FileLocator.findFile(java.lang.String path, java.lang.String separator, java.lang.String filename) finds the file in the given path.
boolean	Global.get(java.lang.String shortKey, boolean defaultValue, java.util.Properties map, I_PluginConfig pluginConfig) Checks PluginInfo as well.
double	Global.get(java.lang.String shortKey, double defaultValue, java.util.Properties map, I_PluginConfig pluginConfig)
int	Global.get(java.lang.String shortKey, int defaultValue, java.util.Properties map, I_PluginConfig pluginConfig)
long	Global.get(java.lang.String shortKey, long defaultValue, java.util.Properties map, I_PluginConfig pluginConfig)
java.lang.String	Global.get(java.lang.String shortKey, java.lang.String defaultValue, java.util.Properties map, I_PluginConfig pluginConfig) It searches for the given property.
java.lang.String	MsgUnit.getContentStr() Convenience method to get the raw content as a string, the encoding is UTF-8 if not specified by clientProperty Constants.CLIENTPROPERTY_CONTENT_CHARSET,
javax.xml.parsers.DocumentBuilderFactory	Global.getDocumentBuilderFactory() Get the configured DocumentBuilderFactoryFactory.
HttpIORServer	Global.getHttpServer() Access the http server which allows bootstrapping the CORBA IOR
JmxWrapper	Global.getJmxWrapper()
java.util.logging.Level	Global.getLogLevel(java.lang.String loggerName) Get the current loglevel.
static java.util.Enumeration	XmlNotPortable.getNodeSetFromXPath(java.lang.String expression, org.w3c.dom.Document document) Do XPath query on DOM
java.util.Map	Global.getPersistentMap(java.lang.String id) Returns a persistent map.
org.w3c.dom.NamedNodeMap	XmlToDom.getRootAttributes() The syntax of the XmlKey_literal String.
org.w3c.dom.Node	XmlToDom.getRootNode() Fills the DOM tree, and assures that a valid is used.
javax.xml.parsers.SAXParserFactory	Global.getSAXParserFactory() Get the configured SAXParserFactory.
protected void	SaxHandlerBase.init(org.xml.sax.InputSource inputSource)
protected void	XmlQoSBase.init(java.lang.String xmlLiteral)
protected void	SaxHandlerBase.init(java.lang.String xmlLiteral)
protected void	SaxHandlerBase.init(java.lang.String xmlSource, org.xml.sax.InputSource inputSource)
private java.io.File	FileDumper.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 java.net.URL	Global.initLogManager(java.lang.String[] args) Configure JDK 1.4 java.util.logging (only once per JVM-Classloader, multiple Global instances share the same).
boolean	Global.isRegisteredMBean(ContextNode ctxNode)
private void	XmlToDom.loadDomTree() Fills the DOM tree, and assures that a valid is used.
static void	XmlBuffer.main(java.lang.String[] args)
static void	Base64.main(java.lang.String[] args) java org.xmlBlaster.util.Base64 -file MyFile.jpg java org.xmlBlaster.util.Base64 HelloWorld -> SGVsbG9Xb3JsZA== java org.xmlBlaster.util.Base64 -decodeFile MyFile.base64 java org.xmlBlaster.util.Base64 -decode Q2lBOGEyVjVJRzlwWkQwblNHVnNiRzhuSUdOdmJuUmxiblJOYVcxbFBTZDBaWGgwTDNodGJDY2dZMjl1ZEdWdWRFMXBiV1ZGZUhSbGJtUmxaRDBuTVM0d0p6NEtJQ0E4YjNKbkxuaHRiRUpzWVhOMFpYSStQR1JsYlc4dE16NDhMMlJsYlc4dE16NDhMMjl5Wnk1NGJXeENiR0Z6ZEdWeVBnb2dQQzlyWlhrKw==
org.w3c.dom.Node	I_MergeDomNode.mergeNode(org.w3c.dom.Node newNode)
void	XmlToDom.mergeRootNode(I_MergeDomNode merger) Should be called by publish() to merge the local XmlKey DOM into the big xmlBlaster DOM tree
private void	SaxHandlerBase.parse(org.xml.sax.InputSource xmlData) Does the actual parsing
private void	SaxHandlerBase.parse(java.lang.String xmlData)
static org.w3c.dom.Document	XmlToDom.parseToDomTree(Global glob, java.lang.String xmlKey_literal)
java.lang.String[]	Global.peekQueueMessagesToFile(I_Queue queue, int numOfEntries, java.lang.String path, java.lang.String label) Dumps given amount of messages from queue to file.
java.lang.StringBuffer	XmlToDom.printOn() Dump state of this object into XML.
java.lang.StringBuffer	XmlToDom.printOn(java.lang.String extraOffset) Dump state of this object into XML.
void	SimpleXbQueue.push(java.lang.Object obj) Add a unit to the beginning of the queue.
java.lang.String	FileLocator.read(java.net.URL url)
static java.lang.String	FileLocator.readAsciiFile(java.lang.String fileName) Read a file into String.
static java.lang.String	FileLocator.readAsciiFile(java.lang.String parent, java.lang.String child) Read a file into String.
static byte[]	FileLocator.readFile(java.io.File f)
static byte[]	FileLocator.readFile(java.lang.String fileName) Read a file into byte[].
static byte[]	FileLocator.readFile(java.lang.String parent, java.lang.String fileName) Read a file into byte[].
Timestamp	I_TimeoutManager.refreshTimeoutListener(Timestamp key, long delay) Refresh a listener before the timeout happened.
Timestamp	Timeout.refreshTimeoutListener(Timestamp key, long delay) Refresh a listener before the timeout happened.
Timestamp	TimeoutPooled.refreshTimeoutListener(Timestamp key, long delay)
private Timestamp	TimeoutPooled.refreshTimeoutListener(Timestamp key, long delay, boolean throwExceptionIfMissing)
JmxMBeanHandle	Global.registerMBean(ContextNode contextNode, java.lang.Object mbean) JMX support.
static void	FileLocator.writeFile(java.lang.String name, byte[] arr) Write data from StringBuffer into a file.
static void	FileLocator.writeFile(java.lang.String name, java.lang.String str) Write data from StringBuffer into a file.
static void	FileLocator.writeFile(java.lang.String parent, java.lang.String child, byte[] arr) Write data from byte[] into a file.

Constructors in org.xmlBlaster.util with parameters of type XmlBlasterException

StopParseException(XmlBlasterException e)
Use this constructor to stop parsing when an exception occurred.

Constructors in org.xmlBlaster.util that throw XmlBlasterException

FileDumper(Global glob)

FileDumper(Global glob, java.lang.String dirName, boolean forceBase64)

MsgUnit(Global glob, MsgUnitRaw msgUnitRaw, MethodName methodName)

MsgUnit(Global glob, java.lang.String key, byte[] content, java.lang.String qos)
Assumes a PUBLISH.

MsgUnit(Global glob, java.lang.String key, byte[] content, java.lang.String qos, MethodName methodName)
The normal constructor.

MsgUnit(Global glob, java.lang.String key, java.lang.String contentAsString, java.lang.String qos)
Assumes a PUBLISH.

MsgUnit(java.lang.String key, byte[] content, java.lang.String qos)
Uses the default global and assumes a PUBLISH.

MsgUnit(java.lang.String key, java.lang.String contentAsString, java.lang.String qos)
Uses the default global and assumes a PUBLISH.

XmlToDom(Global glob, java.lang.String xmlKey_literal)
Parses given xml string

XslTransformer(Global glob, java.lang.String xslFilename, java.lang.String systemId, javax.xml.transform.URIResolver uriResolver, java.util.Map props)
Constructs a transformer instance.

Uses of XmlBlasterException in org.xmlBlaster.util.admin

Methods in org.xmlBlaster.util.admin that throw XmlBlasterException

long[]	I_AdminQueue.getEntryReferences() Gets the references of the entries in the queue.
int	I_AdminQueue.remove() Removes the first element in the queue.
long	I_AdminQueue.removeNum(long numOfEntries) Removes max num messages.
int	I_AdminQueue.removeTransient() Removes all the transient entries (the ones which have the flag 'persistent' set to false.
long	I_AdminQueue.removeWithPriority(long numOfEntries, long numOfBytes, int minPriority, int maxPriority) Removes max numOfEntries messages (or less depending on the numOfBytes).
java.util.List<I_Entry>	I_AdminQueue.takeWithPriority(int numOfEntries, long numOfBytes, int minPriority, int maxPriority) Takes given number of entries out of the queue.

Uses of XmlBlasterException in org.xmlBlaster.util.admin.extern

Methods in org.xmlBlaster.util.admin.extern that throw XmlBlasterException

static JmxWrapper	JmxWrapper.getInstance(Global glob) Singleton to avoid that different Global instances create more than one JmxWrapper.
void	JmxWrapper.init() Initialize the MBean server and adaptors.
boolean	JmxWrapper.isRegistered(ContextNode contextNode)
private void	JmxWrapper.startRmiRegistry(java.lang.String registryHost, int registryPort) Start xmlBlaster security manager and RMI registry.
void	JmxWrapper.startXmlBlasterConnector(javax.management.MBeanServer mbeanServer) Starts XmlBlasterConnector on mbeanServer-Instance This is a small embedded xmlBlaster server instance which is started.

Constructors in org.xmlBlaster.util.admin.extern that throw XmlBlasterException

JmxWrapper(Global glob)
Constructs an initial JmxWrapper object.

Uses of XmlBlasterException in org.xmlBlaster.util.checkpoint

Methods in org.xmlBlaster.util.checkpoint that throw XmlBlasterException

void	Checkpoint.init(Global glob, PluginInfo pluginInfo)
void	Checkpoint.shutdown()

Uses of XmlBlasterException in org.xmlBlaster.util.classloader

Methods in org.xmlBlaster.util.classloader that throw XmlBlasterException

static LoaderInfo	StandaloneClassLoaderFactory.getLoaderInfo(java.lang.Object caller, java.lang.String plugin, boolean exceptionOnFailure) Retrievs the base path for the object related classpath.
java.net.URLClassLoader	ContextClassLoaderFactory.getPluginClassLoader(PluginInfo pluginInfo)
java.net.URLClassLoader	StandaloneClassLoaderFactory.getPluginClassLoader(PluginInfo pluginInfo) Creates and returns a new URL class loader based on the callers class loader and the callers related additional classes which may exist in a specified path.
java.net.URLClassLoader	OsgiClassLoaderFactory.getPluginClassLoader(PluginInfo pluginInfo)
java.net.URLClassLoader	ClassLoaderFactory.getPluginClassLoader(PluginInfo pluginInfo)
java.net.URLClassLoader	ContextClassLoaderFactory.getXmlBlasterClassLoader()
java.net.URLClassLoader	StandaloneClassLoaderFactory.getXmlBlasterClassLoader() Creates and returns a new URL class loader based on the callers class loader and the callers related additional classes which may exist in a specified path.
java.net.URLClassLoader	OsgiClassLoaderFactory.getXmlBlasterClassLoader()
java.net.URLClassLoader	ClassLoaderFactory.getXmlBlasterClassLoader()
private java.net.URL[]	StandaloneClassLoaderFactory.stringToUrl(java.util.ArrayList stringUrls)

Uses of XmlBlasterException in org.xmlBlaster.util.dispatch

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

private boolean	DispatchConnection.isAuthenticationException(XmlBlasterException ex)
private boolean	DispatchConnection.retry(XmlBlasterException e)
boolean	I_PostSendListener.sendingFailed(MsgQueueEntry[] entries, XmlBlasterException exception) Called if an asynchronous message is rejected by the server.
boolean	I_DispatchManager.sendingFailedNotification(MsgQueueEntry[] entries, XmlBlasterException ex) Notify I_PostSendListener about problem.
void	I_DispatchManager.shutdownFomAnyState(ConnectionStateEnum oldState, XmlBlasterException ex) Call by DispatchConnectionsHandler on state transition
(package private) void	DispatchConnectionsHandler.toDead(DispatchConnection con, XmlBlasterException ex) Call by DispatchConnection on state transition
void	I_ConnectionStatusListener.toDead(I_DispatchManager dispatchManager, ConnectionStateEnum oldState, XmlBlasterException xmlBlasterException)
void	I_DispatchManager.toDead(XmlBlasterException ex)
private void	DispatchConnectionsHandler.updateState(XmlBlasterException ex) Handles the state transition

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

abstract void	DispatchConnection.connectLowlevel() Connect on protocol layer and try an initial low level ping.
abstract DispatchConnection	DispatchConnectionsHandler.createDispatchConnection(AddressBase address) Create a DispatchConnection instance and load the protocol plugin.
abstract void	DispatchConnectionsHandler.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
abstract java.lang.String	DispatchConnection.doPing(java.lang.String data) Does the real ping to the remote server instance.
abstract void	DispatchConnection.doSend(MsgQueueEntry[] msgArr_, boolean isAsyncMode) Send the messages.
void	I_DispatchManager.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	DispatchConnection.handleTransition(boolean byDispatchConnectionsHandler, java.lang.Throwable throwable)
void	I_DispatchManager.handleWorkerException(java.util.List<I_Entry> entryList, java.lang.Throwable throwable) Called by DispatchWorker if an Exception occurred in async mode.
void	DispatchConnection.initialize() Connects on protocol level to the server and tries a ping.
void	DispatchConnectionsHandler.initialize(AddressBase[] cbAddr) Overwrite existing connections with new configuration
abstract void	DispatchConnection.loadPlugin() The derived class should create an instance of the protocol driver.
java.lang.String	I_Callback.ping(java.lang.String qos)
java.lang.String	DispatchConnection.ping(java.lang.String data) Ping the remote server instance (callback of the client or xmlBlaster itself)
protected java.lang.String	DispatchConnection.ping(java.lang.String data, boolean byDispatchConnectionsHandler) Ping the xmlBlaster server or callback server of the client.
void	I_DispatchManager.putPost(I_QueueEntry queueEntry)
void	I_DispatchManager.putPost(I_QueueEntry[] queueEntries)
boolean	I_DispatchManager.putPre(I_QueueEntry queueEntry)
boolean	I_DispatchManager.putPre(I_QueueEntry[] queueEntries)
protected abstract void	DispatchConnection.reconnect() On reconnect polling try to establish the connection
void	I_DispatchManager.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	DispatchWorker.run(java.util.ArrayList entryList) Synchronous push mode.
void	DispatchConnectionsHandler.send(MsgQueueEntry[] msgArr, boolean isAsyncMode) Send the messages back to the client.
void	DispatchConnection.send(MsgQueueEntry[] msgArr, boolean isAsyncMode) Send the messages back to the client.
void	DispatchConnection.setAddress(AddressBase address)
void	I_DispatchManager.setAddresses(AddressBase[] addr) Set new callback addresses, typically after a session login/logout
void	DispatchConnection.shutdown(boolean delayed) Stop all remote connections.
protected void	DispatchConnection.spanPingTimer(long timeout, boolean isPing)
PublishReturnQos	I_Callback.update(MsgUnit msgUnit)
void	I_Callback.updateOneway(MsgUnit[] msgUnitArr)
void	I_DispatchManager.updateProperty(CallbackAddress[] addressArr) Reconfigure dispatcher with given properties.

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

DispatchConnectionsHandler(Global glob, I_DispatchManager dispatchManager)
You need to call initialize() after construction.

Uses of XmlBlasterException in org.xmlBlaster.util.dispatch.plugins

Methods in org.xmlBlaster.util.dispatch.plugins that throw XmlBlasterException

I_MsgDispatchInterceptor	DispatchPluginManager.getPlugin(java.lang.String typeVersion) Return a specific dispatcher plugin, if possible from the cache.
java.util.List<I_Entry>	I_MsgDispatchInterceptor.handleNextMessages(I_DispatchManager dispatchManager, java.util.List<I_Entry> pushEntries) If you returned true from doActivate() the worker thread will ask us to retrieve the next messages from the queue (dispatchManager.getQueue()).
void	I_MsgDispatchInterceptor.initialize(Global glob, java.lang.String typeVersion) Is called once only after the instance is created.
void	I_MsgDispatchInterceptor.postHandleNextMessages(I_DispatchManager dispatchManager, MsgUnit[] processedEntries) Method invoked after having successfully sent the entries in asynchronous modus.
protected void	DispatchPluginManager.postInstantiate(I_Plugin plugin, PluginInfo pluginInfo) Called after getPlugin() but only if plugin was new created
void	I_MsgDispatchInterceptor.shutdown() Shutdown the implementation, sync with data store
void	I_MsgDispatchInterceptor.shutdown(I_DispatchManager dispatchManager) Deregister the given dispatchManager

Uses of XmlBlasterException in org.xmlBlaster.util.dispatch.plugins.prio

Methods in org.xmlBlaster.util.dispatch.plugins.prio with parameters of type XmlBlasterException

void	PriorizedDispatchPlugin.toDead(I_DispatchManager dispatchManager, ConnectionStateEnum oldState, XmlBlasterException xmlBlasterException) Call by DispatchConnectionsHandler on state transition Enforced by interface I_ConnectionStatusListener

Methods in org.xmlBlaster.util.dispatch.plugins.prio that throw XmlBlasterException

java.util.List<I_Entry>	PriorizedDispatchPlugin.handleNextMessages(I_DispatchManager dispatchManager, java.util.List<I_Entry> entries) Enforced by I_MsgDispatchInterceptor.
void	PriorizedDispatchPlugin.initialize(Global glob, java.lang.String typeVersion) Is called by DispatchPluginManager after the instance is created.
private void	ConfigurationParser.parseIt(java.lang.String xmlLiteral)
void	PriorizedDispatchPlugin.postHandleNextMessages(I_DispatchManager dispatchManager, MsgUnit[] processedEntries) Not doing anything in this method since no cleanup needed.
private void	PriorizedDispatchPlugin.putToHoldbackQueue(DispatchManagerEntry managerEntry, MsgQueueEntry entry)
void	XmlBlasterNativeClient.sendPtPMessage(MsgQueueEntry entry, java.lang.String pluginName, java.lang.String action, java.lang.String currStatus) Send a PtP message to the publisher notifying him on problems about dispatching his just published message.
void	PriorizedDispatchPlugin.shutdown()
void	PriorizedDispatchPlugin.shutdown(I_DispatchManager dispatchManager) Deregister a dispatch manager.
private void	PriorizedDispatchPlugin.subscribeStatusMessages() Subscribe to messages according to the current configuration.
void	XmlBlasterNativeClient.subscribeToStatusMessage(java.lang.String msgOid, I_Notify callback) We subscribe to the status message (e.g.

Constructors in org.xmlBlaster.util.dispatch.plugins.prio that throw XmlBlasterException

ConfigurationParser(Global glob, java.lang.String xmlLiteral)

XmlBlasterNativeClient(Global glob_, PriorizedDispatchPlugin plugin, java.lang.String sessionId)
Creates a remote client to xmlBlaster.

Uses of XmlBlasterException in org.xmlBlaster.util.error

Fields in org.xmlBlaster.util.error declared as XmlBlasterException

private XmlBlasterException

MsgErrorInfo.xmlBlasterException

Methods in org.xmlBlaster.util.error that return XmlBlasterException

XmlBlasterException	I_MsgErrorInfo.getXmlBlasterException() Access the exception object describing the problem
XmlBlasterException	MsgErrorInfo.getXmlBlasterException() Access the exception object describing the problem

Methods in org.xmlBlaster.util.error that throw XmlBlasterException

java.lang.String

I_MsgErrorHandler.handleErrorSync(I_MsgErrorInfo msgErrorInfo) The final recovery, all informations necessary are transported in msgErrorInfo.

Uses of XmlBlasterException in org.xmlBlaster.util.http

Methods in org.xmlBlaster.util.http that throw XmlBlasterException

HttpResponse

I_HttpRequest.service(java.lang.String urlPath, java.util.Map properties) A HTTP request needs to be processed

Uses of XmlBlasterException in org.xmlBlaster.util.key

Methods in org.xmlBlaster.util.key that throw XmlBlasterException

java.lang.String	QueryKeyData.checkQueryType(java.lang.String queryType) Check the query type, Constants.XPATH, Constants.EXACT, Constants.DOMAIN are currently supported
MsgKeyData	I_MsgKeyFactory.readObject(java.lang.String xmlKey) Parses the given Key and returns a MsgKeyData holding the data.
QueryKeyData	I_QueryKeyFactory.readObject(java.lang.String xmlKey) Parses the given Key and returns a QueryKeyData holding the data.
QueryKeyData	QueryKeySaxFactory.readObject(java.lang.String xmlKey) Parses the given xml Key and returns a QueryKeyData holding the data.
MsgKeyData	MsgKeySaxFactory.readObject(java.lang.String xmlKey) Parses the given xml Key and returns a MsgKeyData holding the data.
void	QueryKeyData.setQueryType(java.lang.String queryType) Should be avoided to call directly.
void	KeyData.setQueryType(java.lang.String queryType)

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

QueryKeyData(Global glob, java.lang.String query, java.lang.String queryType)

Uses of XmlBlasterException in org.xmlBlaster.util.lexical

Methods in org.xmlBlaster.util.lexical that throw XmlBlasterException

boolean	Sql92Selector.select(java.lang.String query, java.util.Map<java.lang.String,ClientProperty> clientProperties)
boolean	I_Selector.select(java.lang.String query, java.util.Map<java.lang.String,ClientProperty> clientProperties)

Constructors in org.xmlBlaster.util.lexical that throw XmlBlasterException

LikeOpWrapper(Global global, java.lang.String pattern)

LikeOpWrapper(Global global, java.lang.String pattern, char escape)

LikeOpWrapper(Global global, java.lang.String pattern, char escape, boolean doReducedSyntax)

Uses of XmlBlasterException in org.xmlBlaster.util.plugin

Methods in org.xmlBlaster.util.plugin that throw XmlBlasterException

private PluginInfo	PluginManagerBase.checkPluginInfoInRunLevelInfos(PluginInfo pluginInfo) TODO Clean this method since it uses knowledge of the server side
I_Plugin	PluginManagerBase.getDummyPlugin() Tries to return an instance of the default plugin.
I_Plugin	PluginManagerBase.getPluginObject(PluginInfo pluginInfo) Return a specific plugin, if one is loaded already it is taken from cache.
I_Plugin	PluginManagerBase.getPluginObject(java.lang.String typeVersion)
I_Plugin	I_PluginManager.getPluginObject(java.lang.String type, java.lang.String version) Return a specific plugin.
I_Plugin	PluginManagerBase.getPluginObject(java.lang.String type, java.lang.String version) Return a specific plugin, if one is loaded already it is taken from cache.
private void	PluginInfo.init(Global glob, I_PluginManager manager, java.lang.String type_, java.lang.String version_, ContextNode contextNode) see javadoc of constructor
void	I_Plugin.init(Global glob, PluginInfo pluginInfo) This method is called by the PluginManager.
protected I_Plugin	PluginManagerBase.instantiatePlugin(PluginInfo pluginInfo) Create a plugin instance without caching it.
protected I_Plugin	PluginManagerBase.instantiatePlugin(PluginInfo pluginInfo, boolean usePluginCache) Loads a plugin.
private I_Plugin	PluginManagerBase.instantiatePluginFirstPhase(PluginInfo pluginInfo, boolean usePluginCache)
private I_Plugin	PluginManagerBase.instantiatePluginSecondPhase(I_Plugin plugin, PluginInfo pluginInfo)
private void	PluginInfo.parsePropertyValue(java.lang.String rawString)
protected void	PluginManagerBase.postInstantiate(I_Plugin plugin, PluginInfo pluginInfo) Is called after a plugin in instantiated, allows the base class to do specific actions.
void	I_Plugin.shutdown() Cleans up the resource.

Constructors in org.xmlBlaster.util.plugin that throw XmlBlasterException

PluginInfo(Global glob, I_PluginManager manager, java.lang.String typeVersion)

PluginInfo(Global glob, I_PluginManager manager, java.lang.String typeVersion, ContextNode contextNode)

PluginInfo(Global glob, I_PluginManager manager, java.lang.String type, java.lang.String version)

PluginInfo(Global glob, I_PluginManager manager, java.lang.String type, java.lang.String version, ContextNode contextNode)
From pluginEnvClass and instanceId we build a string to lookup the key in the environment e.g.

Uses of XmlBlasterException in org.xmlBlaster.util.pool

Methods in org.xmlBlaster.util.pool that throw XmlBlasterException

void	PoolManager.busyRefresh(java.lang.String instanceId) Restart countdown for resource life cycle.
private java.lang.String	PoolManager.createId(java.lang.String instanceId) Generate a unique resource ID
private ResourceWrapper	PoolManager.findLow(java.lang.String instanceId) Find a resource in busy list.
void	PoolManager.release(java.lang.String instanceId) Release a resource explicitly from 'busy' into the 'idle' pool.
ResourceWrapper	PoolManager.reserve() Get a new resource.
ResourceWrapper	PoolManager.reserve(long localBusyToIdleTimeout, long localIdleToEraseTimeout, java.lang.String instanceId) Get a new resource.
ResourceWrapper	PoolManager.reserve(java.lang.String instanceId) Get a new resource.
java.lang.Object	I_PoolManager.toCreate(java.lang.String instanceId) Is invoked when a new resource is needed.

Uses of XmlBlasterException in org.xmlBlaster.util.property

Methods in org.xmlBlaster.util.property that throw XmlBlasterException

void	Property.addArgs2Props(java.util.Properties argsProps) The same as addArgs2Props(String[] args) but passing the args in a Properties hashtable.
private void	Property.addArgs2Props(java.util.Properties props, java.util.Properties argsProps) See method addArgs2Props(args)
void	Property.addArgs2Props(java.lang.String[] args) Add key/values, for example from startup command line args to the property variable.
static java.util.Properties	Property.argsToProps(java.lang.String[] args) Scan args, correct and check them and return the result in a Properties hash table
static boolean	Args.getArg(java.lang.String[] args, java.lang.String key, boolean defaultVal) Try to find the given key in the args list.
static byte[]	Args.getArg(java.lang.String[] args, java.lang.String key, byte[] defaultVal) Try to find the given key in the args list.
static int	Args.getArg(java.lang.String[] args, java.lang.String key, int defaultVal) Try to find the given key in the args list.
static java.lang.String	Args.getArg(java.lang.String[] args, java.lang.String key, java.lang.String defaultVal) Try to find the given key in the args list.
static boolean	Args.getArg(java.lang.String arg, boolean defVal)
static int	Args.getArg(java.lang.String arg, int defVal)
static java.lang.String	Args.getArg(java.lang.String arg, java.lang.String defVal)
java.io.InputStream	Property.FileInfo.getInputStream() You need to call closeInputStream() when finished.
private void	Property.init(java.lang.String fileName_, boolean scanSystemProperties, java.lang.String[] args, boolean replaceVariables, boolean supportArrays) Internal Initialize.
java.util.Properties	Property.loadProps(Property.FileInfo info, java.util.Properties argsProps) Use this method only the first time to initialize everything.
private java.lang.String	Property.replaceVariable(java.lang.String key, java.lang.String value) Replace dynamic variables, e.g.
java.lang.String	Property.replaceVariableNoException(java.lang.String key, java.lang.String value) Replace dynamic variables, e.g.
private void	Property.replaceVariables() Replace all dynamic variables, e.g.
java.lang.String	Property.replaceVariableWithException(java.lang.String key, java.lang.String value) Replace dynamic variables, e.g.
private void	Property.scanArray(java.lang.String key, java.lang.String value)
private void	Property.scanArrays() We look for keys containing [] brackets and collect them into a map
java.lang.String	Property.set(java.lang.String key, java.lang.String value) Set or overwrite a property, note that currently no variable replacement is implemented for the passed value.
static boolean	Property.toBool(java.lang.String token) Parse a string to boolean.

Constructors in org.xmlBlaster.util.property that throw XmlBlasterException

Property(java.lang.String propertyFileUrl, boolean scanSystemProperties, java.lang.Object applet, boolean replaceVariables)
Construct a property container from supplied property file (URL) and Applet.

Property(java.lang.String fileName, boolean scanSystemProperties, java.util.Properties extraProps, boolean replaceVariables)
Construct a property container from supplied property file and enumeration.

Property(java.lang.String fileName, boolean scanSystemProperties, java.lang.String[] args, boolean replaceVariables)
Construct a property container from supplied property file and args array.

Property(java.lang.String fileName, boolean scanSystemProperties, java.lang.String[] args, boolean replaceVariables, boolean output)
Construct a property container from supplied property file and args array.

Property(java.lang.String fileName, boolean scanSystemProperties, java.lang.String projectname, boolean replaceVariables)
Construct a property container from supplied property file and enumeration.

Uses of XmlBlasterException in org.xmlBlaster.util.protocol

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

protected void

RequestReplyExecutor.executeException(MsgInfo receiver, XmlBlasterException e, boolean udp) Send a one way exception back to the other side

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

protected void	RequestReplyExecutor.executeException(MsgInfo receiver, XmlBlasterException e, boolean udp) Send a one way exception back to the other side
protected void	RequestReplyExecutor.executeResponse(MsgInfo receiver, java.lang.Object response, boolean udp) Send a one way response message back to the other side
static MsgUnitRaw	ProtoConverter.objArray2MsgUnitRaw(java.lang.Object[] inObj) Converts an Object[3] to a MsgUnitRaw.
static MsgUnitRaw[]	ProtoConverter.objMatrix2MsgUnitRawArray(java.lang.Object[] in) Converts an Object[][] to a MsgUnitRaw[].
static java.lang.String[]	ProtoConverter.objToStringArray(java.lang.Object obj)
boolean	RequestReplyExecutor.receiveReply(MsgInfo receiver, boolean udp) Handle common messages
java.lang.Object	RequestReplyExecutor.requestAndBlockForReply(MsgInfo msgInfo, boolean expectingResponse, boolean udp) Send a message and block until the response arrives.
protected abstract void	RequestReplyExecutor.sendMessage(MsgInfo msgInfo, java.lang.String requestId, MethodName methodName, boolean udp) Flush the data to the protocol layer (socket, email, ...).
static MsgUnitRaw	ProtoConverter.vector2MsgUnitRaw(java.util.Vector<java.lang.Object> vec) Converts a Vector to a MsgUnitRaw.
static MsgUnitRaw[]	ProtoConverter.vector2MsgUnitRawArray(java.util.Vector vec) Converts a Vector to a MsgUnitRaw[].
static java.lang.String	ProtoConverter.vector2String(java.util.Vector<java.lang.String> vec) Converts one element of a Vector to a String object.
static java.lang.String[]	ProtoConverter.vector2StringArray(java.util.Vector<java.lang.String> vec) Converts a Vector to a String[] object.

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

Methods in org.xmlBlaster.util.protocol.corba that return XmlBlasterException

static XmlBlasterException

OrbInstanceFactory.convert(Global glob, XmlBlasterException eCorba) Converts the internal CORBA XmlBlasterException to the util.XmlBlasterException.

Methods in org.xmlBlaster.util.protocol.corba with parameters of type XmlBlasterException

static XmlBlasterException

OrbInstanceFactory.convert(XmlBlasterException eUtil) Converts the util.XmlBlasterException to the internal CORBA XmlBlasterException.

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

static MsgUnitRaw	OrbInstanceFactory.convert(Global glob, MessageUnit mu) Converts the internal CORBA message unit to the internal representation.
static MsgUnitRaw[]	OrbInstanceFactory.convert(Global glob, MessageUnit[] msgUnitArr) Converts the internal CORBA message unit array to the internal representation.

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

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

static java.util.ArrayList	MailUtil.accessAttachments(javax.mail.Part p) Access all attachments.
static int	MailUtil.accessPart(javax.mail.Part p, int level, java.util.ArrayList attachments)
private void	SmtpClient.fillProperties(java.lang.String key, java.lang.String defaultValue, java.util.Properties props, Global glob, I_PluginConfig pluginConfig)
Pop3Driver	EmailExecutor.getPop3Driver() Access the Pop3Driver.
static Pop3Driver	Pop3Driver.getPop3Driver(Global glob, I_PluginConfig pluginConfig, java.lang.String msgIdFileName) The Pop3Driver is a singleton in the Global scope.
SmtpClient	EmailExecutor.getSmtpClient() TODO: Put into engine.Global and util.Global (see EventPlugin.java)
static SmtpClient	SmtpClient.getSmtpClient(Global glob, I_PluginConfig pluginConfig) The SmtpClient is a singleton in the Global scope.
private javax.mail.Store	Pop3Driver.getStore() Connect to POP3 store.
void	EmailExecutor.init(Global glob, AddressBase addressBase, PluginInfo pluginConfig) This init() is called after the init(Global, PluginInfo)
void	Pop3Driver.init(Global glob, I_PluginConfig pluginConfig)
void	SmtpClient.init(Global glob, PluginInfo pluginInfo) This method is called by the PluginManager (enforced by I_Plugin).
void	Pop3Driver.init(Global glob, PluginInfo pluginInfo) This method is called by the PluginManager (enforced by I_Plugin).
java.lang.String	EmailExecutor.ping(java.lang.String qos) Ping to check if callback server is alive.
EmailData[]	Pop3Driver.readInbox(boolean clear) Read messages from mail server with POP3.
void	SmtpClient.sendEmail(EmailData emailData)
void	SmtpClient.sendEmail(EmailData emailData, java.lang.String msgIdFileName)
void	SmtpClient.sendEmail(javax.mail.internet.InternetAddress from, javax.mail.internet.InternetAddress to, java.lang.String subject, java.lang.String attachmentName, byte[] attachment, java.lang.String attachmentName2, java.lang.String attachment2, java.lang.String encoding)
java.lang.Object	EmailExecutor.sendEmail(MsgUnitRaw[] msgArr, MethodName methodName, boolean expectingResponse) This sends the update to the client.
java.lang.Object	EmailExecutor.sendEmail(MsgUnitRaw msgUnit, MethodName methodName, boolean expectingResponse)
java.lang.Object	EmailExecutor.sendEmail(java.lang.String qos, MethodName methodName, boolean expectingResponse)
java.lang.Object	EmailExecutor.sendEmail(java.lang.String key, java.lang.String qos, MethodName methodName, boolean expectingResponse)
void	SmtpClient.sendEmailAsync(EmailData emailData)
void	SmtpClient.sendEmailSync(EmailData emailData, java.lang.String msgIdFileName) Send a mail.
protected void	EmailExecutor.sendMessage(MsgInfo msgInfo, java.lang.String requestId, MethodName methodName, boolean udp) Extends RequestReplyExecutor.sendMessage
void	EmailExecutor.sendUpdateOneway(MsgUnitRaw[] msgArr) The oneway variant, without return value.
void	SmtpClient.setSessionProperties(java.util.Properties props, Global glob, I_PluginConfig pluginConfig) Set session properties and create a session.
void	Pop3Driver.setSessionProperties(java.util.Properties properties, Global glob, I_PluginConfig pluginConfig) Set session properties and create a session.

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

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

private void	SocketUrl.createInetAddress()
java.net.ServerSocket	SocketUrl.createServerSocketSSL(int backlog, AddressBase address) Helper to create a server side SSL socket, uses reflection to compile with JDK 1.3 SSL support can't be used with a standard JDK 1.3 Setup:
javax.net.ssl.SSLSocketFactory	SocketUrl.createSocketFactorySSL(AddressBase address)
private javax.net.ssl.SSLSocketFactory	SocketUrl.createSocketFactorySSLInternal(AddressBase address)
java.net.Socket	SocketUrl.createSocketSSL_OLD(SocketUrl localSocketUrl, AddressBase address) Helper to create a SSL socket, uses reflection to compile with JDK 1.3 SSL support can't be used with a standard JDK 1.3
java.net.Socket	SocketUrl.createSocketSSL(SocketUrl localSocketUrl, AddressBase address) Helper to create a SSL socket, uses reflection to compile with JDK 1.3 SSL support can't be used with a standard JDK 1.3
private void	SocketUrl.parse(java.lang.String url)
java.lang.String	SocketExecutor.ping(java.lang.String qos) Ping to check if callback server (or server protocol) is alive.
protected void	SocketExecutor.sendMessage(MsgInfo msgInfo, java.lang.String requestId, MethodName methodName, boolean udp) Flush the data to the socket.
java.lang.String[]	SocketExecutor.sendUpdate(java.lang.String cbSessionId, MsgUnitRaw[] msgArr, boolean expectingResponse, boolean useUdpForOneway, PluginInfo callbackPluginInfo) Updating multiple messages in one sweep, callback to client.

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

SocketUrl(Global glob, AddressBase address)
Extract "hostname" and "port" from environment, if not found use the local host for hostname and the default port 7607.

SocketUrl(Global glob, AddressBase address, boolean isLocal, int defaultServerPort)
Extract hostname and port from environment, if not found use the local host for hostname and the given default port (usually ExecutorBase.DEFAULT_SERVER_PORT=7607).

SocketUrl(Global glob, java.lang.String url)
Parse the given url.

SocketUrl(Global glob, java.lang.String hostname, int port)

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

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

static org.apache.xmlrpc.client.XmlRpcClient

XmlRpcClientFactory.getXmlRpcClient(Global glob, XmlRpcUrl xmlRpcUrl, AddressBase address, boolean useCDATA)

Uses of XmlBlasterException in org.xmlBlaster.util.qos

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

private I_ClientPlugin	ConnectQosData.getClientPlugin()
protected I_ClientPlugin	ConnectQosData.getClientPlugin(java.lang.String type, java.lang.String version) Load a client side security plugin (for internal use only), is needed to create the security QoS string.
java.lang.String	QosData.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
private void	ConnectQosData.initialize(Global glob)
I_ClientPlugin	ConnectQosData.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.
StatusQosData	StatusQosQuickParseFactory.readObject(java.lang.String xmlQos) Parses the given xml Qos and returns a StatusQosData holding the data.
StatusQosData	StatusQosSaxFactory.readObject(java.lang.String xmlQos) Parses the given xml Qos and returns a StatusQosData holding the data.
DisconnectQosData	DisconnectQosSaxFactory.readObject(java.lang.String xmlQos) Parses the given xml Qos and returns a DisconnectQosData holding the data.
MsgQosData	MsgQosSaxFactory.readObject(java.lang.String xmlQos) Parses the given xml Qos and returns a MsgQosData holding the data.
StatusQosData	I_StatusQosFactory.readObject(java.lang.String xmlQos) Parses the given Qos and returns a StatusQosData holding the data.
ConnectQosData	ConnectQosSaxFactory.readObject(java.lang.String xmlQos) Parses the given xml Qos and returns a ConnectQosData holding the data.
DisconnectQosData	I_DisconnectQosFactory.readObject(java.lang.String xmlQos) Parses the given Qos and returns a DisconnectQosData holding the data.
QueryQosData	QueryQosSaxFactory.readObject(java.lang.String xmlQos) Parses the given xml Qos and returns a QueryQosData holding the data.
QueryQosData	I_QueryQosFactory.readObject(java.lang.String xmlQos) Parses the given Qos and returns a QueryQosData holding the data.
ConnectQosData	I_ConnectQosFactory.readObject(java.lang.String xmlQos) Parses the given Qos and returns a ConnectQosData holding the data.
MsgQosData	I_MsgQosFactory.readObject(java.lang.String xmlQos) Parses the given Qos and returns a MsgQosData holding the data.
void	ConnectQosData.setUserId(java.lang.String userId) Allows to set or overwrite the login name for I_SecurityQos.

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

ConnectQosData(Global glob)
Constructor for client side.

ConnectQosData(Global glob, I_ConnectQosFactory factory, java.lang.String serialData, NodeId nodeId)
Constructs the specialized quality of service object for a connect() or connect-return call.

ConnectQosData(Global glob, NodeId nodeId)
Constructor for cluster server.

Uses of XmlBlasterException in org.xmlBlaster.util.queue

Methods in org.xmlBlaster.util.queue that throw XmlBlasterException

java.util.List<I_Entry>	BlockingQueueWrapper.blockingPeek(int numOfEntries, long timeout)
java.util.List<I_Entry>	BlockingQueueWrapper.blockingPeekLowest(int numOfEntries, long timeout, I_QueueEntry limitEntry)
java.util.List<I_Entry>	BlockingQueueWrapper.blockingPeekSamePriority(int numOfEntries, long timeout)
java.util.List<I_Entry>	BlockingQueueWrapper.blockingPeekWithPriority(int numOfEntries, long timeout, int minPrio, int maxPrio)
private java.util.List<I_Entry>	BlockingQueueWrapper.blockingQueueOperation(int numOfEntries, long timeout, int minPrio, int maxPrio, I_QueueEntry limitEntry, BlockingQueueWrapper.I_BlockingQueueCb cb) Blocks until at least numOfEntries are found in the queue, or the timeout has occured.
java.util.List<I_Entry>	BlockingQueueWrapper.blockingTakeLowest(int numOfEntries, long timeout, I_QueueEntry limitEntry)
java.util.List<I_Entry>	BlockingQueueWrapper.blockingTakeWithPriority(int numOfEntries, long timeout, int minPrio, int maxPrio)
I_Entry	I_EntryFactory.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	I_EntryFactory.createEntry(XBStore store, XBMeat meat, XBRef ref) Added for 2008 Queues
EventHelper	StorageEventHandler.generateEventHelper(StorageId storageId) Create an EventHelper instance which matches exactly the given storageId (no wildcards).
java.util.List<I_Entry>	I_Queue.getEntries(I_EntryFilter entryFilter) Gets a copy of the entries (e.g the messages) in the queue.
long[]	I_Queue.getEntryReferences() Gets the references of the entries in the queue.
private EventHelper	StorageEventHandler.getMatchingEvent(EventHelper helper, I_Storage storage) Check if the given storageId matches any of the wanted events.
XBMeat	I_Entry.getMeat()
I_Queue	QueuePluginManager.getPlugin(PluginInfo pluginInfo, StorageId storageId, QueuePropertyBase props)
I_Queue	QueuePluginManager.getPlugin(java.lang.String typeVersion, StorageId storageId, QueuePropertyBase props)
I_Queue	QueuePluginManager.getPlugin(java.lang.String type, java.lang.String version, StorageId storageId, QueuePropertyBase props) Return a new created (persistent) queue plugin.
void	BlockingQueueWrapper.init(I_Queue queue_)
void	I_Queue.initialize(StorageId storageId, java.lang.Object userData) Is called after the instance is created.
void	StorageEventHandler.initialRegistration(java.util.Map storageMap) Callback from StoragePluginManager on registration
I_QueueEntry	I_Queue.peek() Returns the first element in the queue but does not remove it from that queue (leaves it untouched).
java.util.List<I_Entry>	I_Queue.peek(int numOfEntries, long numOfBytes) Returns maximum the first num element in the queue but does not remove it from that queue (leaves it untouched).
java.util.List<I_Entry>	I_Queue.peekLowest(int numOfEntries, long numOfBytes, I_QueueEntry limitEntry, boolean leaveOne) Same as takeLowest but it does not remove the entries.
java.util.List<I_Entry>	I_Queue.peekSamePriority(int numOfEntries, long numOfBytes) Returns maximum the first num element in the queue of highest priority but does not remove it from that queue (leaves it untouched).
java.util.List<I_Entry>	I_Queue.peekStartAt(int numOfEntries, long numOfBytes, I_QueueEntry firstEntryExlusive) Returns maximum the first num element in the queue but does not remove it from that queue (leaves it untouched).
java.util.List<I_Entry>	I_Queue.peekWithLimitEntry(I_QueueEntry limitEntry) Deprecated. you should use directly removeWithLimitEntry
java.util.List<I_Entry>	I_Queue.peekWithPriority(int numOfEntries, long numOfBytes, int minPriority, int maxPriority) Returns maximum given number of entries from the queue (none blocking).
void	I_Queue.put(I_QueueEntry[] queueEntries, boolean ignorePutInterceptor) Puts one queue entry on top of the queue.
void	I_Queue.put(I_QueueEntry queueEntry, boolean ignorePutInterceptor) Puts one queue entry on top of the queue.
void	I_QueuePutListener.putPost(I_QueueEntry queueEntry) Called by I_Queue implementation before leaving put() and somebody has registered for such events.
void	I_QueuePutListener.putPost(I_QueueEntry[] queueEntries) Called by I_Queue implementation before leaving put() and somebody has registered for such events.
boolean	I_QueuePutListener.putPre(I_QueueEntry queueEntry) Called by I_Queue implementation when a put() is invoked and somebody has registered for such events
boolean	I_QueuePutListener.putPre(I_QueueEntry[] queueEntries) Called by I_Queue implementation when a put() is invoked and somebody has registered for such events
java.util.List<I_Entry>	BlockingQueueWrapper.I_BlockingQueueCb.queueOperation(I_Queue queue, int numEntries, long numBytes, int minPrio, int maxPrio, I_QueueEntry limitEntry)
abstract void	StorageEventHandler.registerEventType(I_EventDispatcher dispatcher, java.lang.String event) Base class fills this.eventsHelperMap
void	QueueEventHandler.registerEventType(I_EventDispatcher dispatcher, java.lang.String eventType) Is called from EventPlugin to register the configured eventTypes
void	StorageEventHandler.registerListener(I_Storage storage)
private void	QueuePluginManager.registerOrRemovePlugin(I_Storage plugin, boolean register)
int	I_Queue.remove() Removes the first element in the queue.
long	I_Queue.removeHead(I_QueueEntry toEntry) removes the head of the queue until (but not included) the entry specified as the argument.
void	StorageEventHandler.removeListeners(java.util.Map storageMap)
long	I_Queue.removeNum(long numOfEntries) Removes max num messages.
int	I_Queue.removeRandom(I_Entry entry) Removes the given entry.
boolean[]	I_Queue.removeRandom(I_Entry[] queueEntries) Removes the given entries.
long	I_Queue.removeWithLimitEntry(I_QueueEntry limitEntry, boolean inclusive) It removes the entries which are higher than the entry specified in the argument list.
long	I_Queue.removeWithPriority(long numOfEntries, long numOfBytes, int minPriority, int maxPriority) Removes max numOfEntries messages (or less depending on the numOfBytes).
boolean	QueuePluginManager.setEventHandler(java.lang.String key, StorageEventHandler handler) Set an EventHandler singleton
void	I_Queue.setProperties(java.lang.Object userData) Allows to overwrite properties which where passed on initialize() The properties which support hot configuration are depending on the used implementation
java.util.List<I_Entry>	I_Queue.takeLowest(int numOfEntries, long numOfBytes, I_QueueEntry limitEntry, boolean leaveOne) Takes entries from the back of the queue.
java.util.List<I_Entry>	I_Queue.takeWithPriority(int numOfEntries, long numOfBytes, int minPriority, int maxPriority) Takes given number of entries out of the queue.
byte[]	I_EntryFactory.toBlob(I_Entry entry) Parses the specified entry to a byte array (serializing).

Constructors in org.xmlBlaster.util.queue that throw XmlBlasterException

EventHelper(java.lang.String eventType, java.lang.String type, java.lang.String id1, java.lang.String id2, java.lang.String val, I_EventDispatcher eventDispatcher)

StorageId(Global glob, java.lang.String id)
Deprecated. Old xb_entries only

Uses of XmlBlasterException in org.xmlBlaster.util.queue.cache

Methods in org.xmlBlaster.util.queue.cache that throw XmlBlasterException

private long	CacheQueueInterceptorPlugin.checkEntriesAvailable(I_Queue queue, long valueToCheckAgainst, boolean ifFullThrowException, java.lang.String extraTxt)
private long	CacheQueueInterceptorPlugin.checkSpaceAvailable(I_Queue queue, long valueToCheckAgainst, boolean ifFullThrowException, java.lang.String extraTxt) Helper method to check the space left on a given queue.
java.util.List<I_Entry>	CacheQueueInterceptorPlugin.getEntries(I_EntryFilter entryFilter)
long[]	CacheQueueInterceptorPlugin.getEntryReferences() Gets the references of the entries in the queue.
void	CacheQueueInterceptorPlugin.initialize(StorageId uniqueQueueId, java.lang.Object userData) Is called after the instance is created.
private int	CacheQueueInterceptorPlugin.loadFromPersistence() Loads from the persistence so much data as it fits into the transient queue.
I_QueueEntry	CacheQueueInterceptorPlugin.peek()
java.util.List<I_Entry>	CacheQueueInterceptorPlugin.peek(int numOfEntries, long numOfBytes)
java.util.List<I_Entry>	CacheQueueInterceptorPlugin.peekLowest(int numOfEntries, long numOfBytes, I_QueueEntry limitEntry, boolean leaveOne) Aware: peekLowest is not implemented!!
java.util.List<I_Entry>	CacheQueueInterceptorPlugin.peekSamePriority(int numOfEntries, long numOfBytes)
java.util.List<I_Entry>	CacheQueueInterceptorPlugin.peekStartAt(int numOfEntries, long numOfBytes, I_QueueEntry firstEntryExlusive)
java.util.List<I_Entry>	CacheQueueInterceptorPlugin.peekWithLimitEntry(I_QueueEntry limitEntry) Deprecated.
java.util.List<I_Entry>	CacheQueueInterceptorPlugin.peekWithPriority(int numOfEntries, long numOfBytes, int minPriority, int maxPriority)
void	CacheQueueInterceptorPlugin.put(I_QueueEntry[] queueEntries, boolean ignorePutInterceptor) All entries are stored into the transient queue.
void	CacheQueueInterceptorPlugin.put(I_QueueEntry queueEntry, boolean ignorePutInterceptor)
int	CacheQueueInterceptorPlugin.remove() Removes the first element in the queue This method does not block.
long	CacheQueueInterceptorPlugin.removeHead(I_QueueEntry toEntry)
long	CacheQueueInterceptorPlugin.removeNum(long numOfEntries) Removes max num messages.
int	CacheQueueInterceptorPlugin.removeRandom(I_Entry entry)
boolean[]	CacheQueueInterceptorPlugin.removeRandom(I_Entry[] queueEntries)
int	CacheQueueInterceptorPlugin.removeRandom(long dataId) Removes the given entry.
long	CacheQueueInterceptorPlugin.removeRandom(long[] dataIdArray) Removes the given entries.
private boolean[]	CacheQueueInterceptorPlugin.removeRandomNoNotify(I_Entry[] queueEntries)
int	CacheQueueInterceptorPlugin.removeTransient()
long	CacheQueueInterceptorPlugin.removeWithLimitEntry(I_QueueEntry limitEntry, boolean inclusive)
long	CacheQueueInterceptorPlugin.removeWithPriority(long numOfEntries, long numOfBytes, int minPriority, int maxPriority)
void	CacheQueueInterceptorPlugin.setProperties(java.lang.Object userData)
java.util.List<I_Entry>	CacheQueueInterceptorPlugin.takeLowest(int numOfEntries, long numOfBytes, I_QueueEntry limitEntry, boolean leaveOne) Aware: takeLowest for more than one entry is not implemented!!
java.util.List<I_Entry>	CacheQueueInterceptorPlugin.takeWithPriority(int numOfEntries, long numOfBytes, int minPriority, int maxPriority)
int	CacheQueueInterceptorPlugin.update(I_QueueEntry queueEntry) Updates the given message queue entry with a new value.

Uses of XmlBlasterException in org.xmlBlaster.util.queue.jdbc

Methods in org.xmlBlaster.util.queue.jdbc with parameters of type XmlBlasterException

private void	XBDatabaseAccessorDelegate.handleException(int retryCounter, XmlBlasterException e) If we re-throw the exception we change to RESOURCE_DB_UNAVAILABLE as this triggers an immediate shutdown in Main.java newException(XmlBlasterException)
private void	CommonTableDatabaseAccessorDelegate.handleException(int retryCounter, XmlBlasterException e) If we re-throw the exception we change to RESOURCE_DB_UNAVAILABLE as this triggers an immediate shutdown in Main.java newException(XmlBlasterException)

Methods in org.xmlBlaster.util.queue.jdbc that throw XmlBlasterException

int[]	CommonTableDatabaseAccessor.addEntries(java.lang.String queueName, I_Entry[] entries) Adds several rows to the specified queue table in batch mode to improve performance
int[]	CommonTableDatabaseAccessorDelegate.addEntries(java.lang.String queueName, I_Entry[] entries)
int[]	XBDatabaseAccessorDelegate.addEntries(XBStore store, I_Entry[] entries)
int[]	XBDatabaseAccessor.addEntries(XBStore store, I_Entry[] entries) Adds several rows to the specified queue table in batch mode to improve performance
private int[]	CommonTableDatabaseAccessor.addEntriesSingleMode(java.sql.Connection conn, java.lang.String queueName, I_Entry[] entries)
private int[]	XBDatabaseAccessor.addEntriesSingleMode(java.sql.Connection conn, XBStore store, I_Entry[] entries)
boolean	CommonTableDatabaseAccessor.addEntry(java.lang.String queueName, I_Entry entry) Adds a row to the specified queue table
boolean	XBDatabaseAccessorDelegate.addEntry(XBStore store, I_Entry entry)
boolean	XBDatabaseAccessor.addEntry(XBStore store, I_Entry entry) Adds a row to the specified queue table
private boolean	CommonTableDatabaseAccessor.addSingleEntry(java.lang.String queueName, I_Entry entry, java.sql.Connection conn) Adds a row to the specified queue table
private boolean	XBDatabaseAccessor.addSingleEntry(XBStore store, I_Entry entry, java.sql.Connection conn) Adds a row to the specified queue table
I_MapEntry	JdbcQueue.change(I_MapEntry entry, I_ChangeCallback callback)
I_MapEntry	JdbcQueueCommonTablePlugin.change(I_MapEntry entry, I_ChangeCallback callback)
I_MapEntry	JdbcQueue.change(long uniqueId, I_ChangeCallback callback)
I_MapEntry	JdbcQueueCommonTablePlugin.change(long uniqueId, I_ChangeCallback callback)
int	CommonTableDatabaseAccessor.cleanUp(java.lang.String queueName) Cleans up the specified queue.
int	XBDatabaseAccessorDelegate.cleanUp(XBStore store)
int	XBDatabaseAccessor.cleanUp(XBStore store) Cleans up the specified queue.
long	XBDatabaseAccessorDelegate.clearQueue(XBStore store)
long	XBDatabaseAccessor.clearQueue(XBStore store)
void	PreparedQuery.close(boolean success) Close the connection.
private java.util.List<I_Entry>	XBDatabaseAccessor.createEntries(XBStore store, java.util.List<XBMeat> meatList, java.util.List<XBRef> refList, I_EntryFilter filter, I_Storage storage)
private I_Entry	XBDatabaseAccessor.createEntry(XBStore store, XBMeat meat, XBRef ref)
static CommonTableDatabaseAccessor	CommonTableDatabaseAccessor.createInstance(Global glob, I_EntryFactory factory, java.lang.String confType, java.lang.String confVersion, java.util.Properties properties) The Properties to use as a default are these from the QueuePlugin with the configuration name specified by defaultConfName (default is 'JDBC').
static XBDatabaseAccessor	XBDatabaseAccessor.createInstance(Global glob, java.lang.String confType, java.lang.String confVersion, java.util.Properties properties) The Properties to use as a default are these from the QueuePlugin with the configuration name specified by defaultConfName (default is 'JDBC').
int	CommonTableDatabaseAccessor.deleteAllTransient(java.lang.String queueName) deletes all transient messages
long	XBDatabaseAccessorDelegate.deleteAllTransient(XBStore store)
long	XBDatabaseAccessor.deleteAllTransient(XBStore store) deletes all transient messages
boolean[]	CommonTableDatabaseAccessor.deleteEntries(java.lang.String queueName, long[] uniqueIds) Deletes the entries specified by the entries array.
boolean[]	CommonTableDatabaseAccessorDelegate.deleteEntries(java.lang.String queueName, long[] uniqueIds) 2008-02-11 10:37:41.710 SEVERE 97-pool-1-thread-65 RL10 org.xmlBlaster.Main newException: PANIC: Doing immediate shutdown caused by exception: XmlBlasterException errorCode=[resource.db.unknown] serverSideException=true location=[JdbcManagerCommonTable.deleteEntries] message=[#16564M An unknown error with the backend database using JDBC occurred -> http://www.xmlblaster.org/xmlBlaster/doc/requirements/admin.errorcodes.listing.html#resource.db.unknown : com.microsoft.sqlserver.jdbc.SQLServerException: Transaction (Process ID 76) was deadlocked on lock | communication buffer resources with another process and has been chosen as the deadlock victim.
int	XBDatabaseAccessorDelegate.deleteEntries(XBStore store, long refId, long meatId)
long	XBDatabaseAccessorDelegate.deleteEntries(XBStore store, XBRef[] refs, XBMeat[] meats)
long	XBDatabaseAccessor.deleteEntries(XBStore store, XBRef[] refs, XBMeat[] meats) Deletes the entries specified by the entries array.
private boolean[]	CommonTableDatabaseAccessor.deleteEntriesNoSplit(java.lang.String queueName, long[] uniqueIds)
int	CommonTableDatabaseAccessor.deleteEntry(java.lang.String queueName, long uniqueId) Deletes the entry specified
int	XBDatabaseAccessor.deleteEntry(XBStore store, long refId, long meatId) Deletes the entry specified
ReturnDataHolder	CommonTableDatabaseAccessor.deleteFirstEntries(java.lang.String queueName, long numOfEntries, long amount) Deletes number of entries specified by the argument list.
long	XBDatabaseAccessorDelegate.deleteFirstRefs(XBStore store, long numOfEntries)
long	XBDatabaseAccessor.deleteFirstRefs(XBStore store, long numOfEntries) Deletes number of entries specified by the argument list.
void	XBDatabaseAccessorDelegate.deleteStore(long storeId)
void	XBDatabaseAccessor.deleteStore(long storeId) Deletes the store.
void	JdbcQueue.destroy() Cleans up the current queue (it deletes all the entries and frees the table used and cleans up all tables in the database).
void	JdbcQueueCommonTablePlugin.destroy() Cleans up the current queue (it deletes all the entries and frees the table used and cleans up all tables in the database).
void	JdbcConnectionPool.discardConnection(java.sql.Connection conn) Discards the passed connection from the pool and instead adds a new fresh connection to the pool.
protected void	XBDatabaseAccessor.QueueGlobalInfo.doInit(Global glob, PluginInfo plugInfo)
protected void	XBDatabaseAccessorDelegate.doInit(I_Info info)
protected void	XBRefFactory.doInit(I_Info info)
protected void	XBDatabaseAccessor.doInit(I_Info info)
protected abstract void	XBFactoryBase.doInit(I_Info info)
private java.sql.Connection	JdbcConnectionPool.get(long delay) returns null if no connection available
I_MapEntry	JdbcQueue.get(long uniqueId)
I_MapEntry	JdbcQueueCommonTablePlugin.get(long uniqueId)
I_MapEntry[]	JdbcQueue.getAll(I_EntryFilter entryFilter)
I_MapEntry[]	JdbcQueueCommonTablePlugin.getAll(I_EntryFilter entryFilter)
java.util.List<XBStore>	XBDatabaseAccessor.getAllOfType(java.lang.String node, java.lang.String type)
ReturnDataHolder	CommonTableDatabaseAccessor.getAndDeleteLowest(StorageId storageId, int numOfEntries, long numOfBytes, int maxPriority, long minUniqueId, boolean leaveOne, boolean doDelete) Under the same transaction it gets and deletes all the entries which fit into the constrains specified in the argument list.
ReturnDataHolder	XBDatabaseAccessorDelegate.getAndDeleteLowest(XBStore store, int numOfEntries, long numOfBytes, int maxPriority, long minUniqueId, boolean leaveOne, boolean doDelete, I_Storage storage)
ReturnDataHolder	XBDatabaseAccessor.getAndDeleteLowest(XBStore store, int numOfEntries, long numOfBytes, int maxPriority, long minUniqueId, boolean leaveOne, boolean doDelete, I_Storage storage) Under the same transaction it gets and deletes all the entries which fit into the constrains specified in the argument list.
java.sql.Connection	JdbcConnectionPool.getConnection() Returns a free connection.
java.util.ArrayList	JdbcQueue.getEntries(I_EntryFilter entryFilter)
java.util.ArrayList	JdbcQueueCommonTablePlugin.getEntries(I_EntryFilter entryFilter)
java.util.ArrayList	CommonTableDatabaseAccessor.getEntries(StorageId storageId, int numOfEntries, long numOfBytes, I_EntryFilter entryFilter) gets the first numOfEntries of the queue.
java.util.ArrayList	CommonTableDatabaseAccessorDelegate.getEntries(StorageId storageId, int numOfEntries, long numOfBytes, I_EntryFilter entryFilter)
java.util.ArrayList	CommonTableDatabaseAccessor.getEntries(StorageId storageId, long[] dataids) gets all the entries which have the dataid specified in the argument list.
java.util.List<I_Entry>	XBDatabaseAccessorDelegate.getEntries(XBStore store, int numOfEntries, long numOfBytes, I_EntryFilter entryFilter, boolean isRef, I_Storage storage)
java.util.List<I_Entry>	XBDatabaseAccessor.getEntries(XBStore store, int numOfEntries, long numOfBytes, I_EntryFilter entryFilter, boolean isRef, I_Storage storage) gets the first numOfEntries of the queue.
java.util.List<I_Entry>	XBDatabaseAccessorDelegate.getEntries(XBStore store, XBRef[] refs, XBMeat[] meats)
java.util.List<I_Entry>	XBDatabaseAccessor.getEntries(XBStore store, XBRef[] refs, XBMeat[] meats) gets all the entries which have the dataid specified in the argument list.
java.util.ArrayList	CommonTableDatabaseAccessor.getEntriesByPriority(StorageId storageId, int numOfEntries, long numOfBytes, int minPrio, int maxPrio, I_EntryFilter entryFilter) gets the first numOfEntries of the queue which have the priority in the range specified by prioMin and prioMax (inclusive).
java.util.List<I_Entry>	XBDatabaseAccessorDelegate.getEntriesByPriority(XBStore store, int numOfEntries, long numOfBytes, int minPrio, int maxPrio)
java.util.List<I_Entry>	XBDatabaseAccessor.getEntriesByPriority(XBStore store, int numOfEntries, long numOfBytes, int minPrio, int maxPrio) gets the first numOfEntries of the queue which have the priority in the range specified by prioMin and prioMax (inclusive).
java.util.ArrayList	CommonTableDatabaseAccessor.getEntriesBySamePriority(StorageId storageId, int numOfEntries, long numOfBytes) gets the first numOfEntries of the queue which have the same priority.
java.util.List<I_Entry>	XBDatabaseAccessorDelegate.getEntriesBySamePriority(XBStore store, int numOfEntries, long numOfBytes)
java.util.List<I_Entry>	XBDatabaseAccessor.getEntriesBySamePriority(XBStore store, int numOfEntries, long numOfBytes) gets the first numOfEntries of the queue which have the same priority.
XBEntry[]	XBDatabaseAccessorDelegate.getEntriesLike(java.lang.String queueNamePattern, java.lang.String flag, int numOfEntries, long numOfBytes, I_EntryFilter entryFilter)
XBEntry[]	XBDatabaseAccessor.getEntriesLike(java.lang.String queueNamePattern, java.lang.String flag, int numOfEntries, long numOfBytes, I_EntryFilter entryFilter) Raw access to the table.
java.util.ArrayList	CommonTableDatabaseAccessor.getEntriesLike(java.lang.String queueNamePattern, java.lang.String flag, int numOfEntries, long numOfBytes, I_EntryFilter entryFilter) Raw access to the table.
java.util.ArrayList	CommonTableDatabaseAccessor.getEntriesWithLimit(StorageId storageId, I_Entry limitEntry) gets the first numOfEntries of the queue until the limitEntry is reached.
java.util.List<I_Entry>	XBDatabaseAccessorDelegate.getEntriesWithLimit(XBStore store, I_Entry limitEntry, I_Storage storage)
java.util.List<I_Entry>	XBDatabaseAccessor.getEntriesWithLimit(XBStore store, I_Entry limitEntry, I_Storage storage) gets the first numOfEntries of the queue until the limitEntry is reached.
long[]	JdbcQueue.getEntryReferences() Gets the references of the entries in the queue.
long[]	JdbcQueueCommonTablePlugin.getEntryReferences() Gets the references of the entries in the queue.
protected XBDatabaseAccessor	JdbcQueue.getFactory(PluginInfo plugInfo) Returns the factory for a specific queue.
protected CommonTableDatabaseAccessor	JdbcQueueCommonTablePlugin.getJdbcQueueManagerCommonTable(PluginInfo pluginInfo) Returns a JdbcManagerCommonTable for a specific queue.
EntryCount	CommonTableDatabaseAccessor.getNumOfAll(java.lang.String queueName) Gets the real number of entries.
EntryCount	XBDatabaseAccessorDelegate.getNumOfAll(XBStore store)
EntryCount	XBDatabaseAccessor.getNumOfAll(XBStore store) Gets the real number of entries.
private long	JdbcQueue.getNumOfBytes_() It returns the size of the queue.
private long	JdbcQueueCommonTablePlugin.getNumOfBytes_() It returns the size of the queue.
long	CommonTableDatabaseAccessor.getNumOfBytes(java.lang.String queueName) Deprecated. Use CommonTableDatabaseAccessor.getNumOfAll(String)
private long	JdbcQueue.getNumOfEntries_() It returns the size of the queue.
private long	JdbcQueueCommonTablePlugin.getNumOfEntries_() It returns the size of the queue.
long	CommonTableDatabaseAccessor.getNumOfEntries(java.lang.String queueName) Deprecated. Use CommonTableDatabaseAccessor.getNumOfAll(String)
private long	JdbcQueue.getNumOfPersistentBytes_(boolean verbose) It returns the number of persistent entries in the queue.
private long	JdbcQueueCommonTablePlugin.getNumOfPersistentBytes_(boolean verbose) It returns the number of persistent entries in the queue.
private long	JdbcQueue.getNumOfPersistentEntries_(boolean verbose) It returns the number of persistent entries in the queue.
private long	JdbcQueueCommonTablePlugin.getNumOfPersistentEntries_(boolean verbose) It returns the number of persistent entries in the queue.
long	CommonTableDatabaseAccessor.getNumOfPersistents(java.lang.String queueName) Deprecated. Use CommonTableDatabaseAccessor.getNumOfAll(String)
java.util.List<I_Entry>	XBDatabaseAccessorDelegate.getRefEntries(XBStore store, int numOfEntries, long numOfBytes, I_EntryFilter entryFilter, I_Storage storage, I_QueueEntry firstEntryExlusive)
java.util.List<I_Entry>	XBDatabaseAccessor.getRefEntries(XBStore store, int numOfEntries, long numOfBytes, I_EntryFilter entryFilter, I_Storage storage, I_QueueEntry firstEntryExlusive)
long	CommonTableDatabaseAccessor.getSizeOfPersistents(java.lang.String queueName) Deprecated. Use CommonTableDatabaseAccessor.getNumOfAll(String) Replaced all four selects with one: "select count(*), sum(byteSize), durable from XB_ENTRIES WHERE queueName='history_xmlBlaster_192_168_1_4_3412Hello' GROUP BY durable;"
XBStore	XBDatabaseAccessor.getXBStore(StorageId uniqueQueueId)
private void	XBDatabaseAccessorDelegate.handleException(int retryCounter, XmlBlasterException e) If we re-throw the exception we change to RESOURCE_DB_UNAVAILABLE as this triggers an immediate shutdown in Main.java newException(XmlBlasterException)
private void	CommonTableDatabaseAccessorDelegate.handleException(int retryCounter, XmlBlasterException e) If we re-throw the exception we change to RESOURCE_DB_UNAVAILABLE as this triggers an immediate shutdown in Main.java newException(XmlBlasterException)
I_Info	XBDatabaseAccessor.init(I_Info origInfo)
I_Info	XBFactoryBase.init(I_Info origInfo)
I_Info	XBFactory.init(I_Info origInfo)
protected boolean	XBDatabaseAccessor.initFactory(Global global, PluginInfo plugInfo)
void	JdbcConnectionPool.initialize(Global glob, java.util.Properties pluginProperties) Is called after the instance is created.
void	JdbcQueue.initialize(StorageId uniqueQueueId, java.lang.Object userData) Is called after the instance is created.
void	JdbcQueueCommonTablePlugin.initialize(StorageId uniqueQueueId, java.lang.Object userData) Is called after the instance is created.
java.sql.ResultSet	PreparedQuery.inTransactionRequest(java.lang.String request)
long	CommonTableDatabaseAccessor.modifyEntry(java.lang.String queueName, I_Entry entry, I_Entry oldEntry) modifies a row in the specified queue table
long	CommonTableDatabaseAccessorDelegate.modifyEntry(java.lang.String queueName, I_Entry entry, I_Entry oldEntry)
long	XBDatabaseAccessorDelegate.modifyEntry(XBStore store, XBMeat entry, XBMeat oldEntry, boolean onlyRefCounters)
long	XBDatabaseAccessor.modifyEntry(XBStore store, XBMeat entry, XBMeat oldEntry, boolean onlyRefCounters) modifies a row in the specified queue table
private java.util.Hashtable<java.lang.String,java.lang.String>	JdbcConnectionPool.parseMapping(Property prop) This method is used in the init method
I_QueueEntry	JdbcQueue.peek()
I_QueueEntry	JdbcQueueCommonTablePlugin.peek()
java.util.ArrayList	JdbcQueue.peek(int numEntries, long numBytes)
java.util.ArrayList	JdbcQueueCommonTablePlugin.peek(int numOfEntries, long numOfBytes)
java.util.ArrayList	JdbcQueue.peekLowest(int numEntries, long numBytes, I_QueueEntry limitEntry, boolean leaveOne)
java.util.ArrayList	JdbcQueueCommonTablePlugin.peekLowest(int numOfEntries, long numOfBytes, I_QueueEntry limitEntry, boolean leaveOne)
java.util.ArrayList	JdbcQueue.peekSamePriority(int numEntries, long numBytes)
java.util.ArrayList	JdbcQueueCommonTablePlugin.peekSamePriority(int numOfEntries, long numOfBytes)
java.util.ArrayList	JdbcQueue.peekStartAt(int numOfEntries, long numOfBytes, I_QueueEntry firstEntryExlusive)
java.util.ArrayList	JdbcQueueCommonTablePlugin.peekStartAt(int numOfEntries, long numOfBytes, I_QueueEntry firstEntryExlusive)
java.util.ArrayList	JdbcQueue.peekWithLimitEntry(I_QueueEntry limitEntry) Deprecated.
java.util.ArrayList	JdbcQueueCommonTablePlugin.peekWithLimitEntry(I_QueueEntry limitEntry) Deprecated.
java.util.ArrayList	JdbcQueue.peekWithPriority(int numEntries, long numBytes, int minPriority, int maxPriority)
java.util.ArrayList	JdbcQueueCommonTablePlugin.peekWithPriority(int numOfEntries, long numOfBytes, int minPriority, int maxPriority)
private java.util.ArrayList	CommonTableDatabaseAccessor.processResultSet(java.sql.ResultSet rs, StorageId storageIdDefault, int numOfEntries, long numOfBytes, boolean onlyId, I_EntryFilter entryFilter)
private ReturnDataHolder	CommonTableDatabaseAccessor.processResultSetForDeleting(java.sql.ResultSet rs, int numOfEntries, long numOfBytes, java.util.List<java.lang.Long> retL) It accepts result sets with (long dataId, long size)
private boolean	JdbcConnectionPool.put(java.sql.Connection conn)
private boolean	JdbcQueue.put(I_Entry entry) Internally used for I_MapEntry and I_QueueEntry
private boolean	JdbcQueueCommonTablePlugin.put(I_Entry entry) Internally used for I_MapEntry and I_QueueEntry
int	JdbcQueue.put(I_MapEntry mapEntry)
int	JdbcQueueCommonTablePlugin.put(I_MapEntry mapEntry)
void	JdbcQueue.put(I_QueueEntry[] queueEntries, boolean ignorePutInterceptor)
void	JdbcQueueCommonTablePlugin.put(I_QueueEntry[] queueEntries, boolean ignorePutInterceptor)
void	JdbcQueue.put(I_QueueEntry queueEntry, boolean ignorePutInterceptor)
void	JdbcQueueCommonTablePlugin.put(I_QueueEntry queueEntry, boolean ignorePutInterceptor)
private void	JdbcConnectionPool.releaseConnection(java.sql.Connection conn) Used to give back a connection to the pool.
void	JdbcConnectionPool.releaseConnection(java.sql.Connection conn, boolean success) Used to give back a connection to the pool.
private void	XBDatabaseAccessor.releaseConnection(java.sql.Connection conn, boolean success, java.lang.String msg)
int	JdbcQueue.remove() Removes the first element in the queue This method does not block.
int	JdbcQueueCommonTablePlugin.remove() Removes the first element in the queue This method does not block.
int	JdbcQueue.remove(I_MapEntry mapEntry)
int	JdbcQueueCommonTablePlugin.remove(I_MapEntry mapEntry)
int	JdbcQueue.remove(long uniqueId) This method is always invoked with the I_Map interface
int	JdbcQueueCommonTablePlugin.remove(long uniqueId)
long	CommonTableDatabaseAccessor.removeEntriesWithLimit(StorageId storageId, I_Entry limitEntry, boolean inclusive) deletes the first numOfEntries of the queue until the limitEntry is reached.
long	XBDatabaseAccessorDelegate.removeEntriesWithLimit(XBStore store, XBRef limitEntry, boolean inclusive)
long	XBDatabaseAccessor.removeEntriesWithLimit(XBStore store, XBRef limitEntry, boolean inclusive) deletes the first numOfEntries of the queue until the limitEntry is reached.
long	JdbcQueue.removeHead(I_QueueEntry toEntry)
long	JdbcQueueCommonTablePlugin.removeHead(I_QueueEntry toEntry)
long	JdbcQueue.removeNum(long numEntries) Removes max numOfEntries messages.
long	JdbcQueueCommonTablePlugin.removeNum(long numOfEntries) Removes max numOfEntries messages.
I_MapEntry	JdbcQueue.removeOldest()
I_MapEntry	JdbcQueueCommonTablePlugin.removeOldest()
int	JdbcQueue.removeRandom(I_Entry entry)
int	JdbcQueueCommonTablePlugin.removeRandom(I_Entry entry)
boolean[]	JdbcQueue.removeRandom(I_Entry[] queueEntries)
boolean[]	JdbcQueueCommonTablePlugin.removeRandom(I_Entry[] queueEntries)
int	JdbcQueue.removeRandom(long dataId) Removes the given entry.
int	JdbcQueueCommonTablePlugin.removeRandom(long dataId) Removes the given entry.
boolean[]	JdbcQueue.removeRandom(long[] dataIdArray) Removes the given entries.
boolean[]	JdbcQueueCommonTablePlugin.removeRandom(long[] dataIdArray) Removes the given entries.
long	JdbcQueue.removeWithLimitEntry(I_QueueEntry limitEntry, boolean inclusive)
long	JdbcQueueCommonTablePlugin.removeWithLimitEntry(I_QueueEntry limitEntry, boolean inclusive)
long	JdbcQueue.removeWithPriority(long numEntries, long numBytes, int minPriority, int maxPriority)
long	JdbcQueueCommonTablePlugin.removeWithPriority(long numOfEntries, long numOfBytes, int minPriority, int maxPriority)
void	JdbcQueue.setProperties(java.lang.Object userData)
void	JdbcQueueCommonTablePlugin.setProperties(java.lang.Object userData)
void	CommonTableDatabaseAccessor.setUp() Sets up a table for the queue specified by this queue name.
void	XBDatabaseAccessor.setUp(boolean deleteAllTransients) Sets up a table for the queue specified by this queue name.
boolean	CommonTableDatabaseAccessor.tablesCheckAndSetup(boolean createTables) Checks if all necessary tables exist.
I_QueueEntry	JdbcQueue.take() Currently not supported by I_Queue.
I_QueueEntry	JdbcQueueCommonTablePlugin.take() Currently not supported by I_Queue.
java.util.ArrayList	JdbcQueue.take(int numEntries, long numBytes) Currently not supported by I_Queue.
java.util.ArrayList	JdbcQueueCommonTablePlugin.take(int numOfEntries, long numOfBytes) Currently not supported by I_Queue.
java.util.ArrayList	JdbcQueue.takeLowest(int numEntries, long numBytes, I_QueueEntry limitEntry, boolean leaveOne)
java.util.ArrayList	JdbcQueueCommonTablePlugin.takeLowest(int numOfEntries, long numOfBytes, I_QueueEntry limitEntry, boolean leaveOne)
java.util.ArrayList	JdbcQueue.takeWithPriority(int numOfEntries, long numOfBytes, int minPriority, int maxPriority)
java.util.ArrayList	JdbcQueueCommonTablePlugin.takeWithPriority(int numOfEntries, long numOfBytes, int minPriority, int maxPriority)
private void	XBDatabaseAccessor.throwXblEx(java.lang.Throwable origEx, ErrorCode errCode, java.lang.String msg)
int	JdbcQueue.update(I_QueueEntry queueEntry) Updates the given message queue entry with a new value.
int	JdbcQueueCommonTablePlugin.update(I_QueueEntry queueEntry) Updates the given message queue entry with a new value.
private int	CommonTableDatabaseAccessor.update(java.lang.String request) A generic invocation for a simple update on the database.
void	JdbcQueue.updateCounters(I_MapEntry entry)
void	JdbcQueueCommonTablePlugin.updateCounters(I_MapEntry entry)
int	XBDatabaseAccessorDelegate.wipeOutDB(boolean doSetupNewTables)
int	XBDatabaseAccessor.wipeOutDB(boolean doSetupNewTables) Wipes out the entire DB.
int	CommonTableDatabaseAccessor.wipeOutDB(boolean doSetupNewTables) Wipes out the entire DB.
static void	XBDatabaseAccessor.wipeOutDB(Global glob, java.lang.String confType, java.lang.String confVersion, java.util.Properties properties, boolean setupNewTables) wipes out the db.
static void	CommonTableDatabaseAccessor.wipeOutDB(Global glob, java.lang.String confType, java.lang.String confVersion, java.util.Properties properties, boolean setupNewTables) wipes out the db.

Constructors in org.xmlBlaster.util.queue.jdbc that throw XmlBlasterException

CommonTableDatabaseAccessor(JdbcConnectionPool pool, I_EntryFactory factory, java.lang.String managerName, I_Storage storage)

CommonTableDatabaseAccessorDelegate(JdbcConnectionPool pool, I_EntryFactory factory, java.lang.String managerName, I_Storage storage)

PreparedQuery(JdbcConnectionPool pool, java.lang.String request, boolean isAutoCommit, int fetchSize)
This constructor can be used if you want to have several invocations whitin the same transaction.

PreparedQuery(JdbcConnectionPool pool, java.lang.String request, int fetchSize)

Uses of XmlBlasterException in org.xmlBlaster.util.queue.ram

Methods in org.xmlBlaster.util.queue.ram that throw XmlBlasterException

void	RamQueuePlugin.destroy() destroys silently all the resources associated to this queue.
private ReturnDataHolder	RamQueuePlugin.genericPeek(int numOfEntries, long numOfBytes, int minPrio, int maxPrio)
java.util.ArrayList	RamQueuePlugin.getEntries(I_EntryFilter entryFilter) Gets a copy of the entries (the messages) in the queue.
long[]	RamQueuePlugin.getEntryReferences() Gets the references of the messages in the queue.
void	RamQueuePlugin.initialize(StorageId uniqueQueueId, java.lang.Object userData) Is called after the instance is created.
java.util.ArrayList	RamQueuePlugin.peek(int numOfEntries, long numOfBytes)
java.util.ArrayList	RamQueuePlugin.peekLowest(int numOfEntries, long numOfBytes, I_QueueEntry limitEntry, boolean leaveOne)
java.util.ArrayList	RamQueuePlugin.peekSamePriority(int numOfEntries, long numOfBytes)
java.util.ArrayList	RamQueuePlugin.peekStartAt(int numOfEntries, long numOfBytes, I_QueueEntry firstEntryExlusive)
java.util.ArrayList	RamQueuePlugin.peekWithLimitEntry(I_QueueEntry limitEntry) Deprecated.
java.util.ArrayList	RamQueuePlugin.peekWithPriority(int numOfEntries, long numOfBytes, int minPrio, int maxPrio)
void	RamQueuePlugin.put(I_QueueEntry[] msgArr, boolean ignorePutInterceptor) Put messages into the queue, blocks if take thread blocks synchronize
void	RamQueuePlugin.put(I_QueueEntry entry, boolean ignorePutInterceptor) Put a message into the queue, blocks if take thread blocks synchronize
int	RamQueuePlugin.remove()
long	RamQueuePlugin.removeHead(I_QueueEntry toEntry)
long	RamQueuePlugin.removeNum(long numOfEntries)
int	RamQueuePlugin.removeRandom(I_Entry entry)
boolean[]	RamQueuePlugin.removeRandom(I_Entry[] queueEntries)
int	RamQueuePlugin.removeTransient()
long	RamQueuePlugin.removeWithLimitEntry(I_QueueEntry limitEntry, boolean inclusive)
long	RamQueuePlugin.removeWithPriority(long numOfEntries, long numOfBytes, int minPriority, int maxPriority)
void	RamQueuePlugin.setProperties(java.lang.Object userData) Allows to overwrite properties which where passed on initialize().
I_QueueEntry	RamQueuePlugin.take() Currently NOT supported by I_Queue.
java.util.ArrayList	RamQueuePlugin.take(int numOfEntries, long numOfBytes) Currently NOT supported by I_Queue.
java.util.ArrayList	RamQueuePlugin.takeLowest(int numOfEntries, long numOfBytes, I_QueueEntry limitEntry, boolean leaveOne)
private java.util.ArrayList	RamQueuePlugin.takeOrPeekLowest(int numOfEntries, long numOfBytes, I_QueueEntry limitEntry, boolean leaveOne, boolean doDelete)
java.util.ArrayList	RamQueuePlugin.takeSamePriority(int numOfEntries, long numOfBytes)
java.util.ArrayList	RamQueuePlugin.takeWithPriority(int numOfEntries, long numOfBytes, int minPriority, int maxPriority)

Uses of XmlBlasterException in org.xmlBlaster.util.queuemsg

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

XBMeat	MsgQueueEntry.getMeat() For the new queues
MsgUnit	DummyEntry.getMsgUnit()
abstract MsgUnit	MsgQueueEntry.getMsgUnit()

Uses of XmlBlasterException in org.xmlBlaster.util.servlet

Methods in org.xmlBlaster.util.servlet that throw XmlBlasterException

(package private) static org.xml.sax.Parser	ReqBaseServlet.createParser()
com.jclark.xsl.sax.XSLProcessorImpl	ReqBaseServlet.getStylesheet(java.lang.String reqDir, java.lang.String xslFile)

Uses of XmlBlasterException in org.xmlBlaster.util.xbformat

Methods in org.xmlBlaster.util.xbformat that return XmlBlasterException

XmlBlasterException

MsgInfo.getException() On errors.

Methods in org.xmlBlaster.util.xbformat with parameters of type XmlBlasterException

void	MsgInfo.addException(XmlBlasterException e) Use for exception message NOTE: Exceptions don't return

Methods in org.xmlBlaster.util.xbformat that throw XmlBlasterException

void	MsgInfo.addException(XmlBlasterException e) Use for exception message NOTE: Exceptions don't return
void	MsgInfo.addKeyAndQos(java.lang.String key, java.lang.String qos) Use for methods get, subscribe, unSubscribe, erase
void	MsgInfo.addMessage(java.lang.String qos) Add a QoS value, use for methods connect, disconnect, ping.
void	MsgInfo.addMessage(java.lang.String[] qos) Add a QoS array value.
void	MsgInfo.addQos(java.lang.String[] qos)
byte[]	MsgInfo.createRawMsg() Access the serialized message, ready to send over the wire.
byte[]	XbfParser.createRawMsg(MsgInfo msgInfo) Returns a raw data string.
byte[]	XmlScriptParser.createRawMsg(MsgInfo msgInfo) Returns a XML data string.
byte[]	I_MsgInfoParser.createRawMsg(MsgInfo msgInfo) Dumps the given MsgInfo to a byte array
byte[]	MsgInfo.createRawMsg(java.lang.String className) Access the serialized message, ready to send over the wire.
boolean	XmlScriptParser.fireMethod(MethodName methodName, java.lang.String sessionId, java.lang.String requestId, byte type) Called during XML parsing.
I_MsgInfoParser	MsgInfoParserFactory.getMsgInfoParser(Global glob, I_ProgressListener progressListener, java.lang.String className, I_PluginConfig pluginConfig) Create a new parser instance.
I_MsgInfoParser	MsgInfo.getMsgInfoParser(java.lang.String className, I_PluginConfig pluginConfig) Note this method gets (returns) the associated I_MsgInfoParser if it was not initialized before.
void	XmlScriptParser.init(Global glob, I_ProgressListener progressListener, I_PluginConfig pluginConfig)
void	I_MsgInfoParser.init(Global glob, I_ProgressListener progressListener, I_PluginConfig pluginConfig) Is guaranteed to be called by the MsgInfoParserFactory after construction.
static MsgInfo[]	MsgInfo.parse(Global glob, I_ProgressListener progressListener, byte[] rawMsg, java.lang.String className, I_PluginConfig pluginConfig) Convenience method.
static MsgInfo[]	MsgInfo.parse(Global glob, I_ProgressListener progressListener, java.io.InputStream in, java.lang.String className, I_PluginConfig pluginConfig) Convenience method.
MsgInfo[]	XmlScriptParser.parse(java.io.InputStream in) This parses the raw message from an InputStream (typically from a email or a socket).
MsgInfo[]	I_MsgInfoParser.parse(java.io.InputStream in) Parses a serialized message from input stream
void	MsgInfo.setMsgInfoParser(java.lang.String className)
void	XmlScriptParser.setProperty(java.lang.String key, java.lang.String value) Called during XML parsing.
java.lang.String	MsgInfo.toLiteral() Get the raw messages as a string, for tests and for dumping only
static java.lang.String	MsgInfo.toLiteral(byte[] rawMsg)
java.lang.String	XbfParser.toLiteral(MsgInfo msgInfo) Get the raw messages as a string, for tests and for dumping only
java.lang.String	XmlScriptParser.toLiteral(MsgInfo msgInfo) Get the raw messages as a string, for tests and for dumping only
java.lang.String	I_MsgInfoParser.toLiteral(MsgInfo msgInfo) Get the raw messages as a string, for tests and for dumping only.

Constructors in org.xmlBlaster.util.xbformat that throw XmlBlasterException

MsgInfo(Global glob, byte type, MethodName methodName, java.lang.String sessionId, I_ProgressListener progressListener, java.lang.String msgInfoParserClassName)