|
xmlBlaster 2.2.0 API | |||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use MsgQueueEntry | |
---|---|
org.xmlBlaster.authentication | |
org.xmlBlaster.client | This is the Java client side package. |
org.xmlBlaster.client.dispatch | |
org.xmlBlaster.client.queuemsg | |
org.xmlBlaster.engine | The core implementation. |
org.xmlBlaster.engine.dispatch | |
org.xmlBlaster.engine.distributor.plugins | |
org.xmlBlaster.engine.queuemsg | |
org.xmlBlaster.util.dispatch | |
org.xmlBlaster.util.dispatch.plugins.prio | |
org.xmlBlaster.util.error | |
org.xmlBlaster.util.queuemsg |
Uses of MsgQueueEntry in org.xmlBlaster.authentication |
---|
Methods in org.xmlBlaster.authentication with parameters of type MsgQueueEntry | |
---|---|
private int |
SubjectInfo.forwardToSessionQueue(MsgQueueEntry entry)
Forward the given message to session queue. |
void |
SessionInfo.queueMessage(MsgQueueEntry entry)
Put the given message entry into the queue |
void |
SubjectInfo.queueMessage(MsgQueueEntry entry)
PtP mode: If the qos is set to forceQueuing the message is queued. |
Uses of MsgQueueEntry in org.xmlBlaster.client |
---|
Methods in org.xmlBlaster.client with parameters of type MsgQueueEntry | |
---|---|
void |
XmlBlasterAccess.postSend(MsgQueueEntry[] entries)
Called after a messages is send from the client side queue, but not for oneway messages. |
private java.lang.Object |
XmlBlasterAccess.queueMessage(MsgQueueEntry entry)
Put the given message entry into the queue |
boolean |
XmlBlasterAccess.sendingFailed(MsgQueueEntry[] entries,
XmlBlasterException exception)
|
Uses of MsgQueueEntry in org.xmlBlaster.client.dispatch |
---|
Fields in org.xmlBlaster.client.dispatch declared as MsgQueueEntry | |
---|---|
private MsgQueueEntry |
ClientDispatchConnection.connectEntry
|
Methods in org.xmlBlaster.client.dispatch with parameters of type MsgQueueEntry | |
---|---|
private void |
ClientDispatchConnection.connect(MsgQueueEntry entry)
Encrypt and send a connect request, decrypt the returned data |
private void |
ClientDispatchConnection.disconnect(MsgQueueEntry entry)
Encrypt and send a disconnect request, decrypt the returned data |
void |
ClientDispatchConnection.doSend(MsgQueueEntry[] msgArr_,
boolean isAsyncMode)
Send the messages to xmlBlaster. |
private void |
ClientDispatchConnection.erase(MsgQueueEntry entry)
Encrypt and send a erase request, decrypt the returned data |
private void |
ClientDispatchConnection.get(MsgQueueEntry entry)
Encrypt and send a synchronous get request, decrypt the returned data |
void |
ClientDispatchManager.postSendNotification(MsgQueueEntry entry)
|
void |
ClientDispatchManager.postSendNotification(MsgQueueEntry[] entries)
|
private void |
ClientDispatchConnection.publish(MsgQueueEntry[] msgArr_)
|
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) |
boolean |
ClientDispatchManager.sendingFailedNotification(MsgQueueEntry[] entries,
XmlBlasterException ex)
Notify I_PostSendListener about problem. |
private void |
ClientDispatchConnection.subscribe(MsgQueueEntry entry)
Encrypt and send a subscribe request, decrypt the returned data |
private void |
ClientDispatchConnection.unSubscribe(MsgQueueEntry entry)
Encrypt and send a unSubscribe request, decrypt the returned data |
Uses of MsgQueueEntry in org.xmlBlaster.client.queuemsg |
---|
Subclasses of MsgQueueEntry in org.xmlBlaster.client.queuemsg | |
---|---|
class |
MsgQueueConnectEntry
Wraps an connect() message into an entry for a sorted queue. |
class |
MsgQueueDisconnectEntry
Wraps an disconnect() message into an entry for a sorted queue. |
class |
MsgQueueEraseEntry
Wraps an erase() message into an entry for a sorted queue. |
class |
MsgQueueGetEntry
Wraps an get() message into an entry for a sorted queue. |
class |
MsgQueuePublishEntry
Wraps an publish() message into an entry for a sorted queue. |
class |
MsgQueueSubscribeEntry
Wraps an subscribe() message into an entry for a sorted queue. |
class |
MsgQueueUnSubscribeEntry
Wraps an unSubscribe() message into an entry for a sorted queue. |
Uses of MsgQueueEntry in org.xmlBlaster.engine |
---|
Methods in org.xmlBlaster.engine with parameters of type MsgQueueEntry | |
---|---|
java.lang.String[] |
RequestBroker.deadMessage(MsgQueueEntry[] entries,
I_Queue queue,
java.lang.String reason)
Publish dead letters, expired letters should be filtered away before. |
Uses of MsgQueueEntry in org.xmlBlaster.engine.dispatch |
---|
Methods in org.xmlBlaster.engine.dispatch with parameters of type MsgQueueEntry | |
---|---|
void |
CbDispatchConnection.doSend(MsgQueueEntry[] msgArr_,
boolean isAsyncMode)
Send the messages back to the client. |
void |
ServerDispatchManager.postSendNotification(MsgQueueEntry entry)
|
void |
ServerDispatchManager.postSendNotification(MsgQueueEntry[] entries)
|
void |
ServerDispatchManager.removeFromQueue(MsgQueueEntry[] entries,
boolean postSendNotify)
Messages are successfully sent, remove them now from queue (sort of a commit()): We remove filtered/destroyed messages as well (which doen't show up in entryListChecked) |
boolean |
ServerDispatchManager.sendingFailedNotification(MsgQueueEntry[] entries,
XmlBlasterException ex)
Notify I_PostSendListener about problem. |
Uses of MsgQueueEntry in org.xmlBlaster.engine.distributor.plugins |
---|
Methods in org.xmlBlaster.engine.distributor.plugins with parameters of type MsgQueueEntry | |
---|---|
private void |
ConsumableQueuePlugin.givingUpDistribution(SubscriptionInfo sub,
MsgUnitWrapper msgUnitWrapper,
MsgQueueEntry entry,
java.lang.Throwable e)
|
Uses of MsgQueueEntry in org.xmlBlaster.engine.queuemsg |
---|
Subclasses of MsgQueueEntry in org.xmlBlaster.engine.queuemsg | |
---|---|
class |
MsgQueueHistoryEntry
Wraps an publish() message into an entry for a sorted queue. |
class |
MsgQueueUpdateEntry
Wraps an publish() message into an entry for a sorted queue. |
class |
ReferenceEntry
Wraps an publish() message into an entry for a sorted queue. |
Uses of MsgQueueEntry in org.xmlBlaster.util.dispatch |
---|
Methods in org.xmlBlaster.util.dispatch with parameters of type MsgQueueEntry | |
---|---|
abstract void |
DispatchConnection.doSend(MsgQueueEntry[] msgArr_,
boolean isAsyncMode)
Send the messages. |
void |
I_PostSendListener.postSend(MsgQueueEntry[] msgQueueEntries)
Called after a messages is send asynchronously from connection queue. |
void |
I_DispatchManager.postSendNotification(MsgQueueEntry entry)
|
void |
I_DispatchManager.postSendNotification(MsgQueueEntry[] entries)
|
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 |
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. |
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. |
Uses of MsgQueueEntry in org.xmlBlaster.util.dispatch.plugins.prio |
---|
Methods in org.xmlBlaster.util.dispatch.plugins.prio with parameters of type MsgQueueEntry | |
---|---|
private DispatchAction |
PriorizedDispatchPlugin.getDispatchAction(DispatchManagerEntry managerEntry,
MsgQueueEntry entry)
Lookup the corresponding DispatchAction object this message priority. |
private void |
PriorizedDispatchPlugin.putToHoldbackQueue(DispatchManagerEntry managerEntry,
MsgQueueEntry entry)
|
void |
XmlBlasterNativeClient.sendPtPMessage(MsgQueueEntry entry,
java.lang.String pluginName,
java.lang.String action,
java.lang.String currStatus)
Send a PtP message to the publisher notifying him on problems about dispatching his just published message. |
Uses of MsgQueueEntry in org.xmlBlaster.util.error |
---|
Fields in org.xmlBlaster.util.error declared as MsgQueueEntry | |
---|---|
private MsgQueueEntry[] |
MsgErrorInfo.msgQueueEntries
|
Methods in org.xmlBlaster.util.error that return MsgQueueEntry | |
---|---|
MsgQueueEntry[] |
I_MsgErrorInfo.getMsgQueueEntries()
Access the message entry object to be handled |
MsgQueueEntry[] |
MsgErrorInfo.getMsgQueueEntries()
Access the message entry object to be handled |
Constructors in org.xmlBlaster.util.error with parameters of type MsgQueueEntry | |
---|---|
MsgErrorInfo(Global glob,
MsgQueueEntry[] msgQueueEntries,
I_DispatchManager dispatchManager,
java.lang.Throwable throwable)
Creates an error info instance for an array of message queue entries |
|
MsgErrorInfo(Global glob,
MsgQueueEntry msgQueueEntry,
I_DispatchManager dispatchManager,
java.lang.Throwable throwable)
Creates an error info instance with errorCode="internal.unknown" |
Uses of MsgQueueEntry in org.xmlBlaster.util.queuemsg |
---|
Subclasses of MsgQueueEntry in org.xmlBlaster.util.queuemsg | |
---|---|
class |
DummyEntry
|
Fields in org.xmlBlaster.util.queuemsg declared as MsgQueueEntry | |
---|---|
protected MsgQueueEntry |
MsgQueueEntry.refToCloneOrigin
|
Methods in org.xmlBlaster.util.queuemsg with parameters of type MsgQueueEntry | |
---|---|
(package private) void |
MsgQueueEntry.setRefToCloneOrigin(MsgQueueEntry origEntry)
If this instance is a clone we can remember who cloned us. |
|
xmlBlaster 2.2.0 API | |||||||||
PREV NEXT | FRAMES NO FRAMES |