|
xmlBlaster 2.2.0 client API | |||||||||
PREV NEXT | FRAMES NO FRAMES |
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 |
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 | |||||||||
PREV NEXT | FRAMES NO FRAMES |