Uses of Class
org.xmlBlaster.engine.MsgUnitWrapper

Packages that use MsgUnitWrapper

org.xmlBlaster.engine	The core implementation.
org.xmlBlaster.engine.distributor
org.xmlBlaster.engine.distributor.plugins
org.xmlBlaster.engine.persistence
org.xmlBlaster.engine.persistence.filestore
org.xmlBlaster.engine.queuemsg

Uses of MsgUnitWrapper in org.xmlBlaster.engine

Fields in org.xmlBlaster.engine declared as MsgUnitWrapper

private MsgUnitWrapper

TopicHandler.msgUnitWrapperUnderConstruction

Methods in org.xmlBlaster.engine that return MsgUnitWrapper

MsgUnitWrapper	TopicHandler.getMsgUnitWrapper(long uniqueId)
MsgUnitWrapper[]	TopicHandler.getMsgUnitWrapperArr(int num, boolean newestFirst) Returns a snapshot of all entries in the history
MsgUnitWrapper	TopicAccessor.lookupDirtyRead(java.lang.String topicId, long msgUnitWrapperUniqueId) Access the message meat without a lock.
MsgUnitWrapper	TopicAccessor.lookupNewest(java.lang.String topicId) Access the newest entry.

Methods in org.xmlBlaster.engine with parameters of type MsgUnitWrapper

(package private) void	TopicHandler.change(MsgUnitWrapper msgUnitWrapper)
void	TopicAccessor.changeDirtyRead(MsgUnitWrapper msgUnitWrapper)
boolean	TopicHandler.checkFilter(SessionInfo publisherSessionInfo, SubscriptionInfo sub, MsgUnitWrapper msgUnitWrapper, boolean handleException) Checks if the filters allow this message to be sent to the specified session
static MsgQueueUpdateEntry	TopicHandler.createEntryFromWrapper(MsgUnitWrapper msgUnitWrapper, SubscriptionInfo sub)
void	TopicAccessor.entryDestroyed_scheduleForExecution(MsgUnitWrapper msgUnitWrapper) Queue request for later execution, to be outside of sync-locks
void	TopicHandler.entryDestroyed(MsgUnitWrapper msgUnitWrapper) Event triggered by MsgUnitWrapper itself when it reaches destroy state.
private void	TopicHandler.forwardToDestinations(SessionInfo publisherSessionInfo, MsgUnitWrapper cacheEntry, PublishQosServer publishQos) Forward PtP messages.
private int	TopicHandler.invokeCallback(SessionInfo publisherSessionInfo, SubscriptionInfo sub, MsgUnitWrapper msgUnitWrapper, boolean doErrorHandling) Put the message into the callback queue of the subscribed client (Pub/Sub mode only).
private void	TopicHandler.invokeCallbackAndHandleFailure(SessionInfo publisherSessionInfo, MsgUnitWrapper msgUnitWrapper) Send updates to all subscribed clients.
static boolean	TopicHandler.isDirtyRead(SubscriptionInfo sub, MsgUnitWrapper msgUnitWrapper) Checks if the subscriber is a cluster and the message has the 'dirtyRead' flag set.
(package private) boolean	TopicHandler.isInMsgStore(MsgUnitWrapper msgUnitWrapper) Check if the MsgUnitWrapper is owned by the TopicHandler (during construction).
static boolean	TopicHandler.subscriberMayReceiveIt(SubscriptionInfo sub, MsgUnitWrapper msgUnitWrapper)

Uses of MsgUnitWrapper in org.xmlBlaster.engine.distributor

Methods in org.xmlBlaster.engine.distributor with parameters of type MsgUnitWrapper

void	I_MsgDistributor.distribute(MsgUnitWrapper msgUnitWrapper) This method should not throw any exception so it is responsability of the plugin developer to catch Throwable and make the necessary error handling.

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

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

void	ConsumableQueuePlugin.distribute(MsgUnitWrapper msgUnitWrapper)
private boolean	ConsumableQueuePlugin.distributeOneEntry(MsgUnitWrapper msgUnitWrapper, MsgQueueHistoryEntry entry, java.util.List subInfoList) Distributes one single entry taken from the history queue.
private void	ConsumableQueuePlugin.givingUpDistribution(SubscriptionInfo sub, MsgUnitWrapper msgUnitWrapper, MsgQueueEntry entry, java.lang.Throwable e)

Uses of MsgUnitWrapper in org.xmlBlaster.engine.persistence

Methods in org.xmlBlaster.engine.persistence with parameters of type MsgUnitWrapper

java.lang.String	MsgFileDumper.store(MsgUnitWrapper msgUnitWrapper) Allows a message to be stored.
void	I_PersistenceDriver.store(MsgUnitWrapper messageWrapper) Deprecated. Allows a message to be stored.
private java.lang.String	MsgFileDumper.store(MsgUnitWrapper msgUnitWrapper, boolean updateOnly)
java.lang.String	MsgFileDumper.update(MsgUnitWrapper msgUnitWrapper) Allows a stored message content to be updated.
void	I_PersistenceDriver.update(MsgUnitWrapper messageWrapper) Deprecated. Allows a stored message content to be updated.

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

Methods in org.xmlBlaster.engine.persistence.filestore with parameters of type MsgUnitWrapper

void	FileDriver.store(MsgUnitWrapper messageWrapper) Allows a message to be stored.
void	FileDriver.update(MsgUnitWrapper messageWrapper) Allows a stored message content to be updated.

Uses of MsgUnitWrapper in org.xmlBlaster.engine.queuemsg

Methods in org.xmlBlaster.engine.queuemsg that return MsgUnitWrapper

MsgUnitWrapper	ReferenceEntry.getMsgUnitWrapper() The caller needs to synchronize over msgCache
private MsgUnitWrapper	ReferenceEntry.lookup()

Methods in org.xmlBlaster.engine.queuemsg with parameters of type MsgUnitWrapper

void	ReferenceEntry.setMsgUnitWrapper(MsgUnitWrapper msgUnitWrapper)

Constructors in org.xmlBlaster.engine.queuemsg with parameters of type MsgUnitWrapper

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

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

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

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

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