|
xmlBlaster 2.2.0 API | |||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use MsgQosData | |
---|---|
org.xmlBlaster.client | This is the Java client side package. |
org.xmlBlaster.client.qos | |
org.xmlBlaster.client.queuemsg | |
org.xmlBlaster.contrib.dbwatcher.mom | |
org.xmlBlaster.contrib.replication | |
org.xmlBlaster.engine | The core implementation. |
org.xmlBlaster.engine.event | |
org.xmlBlaster.engine.qos | |
org.xmlBlaster.engine.queuemsg | |
org.xmlBlaster.jms | |
org.xmlBlaster.test.classtest | Tests classes of the xmlBlaster distribution. |
org.xmlBlaster.util.qos |
Uses of MsgQosData in org.xmlBlaster.client |
---|
Methods in org.xmlBlaster.client with parameters of type MsgQosData | |
---|---|
private PublishReturnQos |
XmlBlasterAccess.publishSingleChunk(MsgKeyData keyData,
MsgQosData chunkQosData,
byte[] buf,
int length,
boolean isLastChunk,
long count,
java.lang.Exception ex)
|
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. |
Uses of MsgQosData in org.xmlBlaster.client.qos |
---|
Fields in org.xmlBlaster.client.qos declared as MsgQosData | |
---|---|
private MsgQosData |
PublishQos.msgQosData
|
private MsgQosData |
UpdateQos.msgQosData
|
private MsgQosData |
GetReturnQos.msgQosData
|
Methods in org.xmlBlaster.client.qos that return MsgQosData | |
---|---|
MsgQosData |
PublishQos.getData()
|
MsgQosData |
UpdateQos.getData()
Get the QoS data object which i'm hiding |
MsgQosData |
GetReturnQos.getData()
Get the QoS data object which i'm hiding |
Constructors in org.xmlBlaster.client.qos with parameters of type MsgQosData | |
---|---|
GetReturnQos(Global glob,
MsgQosData msgQosData)
Default constructor for transient messages. |
|
UpdateQos(Global glob,
MsgQosData msgQosData)
Default constructor for transient messages. |
Uses of MsgQosData in org.xmlBlaster.client.queuemsg |
---|
Fields in org.xmlBlaster.client.queuemsg declared as MsgQosData | |
---|---|
private MsgQosData |
MsgQueuePublishEntry.msgQosData
|
Uses of MsgQosData in org.xmlBlaster.contrib.dbwatcher.mom |
---|
Methods in org.xmlBlaster.contrib.dbwatcher.mom with parameters of type MsgQosData | |
---|---|
private void |
XmlBlasterPublisher.addStringPropToQos(java.util.Map attrMap,
MsgQosData qos)
|
Uses of MsgQosData in org.xmlBlaster.contrib.replication |
---|
Methods in org.xmlBlaster.contrib.replication that return MsgQosData | |
---|---|
MsgQosData |
ReplSourceEngine.preparePubQos(MsgQosData qosData)
|
Methods in org.xmlBlaster.contrib.replication with parameters of type MsgQosData | |
---|---|
MsgQosData |
ReplSourceEngine.preparePubQos(MsgQosData qosData)
|
Uses of MsgQosData in org.xmlBlaster.engine |
---|
Methods in org.xmlBlaster.engine that return MsgQosData | |
---|---|
MsgQosData |
MsgUnitWrapper.getMsgQosData()
|
Methods in org.xmlBlaster.engine with parameters of type MsgQosData | |
---|---|
private void |
TopicHandler.administrativeInitialize(MsgKeyData msgKeyData,
MsgQosData publishQos,
PublishQosServer publishQosServer)
Initialize the messageUnit cache and the history queue for this topic |
private boolean |
TopicHandler.allowedToReconfigureTopicAndFixWrongLimits(MsgQosData msgQosData)
Currently we support growing and shrinking, note that shrinking is not thoroughly tested. |
java.lang.String |
RequestBroker.update(SessionInfo sessionInfo,
UpdateKey updateKey,
byte[] content,
MsgQosData msgQosData)
Used for cluster internal updates. |
Uses of MsgQosData in org.xmlBlaster.engine.event |
---|
Methods in org.xmlBlaster.engine.event that return MsgQosData | |
---|---|
MsgQosData |
PublishDestinationHelper.getPublishQos(java.lang.String summary,
java.lang.String description,
java.lang.String eventType,
java.lang.String errorCode,
SessionName sessionName)
|
Uses of MsgQosData in org.xmlBlaster.engine.qos |
---|
Fields in org.xmlBlaster.engine.qos declared as MsgQosData | |
---|---|
private MsgQosData |
PublishQosServer.msgQosData
|
private MsgQosData |
UpdateQosServer.msgQosData
|
private MsgQosData |
GetReturnQosServer.msgQosData
|
Methods in org.xmlBlaster.engine.qos that return MsgQosData | |
---|---|
MsgQosData |
PublishQosServer.getData()
Access the internal data struct |
MsgQosData |
GetReturnQosServer.getData()
|
MsgQosData |
UpdateQosServer.getMsgQosData()
|
Methods in org.xmlBlaster.engine.qos with parameters of type MsgQosData | |
---|---|
static void |
UpdateQosServer.incrRedeliver(MsgQosData msgQosData)
|
static void |
UpdateQosServer.setData(MsgQosData msgQosData,
java.lang.String state,
java.lang.String subscriptionId)
Static manipulator if you want to avoid constructing one instance of UpdateQosServer |
static java.lang.String |
UpdateQosServer.toXml(MsgQosData msgQosData,
long index,
long size)
Static manipulator if you want to avoid constructing one instance of UpdateQosServer |
Constructors in org.xmlBlaster.engine.qos with parameters of type MsgQosData | |
---|---|
GetReturnQosServer(Global glob,
MsgQosData msgQosData,
java.lang.String state)
|
|
PublishQosServer(ServerScope glob,
MsgQosData msgQosData,
boolean fromPersistenceStore)
Constructor which accepts parsed object. |
|
UpdateQosServer(Global glob,
MsgQosData msgQosData)
A constructor for PtP messages. |
|
UpdateQosServer(Global glob,
MsgQosData msgQosData,
java.lang.String state)
A constructor for PtP messages. |
|
UpdateQosServer(Global glob,
MsgQosData msgQosData,
java.lang.String state,
java.lang.String subscriptionId)
A constructor for Pub/Sub message (with a subscriptionId). |
Uses of MsgQosData in org.xmlBlaster.engine.queuemsg |
---|
Methods in org.xmlBlaster.engine.queuemsg that return MsgQosData | |
---|---|
MsgQosData |
ReferenceEntry.getMsgQosData()
|
MsgQosData |
TopicEntry.getMsgQosData()
|
Uses of MsgQosData in org.xmlBlaster.jms |
---|
Methods in org.xmlBlaster.jms with parameters of type MsgQosData | |
---|---|
static XBMessage |
MessageHelper.convertFromMsgUnit(XBSession session,
java.lang.String sender,
MsgKeyData keyData,
byte[] content,
MsgQosData qosData)
Used in the message consumer update method. |
Uses of MsgQosData in org.xmlBlaster.test.classtest |
---|
Methods in org.xmlBlaster.test.classtest that return MsgQosData | |
---|---|
private MsgQosData |
RunLevelTest.getQosData(java.lang.String attrVal)
|
Uses of MsgQosData in org.xmlBlaster.util.qos |
---|
Fields in org.xmlBlaster.util.qos declared as MsgQosData | |
---|---|
private MsgQosData |
MsgQosSaxFactory.msgQosData
|
Methods in org.xmlBlaster.util.qos that return MsgQosData | |
---|---|
MsgQosData |
MsgQosSaxFactory.readObject(java.lang.String xmlQos)
Parses the given xml Qos and returns a MsgQosData holding the data. |
MsgQosData |
I_MsgQosFactory.readObject(java.lang.String xmlQos)
Parses the given Qos and returns a MsgQosData holding the data. |
Methods in org.xmlBlaster.util.qos with parameters of type MsgQosData | |
---|---|
java.lang.String |
MsgQosSaxFactory.writeObject(MsgQosData msgQosData,
java.lang.String extraOffset,
java.util.Properties props)
Dump state of this object into a XML ASCII string. |
java.lang.String |
I_MsgQosFactory.writeObject(MsgQosData msgQosData,
java.lang.String extraOffset,
java.util.Properties props)
Serialize the given data object. |
|
xmlBlaster 2.2.0 API | |||||||||
PREV NEXT | FRAMES NO FRAMES |