public abstract class MProducer extends java.lang.Object implements MObject
Modifier and Type | Field and Description |
---|---|
protected MSession |
m_session |
AMX, JMS, M_FILE_SINK_ID, M_HAWK_SINK_ID, M_JMS_SINK_ID, M_RV_SINK_ID, M_SINK_ID, M_STDERR_SINK_ID, M_STDOUT_SINK_ID, M_STREAM_SINK_ID, RV
Constructor and Description |
---|
MProducer() |
Modifier and Type | Method and Description |
---|---|
abstract void |
addTPluginName(java.lang.String sTPluginName) |
void |
disableJmsMessageId(boolean bShouldDisable) |
abstract int |
getDeliveryMode() |
abstract java.lang.String |
getDestinationName() |
abstract MEndpointSpec |
getEndpointSpec() |
abstract long |
getNumMessagesPublished() |
abstract java.lang.String |
getReplyDestinationName() |
boolean |
isAeMsgOn() |
abstract void |
send(MTree msg) |
abstract void |
sendWithReply(MTree msg,
MSubscriber subscriber) |
abstract MTree |
sendWithSyncReply(MTree msg,
long timeout) |
void |
setAeMsgOn(boolean aeMsgOn) |
abstract void |
setDestinationName(java.lang.String subj) |
void |
setJmsCorrelationId(java.lang.String sCorrelationId) |
void |
setJmsPriority(int priority) |
abstract void |
setReplyDestinationName(java.lang.String replySubj) |
abstract void |
unRegisterListener(java.lang.String listenerName) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getTransportID
protected MSession m_session
public abstract void send(MTree msg) throws MException
MException
public abstract void sendWithReply(MTree msg, MSubscriber subscriber) throws MException
MException
public abstract MTree sendWithSyncReply(MTree msg, long timeout) throws MException
MException
public abstract java.lang.String getDestinationName()
public abstract void setDestinationName(java.lang.String subj) throws MException
MException
public abstract void setReplyDestinationName(java.lang.String replySubj)
public abstract java.lang.String getReplyDestinationName()
public abstract int getDeliveryMode()
public void setAeMsgOn(boolean aeMsgOn)
public boolean isAeMsgOn()
public abstract long getNumMessagesPublished()
public abstract MEndpointSpec getEndpointSpec()
public abstract void addTPluginName(java.lang.String sTPluginName)
public void setJmsCorrelationId(java.lang.String sCorrelationId)
public void disableJmsMessageId(boolean bShouldDisable)
public void setJmsPriority(int priority)
public abstract void unRegisterListener(java.lang.String listenerName) throws MException
MException