Uses of Class
org.xmlBlaster.util.queuemsg.MsgQueueEntry

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.