Uses of Class
org.xmlBlaster.util.MsgUnit

Packages that use MsgUnit

org.xmlBlaster.client	This is the Java client side package.
org.xmlBlaster.client.protocol
org.xmlBlaster.client.queuemsg
org.xmlBlaster.client.script
org.xmlBlaster.util	Java helper classes for server and client programming.
org.xmlBlaster.util.checkpoint
org.xmlBlaster.util.dispatch
org.xmlBlaster.util.dispatch.plugins
org.xmlBlaster.util.dispatch.plugins.prio
org.xmlBlaster.util.error
org.xmlBlaster.util.queuemsg

Uses of MsgUnit in org.xmlBlaster.client

Methods in org.xmlBlaster.client that return MsgUnit

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.
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.
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.
MsgUnit	XmlDbMessageWrapper.toMessage() Creates the complete message for you, which you can publish to xmlBlaster.

Methods in org.xmlBlaster.client with parameters of type MsgUnit

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

Uses of MsgUnit in org.xmlBlaster.client.protocol

Methods in org.xmlBlaster.client.protocol that return MsgUnit

MsgUnit[]

I_XmlBlaster.get(java.lang.String xmlKey, java.lang.String qos)

Methods in org.xmlBlaster.client.protocol with parameters of type MsgUnit

PublishReturnQos	I_XmlBlaster.publish(MsgUnit msgUnit)
PublishReturnQos[]	I_XmlBlaster.publishArr(MsgUnit[] msgUnitArr)
void	I_XmlBlaster.publishOneway(MsgUnit[] msgUnitArr)

Uses of MsgUnit in org.xmlBlaster.client.queuemsg

Methods in org.xmlBlaster.client.queuemsg that return MsgUnit

MsgUnit	MsgQueueEraseEntry.getMsgUnit()
MsgUnit	MsgQueueGetEntry.getMsgUnit()
MsgUnit	MsgQueueUnSubscribeEntry.getMsgUnit()
MsgUnit	MsgQueuePublishEntry.getMsgUnit() Get the message unit, you must call getUpdateQos(int,int,int) before to generate the update QoS.
MsgUnit	MsgQueueDisconnectEntry.getMsgUnit()
MsgUnit	MsgQueueConnectEntry.getMsgUnit()
MsgUnit	MsgQueueSubscribeEntry.getMsgUnit()

Constructors in org.xmlBlaster.client.queuemsg with parameters of type MsgUnit

MsgQueuePublishEntry(Global glob, MethodName entryType, PriorityEnum priority, StorageId storageId, Timestamp publishEntryTimestamp, long sizeInBytes, MsgUnit msgUnit)
For persistence recovery

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)

Uses of MsgUnit in org.xmlBlaster.client.script

Methods in org.xmlBlaster.client.script that return MsgUnit

protected MsgUnit

XmlScriptInterpreter.buildMsgUnit()

Methods in org.xmlBlaster.client.script with parameters of type MsgUnit

boolean	I_MsgUnitCb.intercept(MsgUnit msgUnit)
java.lang.String	XmlScriptInterpreter.wrapForScripting(MsgUnit msgUnit, java.lang.String comment)
static java.lang.String	XmlScriptInterpreter.wrapForScripting(java.lang.String rootTag, MsgUnit[] msgUnitArr, java.lang.String comment)
static java.lang.String	XmlScriptInterpreter.wrapForScripting(java.lang.String rootTag, MsgUnit msgUnit, java.lang.String comment) Dump the MsgUnit to XML, the dump includes the xml header (UTF-8).

Uses of MsgUnit in org.xmlBlaster.util

Methods in org.xmlBlaster.util that return MsgUnit

MsgUnit

MsgUnit.getClone() Deep clone this message unit.

Constructors in org.xmlBlaster.util with parameters of type MsgUnit

MsgUnit(MsgUnit old, KeyData key, byte[] content, QosData qos)
Clone this message unit (but not the content).

Uses of MsgUnit in org.xmlBlaster.util.checkpoint

Methods in org.xmlBlaster.util.checkpoint with parameters of type MsgUnit

void	I_Checkpoint.passingBy(int checkpoint, MsgUnit msgUnit, SessionName destination, java.lang.String[] context) A message is passing a checkpoint.
void	Checkpoint.passingBy(int checkpoint, MsgUnit msgUnit, SessionName destination, java.lang.String[] context)

Uses of MsgUnit in org.xmlBlaster.util.dispatch

Methods in org.xmlBlaster.util.dispatch with parameters of type MsgUnit

PublishReturnQos	I_Callback.update(MsgUnit msgUnit)
void	I_Callback.updateOneway(MsgUnit[] msgUnitArr)

Uses of MsgUnit in org.xmlBlaster.util.dispatch.plugins

Methods in org.xmlBlaster.util.dispatch.plugins with parameters of type MsgUnit

void	I_MsgDispatchInterceptor.postHandleNextMessages(I_DispatchManager dispatchManager, MsgUnit[] processedEntries) Method invoked after having successfully sent the entries in asynchronous modus.

Uses of MsgUnit in org.xmlBlaster.util.dispatch.plugins.prio

Methods in org.xmlBlaster.util.dispatch.plugins.prio with parameters of type MsgUnit

void	PriorizedDispatchPlugin.postHandleNextMessages(I_DispatchManager dispatchManager, MsgUnit[] processedEntries) Not doing anything in this method since no cleanup needed.

Uses of MsgUnit in org.xmlBlaster.util.error

Methods in org.xmlBlaster.util.error that return MsgUnit

MsgUnit	I_MsgErrorInfo.getMsgUnit() Is not null for client calls into server like XmlBlasterImpl.publish() where no queue is involved.
MsgUnit	MsgErrorInfo.getMsgUnit()

Constructors in org.xmlBlaster.util.error with parameters of type MsgUnit

MsgErrorInfo(Global glob, SessionName sessionName, MsgUnit msgUnit, java.lang.Throwable throwable)
Creates an error info instance from server side XmlBlasterImpl.publish failure (remote method invokation) without a queue involved

Uses of MsgUnit in org.xmlBlaster.util.queuemsg

Methods in org.xmlBlaster.util.queuemsg that return MsgUnit

MsgUnit	DummyEntry.getMsgUnit()
abstract MsgUnit	MsgQueueEntry.getMsgUnit()