xmlBlaster 2.2.0 client API

Uses of Class
org.xmlBlaster.util.XmlBlasterException

Packages that use XmlBlasterException
javaclients Java examples, start reading the HelloWorld clients. 
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.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.xbformat   
 

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

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
 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)
           
 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)
           
 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.
 org.xmlBlaster.authentication.plugins.I_ClientPlugin PluginLoader.getClientPlugin(java.lang.String mechanism, java.lang.String version)
          Load another plugin.
 org.xmlBlaster.authentication.plugins.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()
           
 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.
 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.
 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.
 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.
 int StreamingCallback.sendInitialQueueEntries()
           
 void XmlBlasterAccess.setCallbackDispatcherActive(boolean activate)
           
 void I_XmlBlasterAccess.setCallbackDispatcherActive(boolean activate)
          Switch callback dispatcher on/off.
 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.
 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)
           
 

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
 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
 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
 java.lang.String ClientDispatchConnection.doPing(java.lang.String data)
           
 void ClientDispatchConnection.doSend(MsgQueueEntry[] msgArr_, boolean isAsyncMode)
          Send the messages to xmlBlaster.
 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.
 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.
 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, org.xmlBlaster.authentication.plugins.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
 byte[] DirectoryManager.getContent(FileInfo info)
          Gets the content from the specified file as a byte[].
 void Publisher.init()
          Connects to the xmlBlaster.
 void FilePollerPlugin.init(Global global, PluginInfo pluginInfo)
           
 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)
           
 java.lang.String[] CorbaConnection.erase(java.lang.String xmlKey, java.lang.String qos)
           
 MsgUnitRaw[] CorbaConnection.get(java.lang.String xmlKey, java.lang.String qos)
           
 org.xmlBlaster.protocol.corba.authenticateIdl.AuthServer CorbaConnection.getAuthenticationService(Address address)
          Access the authentication service.
 java.lang.String CorbaCallbackServer.getCbAddress()
           
 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
 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(org.xmlBlaster.protocol.rmi.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()
           
 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.
 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)
           
 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.
 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.
 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
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
 org.xmlBlaster.authentication.plugins.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)
           
 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
 

Uses of XmlBlasterException in org.xmlBlaster.util
 

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)
           
 boolean Global.isRegisteredMBean(ContextNode ctxNode)
           
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
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)
           
 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)
           
 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()
           
 

Uses of XmlBlasterException in org.xmlBlaster.util.dispatch
 

Methods in org.xmlBlaster.util.dispatch with parameters of type XmlBlasterException
 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
 void I_ConnectionStatusListener.toDead(I_DispatchManager dispatchManager, ConnectionStateEnum oldState, XmlBlasterException xmlBlasterException)
           
 void I_DispatchManager.toDead(XmlBlasterException ex)
           
 

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.
 void PriorizedDispatchPlugin.postHandleNextMessages(I_DispatchManager dispatchManager, MsgUnit[] processedEntries)
          Not doing anything in this method since no cleanup needed.
 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.
 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
 

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
 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.
 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.
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.
 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.
 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.
 java.util.Properties Property.loadProps(Property.FileInfo info, java.util.Properties argsProps)
          Use this method only the first time to initialize everything.
 java.lang.String Property.replaceVariableNoException(java.lang.String key, java.lang.String value)
          Replace dynamic variables, e.g.
 java.lang.String Property.replaceVariableWithException(java.lang.String key, java.lang.String value)
          Replace dynamic variables, e.g.
 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, org.xmlBlaster.protocol.corba.serverIdl.XmlBlasterException eCorba)
          Converts the internal CORBA XmlBlasterException to the util.XmlBlasterException.
 

Methods in org.xmlBlaster.util.protocol.corba with parameters of type XmlBlasterException
static org.xmlBlaster.protocol.corba.serverIdl.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, org.xmlBlaster.protocol.corba.serverIdl.MessageUnit mu)
          Converts the internal CORBA message unit to the internal representation.
static MsgUnitRaw[] OrbInstanceFactory.convert(Global glob, org.xmlBlaster.protocol.corba.serverIdl.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)
           
 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.
 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
 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)
           
 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
 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, org.xmlBlaster.protocol.xmlrpc.XmlRpcUrl xmlRpcUrl, AddressBase address, boolean useCDATA)
           
 

Uses of XmlBlasterException in org.xmlBlaster.util.qos
 

Methods in org.xmlBlaster.util.qos that throw XmlBlasterException
protected  org.xmlBlaster.authentication.plugins.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
 org.xmlBlaster.authentication.plugins.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)
           
 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.
 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)
           
 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
 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.
 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.
 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 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
 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
 org.xmlBlaster.engine.msgstore.I_MapEntry JdbcQueue.change(org.xmlBlaster.engine.msgstore.I_MapEntry entry, org.xmlBlaster.engine.msgstore.I_ChangeCallback callback)
           
 org.xmlBlaster.engine.msgstore.I_MapEntry JdbcQueueCommonTablePlugin.change(org.xmlBlaster.engine.msgstore.I_MapEntry entry, org.xmlBlaster.engine.msgstore.I_ChangeCallback callback)
           
 org.xmlBlaster.engine.msgstore.I_MapEntry JdbcQueue.change(long uniqueId, org.xmlBlaster.engine.msgstore.I_ChangeCallback callback)
           
 org.xmlBlaster.engine.msgstore.I_MapEntry JdbcQueueCommonTablePlugin.change(long uniqueId, org.xmlBlaster.engine.msgstore.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)
           
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.
 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 XBDatabaseAccessorDelegate.doInit(org.xmlBlaster.contrib.I_Info info)
           
protected  void XBRefFactory.doInit(org.xmlBlaster.contrib.I_Info info)
           
protected  void XBDatabaseAccessor.doInit(org.xmlBlaster.contrib.I_Info info)
           
protected abstract  void XBFactoryBase.doInit(org.xmlBlaster.contrib.I_Info info)
           
 org.xmlBlaster.engine.msgstore.I_MapEntry JdbcQueue.get(long uniqueId)
           
 org.xmlBlaster.engine.msgstore.I_MapEntry JdbcQueueCommonTablePlugin.get(long uniqueId)
           
 org.xmlBlaster.engine.msgstore.I_MapEntry[] JdbcQueue.getAll(I_EntryFilter entryFilter)
           
 org.xmlBlaster.engine.msgstore.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.
 long CommonTableDatabaseAccessor.getNumOfBytes(java.lang.String queueName)
          Deprecated. Use CommonTableDatabaseAccessor.getNumOfAll(String)
 long CommonTableDatabaseAccessor.getNumOfEntries(java.lang.String queueName)
          Deprecated. Use CommonTableDatabaseAccessor.getNumOfAll(String)
 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)
           
 org.xmlBlaster.contrib.I_Info XBDatabaseAccessor.init(org.xmlBlaster.contrib.I_Info origInfo)
           
 org.xmlBlaster.contrib.I_Info XBFactoryBase.init(org.xmlBlaster.contrib.I_Info origInfo)
           
 org.xmlBlaster.contrib.I_Info XBFactory.init(org.xmlBlaster.contrib.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.
 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
 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)
           
 int JdbcQueue.put(org.xmlBlaster.engine.msgstore.I_MapEntry mapEntry)
           
 int JdbcQueueCommonTablePlugin.put(org.xmlBlaster.engine.msgstore.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)
           
 void JdbcConnectionPool.releaseConnection(java.sql.Connection conn, boolean success)
          Used to give back a connection to the pool.
 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(org.xmlBlaster.engine.msgstore.I_MapEntry mapEntry)
           
 int JdbcQueueCommonTablePlugin.remove(org.xmlBlaster.engine.msgstore.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.
 org.xmlBlaster.engine.msgstore.I_MapEntry JdbcQueue.removeOldest()
           
 org.xmlBlaster.engine.msgstore.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)
           
 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.
 void JdbcQueue.updateCounters(org.xmlBlaster.engine.msgstore.I_MapEntry entry)
           
 void JdbcQueueCommonTablePlugin.updateCounters(org.xmlBlaster.engine.msgstore.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)
           
 

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


xmlBlaster 2.2.0 client API

Copyright © 1999-2014 The xmlBlaster.org contributers.